Searched refs:grpc_stream_url (Results 1 – 2 of 2) sorted by relevance
| /external/tensorflow/tensorflow/core/debug/ |
| D | debug_io_utils.cc | 808 const uint64 wall_time_us, const string& grpc_stream_url, in SendTensorThroughGrpcStream() argument
811 !IsReadGateOpen(grpc_stream_url, debug_node_key.debug_node_name)) { in SendTensorThroughGrpcStream()
819 SendEventProtoThroughGrpcStream(event, grpc_stream_url)); in SendTensorThroughGrpcStream()
821 if (IsWriteGateOpen(grpc_stream_url, debug_node_key.debug_node_name)) { in SendTensorThroughGrpcStream()
824 GetOrCreateDebugGrpcChannel(grpc_stream_url, &debug_grpc_channel)); in SendTensorThroughGrpcStream()
834 EventReply* event_reply, const string& grpc_stream_url) { in ReceiveEventReplyProtoThroughGrpcStream() argument
837 GetOrCreateDebugGrpcChannel(grpc_stream_url, &debug_grpc_channel)); in ReceiveEventReplyProtoThroughGrpcStream()
842 "Reading EventReply from stream URL ", grpc_stream_url, " failed.")); in ReceiveEventReplyProtoThroughGrpcStream()
847 const string& grpc_stream_url, DebugGrpcChannel** debug_grpc_channel) { in GetOrCreateDebugGrpcChannel() argument
849 grpc_stream_url.find(DebugIO::kGrpcURLScheme) == 0 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);
|