| 369 | } |
| 370 | |
| 371 | unique_ptr<TransmitDataCtx> KrpcDataStreamRecvr::SenderQueue::DequeueDeferredRpc() { |
| 372 | lock_.DCheckLocked(); |
| 373 | DCHECK(!deferred_rpcs_.empty()); |
| 374 | unique_ptr<TransmitDataCtx> ctx = move(deferred_rpcs_.front()); |
| 375 | deferred_rpcs_.pop(); |
| 376 | if (deferred_rpcs_.empty()) recvr_->total_has_deferred_rpcs_timer_->Stop(); |
| 377 | recvr_->num_deferred_rpcs_.Add(-1); |
| 378 | return ctx; |
| 379 | } |
| 380 | |
| 381 | unique_ptr<TransmitDataCtx> |
| 382 | KrpcDataStreamRecvr::SenderQueue::DequeuePendingDeferredRpc() { |