Method accept

src/system/executor.cc:270–277

void Executor::accept(const MessagePtr& msg) {
  Lock l(recved_msg_mu_);
  auto sender = rnode(msg->sender);
  if (!sender) return;
  sender->decodeFilter(msg);
  recved_msgs_.push_back(msg);
  dag_cond_.notify_one();
}

void Executor::NodeInfo::addSubNode(RNode* s) {
  CHECK_NOTNULL(s);