Searched refs:DebugGrpcChannel (Results 1 – 2 of 2) sorted by relevance
726 DebugGrpcChannel::DebugGrpcChannel(const string& server_stream_addr) in DebugGrpcChannel() function in tensorflow::DebugGrpcChannel730 Status DebugGrpcChannel::Connect(const int64 timeout_micros) { in Connect()750 bool DebugGrpcChannel::WriteEvent(const Event& event) { in WriteEvent()755 bool DebugGrpcChannel::ReadEventReply(EventReply* event_reply) { in ReadEventReply()760 void DebugGrpcChannel::ReceiveAndProcessEventReplies(const size_t max_replies) { in ReceiveAndProcessEventReplies()776 Status DebugGrpcChannel::ReceiveServerRepliesAndClose() { in ReceiveServerRepliesAndClose()798 std::unordered_map<string, std::unique_ptr<DebugGrpcChannel>>*800 static std::unordered_map<string, std::unique_ptr<DebugGrpcChannel>>* in GetStreamChannels()802 new std::unordered_map<string, std::unique_ptr<DebugGrpcChannel>>(); in GetStreamChannels()822 DebugGrpcChannel* debug_grpc_channel = nullptr; in SendTensorThroughGrpcStream()[all …]
261 class DebugGrpcChannel {269 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);