| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | _service.py | 20 def __init__(self, rpc, handler): argument
45 def _unary_response(argument, implementation, rpc, servicer_context): argument
54 def _stream_response(argument, implementation, rpc, servicer_context): argument
73 def unary_unary(implementation, rpc, request, servicer_context): argument
77 def unary_stream(implementation, rpc, request, servicer_context): argument
81 def stream_unary(implementation, rpc, handler, servicer_context): argument
86 def stream_stream(implementation, rpc, handler, servicer_context): argument
|
| D | _server.py | 33 def service(implementation, rpc, servicer_context): argument
41 def service(implementation, rpc, servicer_context): argument
49 def service(implementation, rpc, servicer_context): argument
57 def service(implementation, rpc, servicer_context): argument
|
| /external/perfetto/ui/src/common/ |
| D | engine.ts | 152 const rpc = TraceProcessorRpc.decode(rpcMsgEncoded); constant
240 const rpc = TraceProcessorRpc.create(); constant
252 const rpc = TraceProcessorRpc.create(); constant
266 const rpc = TraceProcessorRpc.create(); constant
284 const rpc = TraceProcessorRpc.create(); constant
294 const rpc = TraceProcessorRpc.create(); constant
323 const rpc = TraceProcessorRpc.create(); constant
343 const rpc = TraceProcessorRpc.create(); constant
361 const rpc = TraceProcessorRpc.create(); constant
|
| /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/cronet/third_party/libevent/ |
| D | evrpc.c | 84 struct evrpc *rpc; in evrpc_free() local
208 evrpc_register_rpc(struct evrpc_base *base, struct evrpc *rpc, in evrpc_register_rpc()
233 struct evrpc *rpc; in evrpc_unregister_rpc() local
261 struct evrpc *rpc = arg; in evrpc_request_cb() local
320 struct evrpc *rpc = rpc_state->rpc; in evrpc_reqstate_free() local
334 struct evrpc *rpc = rpc_state->rpc; in evrpc_request_done() local
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 273 Rpc rpc = new Rpc(transport).halfClose(); in negotiationFailurePropagatesToStatus() local
306 Rpc rpc = new Rpc(transport).halfClose(); in tlsNegotiationFailurePropagatesToStatus() local
329 Rpc rpc = new Rpc(transport).halfClose(); in channelExceptionDuringNegotiatonPropagatesToStatus() local
360 Rpc rpc = new Rpc(transport).halfClose(); in handlerExceptionDuringNegotiatonPropagatesToStatus() local
431 Rpc rpc = new Rpc(transport); in failingToConstructChannelShouldFailGracefully() local
540 Rpc rpc = new Rpc(transport).halfClose(); in clientStreamGetsAttributes() local
558 Rpc rpc = new Rpc(transport).halfClose(); in keepAliveEnabled() local
570 Rpc rpc = new Rpc(transport).halfClose(); in keepAliveDisabled() 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.ts | 41 readonly rpc: Rpc; property in RpcTimeout
58 private rpc: Rpc; property in Call
|
| D | client.ts | 177 private rpc( method in Client
253 const rpc = this.rpc(packet, channelClient); constant
|
| /external/tensorflow/tensorflow/distribute/experimental/rpc/kernels/oss/ |
| D | grpc_credentials.cc | 20 namespace rpc { namespace
|
| /external/openscreen/cast/protocol/castv2/streaming_examples/ |
| D | rpc.json | 5 "rpc": "SGVsbG8gZnJvbSB0aGUgQ2FzdCBSZWNlaXZlciE=" string
|
| /external/pigweed/pw_rpc/ |
| D | packet_meta.cc | 27 namespace pw::rpc { namespace
|
| D | server_call.cc | 17 namespace pw::rpc::internal { namespace
|
| D | client_server.cc | 17 namespace pw::rpc { namespace
|
| /external/sl4a/ScriptingLayerForAndroid/src/com/googlecode/android_scripting/activity/ |
| D | ApiBrowser.java | 214 MethodDescriptor rpc = (MethodDescriptor) getListAdapter().getItem(info.position); in onContextItemSelected() local
249 MethodDescriptor rpc = in onActivityResult() local
268 private void insertText(MethodDescriptor rpc, String[] values) { in insertText()
|
| /external/pigweed/pw_rpc/raw/ |
| D | service_nc_test.cc | 18 namespace pw::rpc { namespace
|
| /external/pigweed/pw_rpc/pwpb/ |
| D | server_reader_writer.cc | 19 namespace pw::rpc::internal { namespace
|
| /external/pigweed/pw_rpc/nanopb/ |
| D | server_reader_writer.cc | 19 namespace pw::rpc::internal { namespace
|