Searched refs:grpc_stream_url (Results 1 – 2 of 2) sorted by relevance
| /external/tensorflow/tensorflow/core/debug/ |
| D | debug_io_utils.cc | 809 const uint64 wall_time_us, const string& grpc_stream_url, in SendTensorThroughGrpcStream() argument
812 !IsReadGateOpen(grpc_stream_url, debug_node_key.debug_node_name)) { in SendTensorThroughGrpcStream()
820 SendEventProtoThroughGrpcStream(event, grpc_stream_url)); in SendTensorThroughGrpcStream()
822 if (IsWriteGateOpen(grpc_stream_url, debug_node_key.debug_node_name)) { in SendTensorThroughGrpcStream()
825 GetOrCreateDebugGrpcChannel(grpc_stream_url, &debug_grpc_channel)); in SendTensorThroughGrpcStream()
835 EventReply* event_reply, const string& grpc_stream_url) { in ReceiveEventReplyProtoThroughGrpcStream() argument
838 GetOrCreateDebugGrpcChannel(grpc_stream_url, &debug_grpc_channel)); in ReceiveEventReplyProtoThroughGrpcStream()
843 "Reading EventReply from stream URL ", grpc_stream_url, " failed.")); in ReceiveEventReplyProtoThroughGrpcStream()
848 const string& grpc_stream_url, DebugGrpcChannel** debug_grpc_channel) { in GetOrCreateDebugGrpcChannel() argument
850 absl::StartsWith(grpc_stream_url, DebugIO::kGrpcURLScheme) in GetOrCreateDebugGrpcChannel()
[all …]
|
| D | debug_io_utils.h | 344 const string& grpc_stream_url,
361 const Event& event_proto, const string& grpc_stream_url,
366 EventReply* event_reply, const string& grpc_stream_url);
380 static Status CloseGrpcStream(const string& grpc_stream_url);
408 const string& grpc_stream_url, DebugGrpcChannel** debug_grpc_channel);
|