Home
last modified time | relevance | path

Searched refs:rpc (Results 1 – 25 of 638) sorted by relevance

12345678910>>...26

/external/grpc-grpc/src/python/grpcio_tests/tests/testing/
D_client_test.py57 invocation_metadata, request, rpc = (
60 rpc.send_initial_metadata(())
61 rpc.terminate(_application_common.UNARY_UNARY_RESPONSE, (),
73 invocation_metadata, request, rpc = (
76 rpc.send_initial_metadata(())
77 rpc.terminate((), grpc.StatusCode.OK, '')
88 invocation_metadata, rpc = self._real_time_channel.take_stream_unary(
90 rpc.send_initial_metadata(())
91 first_request = rpc.take_request()
92 second_request = rpc.take_request()
[all …]
D_server_test.py41 rpc = self._real_time_server.invoke_unary_unary(
44 initial_metadata = rpc.initial_metadata()
45 response, trailing_metadata, code, details = rpc.termination()
51 rpc = self._real_time_server.invoke_unary_stream(
54 initial_metadata = rpc.initial_metadata()
55 trailing_metadata, code, details = rpc.termination()
60 rpc = self._real_time_server.invoke_stream_unary(
62 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
63 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
64 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
[all …]
/external/ltp/testcases/network/rpc/rpc-tirpc/
D.gitignore15 /tests_pack/rpc_suite/rpc/rpc_stdcall_clnt_control/rpc_clnt_control
16 /tests_pack/rpc_suite/rpc/rpc_stdcall_clnt_control/rpc_clnt_control_dataint
17 /tests_pack/rpc_suite/rpc/rpc_stdcall_svc_sendreply/rpc_svc_sendreply
18 /tests_pack/rpc_suite/rpc/rpc_stdcall_svc_sendreply/rpc_svc_sendreply_client
19 /tests_pack/rpc_suite/rpc/rpc_createdestroy_clntraw_create/rpc_clntraw_create_performance
20 /tests_pack/rpc_suite/rpc/rpc_createdestroy_clntraw_create/rpc_clntraw_create
21 /tests_pack/rpc_suite/rpc/rpc_createdestroy_clntraw_create/rpc_clntraw_create_complex
22 /tests_pack/rpc_suite/rpc/rpc_err_clnt_sperrno/rpc_clnt_sperrno
23 /tests_pack/rpc_suite/rpc/rpc_addrmanagmt_pmap_getmaps/rpc_pmap_getmaps
24 /tests_pack/rpc_suite/rpc/rpc_regunreg_xprt_register/rpc_xprt_register
[all …]
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/
D_service.py20 def __init__(self, rpc, handler): argument
21 self._rpc = rpc
45 def _unary_response(argument, implementation, rpc, servicer_context): argument
49 rpc.application_exception_abort(exception)
51 rpc.unary_response_complete(response)
54 def _stream_response(argument, implementation, rpc, servicer_context): argument
58 rpc.application_exception_abort(exception)
64 rpc.stream_response_complete()
67 rpc.application_exception_abort(exception)
70 rpc.stream_response(response)
[all …]
D_server.py33 def service(implementation, rpc, servicer_context): argument
34 _service.unary_unary(implementation, rpc, request, servicer_context)
41 def service(implementation, rpc, servicer_context): argument
42 _service.unary_stream(implementation, rpc, request, servicer_context)
49 def service(implementation, rpc, servicer_context): argument
50 _service.stream_unary(implementation, rpc, handler, servicer_context)
57 def service(implementation, rpc, servicer_context): argument
58 _service.stream_stream(implementation, rpc, handler, servicer_context)
73 rpc = _rpc.Rpc(handler, invocation_metadata)
74 if handler.add_termination_callback(rpc.extrinsic_abort):
[all …]
/external/grpc-grpc/examples/ruby/pubsub/tech/pubsub/proto/
Dpubsub_services.rb35 rpc :CreateTopic, Topic, Topic
36 rpc :Publish, PublishRequest, Google::Protobuf::Empty
37 rpc :PublishBatch, PublishBatchRequest, PublishBatchResponse
38 rpc :GetTopic, GetTopicRequest, Topic
39 rpc :ListTopics, ListTopicsRequest, ListTopicsResponse
40 rpc :DeleteTopic, DeleteTopicRequest, Google::Protobuf::Empty
56 rpc :CreateSubscription, Subscription, Subscription
57 rpc :GetSubscription, GetSubscriptionRequest, Subscription
58 rpc :ListSubscriptions, ListSubscriptionsRequest, ListSubscriptionsResponse
59 rpc :DeleteSubscription, DeleteSubscriptionRequest, Google::Protobuf::Empty
[all …]
/external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/
Decho.proto24 rpc Echo(EchoRequest) returns (EchoResponse);
25 rpc Echo1(EchoRequest) returns (EchoResponse);
26 rpc Echo2(EchoRequest) returns (EchoResponse);
27 rpc CheckDeadlineUpperBound(SimpleRequest) returns (StringValue);
28 rpc CheckDeadlineSet(SimpleRequest) returns (StringValue);
31 rpc CheckClientInitialMetadata(SimpleRequest) returns (SimpleResponse);
32 rpc RequestStream(stream EchoRequest) returns (EchoResponse);
33 rpc ResponseStream(EchoRequest) returns (stream EchoResponse);
34 rpc BidiStream(stream EchoRequest) returns (stream EchoResponse);
35 rpc Unimplemented(EchoRequest) returns (EchoResponse);
[all …]
Dtest.proto30 rpc EmptyCall(grpc.testing.Empty) returns (grpc.testing.Empty);
33 rpc UnaryCall(SimpleRequest) returns (SimpleResponse);
38 rpc CacheableUnaryCall(SimpleRequest) returns (SimpleResponse);
42 rpc StreamingOutputCall(StreamingOutputCallRequest)
47 rpc StreamingInputCall(stream StreamingInputCallRequest)
53 rpc FullDuplexCall(stream StreamingOutputCallRequest)
60 rpc HalfDuplexCall(stream StreamingOutputCallRequest)
65 rpc UnimplementedCall(grpc.testing.Empty) returns (grpc.testing.Empty);
72 rpc UnimplementedCall(grpc.testing.Empty) returns (grpc.testing.Empty);
77 rpc Start(grpc.testing.ReconnectParams) returns (grpc.testing.Empty);
[all …]
/external/pigweed/pw_rpc/py/pw_rpc/
Dclient.py58 rpc: PendingRpc,
65 self.open(rpc, context, override_pending, keep_open)
66 _LOG.debug('Starting %s', rpc)
67 return packets.encode_request(rpc, request)
70 rpc: PendingRpc,
78 rpc.channel.output( # type: ignore
79 self.request(rpc, request, context, override_pending, keep_open))
82 rpc: PendingRpc,
95 self._pending[rpc] = metadata
96 elif self._pending.setdefault(rpc, metadata) is not metadata:
[all …]
Dcallback_client.py79 def _default_response(rpc: PendingRpc, response: Any) -> None:
80 _LOG.info('%s response: %s', rpc, response)
83 def _default_completion(rpc: PendingRpc, status: Status) -> None:
84 _LOG.info('%s finished: %s', rpc, status)
87 def _default_error(rpc: PendingRpc, status: Status) -> None:
88 _LOG.error('%s error: %s', rpc, status)
155 def __init__(self, rpc: PendingRpc, timeout: Optional[float]):
158 self.rpc = rpc
163 def __init__(self, rpc: PendingRpc, status: Status):
170 self.rpc = rpc
[all …]
Dpackets.py34 def _ids(rpc: tuple) -> tuple:
35 return tuple(item if isinstance(item, int) else item.id for item in rpc)
38 def encode_request(rpc: tuple, request: message.Message) -> bytes:
39 channel, service, method = _ids(rpc)
49 def encode_response(rpc: tuple, response: message.Message) -> bytes:
50 channel, service, method = _ids(rpc)
68 def encode_cancel(rpc: tuple) -> bytes:
69 channel, service, method = _ids(rpc)
/external/llvm-project/llvm/include/llvm/ExecutionEngine/Orc/
DOrcRemoteTargetRPCAPI.h76 namespace rpc {
171 : public rpc::Function<RegisterEHFrames,
179 : public rpc::Function<DeregisterEHFrames,
193 : public rpc::Function<CallIntVoid, int32_t(JITTargetAddress Addr)> {
201 : public rpc::Function<CallIntInt, int32_t(JITTargetAddress Addr, int)> {
209 : public rpc::Function<CallMain, int32_t(JITTargetAddress Addr,
218 : public rpc::Function<CallVoidVoid, void(JITTargetAddress FnAddr)> {
230 : public rpc::Function<CreateRemoteAllocator,
238 : public rpc::Function<DestroyRemoteAllocator,
246 : public rpc::Function<ReadMem, std::vector<uint8_t>(JITTargetAddress Src,
[all …]
/external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/ExecutionEngine/Orc/
DOrcRemoteTargetRPCAPI.h76 namespace rpc {
172 : public rpc::Function<RegisterEHFrames,
180 : public rpc::Function<DeregisterEHFrames,
194 : public rpc::Function<CallIntVoid, int32_t(JITTargetAddress Addr)> {
202 : public rpc::Function<CallMain, int32_t(JITTargetAddress Addr,
211 : public rpc::Function<CallVoidVoid, void(JITTargetAddress FnAddr)> {
223 : public rpc::Function<CreateRemoteAllocator,
231 : public rpc::Function<DestroyRemoteAllocator,
239 : public rpc::Function<ReadMem, std::vector<uint8_t>(JITTargetAddress Src,
247 : public rpc::Function<ReserveMem,
[all …]
/external/grpc-grpc/src/ruby/pb/src/proto/grpc/testing/
Dtest_services_pb.rb39 rpc :EmptyCall, Empty, Empty
41 rpc :UnaryCall, SimpleRequest, SimpleResponse
45 rpc :CacheableUnaryCall, SimpleRequest, SimpleResponse
48 rpc :StreamingOutputCall, StreamingOutputCallRequest, stream(StreamingOutputCallResponse)
51 rpc :StreamingInputCall, stream(StreamingInputCallRequest), StreamingInputCallResponse
55 rpc :FullDuplexCall, stream(StreamingOutputCallRequest), stream(StreamingOutputCallResponse)
60 rpc :HalfDuplexCall, stream(StreamingOutputCallRequest), stream(StreamingOutputCallResponse)
63 rpc :UnimplementedCall, Empty, Empty
80 rpc :UnimplementedCall, Empty, Empty
95 rpc :Start, ReconnectParams, Empty
[all …]
/external/grpc-grpc/src/ruby/spec/generic/
Dservice_spec.rb72 rpc :AnRpc, GoodMsg, GoodMsg
82 rpc :AnRpc, GoodMsg, GoodMsg
130 rpc :AnRpc, GoodMsg
138 rpc :AnRpc
149 rpc :AnRpc, GoodMsg, Object
166 rpc :AnRpc, OnlyMarshal, GoodMsg
182 rpc :AnRpc, GoodMsg, OnlyUnmarshal
193 rpc :AnRpc, GoodMsg, GoodMsg
205 rpc :AnRpc, EncodeDecodeMsg, EncodeDecodeMsg
216 rpc :AnRpc, GoodMsg, GoodMsg
[all …]
/external/libevent/
Devrpc.c95 struct evrpc *rpc; in evrpc_free() local
100 while ((rpc = TAILQ_FIRST(&base->registered_rpcs)) != NULL) { in evrpc_free()
101 r = evrpc_unregister_rpc(base, rpc->uri); in evrpc_free()
228 evrpc_register_rpc(struct evrpc_base *base, struct evrpc *rpc, in evrpc_register_rpc() argument
231 char *constructed_uri = evrpc_construct_uri(rpc->uri); in evrpc_register_rpc()
233 rpc->base = base; in evrpc_register_rpc()
234 rpc->cb = cb; in evrpc_register_rpc()
235 rpc->cb_arg = cb_arg; in evrpc_register_rpc()
237 TAILQ_INSERT_TAIL(&base->registered_rpcs, rpc, next); in evrpc_register_rpc()
242 rpc); in evrpc_register_rpc()
[all …]
/external/nos/host/generic/nugget/proto/nugget/app/identity/
Didentity.proto36 rpc WICinitialize (WICinitializeRequest) returns (WICinitializeResponse);
37 …rpc WICinitializeForUpdate (WICinitializeForUpdateRequest) returns (WICinitializeForUpdateResponse…
38 …rpc WICcreateCredentialKey (WICcreateCredentialKeyRequest) returns (WICcreateCredentialKeyResponse…
39 …rpc WICstartPersonalization (WICstartPersonalizationRequest) returns (WICstartPersonalizationRespo…
40 …rpc WICaddAccessControlProfile (WICaddAccessControlProfileRequest) returns (WICaddAccessControlPro…
41 rpc WICbeginAddEntry (WICbeginAddEntryRequest) returns (WICbeginAddEntryResponse);
42 rpc WICaddEntryValue (WICaddEntryValueRequest) returns (WICaddEntryValueResponse);
43 …rpc WICfinishAddingEntries (WICfinishAddingEntriesRequest) returns (WICfinishAddingEntriesResponse…
44 rpc ICinitialize (ICinitializeRequest) returns (ICinitializeResponse);
45 …rpc ICcreateEphemeralKeyPair (ICcreateEphemeralKeyPairRequest) returns (ICcreateEphemeralKeyPairRe…
[all …]
/external/tensorflow/tensorflow/core/protobuf/
Dworker_service.proto42 rpc GetStatus(GetStatusRequest) returns (GetStatusResponse);
45 rpc CreateWorkerSession(CreateWorkerSessionRequest)
49 rpc DeleteWorkerSession(DeleteWorkerSessionRequest)
53 rpc RegisterGraph(RegisterGraphRequest) returns (RegisterGraphResponse);
56 rpc DeregisterGraph(DeregisterGraphRequest) returns (DeregisterGraphResponse);
59 rpc RunGraph(RunGraphRequest) returns (RunGraphResponse);
62 rpc CleanupGraph(CleanupGraphRequest) returns (CleanupGraphResponse);
65 rpc CleanupAll(CleanupAllRequest) returns (CleanupAllResponse);
68 rpc RecvTensor(RecvTensorRequest) returns (RecvTensorResponse) {
73 rpc Logging(LoggingRequest) returns (LoggingResponse);
[all …]
/external/nos/host/generic/nugget/proto/nugget/app/keymaster/
Dkeymaster.proto50 rpc AddRngEntropy (AddRngEntropyRequest) returns (AddRngEntropyResponse);
51 rpc GenerateKey (GenerateKeyRequest) returns (GenerateKeyResponse);
52 rpc GetKeyCharacteristics (GetKeyCharacteristicsRequest) returns (GetKeyCharacteristicsResponse);
53 rpc ImportKey (ImportKeyRequest) returns (ImportKeyResponse);
54 rpc ExportKey (ExportKeyRequest) returns (ExportKeyResponse);
55 rpc StartAttestKey (StartAttestKeyRequest) returns (StartAttestKeyResponse);
56 rpc UpgradeKey (UpgradeKeyRequest) returns (UpgradeKeyResponse);
57 rpc DeleteKey (DeleteKeyRequest) returns (DeleteKeyResponse);
58 rpc DeleteAllKeys (DeleteAllKeysRequest) returns (DeleteAllKeysResponse);
59 rpc DestroyAttestationIds (DestroyAttestationIdsRequest) returns (DestroyAttestationIdsResponse);
[all …]
/external/nos/host/generic/nugget/proto/nugget/app/avb/
Davb.proto30 rpc GetState (GetStateRequest) returns (GetStateResponse);
31 rpc Load (LoadRequest) returns (LoadResponse);
32 rpc Store (StoreRequest) returns (StoreResponse);
33 rpc GetLock (GetLockRequest) returns (GetLockResponse);
34 rpc CarrierLock (CarrierLockRequest) returns (CarrierLockResponse);
35 rpc CarrierUnlock (CarrierUnlockRequest) returns (CarrierUnlockResponse);
36 rpc SetDeviceLock (SetDeviceLockRequest) returns (SetDeviceLockResponse);
37 rpc SetBootLock (SetBootLockRequest) returns (SetBootLockResponse);
38 rpc SetOwnerLock (SetOwnerLockRequest) returns (SetOwnerLockResponse);
39 rpc SetProduction (SetProductionRequest) returns (SetProductionResponse);
[all …]
/external/grpc-grpc-java/protobuf/src/main/java/io/grpc/protobuf/
DStatusProto.java35 private static final Metadata.Key<com.google.rpc.Status> STATUS_DETAILS_KEY =
38 ProtoLiteUtils.metadataMarshaller(com.google.rpc.Status.getDefaultInstance()));
51 public static StatusRuntimeException toStatusRuntimeException(com.google.rpc.Status statusProto) { in toStatusRuntimeException()
69 com.google.rpc.Status statusProto, Metadata metadata) { in toStatusRuntimeException()
84 public static StatusException toStatusException(com.google.rpc.Status statusProto) { in toStatusException()
102 com.google.rpc.Status statusProto, Metadata metadata) { in toStatusException()
106 private static Status toStatus(com.google.rpc.Status statusProto) { in toStatus()
112 private static Metadata toMetadata(com.google.rpc.Status statusProto) { in toMetadata()
118 private static Metadata toMetadata(com.google.rpc.Status statusProto, Metadata metadata) { in toMetadata()
134 public static com.google.rpc.Status fromThrowable(Throwable t) { in fromThrowable()
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
DBUILD33 "//tensorflow/core/distributed_runtime/rpc:grpc_channel",
34 "//tensorflow/core/distributed_runtime/rpc:grpc_client_cq_tag",
35 "//tensorflow/core/distributed_runtime/rpc:grpc_state",
36 "//tensorflow/core/distributed_runtime/rpc:grpc_util",
51 "//tensorflow/core/distributed_runtime/rpc:async_service_interface",
52 "//tensorflow/core/distributed_runtime/rpc:grpc_call",
53 "//tensorflow/core/distributed_runtime/rpc:grpc_channel",
54 "//tensorflow/core/distributed_runtime/rpc:grpc_util",
55 "//tensorflow/core/distributed_runtime/rpc:grpc_worker_cache",
72 "//tensorflow/core/distributed_runtime/rpc:grpc_channel",
/external/tensorflow/tensorflow/compiler/xla/rpc/
Dxla_service.proto57 rpc Unregister(UnregisterRequest) returns (UnregisterResponse) {
62 rpc DeconstructTuple(DeconstructTupleRequest)
70 rpc Unpack(UnpackRequest) returns (UnpackResponse) {
74 rpc GetShape(GetShapeRequest) returns (GetShapeResponse) {
78 rpc GetComputationGraphStats(ComputationGraphStatsRequest)
83 rpc LoadData(LoadDataRequest) returns (LoadDataResponse) {
87 rpc TransferToClient(TransferToClientRequest)
93 rpc TransferToServer(TransferToServerRequest)
98 rpc TransferToInfeed(TransferToInfeedRequest)
103 rpc TransferFromOutfeed(TransferFromOutfeedRequest)
[all …]
/external/python/cpython3/Lib/idlelib/idle_test/
Dtest_rpc.py3 from idlelib import rpc
12 func, (cbytes,) = rpc.pickle_code(f.__code__)
13 self.assertIs(func, rpc.unpickle_code)
15 code = rpc.unpickle_code(cbytes)
20 rpc.CodePickler.dispatch_table)
25 self.assertIn(b'test_rpc.py', rpc.dumps(f.__code__))
/external/perfetto/protos/perfetto/ipc/
Dconsumer_port.proto34 // rpc CreateBuffers(CreateBuffersRequest) returns (CreateBuffersResponse) {}
45 rpc EnableTracing(EnableTracingRequest) returns (EnableTracingResponse) {}
48 rpc DisableTracing(DisableTracingRequest) returns (DisableTracingResponse) {}
55 rpc ReadBuffers(ReadBuffersRequest) returns (stream ReadBuffersResponse) {}
59 rpc FreeBuffers(FreeBuffersRequest) returns (FreeBuffersResponse) {}
68 rpc Flush(FlushRequest) returns (FlushResponse) {}
76 rpc StartTracing(StartTracingRequest) returns (StartTracingResponse) {}
80 rpc ChangeTraceConfig(ChangeTraceConfigRequest)
86 rpc Detach(DetachRequest) returns (DetachResponse) {}
92 rpc Attach(AttachRequest) returns (AttachResponse) {}
[all …]

12345678910>>...26