| 359 | } |
| 360 | |
| 361 | void KrpcDataStreamRecvr::SenderQueue::EnqueueDeferredRpc( |
| 362 | unique_ptr<TransmitDataCtx> payload) { |
| 363 | lock_.DCheckLocked(); |
| 364 | TRACE_TO(payload->rpc_context->trace(), "Enqueuing deferred RPC"); |
| 365 | if (deferred_rpcs_.empty()) recvr_->total_has_deferred_rpcs_timer_->Start(); |
| 366 | deferred_rpcs_.push(move(payload)); |
| 367 | recvr_->num_deferred_rpcs_.Add(1); |
| 368 | COUNTER_ADD(recvr_->total_deferred_rpcs_counter_, 1); |
| 369 | } |
| 370 | |
| 371 | unique_ptr<TransmitDataCtx> KrpcDataStreamRecvr::SenderQueue::DequeueDeferredRpc() { |
| 372 | lock_.DCheckLocked(); |