Method process

src/learner/bcd.h:283–311

  virtual ~BCDWorker() { }

  void process(const MessagePtr& msg) {
    CHECK(msg->task.has_bcd());
    auto bcd = msg->task.bcd();
    int time  = msg->task.time() * time_ratio_;
    switch (bcd.cmd()) {
      case BCDCall::LOAD_DATA: {
        LoadDataReturn ret;
        int hit_cache = 0;
        CHECK(bcd.has_data());
        loadData(bcd.data(), ret.mutable_example_info(), &hit_cache);
        ret.set_hit_cache(hit_cache);
        sys_.replyProtocalMessage(msg, ret);
        break;
      }
      case BCDCall::PREPROCESS_DATA:
        preprocessData(time, bcd);
        break;
      case BCDCall::UPDATE_MODEL:
        computeGradient(time, bcd, msg);
        msg->finished = false;  //
        break;
      case BCDCall::EVALUATE_PROGRESS: {
        BCDProgress prog; evaluate(&prog);
        sys_.replyProtocalMessage(msg, prog);
        break;
      }
      default: break;
    }
  }
 protected:
  virtual void computeGradient(int time, const BCDCall& bcd, MessagePtr msg) = 0;
  virtual void evaluate(BCDProgress* prog) = 0;