Method EnqueueDeserializeTask

be/src/runtime/krpc-data-stream-mgr.cc:263–269

}

void KrpcDataStreamMgr::EnqueueDeserializeTask(const TUniqueId& finst_id,
    PlanNodeId dest_node_id, int sender_id, int num_requests) {
  for (int i = 0; i < num_requests; ++i) {
    DeserializeTask payload = {finst_id, dest_node_id, sender_id, MonotonicNanos()};
    deserialize_pool_.Offer(move(payload));
  }
}

void KrpcDataStreamMgr::DeserializeThreadFn(int thread_id, const DeserializeTask& task) {
  int64_t queue_wait_time_ns = MonotonicNanos() - task.enqueue_time_ns;