Method CompleteAll

tensorflow/core/distributed_runtime/rpc/grpc_state.cc:162–166

}

void ExchangeQueue::CompleteAll(Status status) {
  for (Exchange& exchange : exchanges_) {
    exchange.Complete(status);
  }
}

namespace {
std::set<std::pair<Exchange::State, Exchange::State>>*