Home
last modified time | relevance | path

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

12345678910>>...54

/aosp_15_r20/external/grpc-grpc/src/ruby/ext/grpc/
H A 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 …]
/aosp_15_r20/external/pytorch/benchmarks/distributed/rpc/parameter_server/
H A Dlauncher.py9 from server import server_map
29 def get_name(rank, args): argument
33 Args:
35 args (parser): benchmark configurations
37 t_count = args.ntrainer + args.ncudatrainer
38 s_count = args.nserver + args.ncudaserver
42 return f"server{rank}"
47 def get_server_rank(args, rank): argument
49 A function that gets the server rank for
51 Args:
[all …]
/aosp_15_r20/external/rust/android-crates-io/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 …]
/aosp_15_r20/external/rust/android-crates-io/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 …]
/aosp_15_r20/external/grpc-grpc/tools/run_tests/performance/templates/
H A 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 …]
H A 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 …]
H A 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 …]
H A 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 …]
/aosp_15_r20/external/grpc-grpc/src/core/ext/transport/chttp2/server/
H A 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 …]
/aosp_15_r20/external/python/cpython3/Lib/test/
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 …]
/aosp_15_r20/frameworks/base/core/proto/android/os/
H A Dincident.proto8 * http://www.apache.org/licenses/LICENSE-2.0
36 import "frameworks/base/core/proto/android/server/activitymanagerservice.proto";
37 import "frameworks/base/core/proto/android/server/alarm/alarmmanagerservice.proto";
38 import "frameworks/base/core/proto/android/server/bluetooth_manager_service.proto";
39 import "frameworks/base/core/proto/android/server/fingerprint.proto";
40 import "frameworks/base/core/proto/android/server/jobscheduler.proto";
41 import "frameworks/base/core/proto/android/server/location/context_hub.proto";
42 import "frameworks/base/core/proto/android/server/powermanagerservice.proto";
43 import "frameworks/base/core/proto/android/server/powerstatsservice.proto";
44 import "frameworks/base/core/proto/android/server/windowmanagerservice.proto";
[all …]
/aosp_15_r20/external/grpc-grpc/tools/run_tests/
H A 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 …]
/aosp_15_r20/external/rust/android-crates-io/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 …]
/aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/
H A 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 …]
/aosp_15_r20/tools/test/connectivity/acts_tests/acts_contrib/test_utils/net/
Dsocket_test_utils.py2 # Copyright 2018 - The Android Open Source Project
8 # http://www.apache.org/licenses/LICENSE-2.0
31 Args:
32 1. ad - android device object
33 2. domain - IPv4 or IPv6 type
34 3. sock_type - UDP or TCP socket
35 4. ip - IP addr on the device
36 5. port - open socket on port
50 Args:
51 1. ad - android device object
[all …]
/aosp_15_r20/prebuilts/jdk/jdk8/linux-x86/sample/nio/server/
DServer.java8 * - Redistributions of source code must retain the above copyright
11 * - Redistributions in binary form must reproduce the above copyright
15 * - Neither the name of Oracle nor the names of its
35 * required for a production-quality application, such as security checks,
48 * The main server base class.
50 * This class is responsible for setting up most of the server state
51 * before the actual server subclasses take over.
56 public abstract class Server { class
65 Server(int port, int backlog, in Server() method in Server
78 * If this is a secure server, we now setup the SSLContext we'll
[all …]
/aosp_15_r20/prebuilts/jdk/jdk8/darwin-x86/sample/nio/server/
DServer.java8 * - Redistributions of source code must retain the above copyright
11 * - Redistributions in binary form must reproduce the above copyright
15 * - Neither the name of Oracle nor the names of its
35 * required for a production-quality application, such as security checks,
48 * The main server base class.
50 * This class is responsible for setting up most of the server state
51 * before the actual server subclasses take over.
56 public abstract class Server { class
65 Server(int port, int backlog, in Server() method in Server
78 * If this is a secure server, we now setup the SSLContext we'll
[all …]
/aosp_15_r20/external/grpc-grpc/test/core/end2end/
H A Dend2end_test_suites.cc7 // http://www.apache.org/licenses/LICENSE-2.0
48 #include "src/core/ext/transport/chaotic_good/server/chaotic_good_server.h"
101 MutexLock lock(&state->mu); in Rand()
102 return absl::Uniform<uint64_t>(state->gen); in Rand()
115 void AddFailAuthCheckIfNeeded(const ChannelArgs& args, in AddFailAuthCheckIfNeeded() argument
117 if (args.Contains(FAIL_AUTH_CHECK_SERVER_ARG_NAME)) { in AddFailAuthCheckIfNeeded()
129 const ChannelArgs& args, grpc_completion_queue* cq, in MakeServer() argument
133 auto* server = grpc_server_create( in MakeServer() local
134 args.Set(GRPC_ARG_ENABLE_CENSUS, true).ToC().get(), nullptr); in MakeServer()
135 grpc_server_register_completion_queue(server, cq, nullptr); in MakeServer()
[all …]
/aosp_15_r20/external/grpc-grpc/test/cpp/end2end/xds/
H A Dxds_core_end2end_test.cc7 // http://www.apache.org/licenses/LICENSE-2.0
43 // XdsClientTest - basic tests of XdsClient functionality
54 balancer_->ads_service()->set_wrap_resources(true); in TEST_P()
56 EdsResourceArgs args({ in TEST_P() local
59 balancer_->ads_service()->SetEdsResource(BuildEdsResource(args)); in TEST_P()
61 channel_->GetState(true /* try_to_connect */); in TEST_P()
64 // Send kNumRpcsPerAddress RPCs per server. in TEST_P()
69 backends_[i]->backend_service()->request_count()); in TEST_P()
73 channel_->GetLoadBalancingPolicyName()); in TEST_P()
78 EdsResourceArgs args({{"locality0", CreateEndpointsForBackends(0, 1)}}); in TEST_P() local
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/surface/
Dserver.cc2 // Copyright 2015-2016 gRPC authors.
8 // http://www.apache.org/licenses/LICENSE-2.0
19 #include "src/core/lib/surface/server.h"
87 // Server::RequestedCall
90 struct Server::RequestedCall {
138 // Server::RegisteredMethod
141 struct Server::RegisteredMethod {
162 // Server::RequestMatcherInterface
174 class Server::RequestMatcherInterface {
179 // yet matched to an application-requested RPC).
[all …]
/aosp_15_r20/prebuilts/go/linux-x86/src/net/rpc/
Dserver.go2 // Use of this source code is governed by a BSD-style
7 network or other I/O connection. A server registers an object, making it visible
9 methods of the object will be accessible remotely. A server may register multiple
16 - the method's type is exported.
17 - the method is exported.
18 - the method has two arguments, both exported (or builtin) types.
19 - the method's second argument is a pointer.
20 - the method has return type error.
32 The method's return value, if non-nil, is passed back as a string that the client
36 The server may handle requests on a single connection by calling [ServeConn]. More
[all …]
/aosp_15_r20/prebuilts/clang/host/linux-x86/clang-r530567/python3/lib/python3.11/multiprocessing/
Dmanagers.py7 # Copyright (c) 2006-2008, R Oudkerk
82 # Function for communication with a manager's server process
85 def dispatch(c, id, methodname, args=(), kwds={}): argument
89 c.send((id, methodname, args, kwds))
112 return ('\n' + '-'*75 + '\n' + str(self.args[0]) + '-'*75)
136 # Server which is run in a process controlled by a manager
139 class Server(object): class
141 Server class which runs in a process controlled by a manager object
166 Run the server forever
192 t = threading.Thread(target=self.handle_request, args=(c,))
[all …]

12345678910>>...54