Searched refs:DebugGrpcChannel (Results 1 – 2 of 2) sorted by relevance
727 DebugGrpcChannel::DebugGrpcChannel(const string& server_stream_addr) in DebugGrpcChannel() function in tensorflow::DebugGrpcChannel731 Status DebugGrpcChannel::Connect(const int64 timeout_micros) { in Connect()751 bool DebugGrpcChannel::WriteEvent(const Event& event) { in WriteEvent()756 bool DebugGrpcChannel::ReadEventReply(EventReply* event_reply) { in ReadEventReply()761 void DebugGrpcChannel::ReceiveAndProcessEventReplies(const size_t max_replies) { in ReceiveAndProcessEventReplies()777 Status DebugGrpcChannel::ReceiveServerRepliesAndClose() { in ReceiveServerRepliesAndClose()799 std::unordered_map<string, std::unique_ptr<DebugGrpcChannel>>*801 static std::unordered_map<string, std::unique_ptr<DebugGrpcChannel>>* in GetStreamChannels()803 new std::unordered_map<string, std::unique_ptr<DebugGrpcChannel>>(); in GetStreamChannels()823 DebugGrpcChannel* debug_grpc_channel = nullptr; in SendTensorThroughGrpcStream()[all …]
261 class DebugGrpcChannel {269 explicit DebugGrpcChannel(const string& server_stream_addr);271 virtual ~DebugGrpcChannel() {}394 static std::unordered_map<string, std::unique_ptr<DebugGrpcChannel>>*408 const string& grpc_stream_url, DebugGrpcChannel** debug_grpc_channel);