| 469 | } |
| 470 | |
| 471 | KrpcDataStreamMgr::~KrpcDataStreamMgr() { |
| 472 | shutdown_promise_.Set(true); |
| 473 | deserialize_pool_.Shutdown(); |
| 474 | LOG(INFO) << "Waiting for data-stream-mgr maintenance thread..."; |
| 475 | if (maintenance_thread_.get() != nullptr) maintenance_thread_->Join(); |
| 476 | LOG(INFO) << "Waiting for deserialization thread pool..."; |
| 477 | deserialize_pool_.Join(); |
| 478 | } |
| 479 | |
| 480 | TransmitDataCtx::TransmitDataCtx( |
| 481 | const TransmitDataRequestPB* request, TransmitDataResponsePB* response, |