bool create_group()

in src/posix_aio.cc [120:144]

• 20 lines of code
• 4 McCabe index (conditional complexity)

			bool create_group(int group_id, int n_concurrent) {
				if (!started) assert(!"IOManager not started!");

				// create the queue for this group
				group_queues_mutex.lock();
				if (group_queues.count(group_id)) {
					fprintf(stderr, "group already exists\n");
					group_queues_mutex.unlock();
					return false;
				}
				group_queues[group_id] = std::make_shared<std::vector<std::shared_ptr<_PosixAsyncIop>>>();
				group_queues_mutex.unlock();

				//create the vector of aiocbs for this group
				suspend_mutex.lock();
				if (suspend_vecs.count(group_id)) {
					fprintf(stderr, "group already exists\n");
					suspend_mutex.unlock();
					return false;
				}
				suspend_vecs[group_id] = std::make_shared<std::vector<aiocb*>>();
				suspend_mutex.unlock();

				return true;
			}