in src/kernel_aio.cc [135:157]
bool create_group(int group_id, int n_concurrent) {
groups_mutex.lock();
if(groups.count(group_id)) {
d_printf("Group already exists\n");
return false;
}
groups[group_id] = std::make_shared<Group>();
int err = io_queue_init(n_concurrent, &(groups[group_id]->ctx));
if (err) {
errno = -err;
#ifdef ENABLE_DEBUG
perror("io_setup failed");
#endif
return false;
}
assert(groups[group_id]->ctx);
groups_mutex.unlock();
return true;
}