Home
last modified time | relevance | path

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

12345678910>>...48

/external/grpc-grpc/src/ruby/ext/grpc/
Drb_server.c9 * http://www.apache.org/licenses/LICENSE-2.0
43 /* id_insecure_server is used to indicate that a server is insecure */
48 /* The actual server */
55 static void grpc_rb_server_maybe_shutdown_and_notify(grpc_rb_server* server, in grpc_rb_server_maybe_shutdown_and_notify() argument
59 if (!server->shutdown_and_notify_done) { in grpc_rb_server_maybe_shutdown_and_notify()
60 server->shutdown_and_notify_done = 1; in grpc_rb_server_maybe_shutdown_and_notify()
61 if (server->wrapped != NULL) { in grpc_rb_server_maybe_shutdown_and_notify()
62 grpc_server_shutdown_and_notify(server->wrapped, server->queue, tag); in grpc_rb_server_maybe_shutdown_and_notify()
63 ev = rb_completion_queue_pluck(server->queue, tag, deadline, NULL); in grpc_rb_server_maybe_shutdown_and_notify()
65 grpc_server_cancel_all_calls(server->wrapped); in grpc_rb_server_maybe_shutdown_and_notify()
[all …]
/external/grpc-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 …]
/external/rust/crates/grpcio-sys/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 …]
/external/python/cpython3/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 …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc9 // http://www.apache.org/licenses/LICENSE-2.0
21 #include "src/core/ext/transport/chttp2/server/chttp2_server.h"
80 #include "src/core/lib/surface/server.h"
100 const char kUnixAbstractUriPrefix[] = "unix-abstract:";
102 class Chttp2ServerListener : public Server::ListenerInterface {
104 static grpc_error_handle Create(Server* server, grpc_resolved_address* addr,
105 const ChannelArgs& args,
110 Server* server, const char* name, const ChannelArgs& args,
114 Chttp2ServerListener(Server* server, const ChannelArgs& args,
118 void Start(Server* server,
[all …]
/external/python/cpython2/Lib/test/
Dssl_servers.py56 """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)))
115 def log_request(self, format, *args): argument
[all …]
/external/grpc-grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc9 // http://www.apache.org/licenses/LICENSE-2.0
21 #include "src/core/ext/transport/chttp2/server/chttp2_server.h"
82 #include "src/core/lib/surface/server.h"
101 const char kUnixAbstractUriPrefix[] = "unix-abstract:";
104 class Chttp2ServerListener : public Server::ListenerInterface {
106 static grpc_error_handle Create(Server* server, grpc_resolved_address* addr,
107 const ChannelArgs& args,
112 Server* server, const char* name, const ChannelArgs& args,
116 Chttp2ServerListener(Server* server, const ChannelArgs& args,
120 void Start(Server* server,
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests_py3_only/interop/
Dxds_interop_server.py7 # http://www.apache.org/licenses/LICENSE-2.0
39 # NOTE: This interop server is not fully compatible with all xDS interop tests.
49 formatter = logging.Formatter(fmt="%(asctime)s: %(levelname)-8s %(message)s")
61 ) -> empty_pb2.Empty:
67 ) -> messages_pb2.SimpleResponse:
76 server: grpc.Server, maintenance_port: int argument
77 ) -> None:
78 channelz.add_channelz_servicer(server)
80 server.add_insecure_port(listen_address)
88 health_pb2_grpc.add_HealthServicer_to_server(health_servicer, server)
[all …]
/external/python/mobly/mobly/snippet/
Dclient_base.py7 # http://www.apache.org/licenses/LICENSE-2.0
18 .. code-block:: json
63 Connects to a remote device running a JSON RPC compatible server. Users call
64 the function `start_server` to start the server on the remote device before
66 to stop the snippet server and release all the requested resources.
69 package: str, the user-visible name of the snippet library being
79 Args:
80 package: str, the user-visible name of the snippet library being
100 1. before starting server: preparing to start the snippet server.
101 2. start server: starting the snippet server on the remote device.
[all …]
/external/pigweed/pw_rpc/py/pw_rpc/
Dtesting.py7 # https://www.apache.org/licenses/LICENSE-2.0
29 ) -> argparse.Namespace:
30 """Parses arguments for running a Python-based integration test."""
37 '--test-server-command',
40 help='Command that starts the test server.',
43 '--port',
47 'The port to use to connect to the test server. This value is '
48 'passed to the test server as the last argument.'
54 help='Arguments after "--" are passed to unittest.',
57 args = parser.parse_args()
[all …]
/external/grpc-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."""
90 yield next(request_iterator) # pylint: disable=stop-iteration-return
147 def submit(self, fn, *args, **kwargs): argument
148 thread = threading.Thread(target=fn, args=args, kwargs=kwargs)
166 "--wait_for_interrupt", dest="wait_for_interrupt", action="store_true"
168 args = parser.parse_args() variable
170 if args.scenario == UNSTARTED_SERVER:
171 server = grpc.server(DaemonPool(), options=(("grpc.so_reuseport", 0),)) variable
172 if args.wait_for_interrupt:
[all …]
/external/grpc-grpc/test/cpp/qps/
Dqps_worker.cc9 // http://www.apache.org/licenses/LICENSE-2.0
36 #include <grpcpp/server.h>
46 #include "test/cpp/qps/server.h"
73 static std::unique_ptr<Server> CreateServer(const ServerConfig& config) { in CreateServer()
74 gpr_log(GPR_INFO, "Starting server of type %s", 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 …]
/external/grpc-grpc-java/examples/example-xds/src/main/java/io/grpc/examples/helloworldxds/
DXdsHelloWorldServer.java8 * http://www.apache.org/licenses/LICENSE-2.0
20 import io.grpc.Server;
32 * An xDS-managed Server for the {@code Greeter} service.
35 public static void main(String[] args) throws IOException, InterruptedException { in main() argument
39 if (args.length >= 1 && "--xds-creds".equals(args[0])) { in main()
40 // The xDS credentials use the security configured by the xDS server when available. When xDS in main()
44 args = Arrays.copyOfRange(args, 1, args.length); in main()
46 if (args.length >= 1) { in main()
48 port = Integer.parseInt(args[0]); in main()
50 System.err.println("Usage: [--xds-creds] [PORT [HOSTNAME]]"); in main()
[all …]
/external/grpc-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"
44 if (p->wrapped != NULL) {
45 grpc_server_shutdown_and_notify(p->wrapped, completion_queue, NULL);
46 grpc_server_cancel_all_calls(p->wrapped);
49 grpc_server_destroy(p->wrapped);
58 zend_object_std_init(&intern->std, class_type TSRMLS_CC); in PHP_GRPC_FREE_WRAPPED_FUNC_END()
59 object_properties_init(&intern->std, class_type); in PHP_GRPC_FREE_WRAPPED_FUNC_END()
[all …]
/external/pigweed/pw_target_runner/
Ddocs.rst1 .. _module-pw_target_runner:
3 ----------------
5 ----------------
6 .. pigweed-module::
9 The target runner module implements a gRPC server designed to run executables
14 --------
15 The target runner server is responsible for processing requests to distribute
20 Additionally, the server allows many executables to be queued up at once and
23 ``pw watch`` command to re-run all affected unit tests after modifying code.
26 This library provides the core gRPC server and a mechanism through which worker
[all …]
/external/grpc-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 …]
/external/rust/crates/grpcio-sys/grpc/tools/run_tests/
Drun_interop_tests.py8 # http://www.apache.org/licenses/LICENSE-2.0
15 """Run interop (cross-language) tests in parallel."""
86 # disable this test on core-based languages,
103 def client_cmd(self, args): argument
104 return ['cmake/build/interop_client'] + args
106 def client_cmd_http2interop(self, args): argument
107 return ['cmake/build/http2_client'] + args
112 def server_cmd(self, args): argument
113 return ['cmake/build/interop_server'] + args
133 self.client_cwd = '../grpc-dotnet/output/InteropTestsClient'
[all …]
/external/grpc-grpc/test/cpp/util/
Dcreate_test_channel.cc3 // Copyright 2015-2016 gRPC authors.
9 // http://www.apache.org/licenses/LICENSE-2.0
31 "If non-empty, set a static service config on channels created by "
45 grpc::ChannelArguments* /*args*/) override { in GetChannelCredentials()
54 // Register ssl with non-test roots type to the credentials provider.
56 testing::GetCredentialsProvider()->AddSecureType( in AddProdSslType()
61 void MaybeSetCustomChannelArgs(grpc::ChannelArguments* args) { in MaybeSetCustomChannelArgs() argument
63 args->SetString( in MaybeSetCustomChannelArgs()
74 // When cred_type is 'ssl', if server is empty, override_hostname is used to
75 // create channel. Otherwise, connect to server and override hostname if
[all …]

12345678910>>...48