| 94 | } |
| 95 | |
| 96 | Status KrpcDataStreamMgr::Init(MemTracker* service_mem_tracker) { |
| 97 | // MemTracker for tracking memory used for buffering early RPC calls which |
| 98 | // arrive before the receiver is ready. |
| 99 | early_rpcs_tracker_.reset(new MemTracker(-1, "Data Stream Manager Early RPCs", |
| 100 | ExecEnv::GetInstance()->process_mem_tracker())); |
| 101 | service_mem_tracker_ = service_mem_tracker; |
| 102 | RETURN_IF_ERROR(Thread::Create("krpc-data-stream-mgr", "maintenance", |
| 103 | [this](){ this->Maintenance(); }, &maintenance_thread_)); |
| 104 | RETURN_IF_ERROR(deserialize_pool_.Init()); |
| 105 | return Status::OK(); |
| 106 | } |
| 107 | |
| 108 | inline uint32_t KrpcDataStreamMgr::GetHashValue( |
| 109 | const TUniqueId& fragment_instance_id, PlanNodeId dest_node_id) { |
nothing calls this directly
no test coverage detected