Home
last modified time | relevance | path

Searched refs:stub (Results 1 – 25 of 427) sorted by relevance

12345678910>>...18

/third_party/mesa3d/src/mapi/
Dstub.c65 const struct mapi_stub *stub = (const struct mapi_stub *) elem; in stub_compare() local
68 stub_name = &public_string_pool[(size_t) stub->name]; in stub_compare()
89 struct mapi_stub *stub; in stub_add_dynamic() local
97 stub = &dynamic_stubs[idx]; in stub_add_dynamic()
100 stub->addr = entry_generate( in stub_add_dynamic()
102 if (!stub->addr) in stub_add_dynamic()
105 stub->name = (const void *) strdup(name); in stub_add_dynamic()
107 stub->slot = -1; in stub_add_dynamic()
111 return stub; in stub_add_dynamic()
122 struct mapi_stub *stub = NULL; in stub_find_dynamic() local
[all …]
Dmapi_glapi.c129 const struct mapi_stub *stub; in _glapi_add_dispatch() local
136 stub = stub_find_public(funcName); in _glapi_add_dispatch()
137 if (!stub) in _glapi_add_dispatch()
138 stub = stub_find_dynamic(funcName, 0); in _glapi_add_dispatch()
140 slot = (stub) ? stub_get_slot(stub) : -1; in _glapi_add_dispatch()
146 alias = stub; in _glapi_add_dispatch()
148 function_stubs[i] = stub; in _glapi_add_dispatch()
155 struct mapi_stub *stub; in _glapi_add_dispatch() local
160 stub = stub_find_dynamic(funcName, 1); in _glapi_add_dispatch()
161 if (!stub) in _glapi_add_dispatch()
[all …]
/third_party/grpc/src/php/tests/interop/
Dinterop_client.php59 function emptyUnary($stub) argument
62 $stub->EmptyCall(new Grpc\Testing\EmptyMessage())->wait();
72 function largeUnary($stub) argument
74 performLargeUnary($stub);
84 function performLargeUnary($stub, $fillUsername = false, argument
105 list($result, $status) = $stub->UnaryCall($request, [], $options)->wait();
124 function clientCompressedUnary($stub) argument
139 list($result, $status) = $stub->UnaryCall($request, [], [])->wait();
151 list($result, $status) = $stub->UnaryCall($request, $metadata, [])->wait();
172 function serviceAccountCreds($stub, $args) argument
[all …]
/third_party/grpc/src/python/grpcio_tests/tests/interop/
Dmethods.py69 def _large_unary_common_behavior(stub, fill_username, fill_oauth_scope, argument
78 response_future = stub.UnaryCall.future(request,
85 def _empty_unary(stub): argument
86 response = stub.EmptyCall(empty_pb2.Empty())
92 def _large_unary(stub): argument
93 _large_unary_common_behavior(stub, False, False, None)
96 def _client_streaming(stub): argument
107 response = stub.StreamingInputCall(requests)
113 def _server_streaming(stub): argument
129 response_iterator = stub.StreamingOutputCall(request)
[all …]
D_intraop_test_case.py27 methods.TestCase.EMPTY_UNARY.test_interoperability(self.stub, None)
30 methods.TestCase.LARGE_UNARY.test_interoperability(self.stub, None)
33 methods.TestCase.SERVER_STREAMING.test_interoperability(self.stub, None)
36 methods.TestCase.CLIENT_STREAMING.test_interoperability(self.stub, None)
39 methods.TestCase.PING_PONG.test_interoperability(self.stub, None)
43 self.stub, None)
47 self.stub, None)
51 self.stub, None)
/third_party/grpc/src/python/grpcio_tests/tests/http2/
Dnegative_http2_client.py60 def _goaway(stub): argument
61 first_response = stub.UnaryCall(_SIMPLE_REQUEST)
65 second_response = stub.UnaryCall(_SIMPLE_REQUEST)
70 def _rst_after_header(stub): argument
71 resp_future = stub.UnaryCall.future(_SIMPLE_REQUEST)
76 def _rst_during_data(stub): argument
77 resp_future = stub.UnaryCall.future(_SIMPLE_REQUEST)
82 def _rst_after_data(stub): argument
83 resp_future = stub.UnaryCall.future(_SIMPLE_REQUEST)
88 def _ping(stub): argument
[all …]
/third_party/grpc/examples/python/route_guide/
Droute_guide_client.py34 def guide_get_one_feature(stub, point): argument
35 feature = stub.GetFeature(point)
46 def guide_get_feature(stub): argument
48 stub, route_guide_pb2.Point(latitude=409146138, longitude=-746188906))
49 guide_get_one_feature(stub, route_guide_pb2.Point(latitude=0, longitude=0))
52 def guide_list_features(stub): argument
58 features = stub.ListFeatures(rectangle)
71 def guide_record_route(stub): argument
75 route_summary = stub.RecordRoute(route_iterator)
95 def guide_route_chat(stub): argument
[all …]
/third_party/grpc/examples/ruby/errors_and_cancellation/
Derror_examples_client.rb31 def run_get_feature_expect_error(stub) argument
32 resp = stub.get_feature(Point.new)
35 def run_list_features_expect_error(stub) argument
36 resps = stub.list_features(Rectangle.new)
42 def run_record_route_expect_error(stub) argument
43 stub.record_route([])
46 def run_route_chat_expect_error(stub) argument
47 resps = stub.route_chat([])
54 stub = RouteGuide::Stub.new('localhost:50051', :this_channel_is_insecure)
57 run_get_feature_expect_error(stub)
[all …]
/third_party/grpc/test/cpp/end2end/
Dservice_config_end2end_test.cc258 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in SendRpc() argument
268 Status status = stub->Echo(&context, request, response); in SendRpc()
275 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in CheckRpcSendOk() argument
280 SendRpc(stub, &response, 2000, &status, wait_for_ready); in CheckRpcSendOk()
291 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub) { in CheckRpcSendFailure() argument
292 const bool success = SendRpc(stub); in CheckRpcSendFailure()
353 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in WaitForServer() argument
358 SendRpc(stub); in WaitForServer()
360 CheckRpcSendOk(stub, location, true); in WaitForServer()
437 auto stub = BuildStub(channel); in TEST_F() local
[all …]
Dclient_lb_end2end_test.cc291 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in SendRpc() argument
305 Status status = stub->Echo(&context, request, response); in SendRpc()
312 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in CheckRpcSendOk() argument
317 SendRpc(stub, &response, 2000, &status, wait_for_ready); in CheckRpcSendOk()
328 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub) { in CheckRpcSendFailure() argument
329 const bool success = SendRpc(stub); in CheckRpcSendFailure()
390 const std::unique_ptr<grpc::testing::EchoTestService::Stub>& stub, in WaitForServer() argument
395 SendRpc(stub); in WaitForServer()
397 CheckRpcSendOk(stub, location, true); in WaitForServer()
466 auto stub = BuildStub(channel); in TEST_F() local
[all …]
/third_party/icu/icu4c/source/test/hdrtst/
DMakefile.in54 echo 'void junk(){}' >> $$stub ; \
55 $(COMPILE.headers) $(cppflags) $(FLAGS.headers) $(UCONFIG_NO) $$stub || FAIL=1 ; \
56 rm -f $$stub; \
103 …@FAIL=0;NONE="(No deprecated headers)";stub=ht_stub_dtest.cpp;for incfile in `cat $(srcdir)/dfiles…
106 echo "#include <unicode/$$incfile>" > $$stub ; \
107 echo 'void junk(){}' >> $$stub ; \
108 $(COMPILE.cc) $(cppflags) $$stub 2>&1 | tee $$stub.out || FAIL=1 ; \
109 …if ! cat $$stub.out | sed -e 's/^.*#error[^"]*"//' | grep -v ht_ | grep -v "$$incfile header is ob…
113 rm -f $$stub*; \
119 @FAIL=0;stub=ht_stub_cppguardtest.cpp; for file in "$(prefix)/include/unicode"/*.h ; do \
[all …]
/third_party/grpc/examples/python/data_transmission/
Dclient.py38 def simple_method(stub): argument
42 response = stub.SimpleMethod(request)
51 def client_streaming_method(stub): argument
63 response = stub.ClientStreamingMethod(request_messages())
72 def server_streaming_method(stub): argument
76 response_iterator = stub.ServerStreamingMethod(request)
87 def bidirectional_streaming_method(stub): argument
101 response_iterator = stub.BidirectionalStreamingMethod(request_messages())
111 stub = demo_pb2_grpc.GRPCDemoStub(channel)
113 simple_method(stub)
[all …]
/third_party/grpc/src/python/grpcio_tests/tests_aio/interop/
Dmethods.py76 stub: test_pb2_grpc.TestServiceStub, fill_username: bool,
86 response = await stub.UnaryCall(request, credentials=call_credentials)
91 async def _empty_unary(stub: test_pb2_grpc.TestServiceStub) -> None:
92 response = await stub.EmptyCall(empty_pb2.Empty())
98 async def _large_unary(stub: test_pb2_grpc.TestServiceStub) -> None:
99 await _large_unary_common_behavior(stub, False, False, None)
102 async def _client_streaming(stub: test_pb2_grpc.TestServiceStub) -> None:
115 response = await stub.StreamingInputCall(request_gen())
121 async def _server_streaming(stub: test_pb2_grpc.TestServiceStub) -> None:
137 call = stub.StreamingOutputCall(request)
[all …]
/third_party/grpc/src/ruby/spec/generic/
Dclient_stub_spec.rb175 stub = GRPC::ClientStub.new("localhost:#{server_port}",
177 expect(get_response(stub)).to eq(@resp)
186 stub = GRPC::ClientStub.new(host, :this_channel_is_insecure)
188 expect(get_response(stub)).to eq(@resp)
222 stub = GRPC::ClientStub.new('ignored-host',
225 expect(get_response(stub)).to eq(@resp)
233 stub = GRPC::ClientStub.new(host, :this_channel_is_insecure)
234 blk = proc { get_response(stub) }
259 stub = GRPC::ClientStub.new("localhost:#{server_port}",
270 get_response(stub, credentials: creds)
[all …]
Dserver_interceptors_spec.rb40 stub = build_insecure_stub(EchoStub)
41 expect(stub.an_rpc(request)).to be_a(EchoMsg)
50 stub = build_insecure_stub(EchoStub)
55 op = stub.an_rpc(request, client_call_opts)
75 stub = build_insecure_stub(EchoStub)
76 expect(stub.a_client_streaming_rpc(requests)).to be_a(EchoMsg)
85 stub = build_insecure_stub(EchoStub)
90 op = stub.a_client_streaming_rpc(requests, client_call_opts)
110 stub = build_insecure_stub(EchoStub)
111 responses = stub.a_server_streaming_rpc(request)
[all …]
Dclient_interceptors_spec.rb33 stub = build_insecure_stub(EchoStub, opts: interceptors_opts)
36 expect(stub.an_rpc(request)).to be_a(EchoMsg)
45 stub = build_insecure_stub(EchoStub, opts: interceptors_opts)
49 expect(stub.an_rpc(request)).to be_a(EchoMsg)
60 stub = build_insecure_stub(EchoStub, opts: interceptors_opts)
64 expect(stub.a_client_streaming_rpc(requests)).to be_a(EchoMsg)
73 stub = build_insecure_stub(EchoStub, opts: interceptors_opts)
78 expect(stub.a_client_streaming_rpc(requests)).to be_a(EchoMsg)
89 stub = build_insecure_stub(EchoStub, opts: interceptors_opts)
93 responses = stub.a_server_streaming_rpc(request)
[all …]
Drpc_server_spec.rb318 stub = GRPC::ClientStub.new(@host, :this_channel_is_insecure,
320 stub.request_response('/unknown', req, marshal, unmarshal)
333 stub = GRPC::ClientStub.new(@host, :this_channel_is_insecure,
335 stub.request_response('/an_rpc', req, marshal, unmarshal)
351 stub = EchoStub.new(@host, :this_channel_is_insecure, **client_opts)
353 stub.a_client_streaming_rpc_unimplemented(requests)
373 stub = EchoStub.new(@host, :this_channel_is_insecure, **client_opts)
374 n.times { expect(stub.an_rpc(req)).to be_a(EchoMsg) }
385 stub = EchoStub.new(@host, :this_channel_is_insecure, **client_opts)
386 expect(stub.an_rpc(req, metadata: { k1: 'v1', k2: 'v2' }))
[all …]
/third_party/grpc/src/python/grpcio_tests/tests/fork/
Dmethods.py56 def _async_unary(stub): argument
62 response_future = stub.UnaryCall.future(request, timeout=_RPC_TIMEOUT_S)
67 def _blocking_unary(stub): argument
73 response = stub.UnaryCall(request, timeout=_RPC_TIMEOUT_S)
155 _async_unary(stub)
161 stub = test_pb2_grpc.TestServiceStub(channel)
162 _async_unary(stub)
165 _async_unary(stub)
177 stub = test_pb2_grpc.TestServiceStub(channel)
178 _async_unary(stub)
[all …]
/third_party/flatbuffers/tests/MyGame/Example/
DMonsterStorageGrpc.java11 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
15 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
16 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
17 import static io.grpc.stub.ClientCalls.futureUnaryCall;
18 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
19 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
20 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
[all …]
/third_party/grpc/examples/ruby/route_guide/
Droute_guide_client.rb40 def run_get_feature(stub) argument
44 resp = stub.get_feature(pt)
61 def run_list_features(stub) argument
64 resps = stub.list_features(LIST_FEATURES_RECT)
100 def run_record_route(stub, features) argument
105 resp = stub.record_route(reqs.each)
125 def run_route_chat(stub) argument
129 stub.route_chat(sleeping_enumerator.each_item) { |r| p "received #{r.inspect}" }
149 stub = RouteGuide::Stub.new('localhost:50051', :this_channel_is_insecure)
150 run_get_feature(stub)
[all …]
/third_party/grpc/src/ruby/bin/
Dmath_client.rb44 def do_div(stub) argument
49 resp = stub.div(req)
54 def do_sum(stub) argument
60 resp = stub.sum(reqs) # reqs.is_a?(Enumerable)
65 def do_fib(stub) argument
70 resp = stub.fib(req)
77 def do_div_many(stub) argument
85 resp = stub.div_many(reqs)
127 stub = Math::Math::Stub.new(options['host'], **stub_opts)
130 … stub = Math::Math::Stub.new(options['host'], :this_channel_is_insecure, timeout: INFINITE_FUTURE)
[all …]
/third_party/node/test/parallel/
Dtest-dns-lookup-promises.js36 stub: getaddrinfoPositive(['::1']),
41 stub: getaddrinfoPositive(['127.0.0.1']),
46 stub: getaddrinfoPositive(['127.0.0.1'], { family: 4 }),
51 stub: getaddrinfoPositive(['some-address']),
56 stub: getaddrinfoPositive(['some-address2']),
60 ].forEach(async ({ stub, factory, expectation }) => { property
61 getaddrinfoStub = stub;
79 stub: getaddrinfoPositive(['::1', '::2']),
87 stub: getaddrinfoPositive(['::1', '::2']),
95 stub: getaddrinfoPositive(['127.0.0.1', 'some-address']),
[all …]
/third_party/grpc/src/python/grpcio_tests/tests/testing/
D_client_application.py101 def _run_unary_unary(stub): argument
102 response = stub.UnUn(_application_common.UNARY_UNARY_REQUEST)
109 def _run_unary_stream(stub): argument
110 response_iterator = stub.UnStre(_application_common.UNARY_STREAM_REQUEST)
119 def _run_stream_unary(stub): argument
120 response, call = stub.StreUn.with_call(
129 def _run_stream_stream(stub): argument
131 response_iterator = stub.StreStre(iter(request_pipe))
151 def _run_concurrent_stream_unary(stub): argument
153 stub.StreUn.future(iter((_application_common.STREAM_UNARY_REQUEST,) *
[all …]
/third_party/grpc/src/python/grpcio_tests/tests/protoc_plugin/
Dbeta_python_plugin_test.py225 stub = getattr(service_pb2, STUB_FACTORY_IDENTIFIER)(channel)
226 yield servicer_methods, stub
252 stub = getattr(service_pb2, STUB_FACTORY_IDENTIFIER)(channel)
253 yield None, stub
360 with _CreateIncompleteService(self._service_pb2) as (_, stub):
363 stub.UnaryCall(request, test_constants.LONG_TIMEOUT)
372 self._service_pb2) as (methods, stub):
374 response = stub.UnaryCall(request, test_constants.LONG_TIMEOUT)
382 self._service_pb2) as (methods, stub):
386 response_future = stub.UnaryCall.future(
[all …]
/third_party/grpc/test/cpp/ios/CronetTests/
DCppCronetEnd2EndTests.mm95 - (void)sendRPCWithStub:(EchoTestService::Stub*)stub
109 Status s = stub->Echo(&context, request, &response);
141 auto stub = EchoTestService::NewStub(channel);
142 return stub;
151 auto stub = [self getStub];
152 Status s = stub->Echo(&context, request, &response);
160 auto stub = [self getStub];
165 [self, &stub]() { [self sendRPCWithStub:stub.get() numRPCs:10 withBinaryMetadata:NO]; });
173 auto stub = [self getStub];
178 [self, &stub]() { [self sendRPCWithStub:stub.get() numRPCs:10 withBinaryMetadata:YES]; });
[all …]

12345678910>>...18