| /external/autotest/site_utils/ |
| D | server_manager.py | 42 from autotest_lib.frontend.server import models as server_models
47 def _add_role(server, role, action): argument
58 if role in server.get_role_names():
60 'Server %s already has role %s.' % (server.hostname, role))
63 if not server_manager_utils.check_server(server.hostname, role):
65 'Server %s is not ready for role %s.' % (server.hostname, role))
68 server.status == server_models.Server.STATUS.PRIMARY):
76 server_models.ServerRole.objects.create(server=server, role=role)
79 server_manager_actions.try_execute(server, [role], enable=True,
82 print('Role %s is added to server %s.' % (role, server.hostname))
[all …]
|
| D | server_manager_utils.py | 25 from autotest_lib.frontend.server import models as server_models
97 return '\n'.join(str(server) for server in servers)
107 for server in servers:
108 if server.date_modified is None:
111 date_modified = str(server.date_modified)
112 attributes = {k: v for k, v in server.attributes.values_list(
114 server_dicts.append({'hostname': server.hostname,
115 'status': server.status,
116 'roles': server.get_role_names(),
117 'date_created': str(server.date_created),
[all …]
|
| /external/grpc-grpc/test/core/util/ |
| D | reconnect_server.cc | 35 static void pretty_print_backoffs(reconnect_server* server) { in pretty_print_backoffs() argument
39 timestamp_list* head = server->head; in pretty_print_backoffs()
41 for (head = server->head; head && head->next; head = head->next, i++) { in pretty_print_backoffs()
50 if (server->max_reconnect_backoff_ms > 0) { in pretty_print_backoffs()
51 max_reconnect_backoff_ms = server->max_reconnect_backoff_ms; in pretty_print_backoffs()
65 reconnect_server* server = static_cast<reconnect_server*>(arg); in on_connect() local
74 if (server->peer == nullptr) { in on_connect()
75 server->peer = peer; in on_connect()
79 } else if (strncmp(server->peer, peer, in on_connect()
81 gpr_log(GPR_ERROR, "mismatched peer! %s vs %s", server->peer, peer); in on_connect()
[all …]
|
| D | test_tcp_server.cc | 39 test_tcp_server* server = static_cast<test_tcp_server*>(data); in on_server_destroyed() local
40 server->shutdown = 1; in on_server_destroyed()
43 void test_tcp_server_init(test_tcp_server* server, in test_tcp_server_init() argument
46 server->tcp_server = nullptr; in test_tcp_server_init()
47 GRPC_CLOSURE_INIT(&server->shutdown_complete, on_server_destroyed, server, in test_tcp_server_init()
49 server->shutdown = 0; in test_tcp_server_init()
50 server->pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in test_tcp_server_init()
51 grpc_pollset_init(server->pollset, &server->mu); in test_tcp_server_init()
52 server->on_connect = on_connect; in test_tcp_server_init()
53 server->cb_data = user_data; in test_tcp_server_init()
[all …]
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.cc | 53 void (*start)(grpc_server* server, void* arg, grpc_pollset** pollsets,
55 void (*destroy)(grpc_server* server, void* arg, grpc_closure* closure);
69 grpc_server* server; member
95 grpc_server* server; member
162 grpc_server* server; member
230 (((channel_data*)(elem)->channel_data)->server)
233 static void fail_call(grpc_server* server, size_t cq_idx, requested_call* rc,
237 static void maybe_finish_shutdown(grpc_server* server);
312 static void request_matcher_init(request_matcher* rm, grpc_server* server) { in request_matcher_init() argument
314 rm->server = server; in request_matcher_init()
[all …]
|
| /external/virglrenderer/vtest/ |
| D | vtest_server.c | 93 struct vtest_server server = { variable
129 list_inithead(&server.new_clients); in main()
130 list_inithead(&server.active_clients); in main()
131 list_inithead(&server.inactive_clients); in main()
133 if (server.do_fork) { in main()
142 if (!server.main_server) { in main()
182 server.do_fork = false; in vtest_server_parse_args()
185 server.do_fork = false; in vtest_server_parse_args()
186 server.loop = false; in vtest_server_parse_args()
190 server.multi_clients = true; in vtest_server_parse_args()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | URLConnectionTest.java | 104 @Rule public final MockWebServer server = new MockWebServer(); field in URLConnectionTest
114 server.setProtocolNegotiationEnabled(false); in setUp()
133 server.enqueue(new MockResponse()); in requestHeaders()
135 connection = client.open(server.getUrl("/")); in requestHeaders()
169 RecordedRequest request = server.takeRequest(); in requestHeaders()
194 connection = client.open(server.getUrl("/")); in getRequestPropertyReturnsLastValue()
201 server.enqueue(new MockResponse().setStatus("HTTP/1.0 200 Fantastic") in responseHeaders()
207 connection = client.open(server.getUrl("/")); in responseHeaders()
235 server.enqueue(new MockResponse().setStatus("HTP/1.1 200 OK")); in serverSendsInvalidResponseHeaders()
237 connection = client.open(server.getUrl("/")); in serverSendsInvalidResponseHeaders()
[all …]
|
| D | ConnectionReuseTest.java | 35 @Rule public final MockWebServer server = new MockWebServer(); field in ConnectionReuseTest
41 server.enqueue(new MockResponse().setBody("a")); in connectionsAreReused()
42 server.enqueue(new MockResponse().setBody("b")); in connectionsAreReused()
45 .url(server.url("/")) in connectionsAreReused()
52 server.enqueue(new MockResponse().setBody("a")); in connectionsAreReusedWithHttp2()
53 server.enqueue(new MockResponse().setBody("b")); in connectionsAreReusedWithHttp2()
56 .url(server.url("/")) in connectionsAreReusedWithHttp2()
62 server.enqueue(new MockResponse().setBody("a")); in connectionsAreNotReusedWithRequestConnectionClose()
63 server.enqueue(new MockResponse().setBody("b")); in connectionsAreNotReusedWithRequestConnectionClose()
66 .url(server.url("/")) in connectionsAreNotReusedWithRequestConnectionClose()
[all …]
|
| D | CacheTest.java | 76 @Rule public MockWebServer server = new MockWebServer(); field in CacheTest
86 server.setProtocolNegotiationEnabled(false); in setUp()
157 server = new MockWebServer(); in assertCached()
172 server.enqueue(mockResponse); in assertCached()
173 server.start(); in assertCached()
176 .url(server.url("/")) in assertCached()
191 server.shutdown(); // tearDown() isn't sufficient; this test starts multiple servers in assertCached()
216 server.enqueue(mockResponse); in testResponseCaching()
219 Request request = new Request.Builder().url(server.url("/")).build(); in testResponseCaching()
247 server.useHttps(sslContext.getSocketFactory(), false); in secureResponseCaching()
[all …]
|
| D | CallTest.java | 89 @Rule public final MockWebServer server = new MockWebServer(); field in CallTest
111 server.enqueue(new MockResponse().setBody("abc").addHeader("Content-Type: text/plain")); in get()
114 .url(server.url("/")) in get()
124 RecordedRequest recordedRequest = server.takeRequest(); in get()
132 server.enqueue(new MockResponse()); in buildRequestUsingHttpUrl()
134 HttpUrl httpUrl = server.url("/"); in buildRequestUsingHttpUrl()
164 server.enqueue(new MockResponse().setResponseCode(500)); in getReturns500()
167 .url(server.url("/")) in getReturns500()
191 server.enqueue(new MockResponse() in repeatedHeaderNames()
196 .url(server.url("/")) in repeatedHeaderNames()
[all …]
|
| /external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/ |
| D | ResponseCacheTest.java | 94 @Rule public MockWebServer server = new MockWebServer(); field in ResponseCacheTest
104 server.setProtocolNegotiationEnabled(false); in setUp()
183 server = new MockWebServer(); in assertCached()
195 server.enqueue(mockResponse); in assertCached()
196 server.start(); in assertCached()
198 URL url = server.getUrl("/"); in assertCached()
211 server.shutdown(); // tearDown() isn't sufficient; this test starts multiple servers in assertCached()
236 server.enqueue(mockResponse); in testResponseCaching()
239 HttpURLConnection urlConnection = openConnection(server.getUrl("/")); in testResponseCaching()
247 urlConnection = openConnection(server.getUrl("/")); // cached! in testResponseCaching()
[all …]
|
| /external/adhd/cras/src/ |
| D | Makefile.am | 34 server/cras_apm_list.c
576 server/cras_alert.c
579 -I$(top_srcdir)/src/server
583 server/cras_alsa_card.c server/cras_alsa_mixer_name.c \
584 server/cras_alsa_ucm_section.c
587 -I$(top_srcdir)/src/server \
588 -I$(top_srcdir)/src/server/config
595 -I$(top_srcdir)/src/server
599 server/cras_audio_area.c
600 audio_area_unittest_CPPFLAGS = $(COMMON_CPPFLAGS) -I$(top_srcdir)/src/server \
[all …]
|
| /external/grpc-grpc/src/php/tests/unit_tests/ |
| D | ServerTest.php | 24 $this->server = null;
29 unset($this->server);
34 $this->server = new Grpc\Server();
35 $this->assertNotNull($this->server);
40 $this->server = new Grpc\Server([]);
41 $this->assertNotNull($this->server);
47 $this->server = new Grpc\Server(['ip' => '127.0.0.1',
49 $this->assertNotNull($this->server);
54 $this->server = new Grpc\Server();
55 $port = $this->server->addHttp2Port('0.0.0.0:0');
[all …]
|
| /external/okhttp/okhttp-urlconnection/src/test/java/com/squareup/okhttp/ |
| D | UrlConnectionCacheTest.java | 81 @Rule public MockWebServer server = new MockWebServer(); field in UrlConnectionCacheTest
91 server.setProtocolNegotiationEnabled(false); in setUp()
166 server = new MockWebServer(); in assertCached()
178 server.enqueue(response); in assertCached()
179 server.start(); in assertCached()
181 URL url = server.getUrl("/"); in assertCached()
195 server.shutdown(); // tearDown() isn't sufficient; this test starts multiple servers in assertCached()
220 server.enqueue(response); in testResponseCaching()
223 HttpURLConnection urlConnection = client.open(server.getUrl("/")); in testResponseCaching()
233 urlConnection = client.open(server.getUrl("/")); // cached! in testResponseCaching()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/ |
| D | ares__close_sockets.c | 22 void ares__close_sockets(ares_channel channel, struct server_state *server) in ares__close_sockets() argument
27 while (server->qhead) in ares__close_sockets()
30 sendreq = server->qhead; in ares__close_sockets()
31 server->qhead = sendreq->next; in ares__close_sockets()
36 server->qtail = NULL; in ares__close_sockets()
39 if (server->tcp_buffer) in ares__close_sockets()
40 ares_free(server->tcp_buffer); in ares__close_sockets()
41 server->tcp_buffer = NULL; in ares__close_sockets()
42 server->tcp_lenbuf_pos = 0; in ares__close_sockets()
45 server->is_broken = 0; in ares__close_sockets()
[all …]
|
| D | ares_process.c | 85 static int open_tcp_socket(ares_channel channel, struct server_state *server);
86 static int open_udp_socket(ares_channel channel, struct server_state *server);
210 struct server_state *server; in write_tcp_data() local
226 server = &channel->servers[i]; in write_tcp_data()
227 if (!server->qhead || server->tcp_socket == ARES_SOCKET_BAD || in write_tcp_data()
228 server->is_broken) in write_tcp_data()
232 if(!FD_ISSET(server->tcp_socket, write_fds)) in write_tcp_data()
236 if(server->tcp_socket != write_fd) in write_tcp_data()
246 FD_CLR(server->tcp_socket, write_fds); in write_tcp_data()
250 for (sendreq = server->qhead; sendreq; sendreq = sendreq->next) in write_tcp_data()
[all …]
|
| /external/chromium-trace/catapult/common/py_utils/py_utils/ |
| D | ts_proxy_server_unittest.py | 25 with ts_proxy_server.TsProxyServer() as server:
26 self.assertIsNotNone(server.port)
27 with ts_proxy_server.TsProxyServer(None, 37124, 37125) as server:
28 self.assertIsNotNone(server.port)
31 with ts_proxy_server.TsProxyServer() as server:
32 self.assertIsNotNone(server.port)
33 server.UpdateOutboundPorts(31242, 14220)
36 with ts_proxy_server.TsProxyServer() as server:
37 self.assertIsNotNone(server.port)
39 server.UpdateOutboundPorts(31242, 'abcde')
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | ServerTest.cs | 34 Server server = new Server in StartAndShutdownServer()
38 server.Start(); in StartAndShutdownServer()
39 server.ShutdownAsync().Wait(); in StartAndShutdownServer()
45 Server server = new Server in StartAndKillServer()
49 server.Start(); in StartAndKillServer()
50 server.KillAsync().Wait(); in StartAndKillServer()
56 Server server = new Server in PickUnusedPort()
61 var boundPort = server.Ports.Single(); in PickUnusedPort()
65 server.Start(); in PickUnusedPort()
66 server.ShutdownAsync().Wait(); in PickUnusedPort()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | HttpOverSpdyTest.java | 68 @Rule public final MockWebServer server = new MockWebServer(); field in HttpOverSpdyTest
85 server.useHttps(sslContext.getSocketFactory(), false); in setUp()
98 server.enqueue(response); in get()
100 connection = client.open(server.getUrl("/foo")); in get()
105 RecordedRequest request = server.takeRequest(); in get()
108 assertEquals(server.getHostName() + ":" + server.getPort(), request.getHeader(hostHeader)); in get()
112 server.enqueue(new MockResponse()); in emptyResponse()
114 connection = client.open(server.getUrl("/foo")); in emptyResponse()
121 server.enqueue(new MockResponse().setBody("ABCDE")); in noDefaultContentLengthOnStreamingPost()
123 connection = client.open(server.getUrl("/foo")); in noDefaultContentLengthOnStreamingPost()
[all …]
|
| D | HttpOverHttp2Test.java | 42 server.enqueue(response); in serverSendsPushPromise_GET()
44 connection = client.open(server.getUrl("/foo")); in serverSendsPushPromise_GET()
49 RecordedRequest request = server.takeRequest(); in serverSendsPushPromise_GET()
52 assertEquals(server.getHostName() + ":" + server.getPort(), request.getHeader(hostHeader)); in serverSendsPushPromise_GET()
54 RecordedRequest pushedRequest = server.takeRequest(); in serverSendsPushPromise_GET()
66 server.enqueue(response); in serverSendsPushPromise_HEAD()
68 connection = client.open(server.getUrl("/foo")); in serverSendsPushPromise_HEAD()
73 RecordedRequest request = server.takeRequest(); in serverSendsPushPromise_HEAD()
76 assertEquals(server.getHostName() + ":" + server.getPort(), request.getHeader(hostHeader)); in serverSendsPushPromise_HEAD()
78 RecordedRequest pushedRequest = server.takeRequest(); in serverSendsPushPromise_HEAD()
[all …]
|
| /external/mockwebserver/src/test/java/com/google/mockwebserver/ |
| D | MockWebServerTest.java | 35 private MockWebServer server; field in MockWebServerTest
40 server = new MockWebServer(); in setUp()
44 server.shutdown(); in tearDown()
107 server.enqueue(new MockResponse().setBody("hello world")); in testRegularResponse()
108 server.play(); in testRegularResponse()
110 URL url = server.getUrl("/"); in testRegularResponse()
118 RecordedRequest request = server.takeRequest(); in testRegularResponse()
124 server.play(); in testRedirect()
125 server.enqueue(new MockResponse() in testRedirect()
127 .addHeader("Location: " + server.getUrl("/new-path")) in testRedirect()
[all …]
|
| /external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
| D | MockWebServerTest.java | 50 @Rule public final MockWebServer server = new MockWebServer(); field in MockWebServerTest
84 server.enqueue(new MockResponse().setBody("hello world")); in regularResponse()
86 URL url = server.getUrl("/"); in regularResponse()
94 RecordedRequest request = server.takeRequest(); in regularResponse()
100 server.enqueue(new MockResponse() in redirect()
102 .addHeader("Location: " + server.getUrl("/new-path")) in redirect()
104 server.enqueue(new MockResponse().setBody("This is the new location!")); in redirect()
106 URLConnection connection = server.getUrl("/").openConnection(); in redirect()
111 RecordedRequest first = server.takeRequest(); in redirect()
113 RecordedRequest redirect = server.takeRequest(); in redirect()
[all …]
|
| /external/libwebsockets/minimal-examples/http-client/minimal-http-client-multi/ |
| D | selftest.sh | 46 spawn "" $5/http-server/minimal-http-server-tls $1/lws-minimal-http-server-tls
48 spawn $SPID $5/http-server/minimal-http-server-tls $1/lws-minimal-http-server-tls
50 spawn $SPID $5/http-server/minimal-http-server-tls $1/lws-minimal-http-server-tls
52 spawn $SPID $5/http-server/minimal-http-server-tls $1/lws-minimal-http-server-tls
54 spawn $SPID $5/http-server/minimal-http-server-tls $1/lws-minimal-http-server-tls
56 spawn $SPID $5/http-server/minimal-http-server-tls $1/lws-minimal-http-server-tls
58 spawn $SPID $5/http-server/minimal-http-server-tls $1/lws-minimal-http-server-tls
60 spawn $SPID $5/http-server/minimal-http-server-tls $1/lws-minimal-http-server-tls
|
| /external/python/cpython3/Lib/test/ |
| D | test_imaplib.py | 119 self.server.is_selected = False
120 self.server.logged = None
186 self.server.logged = None
191 self.server.logged = args[0]
195 self.server.is_selected = True
200 if self.server.is_selected:
201 self.server.is_selected = False
227 self.server = self.server_class((socket_helper.HOST, 0), imap_handler)
230 target=self.server.serve_forever,
239 self.client = self.imap_class(*self.server.server_address)
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| D | CookiesTest.java | 66 MockWebServer server = new MockWebServer(); in testNetscapeResponse() local
67 server.start(); in testNetscapeResponse()
69 server.enqueue(new MockResponse().addHeader("Set-Cookie: a=android; " in testNetscapeResponse()
72 + "domain=" + server.getCookieDomain() + "; " in testNetscapeResponse()
74 get(server, "/path/foo"); in testNetscapeResponse()
84 assertTrue(server.getCookieDomain().equalsIgnoreCase(cookie.getDomain())); in testNetscapeResponse()
94 MockWebServer server = new MockWebServer(); in testRfc2109Response() local
95 server.start(); in testRfc2109Response()
97 server.enqueue(new MockResponse().addHeader("Set-Cookie: a=android; " in testRfc2109Response()
99 + "Domain=" + server.getCookieDomain() + "; " in testRfc2109Response()
[all …]
|