Home
last modified time | relevance | path

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

12345678910>>...52

/third_party/grpc/src/python/grpcio/grpc/framework/interfaces/face/
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 …]
/third_party/grpc/src/python/grpcio_testing/grpc_testing/
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 …]
/third_party/ltp/testcases/network/rpc/rpc-tirpc/
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 …]
/third_party/grpc/src/python/grpcio_tests/tests/testing/
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 …]
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 …]
/third_party/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.proto32 rpc EmptyCall(grpc.testing.Empty) returns (grpc.testing.Empty);
35 rpc UnaryCall(SimpleRequest) returns (SimpleResponse);
40 rpc CacheableUnaryCall(SimpleRequest) returns (SimpleResponse);
44 rpc StreamingOutputCall(StreamingOutputCallRequest)
49 rpc StreamingInputCall(stream StreamingInputCallRequest)
55 rpc FullDuplexCall(stream StreamingOutputCallRequest)
62 rpc HalfDuplexCall(stream StreamingOutputCallRequest)
67 rpc UnimplementedCall(grpc.testing.Empty) returns (grpc.testing.Empty);
74 rpc UnimplementedCall(grpc.testing.Empty) returns (grpc.testing.Empty);
79 rpc Start(grpc.testing.ReconnectParams) returns (grpc.testing.Empty);
[all …]
/third_party/openhitls/testcode/framework/tls/rpc/include/
Drpc_func.h43 * @brief Invoke the RPC to create CTX resources.
48 * @brief Invoke the RPC to create CTX resources with provider.
53 * @brief Invoke the RPC to set the CTX information.
58 * @brief Invoke the RPC to create an SSL resource.
63 * @brief Invoke the RPC to set the SSL information.
68 * @brief The RPC invokes the TLS connection to be listened on.
73 * @brief Invoke the RPC to wait for the TLS connection.
78 * @brief Invoke the RPC interface for TLS connection.
83 * @brief Invoke the RPC to read data through TLS.
88 * @brief Invoke the RPC to write data through TLS.
[all …]
/third_party/grpc/src/python/grpcio_testing/grpc_testing/_server/
D_service.py21 def __init__(self, rpc, handler): argument
22 self._rpc = rpc
46 def _unary_response(argument, implementation, rpc, servicer_context): argument
50 rpc.application_exception_abort(exception)
52 rpc.unary_response_complete(response)
55 def _stream_response(argument, implementation, rpc, servicer_context): argument
59 rpc.application_exception_abort(exception)
65 rpc.stream_response_complete()
68 rpc.application_exception_abort(exception)
71 rpc.stream_response(response)
[all …]
/third_party/grpc/src/python/grpcio/grpc/
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 …]
/third_party/grpc/examples/python/retry/
DREADME.md26 The client RPC will succeed, even with server injecting multiple errors. Here is an example server …
31 INFO:root:Injecting error to RPC from ipv6:[::1]:54471
32 INFO:root:Successfully responding to RPC from ipv6:[::1]:54473
33 INFO:root:Injecting error to RPC from ipv6:[::1]:54491
34 INFO:root:Injecting error to RPC from ipv6:[::1]:54581
35 INFO:root:Injecting error to RPC from ipv6:[::1]:54581
36 INFO:root:Injecting error to RPC from ipv6:[::1]:54581
37 INFO:root:Injecting error to RPC from ipv6:[::1]:54581
38 INFO:root:Successfully responding to RPC from ipv6:[::1]:54581
39 INFO:root:Injecting error to RPC from ipv6:[::1]:55474
[all …]
/third_party/grpc/src/python/grpcio/grpc/aio/
D_base_channel.py31 """Enables asynchronous invocation of a unary-call RPC."""
44 """Asynchronously invokes the underlying RPC.
47 request: The request value for the RPC.
49 for the RPC.
51 service-side of the RPC.
52 credentials: An optional CallCredentials for the RPC. Only valid for
62 RpcError: Indicates that the RPC terminated with non-OK status. The
63 raised RpcError will also be a Call for the RPC affording the RPC's
69 """Enables asynchronous invocation of a server-streaming RPC."""
82 """Asynchronously invokes the underlying RPC.
[all …]
D_base_call.py16 Call objects represents the RPC itself, and offer methods to access / modify
18 RPC, e.g. cancellation.
37 """Provides RPC-related information and action."""
41 """Return True if the RPC is cancelled.
43 The RPC is cancelled when the cancellation was requested with cancel().
46 A bool indicates whether the RPC is cancelled or not.
51 """Return True if the RPC is done.
53 An RPC is done if the RPC is completed, cancelled or aborted.
56 A bool indicates if the RPC is done.
61 """Describes the length of allowed time remaining for the RPC.
[all …]
D_base_server.py58 An integer port on which the server will accept RPC requests.
79 An integer port on which the server will accept RPC requests.
101 the last RPC handler terminates.
157 """Reads one message from the RPC.
162 A response message of the RPC.
170 """Writes one message to the RPC.
198 """Raises an exception to terminate the RPC with a non-OK status.
207 termination of the RPC.
213 RPC to the gRPC runtime.
218 """Sends the trailing metadata for the RPC.
[all …]
/third_party/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 …]
/third_party/grpc/src/core/tsi/alts/handshaker/
Dtransport_security_common_api.h43 /// This method sets the value for max_rpc_versions field of rpc protocol
46 ///- versions: an rpc protocol version instance.
47 ///- max_major: a major version of maximum supported RPC version.
48 ///- max_minor: a minor version of maximum supported RPC version.
57 /// This method sets the value for min_rpc_versions field of rpc protocol
60 ///- versions: an rpc protocol version instance.
61 ///- min_major: a major version of minimum supported RPC version.
62 ///- min_minor: a minor version of minimum supported RPC version.
71 /// This method serializes an rpc protocol version and returns serialized rpc
74 ///- versions: an rpc protocol versions instance.
[all …]
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/runtime/graph_scheduler/actor/rpc/
Drpc_actor.h28 #include "include/backend/distributed/rpc/tcp/tcp_client.h"
29 #include "include/backend/distributed/rpc/tcp/tcp_server.h"
31 #include "include/backend/distributed/rpc/rdma/rdma_client.h"
32 #include "include/backend/distributed/rpc/rdma/rdma_server.h"
34 #include "proto/rpc.pb.h"
48 using distributed::rpc::RPCClientBase;
49 using distributed::rpc::RPCServerBase;
50 using distributed::rpc::TCPClient;
51 using distributed::rpc::TCPServer;
54 using distributed::rpc::kURPCInited;
[all …]
/third_party/grpc/src/ruby/spec/generic/
Dservice_spec.rb64 it 'adds a class method, rpc' do
68 expect(c.methods).to include(:rpc)
71 it 'adds rpc descs using the added class method, #rpc' do
74 rpc :AnRpc, GoodMsg, GoodMsg
84 rpc :AnRpc, GoodMsg, GoodMsg
128 it 'raises if #rpc is missing an arg' do
132 rpc :AnRpc, GoodMsg
140 rpc :AnRpc
146 describe 'when #rpc args are incorrect' do
151 rpc :AnRpc, GoodMsg, Object
[all …]
/third_party/NuttX/fs/nfs/
Drpc_clnt.c88 #include "rpc.h"
95 /* Increment RPC statistics */
114 /* Static data, mostly RPC constants in XDR form */
137 static int rpcclnt_send(struct rpcclnt *rpc, int procid, int prog,
139 static int rpcclnt_receive(struct rpcclnt *rpc, struct sockaddr *aname,
141 static int rpcclnt_reply(struct rpcclnt *rpc, int procid, int prog,
146 static int rpcclnt_reconnect(struct rpcclnt *rpc, struct sockaddr *saddr);
163 static int rpcclnt_send(struct rpcclnt *rpc, int procid, int prog, in rpcclnt_send() argument
175 nbytes = sendto(rpc->rc_so, call, reqlen, 0, in rpcclnt_send()
176 rpc->rc_name, sizeof(struct sockaddr)); in rpcclnt_send()
[all …]
/third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/include/llvm/ExecutionEngine/Orc/
DOrcRemoteTargetRPCAPI.h1 //===- OrcRemoteTargetRPCAPI.h - Orc Remote-target RPC API ------*- C++ -*-===//
9 // This file defines the Orc remote-target RPC API. It should not be used
19 #include "llvm/ExecutionEngine/Orc/RPC/RPCUtils.h"
20 #include "llvm/ExecutionEngine/Orc/RPC/RawByteChannel.h"
76 namespace rpc {
137 } // end namespace rpc
172 : public rpc::Function<RegisterEHFrames,
180 : public rpc::Function<DeregisterEHFrames,
188 /// RPC functions for executing remote code.
194 : public rpc::Function<CallIntVoid, int32_t(JITTargetAddress Addr)> {
[all …]
/third_party/grpc/src/ruby/pb/test/
Dxds_client.rb84 # GRPC is the general RPC module
120 rpc = m.type
121 if !metadata_to_send.key?(rpc)
122 metadata_to_send[rpc] = {}
126 metadata_to_send[rpc][metadata_key] = metadata_value
176 all_stats_per_method = $accumulated_method_stats.map { |rpc, stats_per_method|
177 [rpc,
193 def execute_rpc_in_thread(op, rpc) argument
195 rpc_stats_key = rpc.to_s
213 $thread_results << [rpc, remote_peer]
[all …]
/third_party/grpc/src/php/tests/interop/
Dxds_client.php123 foreach ((array)$client_thread->rpc_config->rpcs_to_send as $rpc) {
124 $results = $client_thread->results[$rpc];
126 $rpcs_by_method[$rpc] = [];
132 if (!array_key_exists($hostname, $rpcs_by_method[$rpc])) {
133 $rpcs_by_method[$rpc][$hostname] = 0;
139 // both by overall, and broken down per RPC
140 $rpcs_by_method[$rpc][$hostname] += 1;
143 // $num_failures here are counted per individual RPC
152 foreach ($rpcs_by_method as $rpc => $rpcs_by_peer_per_method) {
156 $rpcs_by_method_map[$rpc] = $rpcs_by_peer_proto_obj;
[all …]
/third_party/protobuf/python/google/protobuf/
Dservice.py8 """DEPRECATED: Declares the RPC service interfaces.
10 This module declares the abstract interfaces underlying proto2 RPC
11 services. These are intended to be independent of any particular RPC
13 of implementations. Starting with version 2.3.0, RPC implementations should
15 which generate code specific to the particular RPC implementation. This way
25 'google.protobuf.service module is deprecated. RPC implementations '
27 'the RPC implementation. service.py will be removed in Jan 2025',
32 """Exception raised on failed blocking RPC method call."""
38 """Abstract base interface for protocol-buffer-based RPC services.
66 * "rpc_controller" is of the correct type for the RPC implementation being
[all …]
/third_party/ltp/testcases/network/nfs/nfsstat01/
Dnfsstat01.sh16 [ "$name" = "rpc" ] && opt="r" || opt="n"
19 calls="$(grep $name /proc/net/rpc/$nfs_f | cut -d' ' -f$field)"
25 calls=$(tst_rhost_run -c "grep $name /proc/net/rpc/$nfs_f" | \
32 # tracking using the 'nfsstat' command and /proc/net/rpc
35 tst_res TINFO "checking RPC calls for server/client"
37 local server_calls="$(get_calls rpc 2 nfsd)"
38 local client_calls="$(get_calls rpc 2 nfs)"
42 tst_res TINFO "Checking for tracking of RPC calls for server/client"
45 local new_server_calls="$(get_calls rpc 2 nfsd)"
46 local new_client_calls="$(get_calls rpc 2 nfs)"
[all …]
/third_party/grpc/tools/distrib/python/xds_protos/google/rpc/context/
Dattribute_context_pb2.py3 # source: google/rpc/context/attribute_context.proto
20 …rpc/context/attribute_context.proto\x12\x12google.rpc.context\x1a\x19google/protobuf/any.proto\x1a…
24 _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'google.rpc.context.attribute_context_pb2', _gl…
27 …ized_options = b'\n\026com.google.rpc.contextB\025AttributeContextProtoP\001ZUgoogle.golang.org/ge…

12345678910>>...52