| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | _service.py | 21 def __init__(self, rpc, handler): argument
46 def _unary_response(argument, implementation, rpc, servicer_context): argument
55 def _stream_response(argument, implementation, rpc, servicer_context): argument
74 def unary_unary(implementation, rpc, request, servicer_context): argument
78 def unary_stream(implementation, rpc, request, servicer_context): argument
82 def stream_unary(implementation, rpc, handler, servicer_context): argument
88 def stream_stream(implementation, rpc, handler, servicer_context): argument
|
| D | _server.py | 32 def service(implementation, rpc, servicer_context): argument
39 def service(implementation, rpc, servicer_context): argument
46 def service(implementation, rpc, servicer_context): argument
53 def service(implementation, rpc, servicer_context): argument
|
| /external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| D | Packets.java | 25 public static byte[] request(PendingRpc rpc, MessageLite payload) { in request()
37 public static byte[] cancel(PendingRpc rpc) { in cancel()
59 public static byte[] clientStream(PendingRpc rpc, MessageLite payload) { in clientStream()
70 public static byte[] clientStreamEnd(PendingRpc rpc) { in clientStreamEnd()
|
| D | RpcError.java | 23 private final PendingRpc rpc; field in RpcError
26 public RpcError(PendingRpc rpc, Status status) { in RpcError()
32 public PendingRpc rpc() { in rpc() method in RpcError
|
| D | Endpoint.java | 201 private boolean handleNext(PendingRpc rpc, ByteString payload) { in handleNext()
211 private boolean handleUnaryCompleted(PendingRpc rpc, ByteString payload, Status status) { in handleUnaryCompleted()
222 private boolean handleStreamCompleted(PendingRpc rpc, Status status) { in handleStreamCompleted()
232 private boolean handleError(PendingRpc rpc, Status status) { in handleError()
257 PendingRpc rpc = PendingRpc.create(channel, method); in processClientPacket() local
270 private boolean updateCall(RpcPacket packet, PendingRpc rpc) { in updateCall()
|
| D | AbstractCall.java | 36 private final PendingRpc rpc; field in AbstractCall
41 AbstractCall(Endpoint endpoint, PendingRpc rpc) { in AbstractCall()
86 final PendingRpc rpc() { in rpc() method in AbstractCall
|
| D | FutureCall.java | 43 private FutureCall(Endpoint endpoint, PendingRpc rpc) { in FutureCall()
112 UnaryResponseFuture(Endpoint endpoint, PendingRpc rpc) { in UnaryResponseFuture()
148 private StreamResponseFuture(Endpoint endpoint, PendingRpc rpc, Consumer<ResponseT> onNext) { in StreamResponseFuture()
|
| /external/perfetto/ui/src/trace_processor/ |
| D | engine.ts | 205 const rpc = protos.TraceProcessorRpc.decode(rpcMsgEncoded); constant
334 const rpc = protos.TraceProcessorRpc.create(); constant
346 const rpc = protos.TraceProcessorRpc.create(); constant
363 const rpc = protos.TraceProcessorRpc.create(); constant
383 const rpc = protos.TraceProcessorRpc.create(); constant
396 const rpc = protos.TraceProcessorRpc.create(); constant
436 const rpc = protos.TraceProcessorRpc.create(); constant
506 const rpc = protos.TraceProcessorRpc.create(); constant
527 const rpc = protos.TraceProcessorRpc.create(); constant
545 const rpc = protos.TraceProcessorRpc.create(); constant
[all …]
|
| /external/pytorch/torch/csrc/distributed/rpc/ |
| D | request_callback_impl.cpp | 36 namespace torch::distributed::rpc { namespace
43 RpcCommandBase& rpc, in deserializePythonRpcCommandReference()
151 std::unique_ptr<RpcCommandBase> rpc, in deserializePythonRpcCommand()
158 RpcCommandBase& rpc, in processScriptCall()
181 RpcCommandBase& rpc, in processPythonCall()
196 RpcCommandBase& rpc, in processScriptRemoteCall()
217 RpcCommandBase& rpc, in processPythonRemoteCall()
250 RpcCommandBase& rpc, in processRpcWithErrors()
|
| D | request_callback_no_python.cpp | 21 namespace torch::distributed::rpc { namespace
45 std::unique_ptr<RpcCommandBase> rpc, in deserializePythonRpcCommand()
65 std::unique_ptr<RpcCommandBase> rpc = deserializePythonRpcCommand( in processMessage() local
125 RpcCommandBase& rpc, in processRpcWithErrors()
137 RpcCommandBase& rpc, in processScriptCall()
154 RpcCommandBase& rpc, in processPythonCall()
160 RpcCommandBase& rpc, in processPythonRemoteCall()
204 RpcCommandBase& rpc, in processScriptRemoteCall()
284 RpcCommandBase& rpc, in processForwardAutogradReq()
355 RpcCommandBase& rpc, in processBackwardAutogradReq()
[all …]
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 286 Rpc rpc = new Rpc(transport).halfClose(); in negotiationFailurePropagatesToStatus() local
319 Rpc rpc = new Rpc(transport).halfClose(); in tlsNegotiationFailurePropagatesToStatus() local
348 Rpc rpc = new Rpc(transport).halfClose(); in channelExceptionDuringNegotiatonPropagatesToStatus() local
379 Rpc rpc = new Rpc(transport).halfClose(); in handlerExceptionDuringNegotiatonPropagatesToStatus() local
454 Rpc rpc = new Rpc(transport); in failingToConstructChannelShouldFailGracefully() local
591 Rpc rpc = new Rpc(transport).halfClose(); in clientStreamGetsAttributes() local
609 Rpc rpc = new Rpc(transport).halfClose(); in keepAliveEnabled() local
621 Rpc rpc = new Rpc(transport).halfClose(); in keepAliveDisabled() local
713 Rpc rpc = new Rpc(transport).halfClose(); in tlsNegotiationServerExecutorShouldSucceed() local
|
| /external/openscreen/cast/standalone_receiver/ |
| D | simple_remoting_receiver.cc | 72 openscreen::cast::RpcMessage rpc; in SendInitializeMessage() local
83 openscreen::cast::RpcMessage rpc; in SendPlaybackRateMessage() local
|
| /external/openscreen/cast/streaming/ |
| D | rpc_messenger_unittest.cc | 77 void ProcessMessage(const RpcMessage& rpc) { in ProcessMessage()
88 RpcMessage rpc; in TEST_F() local
95 RpcMessage rpc; in TEST_F() local
|
| D | rpc_messenger.cc | 71 auto rpc = std::make_unique<RpcMessage>(); in ProcessMessageFromRemote() local
90 void RpcMessenger::SendMessageToRemote(const RpcMessage& rpc) { in SendMessageToRemote()
|
| /external/libevent/ |
| D | evrpc.c | 95 struct evrpc *rpc; in evrpc_free() local
228 evrpc_register_rpc(struct evrpc_base *base, struct evrpc *rpc, in evrpc_register_rpc()
253 struct evrpc *rpc; in evrpc_unregister_rpc() local
287 struct evrpc *rpc = arg; in evrpc_request_cb() local
342 struct evrpc *rpc; in evrpc_request_cb_closure() local
384 struct evrpc *rpc; in evrpc_reqstate_free_() local
407 struct evrpc *rpc; in evrpc_request_done() local
1111 struct evrpc* rpc = (struct evrpc *)mm_calloc(1, sizeof(struct evrpc)); in evrpc_register_object() local
1140 struct evrpc* rpc = in evrpc_register_generic() local
|
| /external/pigweed/pw_rpc/ts/ |
| D | call_test.ts | 46 const rpc = new FakeRpc(); constant
150 const rpc = new FakeRpc(); constant
|
| D | client.ts | 177 private rpc( method in Client
257 const rpc = this.rpc(packet, channelClient); constant
|
| /external/cronet/stable/third_party/llvm-libc/src/src/__support/RPC/ |
| D | rpc_client.cpp | 14 namespace rpc { namespace
|
| /external/pytorch/torch/csrc/distributed/rpc/metrics/ |
| D | registry.cpp | 3 namespace torch::distributed::rpc { namespace
|
| /external/cronet/tot/third_party/llvm-libc/src/src/__support/RPC/ |
| D | rpc_client.cpp | 14 namespace rpc { namespace
|
| /external/llvm-libc/src/__support/RPC/ |
| D | rpc_client.cpp | 14 namespace rpc { namespace
|
| /external/openscreen/cast/protocol/castv2/streaming_examples/ |
| D | rpc.json | 5 "rpc": "SGVsbG8gZnJvbSB0aGUgQ2FzdCBSZWNlaXZlciE=" string
|
| /external/tensorflow/tensorflow/distribute/experimental/rpc/kernels/oss/ |
| D | grpc_credentials.cc | 20 namespace rpc { namespace
|
| /external/pigweed/pw_rpc/ |
| D | packet_meta.cc | 27 namespace pw::rpc { namespace
|
| D | client_server.cc | 17 namespace pw::rpc { namespace
|