Searched refs:debug_grpc_channel (Results 1 – 2 of 2) sorted by relevance
823 DebugGrpcChannel* debug_grpc_channel = nullptr; in SendTensorThroughGrpcStream() local825 GetOrCreateDebugGrpcChannel(grpc_stream_url, &debug_grpc_channel)); in SendTensorThroughGrpcStream()826 debug_grpc_channel->ReceiveAndProcessEventReplies(1); in SendTensorThroughGrpcStream()836 DebugGrpcChannel* debug_grpc_channel = nullptr; in ReceiveEventReplyProtoThroughGrpcStream() local838 GetOrCreateDebugGrpcChannel(grpc_stream_url, &debug_grpc_channel)); in ReceiveEventReplyProtoThroughGrpcStream()839 if (debug_grpc_channel->ReadEventReply(event_reply)) { in ReceiveEventReplyProtoThroughGrpcStream()848 const string& grpc_stream_url, DebugGrpcChannel** debug_grpc_channel) { in GetOrCreateDebugGrpcChannel() argument866 *debug_grpc_channel = (*stream_channels)[grpc_stream_url].get(); in GetOrCreateDebugGrpcChannel()874 DebugGrpcChannel* debug_grpc_channel; in SendEventProtoThroughGrpcStream() local876 GetOrCreateDebugGrpcChannel(grpc_stream_url, &debug_grpc_channel)); in SendEventProtoThroughGrpcStream()[all …]
408 const string& grpc_stream_url, DebugGrpcChannel** debug_grpc_channel);