Searched refs:debug_grpc_channel (Results 1 – 2 of 2) sorted by relevance
822 DebugGrpcChannel* debug_grpc_channel = nullptr; in SendTensorThroughGrpcStream() local824 GetOrCreateDebugGrpcChannel(grpc_stream_url, &debug_grpc_channel)); in SendTensorThroughGrpcStream()825 debug_grpc_channel->ReceiveAndProcessEventReplies(1); in SendTensorThroughGrpcStream()835 DebugGrpcChannel* debug_grpc_channel = nullptr; in ReceiveEventReplyProtoThroughGrpcStream() local837 GetOrCreateDebugGrpcChannel(grpc_stream_url, &debug_grpc_channel)); in ReceiveEventReplyProtoThroughGrpcStream()838 if (debug_grpc_channel->ReadEventReply(event_reply)) { in ReceiveEventReplyProtoThroughGrpcStream()847 const string& grpc_stream_url, DebugGrpcChannel** debug_grpc_channel) { in GetOrCreateDebugGrpcChannel() argument865 *debug_grpc_channel = (*stream_channels)[grpc_stream_url].get(); in GetOrCreateDebugGrpcChannel()873 DebugGrpcChannel* debug_grpc_channel; in SendEventProtoThroughGrpcStream() local875 GetOrCreateDebugGrpcChannel(grpc_stream_url, &debug_grpc_channel)); in SendEventProtoThroughGrpcStream()[all …]
408 const string& grpc_stream_url, DebugGrpcChannel** debug_grpc_channel);