| 203 | } |
| 204 | |
| 205 | void KrpcDataStreamMgr::AddEarlyClosedSender(const TUniqueId& finst_id, |
| 206 | const EndDataStreamRequestPB* request, EndDataStreamResponsePB* response, |
| 207 | kudu::rpc::RpcContext* rpc_context) { |
| 208 | const int64_t transfer_size = rpc_context->GetTransferSize(); |
| 209 | early_rpcs_tracker_->Consume(transfer_size); |
| 210 | service_mem_tracker_->Release(transfer_size); |
| 211 | RecvrId recvr_id = make_pair(finst_id, request->dest_node_id()); |
| 212 | auto payload = make_unique<EndDataStreamCtx>(request, response, rpc_context); |
| 213 | early_senders_map_[recvr_id].closed_sender_ctxs.emplace_back(move(payload)); |
| 214 | num_senders_waiting_->Increment(1); |
| 215 | total_senders_waited_->Increment(1); |
| 216 | } |
| 217 | |
| 218 | void KrpcDataStreamMgr::AddData(const TransmitDataRequestPB* request, |
| 219 | TransmitDataResponsePB* response, kudu::rpc::RpcContext* rpc_context) { |
nothing calls this directly
no test coverage detected