HomeSort by relevance Sort by last modified time
    Searched full:eventreply (Results 1 - 12 of 12) sorted by null

  /external/tensorflow/tensorflow/core/debug/
debug_grpc_testlib.cc 33 ::grpc::ServerReaderWriter<::tensorflow::EventReply, ::tensorflow::Event>*
40 stream->Write(EventReply());
43 stream->Write(EventReply());
79 // EventReply to 1) unblock the execution and 2) optionally modify the
85 stream->Write(EventReply());
93 EventReply event_reply;
94 EventReply::DebugOpStateChange* change =
106 if (new_states_[i] == EventReply::DebugOpStateChange::READ_WRITE) {
131 const EventReply::DebugOpStateChange::State new_state,
debug_service.proto 28 message EventReply {
93 rpc SendEvents(stream Event) returns (stream EventReply);
96 rpc SendTracebacks(CallTraceback) returns (EventReply);
99 rpc SendSourceFiles(DebuggedSourceFiles) returns (EventReply);
debug_grpc_testlib.h 41 ::grpc::ServerReaderWriter< ::tensorflow::EventReply,
48 const EventReply::DebugOpStateChange::State new_state,
64 std::vector<EventReply::DebugOpStateChange::State> new_states_
debug_io_utils.h 266 // Read an EventReply proto from the debug gRPC stream.
268 // This method blocks and waits for an EventReply from the server.
273 // event_reply: the to-be-modified EventReply proto passed as reference.
277 bool ReadEventReply(EventReply* event_reply);
279 // Receive and process EventReply protos from the gRPC debug server.
282 // DebugOpStateChange fields of the EventReply.
299 std::unique_ptr<::grpc::ClientReaderWriterInterface<Event, EventReply>>
325 // receive_reply: Whether an EventReply proto will be read after event_proto
334 // Receive an EventReply proto through a debug gRPC stream.
336 EventReply* event_reply, const string& grpc_stream_url)
    [all...]
debug_grpc_io_utils_test.cc 283 i == 0 ? EventReply::DebugOpStateChange::READ_ONLY
284 : EventReply::DebugOpStateChange::DISABLED,
324 // sent. In this iteration, the server response with a EventReply proto to
333 i == 0 ? EventReply::DebugOpStateChange::READ_WRITE
334 : EventReply::DebugOpStateChange::DISABLED,
373 EventReply::DebugOpStateChange::READ_ONLY);
376 EventReply::DebugOpStateChange::READ_ONLY);
405 EventReply::DebugOpStateChange::READ_ONLY);
408 EventReply::DebugOpStateChange::READ_ONLY);
433 EventReply::DebugOpStateChange::READ_ONLY)
    [all...]
debug_io_utils.cc 703 bool DebugGrpcChannel::ReadEventReply(EventReply* event_reply) {
709 EventReply event_reply;
713 for (const EventReply::DebugOpStateChange& debug_op_state_change :
726 // Read all EventReply messages (if any) from the server.
774 // TODO(cais): Support new tensor value carried in the EventReply for
782 EventReply* event_reply, const string& grpc_stream_url) {
790 "Reading EventReply from stream URL ", grpc_stream_url, " failed."));
853 return it->second == EventReply::DebugOpStateChange::READ_WRITE;
    [all...]
  /external/tensorflow/tensorflow/python/debug/lib/
debug_service_pb2_grpc.py 44 response_deserializer=tensorflow_dot_core_dot_debug_dot_debug__service__pb2.EventReply.FromString,
49 response_deserializer=tensorflow_dot_core_dot_debug_dot_debug__service__pb2.EventReply.FromString,
54 response_deserializer=tensorflow_dot_core_dot_debug_dot_debug__service__pb2.EventReply.FromString,
96 response_serializer=tensorflow_dot_core_dot_debug_dot_debug__service__pb2.EventReply.SerializeToString,
101 response_serializer=tensorflow_dot_core_dot_debug_dot_debug__service__pb2.EventReply.SerializeToString,
106 response_serializer=tensorflow_dot_core_dot_debug_dot_debug__service__pb2.EventReply.SerializeToString,
grpc_debug_server.py 42 state_change = debug_service_pb2.EventReply.DebugOpStateChange()
64 `None` or an `EventReply` proto to be sent back to the client. If `None`,
65 an `EventReply` proto construct with the default no-arg constructor will
84 `None` or an `EventReply` proto to be sent back to the client. If `None`,
85 an `EventReply` proto construct with the default no-arg constructor will
187 Include all the debug-op state change protos in a `EventReply` proto.
190 event_reply: An `EventReply` to add the `DebugOpStateChange` protos to,
194 An `EventReply` proto with the dequeued `DebugOpStateChange` protos (if
198 event_reply = debug_service_pb2.EventReply()
204 debug_service_pb2.EventReply.DebugOpStateChange.READ_WRITE)
    [all...]
grpc_debug_test_server.py 148 a `EventReply` proto will be returned.
164 return debug_service_pb2.EventReply()
286 return debug_service_pb2.EventReply()
290 return debug_service_pb2.EventReply()
session_debug_grpc_test.py 740 # unblocked by EventReply reponses from the server.
793 # unblocked by EventReply reponses from the server.
    [all...]
  /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/Events/
ClassPrepare002Test.java 66 ReplyPacket eventReply = debuggeeWrapper.vmMirror.setEvent(event);
67 checkReplyPacket(eventReply, "Failed to set CLASS_PREPARE event");
68 int classPrepareRequestId = eventReply.getNextValueAsInt();
69 assertAllDataRead(eventReply);
  /external/tensorflow/tensorflow/core/kernels/
debug_ops_test.cc 619 EventReply::DebugOpStateChange::READ_ONLY);

Completed in 243 milliseconds