OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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 371 milliseconds