Method process

src/system/monitor.h:27–45

  }

  void process(const MessagePtr& msg) {
    NodeID sender = msg->sender;
    Progress prog;
    CHECK(prog.ParseFromString(msg->task.msg()));
    if (merger_) {
      merger_(prog, &progress_[sender]);
    } else {
      progress_[sender] = prog;
    }

    double time = timer_.stop();
    if (time > interval_ && printer_) {
      total_time_ += time;
      printer_(total_time_, &progress_);
      timer_.restart();
    } else {
      timer_.start();
    }
  }
 private:
  AllProgress progress_;
  double interval_;