Searched refs:exchanges_ (Results 1 – 2 of 2) sorted by relevance
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_state.cc | 92 exchanges_.emplace(exchanges_.end(), request_buf, response, std::move(cb), in Emplace()
103 for (Exchange& e : exchanges_) { in GetReadyForRequestWriting()
120 if (exchanges_.empty()) { in GetReadyForResponseReading()
123 Exchange& e = exchanges_[0]; in GetReadyForResponseReading()
133 for (Exchange& e : exchanges_) { in MarkRequestWriteCompleted()
143 return exchanges_.front(); in GetFront()
148 exchanges_.pop_front(); in PopFront()
152 return absl::StrJoin(exchanges_, ", ", [](string* out, const Exchange& e) { in DebugString()
158 exchanges_.swap(other->exchanges_); in Swap()
163 for (Exchange& exchange : exchanges_) { in CompleteAll()
[all …]
|
| D | grpc_state.h | 401 std::deque<Exchange> exchanges_; variable
452 exchanges_.Emplace(request_buf, response, done, in SendNextRequest()
455 exchanges_.Emplace(request_buf, response, done, ""); in SendNextRequest()
469 exchanges_.CallStarted(); in CallStarted()
482 exchanges_.MarkRequestWriteCompleted(); in RequestWriteCompleted()
516 e = &exchanges_.GetFront(); in ResponseReadCompleted()
523 exchanges_.PopFront(); in ResponseReadCompleted()
551 return exchanges_.DebugString(); in DebugString()
571 exchanges_.Swap(&queue); in MarkDoneAndCompleteExchanges()
577 Exchange* exchange = exchanges_.GetReadyForRequestWriting(); in MaybeIssueRequestWriteLocked()
[all …]
|