Method AddWorker

core/bessctl.cc:558–582

  }

  Status AddWorker(ServerContext*, const AddWorkerRequest* request,
                   EmptyResponse* response) override {
    std::lock_guard<std::recursive_mutex> lock(mutex_);

    uint64_t wid = request->wid();
    if (wid >= Worker::kMaxWorkers) {
      return return_with_error(response, EINVAL, "Invalid worker id");
    }
    uint64_t core = request->core();
    if (!is_cpu_present(core)) {
      return return_with_error(response, EINVAL, "Invalid core %d", core);
    }
    if (is_worker_active(wid)) {
      return return_with_error(response, EEXIST, "worker:%d is already active",
                               wid);
    }
    const std::string& scheduler = request->scheduler();
    if (scheduler != "" && scheduler != "experimental") {
      return return_with_error(response, EINVAL, "Invalid scheduler %s",
                               scheduler.c_str());
    }

    launch_worker(wid, core, scheduler);
    return Status::OK;
  }

  Status DestroyWorker(ServerContext*, const DestroyWorkerRequest* request,
                       EmptyResponse* response) override {