: io_uring_size_(io_uring_size), use_submission_queue_polling_(use_submission_queue_polling),

      read_buffer_size_(read_buffer_size), write_timeout_ms_(write_timeout_ms), tls_(tls) {}

OptRef<IoUringWorker> IoUringWorkerFactoryImpl::getIoUringWorker() {

  auto ret = tls_.get();

  if (ret == absl::nullopt) {

    return absl::nullopt;

  }

  return ret;

}

void IoUringWorkerFactoryImpl::onWorkerThreadInitialized() {

  tls_.set([io_uring_size = io_uring_size_,

            use_submission_queue_polling = use_submission_queue_polling_,

            read_buffer_size = read_buffer_size_,

            write_timeout_ms = write_timeout_ms_](Event::Dispatcher& dispatcher) {

    return std::make_shared<IoUringWorkerImpl>(io_uring_size, use_submission_queue_polling,

                                               read_buffer_size, write_timeout_ms, dispatcher);

  });

}

bool IoUringWorkerFactoryImpl::currentThreadRegistered() {

  return !tls_.isShutdown() && tls_.currentThreadRegistered();

}