| /third_party/grpc/src/python/grpcio_tests/tests/testing/ |
| D | _server_test.py | 42 rpc = self._real_time_server.invoke_unary_unary(
45 initial_metadata = rpc.initial_metadata()
46 response, trailing_metadata, code, details = rpc.termination()
52 rpc = self._real_time_server.invoke_unary_stream(
55 initial_metadata = rpc.initial_metadata()
56 trailing_metadata, code, details = rpc.termination()
61 rpc = self._real_time_server.invoke_stream_unary(
63 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
64 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
65 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
[all …]
|
| D | _client_test.py | 57 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 …]
|
| /third_party/ltp/testcases/network/rpc/rpc-tirpc/ |
| D | .gitignore | 11 /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/examples/ruby/pubsub/tech/pubsub/proto/ |
| D | pubsub_services.rb | 35 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/python/grpcio_testing/grpc_testing/_server/ |
| D | _service.py | 21 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 …]
|
| D | _server.py | 33 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 …]
|
| /third_party/grpc/src/proto/grpc/testing/ |
| D | echo.proto | 24 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 …]
|
| D | test.proto | 30 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 …]
|
| /third_party/NuttX/fs/nfs/ |
| D | rpc_clnt.c | 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()
199 static int rpcclnt_receive(struct rpcclnt *rpc, struct sockaddr *aname, in rpcclnt_receive() argument
212 FD_SET((uint32_t)(rpc->rc_so), &fdreadset); in rpcclnt_receive()
217 ret = select(rpc->rc_so + 1, &fdreadset, 0, 0, &timeval); in rpcclnt_receive()
[all …]
|
| /third_party/grpc/src/php/tests/interop/ |
| D | xds_client.php | 72 foreach ($client_thread->results as $rpc => $results) {
74 $rpcs_by_method[$rpc] = [];
80 if (!array_key_exists($hostname, $rpcs_by_method[$rpc])) {
81 $rpcs_by_method[$rpc][$hostname] = 0;
88 $rpcs_by_method[$rpc][$hostname] += 1;
100 foreach ($rpcs_by_method as $rpc => $rpcs_by_peer_per_method) {
104 $rpcs_by_method_map[$rpc] = $rpcs_by_peer_proto_obj;
146 list($rpc,
150 if (!array_key_exists($rpc, $this->metadata_to_send)) {
151 $this->metadata_to_send[$rpc] = [];
[all …]
|
| /third_party/grpc/src/ruby/pb/src/proto/grpc/testing/ |
| D | test_services_pb.rb | 39 rpc :EmptyCall, ::Grpc::Testing::Empty, ::Grpc::Testing::Empty
41 rpc :UnaryCall, ::Grpc::Testing::SimpleRequest, ::Grpc::Testing::SimpleResponse
45 rpc :CacheableUnaryCall, ::Grpc::Testing::SimpleRequest, ::Grpc::Testing::SimpleResponse
48 …rpc :StreamingOutputCall, ::Grpc::Testing::StreamingOutputCallRequest, stream(::Grpc::Testing::Str…
51 …rpc :StreamingInputCall, stream(::Grpc::Testing::StreamingInputCallRequest), ::Grpc::Testing::Stre…
55 …rpc :FullDuplexCall, stream(::Grpc::Testing::StreamingOutputCallRequest), stream(::Grpc::Testing::…
60 …rpc :HalfDuplexCall, stream(::Grpc::Testing::StreamingOutputCallRequest), stream(::Grpc::Testing::…
63 rpc :UnimplementedCall, ::Grpc::Testing::Empty, ::Grpc::Testing::Empty
80 rpc :UnimplementedCall, ::Grpc::Testing::Empty, ::Grpc::Testing::Empty
95 rpc :Start, ::Grpc::Testing::ReconnectParams, ::Grpc::Testing::Empty
[all …]
|
| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/include/llvm/ExecutionEngine/Orc/ |
| D | OrcRemoteTargetRPCAPI.h | 76 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 …]
|
| /third_party/grpc/src/ruby/spec/generic/ |
| D | service_spec.rb | 74 rpc :AnRpc, GoodMsg, GoodMsg
84 rpc :AnRpc, GoodMsg, GoodMsg
132 rpc :AnRpc, GoodMsg
140 rpc :AnRpc
151 rpc :AnRpc, GoodMsg, Object
168 rpc :AnRpc, OnlyMarshal, GoodMsg
184 rpc :AnRpc, GoodMsg, OnlyUnmarshal
195 rpc :AnRpc, GoodMsg, GoodMsg
207 rpc :AnRpc, EncodeDecodeMsg, EncodeDecodeMsg
218 rpc :AnRpc, GoodMsg, GoodMsg
[all …]
|
| /third_party/grpc/src/ruby/pb/test/ |
| D | xds_client.rb | 108 rpc = m.type
109 if !metadata_to_send.key?(rpc)
110 metadata_to_send[rpc] = {}
114 metadata_to_send[rpc][metadata_key] = metadata_value
243 $rpc_config.rpcs_to_send.each do |rpc|
245 metadata = $rpc_config.metadata_to_send.key?(rpc) ?
246 $rpc_config.metadata_to_send[rpc] : {}
248 $num_rpcs_started_by_method[rpc.to_s] += 1
249 num_started = $num_rpcs_started_by_method[rpc.to_s]
251 GRPC.logger.info("Started #{num_started} of #{rpc}")
[all …]
|
| /third_party/python/Lib/idlelib/idle_test/ |
| D | test_rpc.py | 3 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__))
|
| /third_party/grpc/src/ruby/qps/src/proto/grpc/testing/ |
| D | benchmark_service_services_pb.rb | 37 rpc :UnaryCall, ::Grpc::Testing::SimpleRequest, ::Grpc::Testing::SimpleResponse
41 …rpc :StreamingCall, stream(::Grpc::Testing::SimpleRequest), stream(::Grpc::Testing::SimpleResponse)
44 … rpc :StreamingFromClient, stream(::Grpc::Testing::SimpleRequest), ::Grpc::Testing::SimpleResponse
47 … rpc :StreamingFromServer, ::Grpc::Testing::SimpleRequest, stream(::Grpc::Testing::SimpleResponse)
50 …rpc :StreamingBothWays, stream(::Grpc::Testing::SimpleRequest), stream(::Grpc::Testing::SimpleResp…
|
| D | worker_service_services_pb.rb | 41 rpc :RunServer, stream(::Grpc::Testing::ServerArgs), stream(::Grpc::Testing::ServerStatus)
48 rpc :RunClient, stream(::Grpc::Testing::ClientArgs), stream(::Grpc::Testing::ClientStatus)
50 rpc :CoreCount, ::Grpc::Testing::CoreRequest, ::Grpc::Testing::CoreResponse
52 rpc :QuitWorker, ::Grpc::Testing::Void, ::Grpc::Testing::Void
|
| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/ExecutionEngine/OrcError/ |
| D | RPCError.cpp | 20 char llvm::orc::rpc::RPCFatalError::ID = 0;
21 char llvm::orc::rpc::ConnectionClosed::ID = 0;
22 char llvm::orc::rpc::ResponseAbandoned::ID = 0;
23 char llvm::orc::rpc::CouldNotNegotiate::ID = 0;
27 namespace rpc { namespace
|
| /third_party/mindspore/mindspore/ccsrc/debug/debugger/ |
| D | debug_grpc.proto | 24 rpc WaitCMD (Metadata) returns (EventReply) {};
25 rpc SendMetadata (Metadata) returns (EventReply) {};
26 rpc SendGraph (stream Chunk) returns (EventReply) {};
27 rpc SendTensors (stream TensorProto) returns (EventReply) {};
28 rpc SendTensorBase (stream TensorBase) returns (EventReply) {};
29 rpc SendTensorStats (stream TensorSummary) returns (EventReply) {};
30 rpc SendWatchpointHits (stream WatchpointHit) returns (EventReply) {};
31 rpc SendMultiGraphs (stream Chunk) returns (EventReply) {};
32 rpc SendHeartbeat (Heartbeat) returns (EventReply) {};
|
| /third_party/grpc/examples/ruby/lib/ |
| D | route_guide_services_pb.rb | 39 rpc :GetFeature, Point, Feature
46 rpc :ListFeatures, Rectangle, stream(Feature)
51 rpc :RecordRoute, stream(Point), RouteSummary
56 rpc :RouteChat, stream(RouteNote), stream(RouteNote)
|
| /third_party/grpc/src/ruby/bin/ |
| D | math_services_pb.rb | 34 rpc :Div, ::Math::DivArgs, ::Math::DivReply
39 rpc :DivMany, stream(::Math::DivArgs), stream(::Math::DivReply)
43 rpc :Fib, ::Math::FibArgs, stream(::Math::Num)
46 rpc :Sum, stream(::Math::Num), ::Math::Num
|
| /third_party/grpc/test/cpp/util/ |
| D | error_details_test.cc | 29 google::rpc::Status expected; in TEST()
36 google::rpc::Status to; in TEST()
57 google::rpc::Status to; in TEST()
63 google::rpc::Status expected; in TEST()
80 SetErrorDetails(google::rpc::Status(), nullptr).error_code()); in TEST()
84 google::rpc::Status expected; in TEST()
101 google::rpc::Status expected; in TEST()
|
| /third_party/grpc/src/python/grpcio_tests/tests/testing/proto/ |
| D | services.proto | 34 rpc UnUn(Up) returns (Down);
35 rpc UnStre(Charm) returns (stream Strange);
36 rpc StreUn(stream Charm) returns (Strange);
37 rpc StreStre(stream Top) returns (stream Bottom);
41 rpc UnStre(Strange) returns (stream Charm);
|
| /third_party/grpc/src/proto/grpc/status/ |
| D | status.proto | 17 package google.rpc;
21 option go_package = "google.golang.org/genproto/googleapis/rpc/status;status";
24 option java_package = "com.google.rpc";
39 // [google.rpc.Code][google.rpc.Code], but it may accept additional error codes if needed. The
45 // in the package `google.rpc` which can be used for common error conditions.
81 // The status code, which should be an enum value of [google.rpc.Code][google.rpc.Code].
86 // [google.rpc.Status.details][google.rpc.Status.details] field, or localized by the client.
|
| /third_party/grpc/src/ruby/spec/pb/codegen/grpc/testing/ |
| D | package_options_ruby_style.proto | 36 rpc GetTest(AnotherTestRequest) returns (AnotherTestResponse) { }
37 rpc OtherTest(Thing) returns (Thing) { }
38 rpc PackageTest(grpc.testing.Thing) returns (grpc.foo.Foo.Bar) { }
39 rpc FooTest(Foo) returns (Foo) { }
40 rpc NestedMessageTest(Foo) returns (Bar.Baz) { }
|