Method Complete

tensorflow/core/distributed_runtime/rpc/grpc_state.cc:56–65

}

void Exchange::Complete(Status status) {
  if (status.ok()) {
    if (!GrpcMaybeParseProto(&response_buf_, response_)) {
      status.Update(errors::Internal("could not parse rpc response"));
    }
  }
  VLOG(3) << "Completing exchange " << DebugString() << " with "
          << status.ToString();
  cb_(status);
}

std::ostream& operator<<(std::ostream& os, const Exchange::State& state) {
  os << ToString(state);