Home
last modified time | relevance | path

Searched +full:- +full:- +full:server +full:- +full:args (Results 1 – 25 of 1065) sorted by relevance

12345678910>>...43

/third_party/grpc/src/ruby/ext/grpc/
Drb_server.c9 * http://www.apache.org/licenses/LICENSE-2.0
44 /* id_insecure_server is used to indicate that a server is insecure */
49 /* The actual server */
55 static void grpc_rb_server_shutdown_and_notify_internal(grpc_rb_server* server, in grpc_rb_server_shutdown_and_notify_internal() argument
59 if (server->wrapped != NULL) { in grpc_rb_server_shutdown_and_notify_internal()
60 grpc_server_shutdown_and_notify(server->wrapped, server->queue, tag); in grpc_rb_server_shutdown_and_notify_internal()
63 // we will cancel all server calls after the deadline. in grpc_rb_server_shutdown_and_notify_internal()
64 ev = rb_completion_queue_pluck(server->queue, tag, deadline, NULL, NULL); in grpc_rb_server_shutdown_and_notify_internal()
66 grpc_server_cancel_all_calls(server->wrapped); in grpc_rb_server_shutdown_and_notify_internal()
68 server->queue, tag, gpr_inf_future(GPR_CLOCK_REALTIME), NULL, NULL); in grpc_rb_server_shutdown_and_notify_internal()
[all …]
/third_party/grpc/tools/run_tests/performance/templates/
Dloadtest_template_psm_proxied_basic_all_languages.yaml3 # Configuration templates contain client and server configurations for multiple
17 - build:
18 args:
19 - build
20 - --config
21 - opt
22 - //test/cpp/qps:qps_worker
24 - bazel
31 - args:
32 - -c
[all …]
Dloadtest_template_psm_proxyless_basic_all_languages.yaml3 # Configuration templates contain client and server configurations for multiple
17 - build:
18 args:
19 - build
20 - --config
21 - opt
22 - //test/cpp/qps:qps_worker
24 - bazel
31 - args:
32 - -c
[all …]
Dloadtest_template_psm_proxyless_prebuilt_all_languages.yaml3 # Configuration templates contain client and server configurations for multiple
17 - language: cxx
20 - args:
21 - -c
22 - |
23 timeout --kill-after="${KILL_AFTER}" "${POD_TIMEOUT}" \
24 /source/code/bazel-bin/test/cpp/qps/qps_worker \
25 --driver_port="${DRIVER_PORT}"
27 - bash
29 - name: GRPC_XDS_BOOTSTRAP
[all …]
Dloadtest_template_psm_proxied_prebuilt_all_languages.yaml3 # Configuration templates contain client and server configurations for multiple
17 - language: cxx
20 - args:
21 - -c
22 - |
23 timeout --kill-after="${KILL_AFTER}" "${POD_TIMEOUT}" \
24 /source/code/bazel-bin/test/cpp/qps/qps_worker \
25 --driver_port="${DRIVER_PORT}"
27 - bash
30 - args:
[all …]
/third_party/python/Lib/test/
Dssl_servers.py8 from http.server import (HTTPServer as _HTTPServer,
56 """Translate a /-separated PATH to the local filename syntax.
75 def log_message(self, format, *args): argument
78 sys.stdout.write(" server (%s:%d %s):\n [%s] %s\n" %
79 (self.server.server_address,
80 self.server.server_port,
83 format%args))
103 body = body.encode('utf-8')
105 self.send_header("Content-type", "text/plain; charset=utf-8")
106 self.send_header("Content-Length", str(len(body)))
[all …]
Dtest_imaplib.py36 t0 = calendar.timegm((2000, 1, 1, 0, 0, 0, -1, -1, -1))
38 b'25 (INTERNALDATE "01-Jan-2000 00:00:00 +0000")')
41 b'25 (INTERNALDATE "01-Jan-2000 11:30:00 +1130")')
44 b'25 (INTERNALDATE "31-Dec-1999 12:30:00 -1130")')
50 b'25 (INTERNALDATE "02-Apr-2000 02:30:00 +0000")'),
52 b'25 (INTERNALDATE "02-Apr-2000 03:30:00 +0000")'))
56 (2033, 5, 18, 5, 33, 20, -1, -1, -1),
57 (2033, 5, 18, 5, 33, 20, -1, -1, 1),
60 '"18-May-2033 05:33:20 +0200"']
65 @run_with_tz('STD-1DST,M3.2.0,M11.1.0')
[all …]
/third_party/grpc/src/python/grpcio_tests/tests_py3_only/interop/
Dxds_interop_server.py7 # http://www.apache.org/licenses/LICENSE-2.0
46 # NOTE: This interop server is not fully compatible with all xDS interop tests.
57 formatter = logging.Formatter(fmt="%(asctime)s: %(levelname)-8s %(message)s")
69 ) -> empty_pb2.Empty:
75 ) -> messages_pb2.SimpleResponse:
89 server: grpc.Server, maintenance_port: int argument
90 ) -> None:
91 channelz.add_channelz_servicer(server)
93 server.add_insecure_port(listen_address)
101 health_pb2_grpc.add_HealthServicer_to_server(health_servicer, server)
[all …]
/third_party/grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc9 // http://www.apache.org/licenses/LICENSE-2.0
19 #include "src/core/ext/transport/chttp2/server/chttp2_server.h"
83 #include "src/core/server/server.h"
108 const char kUnixAbstractUriPrefix[] = "unix-abstract:";
112 Timestamp GetConnectionDeadline(const ChannelArgs& args) { in GetConnectionDeadline() argument
116 args.GetDurationFromIntMillis(GRPC_ARG_SERVER_HANDSHAKE_TIMEOUT_MS) in GetConnectionDeadline()
123 class Chttp2ServerListener : public Server::ListenerInterface {
125 static grpc_error_handle Create(Server* server,
127 const ChannelArgs& args, int* port_num);
129 static grpc_error_handle CreateWithAcceptor(Server* server, const char* name,
[all …]
/third_party/grpc/test/cpp/qps/
Dqps_worker.cc9 // http://www.apache.org/licenses/LICENSE-2.0
26 #include <grpcpp/server.h>
46 #include "test/cpp/qps/server.h"
73 static std::unique_ptr<Server> CreateServer(const ServerConfig& config) { in CreateServer()
74 LOG(INFO) << "Starting server of type " in CreateServer()
130 return Status(StatusCode::RESOURCE_EXHAUSTED, "Server worker busy"); in RunServer()
141 resp->set_cores(gpr_cpu_num_cores()); in CoreCount()
151 worker_->MarkDone(); in QuitWorker()
160 : impl_(impl), acquired_(impl->TryAcquireInstance()) {} in InstanceGuard()
163 impl_->ReleaseInstance(); in ~InstanceGuard()
[all …]
/third_party/skia/third_party/externals/dawn/src/dawn_wire/server/
DServer.h7 // http://www.apache.org/licenses/LICENSE-2.0
19 #include "dawn_wire/server/ServerBase_autogen.h"
21 namespace dawn_wire { namespace server {
23 class Server; variable
27 // Server::MakeUserdata<T> and then passed as the userdata argument for Dawn
29 // It contains a pointer back to the Server so that the callback can call the
30 // Server to perform operations like serialization, and it contains a weak pointer
31 // |serverIsAlive|. If the weak pointer has expired, it means the server has
32 // been destroyed and the callback must not use the Server pointer.
36 // to userdata->server->MyCallbackHandler.
[all …]
/third_party/grpc/src/python/grpcio_tests/tests/unit/
D_exit_scenarios.py7 # http://www.apache.org/licenses/LICENSE-2.0
14 """Defines a number of module-scope gRPC scenarios to test clean exit."""
91 yield next(request_iterator) # pylint: disable=stop-iteration-return
159 def submit(self, fn, *args, **kwargs): argument
160 thread = threading.Thread(target=fn, args=args, kwargs=kwargs)
178 "--wait_for_interrupt", dest="wait_for_interrupt", action="store_true"
180 args = parser.parse_args() variable
182 if args.scenario == UNSTARTED_SERVER:
183 server = grpc.server(DaemonPool(), options=(("grpc.so_reuseport", 0),)) variable
184 if args.wait_for_interrupt:
[all …]
/third_party/grpc/src/php/ext/grpc/
Dserver.c9 * http://www.apache.org/licenses/LICENSE-2.0
20 * class Server
21 * @see https://github.com/grpc/grpc/tree/master/src/php/ext/grpc/server.c
24 #include "server.h"
45 if (p->wrapped != NULL) {
46 grpc_server_shutdown_and_notify(p->wrapped, completion_queue, NULL);
47 grpc_server_cancel_all_calls(p->wrapped);
50 grpc_server_destroy(p->wrapped);
59 zend_object_std_init(&intern->std, class_type TSRMLS_CC); in PHP_GRPC_FREE_WRAPPED_FUNC_END()
60 object_properties_init(&intern->std, class_type); in PHP_GRPC_FREE_WRAPPED_FUNC_END()
[all …]
/third_party/grpc/templates/test/cpp/naming/
Dresolver_component_tests_defs.include8 # http://www.apache.org/licenses/LICENSE-2.0
16 # This file is auto-generated
27 argp = argparse.ArgumentParser(description='Run c-ares resolver tests')
28 argp.add_argument('--test_bin_path', default=None, type=str,
30 argp.add_argument('--dns_server_bin_path', default=None, type=str,
31 help='Path to local DNS server python script.')
32 argp.add_argument('--records_config_path', default=None, type=str,
35 argp.add_argument('--dns_server_port', default=None, type=int,
36 help=('Port that local DNS server is listening on.'))
37 argp.add_argument('--dns_resolver_bin_path', default=None, type=str,
[all …]
/third_party/grpc/tools/run_tests/
Drun_interop_tests.py8 # http://www.apache.org/licenses/LICENSE-2.0
15 """Run interop (cross-language) tests in parallel."""
90 # disable this test on core-based languages,
106 def client_cmd(self, args): argument
107 return ["cmake/build/interop_client"] + args
109 def client_cmd_http2interop(self, args): argument
110 return ["cmake/build/http2_client"] + args
115 def server_cmd(self, args): argument
116 return ["cmake/build/interop_server"] + args
137 self.client_cwd = "../grpc-dotnet/output/InteropTestsClient"
[all …]
Drun_grpclb_interop_tests.py8 # http://www.apache.org/licenses/LICENSE-2.0
15 """Run interop (cross-language) tests in parallel."""
54 _SERVICE_NAME = "server.test.google.fr"
62 def client_cmd(self, args): argument
63 return ["bins/opt/interop_client"] + args
66 # 1) Set c-ares as the resolver, to
88 self.client_cwd = "/var/local/git/grpc-java"
91 def client_cmd(self, args): argument
97 "openssl x509 -outform der "
98 "-in /external_mount/src/core/tsi/test_creds/ca.pem "
[all …]
/third_party/grpc/test/core/end2end/fixtures/
Dsockpair_fixture.h7 // http://www.apache.org/licenses/LICENSE-2.0
43 #include "src/core/server/server.h"
59 if (ep_.server != nullptr) { in ~SockpairFixture()
60 grpc_endpoint_destroy(ep_.server); in ~SockpairFixture()
65 virtual ChannelArgs MutateClientArgs(ChannelArgs args) { return args; } in MutateClientArgs() argument
66 virtual ChannelArgs MutateServerArgs(ChannelArgs args) { return args; } in MutateServerArgs() argument
70 auto args = MutateServerArgs(in_args); in MakeServer() local
73 auto* server = grpc_server_create(args.ToC().get(), nullptr); in MakeServer() local
74 grpc_server_register_completion_queue(server, cq, nullptr); in MakeServer()
75 pre_server_start(server); in MakeServer()
[all …]
/third_party/grpc/test/core/surface/
Dconcurrent_connectivity_test.cc9 // http://www.apache.org/licenses/LICENSE-2.0
71 // it should never take longer that this to shutdown the server
101 // Always stack-allocate or new ServerThreadArgs; never use gpr_malloc since
105 grpc_server* server = nullptr; member
114 struct ServerThreadArgs* args = static_cast<struct ServerThreadArgs*>(vargs); in server_thread() local
118 ev = grpc_completion_queue_next(args->cq, deadline, nullptr); in server_thread()
127 struct ServerThreadArgs* args = static_cast<struct ServerThreadArgs*>(vargs); in on_connect() local
129 gpr_mu_lock(args->mu); in on_connect()
131 grpc_pollset_kick(args->pollset[0], nullptr)); in on_connect()
132 gpr_mu_unlock(args->mu); in on_connect()
[all …]
/third_party/grpc/test/cpp/naming/utils/
Ddns_server.py8 # http://www.apache.org/licenses/LICENSE-2.0
15 """Starts a local DNS server for use in tests"""
36 from twisted.names import server
39 import twisted.names.server
43 "health-check-local-dns-server-is-alive.resolver-tests.grpctestingexp"
56 def start_local_dns_server(args): argument
79 with open(args.records_config_path) as config:
89 assert record_full_name[-1] == "."
90 record_full_name = record_full_name[:-1]
114 if args.add_a_record:
[all …]
/third_party/grpc/src/python/grpcio_tests/tests/stress/
Dclient.py7 # http://www.apache.org/licenses/LICENSE-2.0
36 "--server_addresses",
42 "--test_cases",
48 "--test_duration_secs",
50 default=-1,
54 "--num_channels_per_server",
55 help="number of channels per server",
60 "--num_stubs_per_channel",
66 "--metrics_port",
72 "--use_test_ca",
[all …]
/third_party/grpc/src/python/grpcio/grpc/aio/
D_base_server.py7 # http://www.apache.org/licenses/LICENSE-2.0
14 """Abstract base classes for server-side classes."""
21 from ._metadata import Metadata # pylint: disable=unused-import
28 class Server(abc.ABC): class
34 ) -> None:
35 """Registers GenericRpcHandlers with this Server.
37 This method is only safe to call before the server is started.
39 Args:
45 def add_insecure_port(self, address: str) -> int:
51 This method may only be called before starting the server.
[all …]
/third_party/grpc/test/cpp/util/
Dcreate_test_channel.cc3 // Copyright 2015-2016 gRPC authors.
9 // http://www.apache.org/licenses/LICENSE-2.0
30 "If non-empty, set a static service config on channels created by "
44 grpc::ChannelArguments* /*args*/) override { in GetChannelCredentials()
53 // Register ssl with non-test roots type to the credentials provider.
55 testing::GetCredentialsProvider()->AddSecureType( in AddProdSslType()
60 void MaybeSetCustomChannelArgs(grpc::ChannelArguments* args) { in MaybeSetCustomChannelArgs() argument
62 args->SetString( in MaybeSetCustomChannelArgs()
73 // When cred_type is 'ssl', if server is empty, override_hostname is used to
74 // create channel. Otherwise, connect to server and override hostname if
[all …]
/third_party/grpc/src/python/grpcio_tests/tests/interop/
Dserver.py7 # http://www.apache.org/licenses/LICENSE-2.0
14 """The Python implementation of the GRPC interoperability test server."""
35 "--port", type=int, required=True, help="the port on which to serve"
38 "--use_tls",
44 "--use_alts",
61 def serve(args): argument
62 server = test_common.test_server()
64 service.TestService(), server
66 if args.use_tls or args.use_alts:
67 credentials = get_server_credentials(args.use_tls)
[all …]
/third_party/mbedtls/tests/scripts/
Dgenerate_tls13_compat_tests.py6 # SPDX-License-Identifier: Apache-2.0 OR GPL-2.0-or-later
23 'ecdsa_secp256r1_sha256': Certificate('data_files/test-ca2.crt',
26 'ecdsa_secp384r1_sha384': Certificate('data_files/test-ca2.crt',
29 'ecdsa_secp521r1_sha512': Certificate('data_files/test-ca2.crt',
32 'rsa_pss_rsae_sha256': Certificate('data_files/test-ca_cat12.crt',
33 'data_files/server2-sha256.crt', 'data_files/server2.key'
64 Base class for generate server/client command.
67 # pylint: disable=too-many-arguments
104 # pylint: disable=no-self-use
108 # pylint: disable=no-self-use
[all …]
/third_party/grpc/src/python/grpcio/grpc/
D__init__.py1 # Copyright 2015-2016 gRPC authors.
7 # http://www.apache.org/licenses/LICENSE-2.0
31 # pylint: disable=ungrouped-imports
126 Args:
149 Args:
171 Args:
201 Args:
250 RESOURCE_EXHAUSTED: Some resource has been exhausted, perhaps a per-user quota, or
304 details: A UTF-8-encodable string to be sent to the client upon
314 """Raised by the gRPC library to indicate non-OK-status RPC termination."""
[all …]

12345678910>>...43