Searched refs:event_reply (Results 1 – 4 of 4) sorted by relevance
161 event_reply = stream_handler.on_value_event(maybe_tensor_event)162 if event_reply is not None:163 yield self._process_debug_op_state_changes(event_reply)184 def _process_debug_op_state_changes(self, event_reply=None): argument197 if event_reply is None:198 event_reply = debug_service_pb2.EventReply()225 new_state_change = event_reply.debug_op_state_changes.add()227 return event_reply
94 EventReply event_reply; in SendEvents() local96 event_reply.add_debug_op_state_changes(); in SendEvents()105 stream->Write(event_reply); in SendEvents()
755 bool DebugGrpcChannel::ReadEventReply(EventReply* event_reply) { in ReadEventReply() argument757 return reader_writer_->Read(event_reply); in ReadEventReply()761 EventReply event_reply; in ReceiveAndProcessEventReplies() local764 ReadEventReply(&event_reply)) { in ReceiveAndProcessEventReplies()766 event_reply.debug_op_state_changes()) { in ReceiveAndProcessEventReplies()834 EventReply* event_reply, const string& grpc_stream_url) { in ReceiveEventReplyProtoThroughGrpcStream() argument838 if (debug_grpc_channel->ReadEventReply(event_reply)) { in ReceiveEventReplyProtoThroughGrpcStream()
307 bool ReadEventReply(EventReply* event_reply);366 EventReply* event_reply, const string& grpc_stream_url);