| 41 | } |
| 42 | |
| 43 | RequestTracker::SequenceNumber RequestTracker::FirstIncomplete() { |
| 44 | std::lock_guard<simple_spinlock> l(lock_); |
| 45 | if (incomplete_rpcs_.empty()) return kNoSeqNo; |
| 46 | return *incomplete_rpcs_.begin(); |
| 47 | } |
| 48 | |
| 49 | void RequestTracker::RpcCompleted(const SequenceNumber& seq_no) { |
| 50 | std::lock_guard<simple_spinlock> l(lock_); |