| /external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| D | RpcManager.java | 38 PendingRpc rpc, StreamObserverCall<?, ?> call, @Nullable MessageLite payload) in start()
53 PendingRpc rpc, StreamObserverCall<?, ?> call, @Nullable MessageLite payload) { in open()
66 public synchronized StreamObserverCall<?, ?> cancel(PendingRpc rpc) in cancel()
77 public synchronized StreamObserverCall<?, ?> clientStream(PendingRpc rpc, MessageLite payload) in clientStream()
87 public synchronized StreamObserverCall<?, ?> clientStreamEnd(PendingRpc rpc) in clientStreamEnd()
98 public synchronized StreamObserverCall<?, ?> clear(PendingRpc rpc) { in clear()
103 public synchronized StreamObserverCall<?, ?> getPending(PendingRpc rpc) { in getPending()
|
| 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 | StreamObserverCall.java | 41 private final PendingRpc rpc; field in StreamObserverCall
54 private StreamObserverFutureCall(RpcManager rpcs, PendingRpc rpc) { in StreamObserverFutureCall()
117 UnaryResponseFuture(RpcManager rpcs, PendingRpc rpc, @Nullable RequestT request) { in UnaryResponseFuture()
148 RpcManager rpcs, PendingRpc rpc, Consumer<ResponseT> onNext, @Nullable RequestT request) { in StreamResponseFuture()
168 PendingRpc rpc, in start()
179 PendingRpc rpc, in open()
187 private StreamObserverCall(RpcManager rpcs, PendingRpc rpc, StreamObserver<ResponseT> observer) { in StreamObserverCall()
|
| D | MethodClient.java | 31 private final PendingRpc rpc; field in MethodClient
33 MethodClient(RpcManager rpcs, PendingRpc rpc, StreamObserver<MessageLite> defaultObserver) { in MethodClient()
49 protected final PendingRpc rpc() { in rpc() method in MethodClient
|
| /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 | 147 const rpc = TraceProcessorRpc.decode(rpcMsgEncoded); constant
225 const rpc = TraceProcessorRpc.create(); constant
239 const rpc = TraceProcessorRpc.create(); constant
252 const rpc = TraceProcessorRpc.create(); constant
264 const rpc = TraceProcessorRpc.create(); constant
292 const rpc = TraceProcessorRpc.create(); constant
|
| /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 | 173 private rpc( method in Client
249 const rpc = this.rpc(packet, channelClient); constant
|
| /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/ |
| D | client_call.cc | 17 namespace pw::rpc::internal { namespace
|
| D | server_call.cc | 17 namespace pw::rpc::internal { namespace
|
| D | client_server.cc | 17 namespace pw::rpc { namespace
|
| D | client.cc | 26 namespace pw::rpc { namespace
|
| D | service.cc | 20 namespace pw::rpc { namespace
|
| D | integration_testing.cc | 24 namespace pw::rpc::integration_test { namespace
|
| /external/openscreen/cast/protocol/castv2/streaming_examples/ |
| D | rpc.json | 5 "rpc": "SGVsbG8gZnJvbSB0aGUgQ2FzdCBSZWNlaXZlciE=" string
|
| /external/pigweed/pw_rpc/nanopb/ |
| D | server_reader_writer.cc | 19 namespace pw::rpc::internal { namespace
|
| D | echo_service_test.cc | 19 namespace pw::rpc { namespace
|