Home
last modified time | relevance | path

Searched refs:server (Results 1 – 25 of 5588) sorted by relevance

12345678910>>...224

/external/autotest/site_utils/
Dserver_manager.py37 from autotest_lib.frontend.server import models as server_models
42 def _add_role(server, role, action): argument
53 if role in server.get_role_names():
55 'Server %s already has role %s.' % (server.hostname, role))
58 if not server_manager_utils.check_server(server.hostname, role):
60 'Server %s is not ready for role %s.' % (server.hostname, role))
63 server.status == server_models.Server.STATUS.PRIMARY):
71 server_models.ServerRole.objects.create(server=server, role=role)
74 server_manager_actions.try_execute(server, [role], enable=True,
77 print 'Role %s is added to server %s.' % (role, server.hostname)
[all …]
Dserver_manager_utils.py21 from autotest_lib.frontend.server import models as server_models
93 return '\n'.join(str(server) for server in servers)
103 for server in servers:
104 if server.date_modified is None:
107 date_modified = str(server.date_modified)
108 attributes = {k: v for k, v in server.attributes.values_list(
110 server_dicts.append({'hostname': server.hostname,
111 'status': server.status,
112 'roles': server.get_role_names(),
113 'date_created': str(server.date_created),
[all …]
/external/grpc-grpc/src/core/lib/surface/
Dserver.cc53 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/grpc-grpc/test/core/util/
Dreconnect_server.cc35 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 …]
Dtest_tcp_server.cc39 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/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
DCallTest.java89 @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 …]
DURLConnectionTest.java104 @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 …]
DConnectionReuseTest.java35 @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 …]
DCacheTest.java76 @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 …]
/external/adhd/cras/src/
DMakefile.am34 server/cras_apm_list.c \
35 server/config/aec_config.c \
36 server/config/apm_config.c
474 server/cras_alert.c
477 -I$(top_srcdir)/src/server
481 server/cras_alsa_card.c server/cras_alsa_mixer_name.c \
482 server/cras_alsa_ucm_section.c
485 -I$(top_srcdir)/src/server \
486 -I$(top_srcdir)/src/server/config
493 -I$(top_srcdir)/src/server
[all …]
/external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/
DResponseCacheTest.java94 @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/okhttp/okhttp-urlconnection/src/test/java/com/squareup/okhttp/
DUrlConnectionCacheTest.java81 @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/grpc-grpc/src/php/tests/unit_tests/
DServerTest.php24 $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-tests/src/test/java/com/squareup/okhttp/internal/framed/
DHttpOverSpdyTest.java68 @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 …]
DHttpOverHttp2Test.java42 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/webrtc/webrtc/base/
Dhttpserver_unittest.cc29 HttpServerMonitor(HttpServer* server) in HttpServerMonitor()
31 server->SignalCloseAllComplete.connect(this, in HttpServerMonitor()
33 server->SignalHttpRequest.connect(this, &HttpServerMonitor::OnRequest); in HttpServerMonitor()
34 server->SignalHttpRequestComplete.connect(this, in HttpServerMonitor()
36 server->SignalConnectionClosed.connect(this, in HttpServerMonitor()
58 void CreateClientConnection(HttpServer& server, in CreateClientConnection() argument
63 server.HandleConnection(client); in CreateClientConnection()
76 HttpServer server; in TEST() local
77 HttpServerMonitor monitor(&server); in TEST()
79 CreateClientConnection(server, monitor, true); in TEST()
[all …]
Dsocket_unittest.cc204 scoped_ptr<AsyncSocket> server( in ConnectInternal() local
206 sink.Monitor(server.get()); in ConnectInternal()
207 EXPECT_EQ(0, server->Bind(SocketAddress(loopback, 0))); in ConnectInternal()
208 EXPECT_EQ(0, server->Listen(5)); in ConnectInternal()
209 EXPECT_EQ(AsyncSocket::CS_CONNECTING, server->GetState()); in ConnectInternal()
212 EXPECT_FALSE(sink.Check(server.get(), testing::SSE_READ)); in ConnectInternal()
213 EXPECT_TRUE(NULL == server->Accept(&accept_addr)); in ConnectInternal()
217 EXPECT_EQ(0, client->Connect(server->GetLocalAddress())); in ConnectInternal()
219 EXPECT_NE(server->GetLocalAddress(), client->GetLocalAddress()); in ConnectInternal()
227 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout); in ConnectInternal()
[all …]
/external/python/cpython3/Lib/test/
Dtest_imaplib.py124 self.server.logged = None
190 self.server.logged = None
195 self.server.logged = args[0]
219 self.server = self.server_class((support.HOST, 0), imap_handler)
222 target=self.server.serve_forever,
231 self.client = self.imap_class(*self.server.server_address)
233 return self.client, self.server
245 self.server.shutdown()
246 self.server.server_close()
256 _, server = self._setup(EOFHandler, connect=False)
[all …]
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DServerTest.cs34 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/mockwebserver/src/test/java/com/google/mockwebserver/
DMockWebServerTest.java35 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/
DMockWebServerTest.java50 @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/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/
DCookiesTest.java66 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 …]
/external/wpa_supplicant_8/hs20/server/
Dhs20-osu-server.txt1 Hotspot 2.0 OSU server
5 16.04 server (64-bit) distribution is used and the web server is
12 secure to be installed in a publicly available Internet server without
19 Ubuntu 16.04 server
41 assumes /home/user/hs20-server to be used, but this can be changed by
44 sudo mkdir -p /home/user/hs20-server
45 sudo chown $USER /home/user/hs20-server
46 mkdir -p /home/user/hs20-server/spp
47 mkdir -p /home/user/hs20-server/AS
53 # hostapd as RADIUS server
[all …]
/external/okhttp/okhttp-apache/src/test/java/com/squareup/okhttp/apache/
DOkApacheClientTest.java34 private MockWebServer server; field in OkApacheClientTest
39 server = new MockWebServer(); in setUp()
40 server.start(); in setUp()
44 server.shutdown(); in tearDown()
48 server.enqueue(new MockResponse().setBody("Hello, World!")); in success()
50 HttpGet request = new HttpGet(server.getUrl("/").toURI()); in success()
57 server.enqueue(new MockResponse().setResponseCode(302).addHeader("Location", "/foo")); in redirect()
58 server.enqueue(new MockResponse().setBody("Hello, Redirect!")); in redirect()
60 HttpGet request = new HttpGet(server.getUrl("/").toURI()); in redirect()
67 server.enqueue(new MockResponse().setResponseCode(422)); in sessionExpired()
[all …]
/external/python/cpython2/Lib/test/
Dtest_imaplib.py114 server = MyServer(addr, hdlr)
115 self.assertEqual(server.server_address, server.socket.getsockname())
121 print "HDLR =", server.RequestHandlerClass
125 target=server.serve_forever,
133 return server, t
135 def reap_server(self, server, thread): argument
137 server.shutdown()
143 server, thread = self.make_server((support.HOST, 0), hdlr)
145 yield server
147 self.reap_server(server, thread)
[all …]

12345678910>>...224