Class BESSControlImpl

core/bessctl.cc:436–1917

}

class BESSControlImpl final : public BESSControl::Service {
 public:
  void set_shutdown_func(const std::function<void()>& func) {
    shutdown_func_ = func;
  }

  Status GetVersion(ServerContext*, const EmptyRequest*,
                    VersionResponse* response) override {
    std::lock_guard<std::recursive_mutex> lock(mutex_);

    response->set_version(google::VersionString());
    return Status::OK;
  }

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

    Status status;
    WorkerPauser wp;

    LOG(INFO) << "*** ResetAll requested ***";

    status = ResetModules(context, request, response);
    if (response->error().code() != 0) {
      return status;
    }

    status = ResetPorts(context, request, response);
    if (response->error().code() != 0) {
      return status;
    }

    status = ResetTcs(context, request, response);
    if (response->error().code() != 0) {
      return status;
    }

    status = ResetWorkers(context, request, response);
    if (response->error().code() != 0) {
      return status;
    }

    return Status::OK;
  }

  Status PauseAll(ServerContext*, const EmptyRequest*,
                  EmptyResponse*) override {
    std::lock_guard<std::recursive_mutex> lock(mutex_);

    pause_all_workers();
    LOG(INFO) << "*** All workers have been paused ***";
    return Status::OK;
  }

  Status PauseWorker(ServerContext*, const PauseWorkerRequest* req,
                     EmptyResponse*) override {
    std::lock_guard<std::recursive_mutex> lock(mutex_);