| /aosp_15_r20/development/tools/winscope/src/trace_processor/ |
| H A D | engine.ts | 147 const rpc = TraceProcessorRpc.decode(rpcMsgEncoded); constant
235 const rpc = TraceProcessorRpc.create(); constant
247 const rpc = TraceProcessorRpc.create(); constant
261 const rpc = TraceProcessorRpc.create(); constant
279 const rpc = TraceProcessorRpc.create(); constant
289 const rpc = TraceProcessorRpc.create(); constant
318 const rpc = TraceProcessorRpc.create(); constant
338 const rpc = TraceProcessorRpc.create(); constant
356 const rpc = TraceProcessorRpc.create(); constant
|
| /aosp_15_r20/external/perfetto/ui/src/trace_processor/ |
| H A D | engine.ts | 179 const rpc = protos.TraceProcessorRpc.decode(rpcMsgEncoded); constant
300 const rpc = protos.TraceProcessorRpc.create(); constant
312 const rpc = protos.TraceProcessorRpc.create(); constant
329 const rpc = protos.TraceProcessorRpc.create(); constant
349 const rpc = protos.TraceProcessorRpc.create(); constant
362 const rpc = protos.TraceProcessorRpc.create(); constant
402 const rpc = protos.TraceProcessorRpc.create(); constant
450 const rpc = protos.TraceProcessorRpc.create(); constant
471 const rpc = protos.TraceProcessorRpc.create(); constant
489 const rpc = protos.TraceProcessorRpc.create(); constant
|
| /aosp_15_r20/packages/services/Car/cpp/computepipe/runner/graph/ |
| D | GrpcGraph.cpp | 38 ::grpc::ClientAsyncResponseReader<RpcType>* rpc, ::grpc::CompletionQueue* cq, in FinishRpcAndGetResult()
100 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::GraphOptionsResponse>> rpc( in initialize() local
149 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleConfigPhase() local
201 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleExecutionPhase() local
241 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleStopWithFlushPhase() local
284 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleStopImmediatePhase() local
324 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in handleResetPhase() local
365 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in StartGraphProfiling() local
389 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::StatusResponse>> rpc( in StopGraphProfiling() local
412 std::unique_ptr<::grpc::ClientAsyncResponseReader<proto::ProfilingDataResponse>> rpc( in GetDebugInfo() local
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| H A 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
|
| H A 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
|
| /aosp_15_r20/external/pytorch/torch/csrc/distributed/rpc/ |
| H A 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 …]
|
| H A 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()
|
| H A D | utils.cpp | 30 namespace torch::distributed::rpc { namespace
173 RpcCommandBase& rpc = *rpcPtr; in deserializeResponse() local
203 RpcCommandBase& rpc = *rpcPtr; in deserializeResponse() local
224 RpcCommandBase& rpc, in deserializeResptoIValueInternal()
|
| /aosp_15_r20/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| H A 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
|
| /aosp_15_r20/external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| H A 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()
|
| H A 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()
|
| H A 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
|
| H A 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()
|
| H A 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
|
| /aosp_15_r20/system/security/provisioner/support/ |
| H A D | rkpd_client.cpp | 45 std::optional<std::string> getRpcId(const sp<IRemotelyProvisionedComponent>& rpc) { in getRpcId()
67 sp<IRemotelyProvisionedComponent> rpc = in findRpcNameById() local
84 std::optional<String16> getRpcName(const sp<IRemotelyProvisionedComponent>& rpc) { in getRpcName()
172 getRpcKeyFuture(const sp<IRemotelyProvisionedComponent>& rpc, int32_t keyId) { in getRpcKeyFuture()
199 std::optional<RemotelyProvisionedKey> getRpcKey(const sp<IRemotelyProvisionedComponent>& rpc, in getRpcKey()
|
| /aosp_15_r20/external/libevent/ |
| H A 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
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/end2end/xds/ |
| H A D | xds_fault_injection_end2end_test.cc | 246 for (auto& rpc : rpcs) { in TEST_P() local
301 for (auto& rpc : rpcs) { in TEST_P() local
386 for (auto& rpc : rpcs) { in TEST_P() local
443 for (auto& rpc : rpcs) { in TEST_P() local
486 for (auto& rpc : rpcs) { in TEST_P() local
497 for (auto& rpc : rpcs) { in TEST_P() local
|
| /aosp_15_r20/external/openscreen/cast/streaming/ |
| H A 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
|
| H A D | rpc_messenger.cc | 71 auto rpc = std::make_unique<RpcMessage>(); in ProcessMessageFromRemote() local
90 void RpcMessenger::SendMessageToRemote(const RpcMessage& rpc) { in SendMessageToRemote()
|
| /aosp_15_r20/external/sl4a/ScriptingLayerForAndroid/src/com/googlecode/android_scripting/activity/ |
| H A 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()
|
| /aosp_15_r20/hardware/interfaces/security/keymint/aidl/default/ta/ |
| H A D | lib.rs | 38 pub mod rpc; module
83 let rpc: Box<dyn kmr_ta::device::RetrieveRpcArtifacts> = Box::new(soft::RpcArtifacts::new( in build_ta() localVariable
|
| /aosp_15_r20/external/openscreen/cast/standalone_receiver/ |
| H A D | simple_remoting_receiver.cc | 72 openscreen::cast::RpcMessage rpc; in SendInitializeMessage() local
83 openscreen::cast::RpcMessage rpc; in SendPlaybackRateMessage() local
|
| /aosp_15_r20/external/pigweed/pw_rpc/ts/ |
| H A D | call_test.ts | 46 const rpc = new FakeRpc(); constant
150 const rpc = new FakeRpc(); constant
|
| H A D | client.ts | 177 private rpc( method in Client
257 const rpc = this.rpc(packet, channelClient); constant
|
| H A D | call.ts | 41 readonly rpc: Rpc; property in RpcTimeout
97 rpc: Rpc; property in Call
|