Home
last modified time | relevance | path

Searched full:rpc (Results 1 – 25 of 13431) sorted by relevance

12345678910>>...538

/aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/
H A Dface.py14 """Interfaces defining the Face layer of RPC Framework."""
42 group: The group identifier of the unrecognized RPC name.
43 method: The method identifier of the unrecognized RPC name.
68 """A value describing RPC abortion.
71 kind: A Kind value identifying how the RPC failed.
72 initial_metadata: The initial metadata from the other side of the RPC or
74 terminal_metadata: The terminal metadata from the other side of the RPC or
76 code: The code value from the other side of the RPC or None if no code value
78 details: The details value from the other side of the RPC or None if no
84 """Types of RPC abortion."""
[all …]
/aosp_15_r20/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/
H A D__init__.py23 """Fixture for a unary-unary RPC invoked by a system under test.
25 Enables users to "play server" for the RPC.
30 """Sends the RPC's initial metadata to the system under test.
33 initial_metadata: The RPC's initial metadata to be "sent" to
40 """Blocks until the system under test has cancelled the RPC."""
45 """Terminates the RPC.
48 response: The response for the RPC.
49 trailing_metadata: The RPC's trailing metadata.
50 code: The RPC's status code.
51 details: The RPC's status details.
[all …]
/aosp_15_r20/packages/modules/Bluetooth/system/blueberry/facade/topshim/
Dfacade.proto8 rpc FetchEvents(FetchEventsRequest) returns (stream FetchEventsResponse) {}
9 rpc ToggleStack(ToggleStackRequest) returns (ToggleStackResponse) {}
10 rpc SetDiscoveryMode(SetDiscoveryModeRequest) returns (google.protobuf.Empty) {}
11 rpc ClearEventFilter(google.protobuf.Empty) returns (google.protobuf.Empty) {}
12 rpc ClearEventMask(google.protobuf.Empty) returns (google.protobuf.Empty) {}
13 rpc ClearFilterAcceptList(google.protobuf.Empty) returns (google.protobuf.Empty) {}
14 rpc DisconnectAllAcls(google.protobuf.Empty) returns (google.protobuf.Empty) {}
15 rpc LeRand(google.protobuf.Empty) returns (google.protobuf.Empty) {}
16 …rpc SetEventFilterConnectionSetupAllDevices(google.protobuf.Empty) returns (google.protobuf.Empty)…
17 rpc AllowWakeByHid(google.protobuf.Empty) returns (google.protobuf.Empty) {}
[all …]
/aosp_15_r20/external/ltp/testcases/network/rpc/rpc-tirpc/
H A D.gitignore11 /tests_pack/rpc_suite/rpc/rpc_stdcall_clnt_control/rpc_clnt_control
12 /tests_pack/rpc_suite/rpc/rpc_stdcall_clnt_control/rpc_clnt_control_dataint
13 /tests_pack/rpc_suite/rpc/rpc_stdcall_svc_sendreply/rpc_svc_sendreply
14 /tests_pack/rpc_suite/rpc/rpc_stdcall_svc_sendreply/rpc_svc_sendreply_client
15 /tests_pack/rpc_suite/rpc/rpc_createdestroy_clntraw_create/rpc_clntraw_create_performance
16 /tests_pack/rpc_suite/rpc/rpc_createdestroy_clntraw_create/rpc_clntraw_create
17 /tests_pack/rpc_suite/rpc/rpc_createdestroy_clntraw_create/rpc_clntraw_create_complex
18 /tests_pack/rpc_suite/rpc/rpc_err_clnt_sperrno/rpc_clnt_sperrno
19 /tests_pack/rpc_suite/rpc/rpc_addrmanagmt_pmap_getmaps/rpc_pmap_getmaps
20 /tests_pack/rpc_suite/rpc/rpc_regunreg_xprt_register/rpc_xprt_register
[all …]
/aosp_15_r20/packages/modules/Bluetooth/system/blueberry/facade/hci/
Dcontroller_facade.proto9 rpc GetMacAddress(google.protobuf.Empty) returns (blueberry.facade.BluetoothAddress) {}
10 rpc WriteLocalName(NameMsg) returns (google.protobuf.Empty) {}
11 rpc GetLocalName(google.protobuf.Empty) returns (NameMsg) {}
12 rpc IsSupportedCommand(OpCodeMsg) returns (SupportedMsg) {}
13 rpc GetLeNumberOfSupportedAdvertisingSets(google.protobuf.Empty) returns (SingleValueMsg) {}
14 rpc SupportsSimplePairing(google.protobuf.Empty) returns (SupportedMsg) {}
15 rpc SupportsSecureConnections(google.protobuf.Empty) returns (SupportedMsg) {}
16 rpc SupportsSimultaneousLeBrEdr(google.protobuf.Empty) returns (SupportedMsg) {}
17 rpc SupportsInterlacedInquiryScan(google.protobuf.Empty) returns (SupportedMsg) {}
18 rpc SupportsRssiWithInquiryResults(google.protobuf.Empty) returns (SupportedMsg) {}
[all …]
/aosp_15_r20/external/pigweed/pw_rpc/py/pw_rpc/
H A Dclient.py47 """Error from incorrectly using the RPC client classes."""
56 """Tracks pending RPCs and encodes outgoing RPC packets."""
72 self, rpc: PendingRpc, request: Message | None, context: object
74 """Starts the provided RPC and returns the encoded packet to send."""
76 self.open(rpc, context)
77 return packets.encode_request(rpc, request)
80 self, rpc: PendingRpc, request: Message | None, context: object
82 """Starts the provided RPC and sends the request packet to the channel.
87 self.open(rpc, context)
88 packet = packets.encode_request(rpc, request)
[all …]
/aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/testing/
H A D_client_test.py64 rpc,
68 rpc.send_initial_metadata(())
69 rpc.terminate(
89 rpc,
93 rpc.send_initial_metadata(())
94 rpc.terminate((), grpc.StatusCode.OK, "")
109 invocation_metadata, rpc = self._real_time_channel.take_stream_unary(
112 rpc.send_initial_metadata(())
113 first_request = rpc.take_request()
114 second_request = rpc.take_request()
[all …]
H A D_server_test.py43 rpc = self._real_time_server.invoke_unary_unary(
49 initial_metadata = rpc.initial_metadata()
50 response, trailing_metadata, code, details = rpc.termination()
56 rpc = self._real_time_server.invoke_unary_stream(
62 initial_metadata = rpc.initial_metadata()
63 trailing_metadata, code, details = rpc.termination()
68 rpc = self._real_time_server.invoke_stream_unary(
71 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
72 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
73 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
[all …]
/aosp_15_r20/external/pytorch/torch/testing/_internal/distributed/rpc/
H A Drpc_test.py20 import torch.distributed.rpc as rpc namespace
22 from torch.distributed.rpc import RRef, _get_debug_info, _rref_context_get_debug_info, WorkerInfo
23 from torch.distributed.rpc.api import _use_rpc_pickler, _thread_local_var, _wait_all
24 from torch.distributed.rpc.internal import (
52 from torch.testing._internal.distributed.rpc.rpc_agent_test_fixture import (
90 # Remote operations are prefixed with the following string for RPC profiling.
141 # it is used to test python user defined function over rpc
143 # methods over rpc
297 return rpc.rpc_sync(dst, torch.add, args=(torch.ones(2, 2), 1))
301 return rpc.rpc_sync(
[all …]
/aosp_15_r20/external/pytorch/torch/distributed/rpc/
H A Dapi.py76 rpc_pickler: (.internal._InternalRPCPickler) Overrides the default RPC pickler
91 "RPC has not been initialized. Call "
92 "torch.distributed.rpc.init_rpc first."
117 # `_ALL_WORKER_NAMES` is initialized on initializing RPC layer.
178 >>> import torch.distributed.rpc as rpc
179 >>> rpc.init_rpc("worker0", rank=0, world_size=2)
180 >>> with rpc._wait_all():
181 >>> fut_1 = rpc.rpc_async(dst, torch.add, (torch.ones(2, 2), 1))
182 >>> fut_2 = rpc.rpc_async(dst, torch.add, (torch.ones(2, 2), 1))
198 This is similar to torch.distributed.all_gather(), but is using RPC. It
[all …]
/aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/
H A D__init__.py298 """Describes the status of an RPC.
305 termination of the RPC.
306 trailing_metadata: The trailing :term:`metadata` in the RPC.
314 """Raised by the gRPC library to indicate non-OK-status RPC termination."""
321 """Provides RPC-related information and action."""
325 """Describes whether the RPC is active or has terminated.
329 True if RPC is active, False otherwise.
335 """Describes the length of allowed time remaining for the RPC.
339 remaining for the RPC to complete before it is considered to have
340 timed out, or None if no deadline was specified for the RPC.
[all …]
/aosp_15_r20/external/sl4a/Common/src/com/googlecode/android_scripting/facade/telephony/
H A DTelephonyManagerFacade.java68 import com.googlecode.android_scripting.rpc.Rpc;
69 import com.googlecode.android_scripting.rpc.RpcDefault;
70 import com.googlecode.android_scripting.rpc.RpcOptional;
71 import com.googlecode.android_scripting.rpc.RpcParameter;
133 @Rpc(description = "Resets TelephonyManager settings to factory default.")
146 @Rpc(description = "Resets Telephony and IMS settings to factory default.")
155 @Rpc(description = "Set network preference.")
162 @Rpc(description = "Set network preference for subscription.")
180 @Rpc(description = "Set network selection mode to automatic for subscriber.")
186 @Rpc(description = "Get network preference.")
[all …]
/aosp_15_r20/external/sdk-platform-java/java-common-protos/proto-google-common-protos/src/main/java/com/google/rpc/
H A DHelp.java17 // source: google/rpc/error_details.proto
19 package com.google.rpc;
31 * Protobuf type {@code google.rpc.Help}
35 // @@protoc_insertion_point(message_implements:google.rpc.Help)
59 return com.google.rpc.ErrorDetailsProto.internal_static_google_rpc_Help_descriptor; in getDescriptor()
65 return com.google.rpc.ErrorDetailsProto.internal_static_google_rpc_Help_fieldAccessorTable in internalGetFieldAccessorTable()
67 com.google.rpc.Help.class, com.google.rpc.Help.Builder.class); in internalGetFieldAccessorTable()
72 // @@protoc_insertion_point(interface_extends:google.rpc.Help.Link)
132 * Protobuf type {@code google.rpc.Help.Link}
136 // @@protoc_insertion_point(message_implements:google.rpc.Help.Link)
[all …]
H A DQuotaFailure.java17 // source: google/rpc/error_details.proto
19 package com.google.rpc;
36 * Protobuf type {@code google.rpc.QuotaFailure}
40 // @@protoc_insertion_point(message_implements:google.rpc.QuotaFailure)
64 return com.google.rpc.ErrorDetailsProto.internal_static_google_rpc_QuotaFailure_descriptor; in getDescriptor()
70 return com.google.rpc.ErrorDetailsProto in internalGetFieldAccessorTable()
73 com.google.rpc.QuotaFailure.class, com.google.rpc.QuotaFailure.Builder.class); in internalGetFieldAccessorTable()
78 // @@protoc_insertion_point(interface_extends:google.rpc.QuotaFailure.Violation)
153 * Protobuf type {@code google.rpc.QuotaFailure.Violation}
157 // @@protoc_insertion_point(message_implements:google.rpc.QuotaFailure.Violation)
[all …]
H A DPreconditionFailure.java17 // source: google/rpc/error_details.proto
19 package com.google.rpc;
26 * For example, if an RPC failed because it required the Terms of Service to be
31 * Protobuf type {@code google.rpc.PreconditionFailure}
35 // @@protoc_insertion_point(message_implements:google.rpc.PreconditionFailure)
59 return com.google.rpc.ErrorDetailsProto in getDescriptor()
66 return com.google.rpc.ErrorDetailsProto in internalGetFieldAccessorTable()
69 com.google.rpc.PreconditionFailure.class, in internalGetFieldAccessorTable()
70 com.google.rpc.PreconditionFailure.Builder.class); in internalGetFieldAccessorTable()
75 // @@protoc_insertion_point(interface_extends:google.rpc.PreconditionFailure.Violation)
[all …]
H A DBadRequest.java17 // source: google/rpc/error_details.proto
19 package com.google.rpc;
29 * Protobuf type {@code google.rpc.BadRequest}
33 // @@protoc_insertion_point(message_implements:google.rpc.BadRequest)
57 return com.google.rpc.ErrorDetailsProto.internal_static_google_rpc_BadRequest_descriptor; in getDescriptor()
63 return com.google.rpc.ErrorDetailsProto.internal_static_google_rpc_BadRequest_fieldAccessorTable in internalGetFieldAccessorTable()
65 com.google.rpc.BadRequest.class, com.google.rpc.BadRequest.Builder.class); in internalGetFieldAccessorTable()
70 // @@protoc_insertion_point(interface_extends:google.rpc.BadRequest.FieldViolation)
186 * Protobuf type {@code google.rpc.BadRequest.FieldViolation}
190 // @@protoc_insertion_point(message_implements:google.rpc.BadRequest.FieldViolation)
[all …]
/aosp_15_r20/external/pigweed/pw_rpc/
H A Dcpp.rst13 RPC server
15 Declare an instance of ``rpc::Server`` and register services with it.
19 The following size report showcases the memory usage of the core RPC server. It
28 RPC server implementation
33 The RPC Server depends on the ``pw::rpc::internal::Method`` class. ``Method``
35 RPC functions. Each supported protobuf implementation extends ``Method`` to
97 RPC client
99 The RPC client is used to send requests to a server and manages the contexts of
104 The ``pw::rpc::Client`` class is instantiated with a list of channels that it
108 To send incoming RPC packets from the transport layer to be processed by a
[all …]
/aosp_15_r20/external/pigweed/pw_rpc/ts/
H A Drpc_classes.ts29 /** Data class for a pending RPC call. */
30 export class Rpc { class
48 * and call ID. This can be used to hash the Rpc.
64 /** Tracks pending RPCs and encodes outgoing RPC packets. */
70 /** Starts the provided RPC and returns the encoded packet to send. */
71 request(rpc: Rpc, request: Message, call: Call): Uint8Array {
72 this.open(rpc, call);
73 console.log(`Starting ${rpc}`);
74 return packets.encodeRequest(rpc.getIdSet(call.callId), request);
89 rpc: Rpc,
[all …]
/aosp_15_r20/external/googleapis/google/analytics/admin/v1alpha/
H A Danalytics_admin.proto49 rpc GetAccount(GetAccountRequest) returns (Account) {
61 rpc ListAccounts(ListAccountsRequest) returns (ListAccountsResponse) {
78 rpc DeleteAccount(DeleteAccountRequest) returns (google.protobuf.Empty) {
86 rpc UpdateAccount(UpdateAccountRequest) returns (Account) {
95 rpc ProvisionAccountTicket(ProvisionAccountTicketRequest)
104 rpc ListAccountSummaries(ListAccountSummariesRequest)
112 rpc GetProperty(GetPropertyRequest) returns (Property) {
125 rpc ListProperties(ListPropertiesRequest) returns (ListPropertiesResponse) {
132 rpc CreateProperty(CreatePropertyRequest) returns (Property) {
151 rpc DeleteProperty(DeletePropertyRequest) returns (Property) {
[all …]
/aosp_15_r20/external/google-cloud-java/java-resourcemanager/google-cloud-resourcemanager/src/test/java/com/google/cloud/resourcemanager/testing/
H A DLocalResourceManagerHelperTest.java55 private static final ResourceManagerRpc rpc = field in LocalResourceManagerHelperTest
96 rpc.list(EMPTY_RPC_OPTIONS).y()) { in clearProjects()
114 rpc.create(PARTIAL_PROJECT); in testCreate()
123 rpc.getPolicy(PARTIAL_PROJECT.getProjectId()); in testCreate()
127 rpc.replacePolicy(PARTIAL_PROJECT.getProjectId(), POLICY); in testCreate()
128 assertEquals(POLICY.getBindings(), rpc.getPolicy(PARTIAL_PROJECT.getProjectId()).getBindings()); in testCreate()
130 rpc.create(PARTIAL_PROJECT); in testCreate()
138 POLICY.getBindings(), rpc.getPolicy(PARTIAL_PROJECT.getProjectId()).getBindings()); in testCreate()
140 returnedProject = rpc.create(PROJECT_WITH_PARENT); in testCreate()
164 rpc.create(project); in testIsInvalidProjectId()
[all …]
/aosp_15_r20/external/google-cloud-java/java-analytics-admin/proto-google-analytics-admin-v1alpha/src/main/proto/google/analytics/admin/v1alpha/
H A Danalytics_admin.proto47 rpc GetAccount(GetAccountRequest) returns (Account) {
59 rpc ListAccounts(ListAccountsRequest) returns (ListAccountsResponse) {
76 rpc DeleteAccount(DeleteAccountRequest) returns (google.protobuf.Empty) {
84 rpc UpdateAccount(UpdateAccountRequest) returns (Account) {
93 rpc ProvisionAccountTicket(ProvisionAccountTicketRequest)
102 rpc ListAccountSummaries(ListAccountSummariesRequest)
110 rpc GetProperty(GetPropertyRequest) returns (Property) {
123 rpc ListProperties(ListPropertiesRequest) returns (ListPropertiesResponse) {
130 rpc CreateProperty(CreatePropertyRequest) returns (Property) {
149 rpc DeleteProperty(DeletePropertyRequest) returns (Property) {
[all …]
/aosp_15_r20/platform_testing/tests/automotive/snippets/phone/src/com/google/android/mobly/snippet/bundled/
H A DDialerSnippet.java24 import com.google.android.mobly.snippet.rpc.Rpc;
38 @Rpc(description = "Open Phone Application.")
44 @Rpc(description = "Open Dial Pad.")
49 @Rpc(description = "Open Dial Pad and dial in a number using keypad.")
54 @Rpc(description = "Make a call.")
59 @Rpc(description = "End the call.")
64 @Rpc(description = "Press the hardkey for ending the call.")
69 @Rpc(description = "Open Call History.")
75 @Rpc(description = "Open Dialer Settings from the Dialer app.")
80 @Rpc(description = "Call Contact From Contact List.")
[all …]
/aosp_15_r20/external/pytorch/docs/source/
H A Drpc.rst1 .. _distributed-rpc-framework:
3 Distributed RPC Framework
6 The distributed RPC framework provides mechanisms for multi-machine model
12 APIs in the RPC package are stable. There are multiple ongoing work items
17 Not all features of the RPC package are yet compatible with CUDA support and
29 The distributed RPC framework makes it easy to run functions remotely, supports
32 across RPC boundaries. These features can be categorized into four sets of APIs.
34 1) **Remote Procedure Call (RPC)** supports running a function on the specified
36 or creating a reference to the return value. There are three main RPC APIs:
37 :meth:`~torch.distributed.rpc.rpc_sync` (synchronous),
[all …]
/aosp_15_r20/external/coreboot/src/southbridge/intel/lynxpoint/
H A Dpcie.c36 static struct root_port_config rpc; variable
53 return PCI_FUNC(dev->path.pci.devfn) == (rpc.num_ports - 1); in root_port_is_last()
64 ASSERT(rp > 0 && rp <= ARRAY_SIZE(rpc.ports)); in is_rp_enabled()
66 if (rpc.ports[rp - 1] == NULL) in is_rp_enabled()
69 return rpc.ports[rp - 1]->enabled; in is_rp_enabled()
75 if (!((rpc.strpfusecfg1 >> 19) & 1)) in root_port_config_update_gbe_port()
79 switch ((rpc.strpfusecfg1 >> 16) & 0x7) { in root_port_config_update_gbe_port()
81 rpc.gbe_port = 3; in root_port_config_update_gbe_port()
84 rpc.gbe_port = 4; in root_port_config_update_gbe_port()
91 rpc.gbe_port = 5; in root_port_config_update_gbe_port()
[all …]
/aosp_15_r20/external/libevent/include/event2/
H A Drpc.h38 /** @file rpc.h
40 * This header files provides basic support for an RPC server and client.
42 * To support RPCs in a server, every supported RPC command needs to be
47 * SendCommand is the name of the RPC command.
49 * It contains all parameters relating to the SendCommand RPC. The
52 * contains the answer to the RPC.
54 * To register an RPC with an HTTP server, you need to first create an RPC
59 * A specific RPC can then be registered with
63 * when the server receives an appropriately formatted RPC, the user callback
66 * void FunctionCB(EVRPC_STRUCT(SendCommand)* rpc, void *arg);
[all …]

12345678910>>...538