| /external/okhttp/okhttp-urlconnection/src/test/java/com/squareup/okhttp/ |
| OkUrlFactoryTest.java | 30 @Rule public MockWebServer server = new MockWebServer(); field in class:OkUrlFactoryTest
43 * throws if it is sent by an origin server.
46 server.enqueue(new MockResponse().setResponseCode(407));
48 HttpURLConnection conn = factory.open(server.getUrl("/"));
57 server.enqueue(new MockResponse().setBody("Isla Sorna"));
59 HttpURLConnection connection = factory.open(server.getUrl("/"));
65 server.enqueue(new MockResponse().setResponseCode(404));
67 HttpURLConnection connection = factory.open(server.getUrl("/"));
72 server.enqueue(new MockResponse()
76 server.enqueue(new MockResponse().setResponseCode(304))
[all...] |
| /libcore/luni/src/test/java/libcore/dalvik/system/ |
| SocketTaggingTest.java | 80 private ServerSocketChannel server; field in class:SocketTaggingTest
84 server = ServerSocketChannel.open();
85 server.configureBlocking(false);
86 server.bind(null);
100 sc.connect(server.getLocalAddress());
120 dc.connect(server.getLocalAddress());
130 s.connect(server.getLocalAddress());
140 d.connect(server.getLocalAddress());
|
| /libcore/luni/src/test/java/libcore/javax/net/ssl/ |
| SSLSessionContextTest.java | 43 SSLSessionContext server) {
45 assertSSLSessionContextSize(expected, server, true);
50 boolean server) {
52 if (server && TestSSLContext.sslServerSocketSupportsSessionTickets()) {
100 SSLSessionContext server = s.c.serverContext.getServerSessionContext(); local
105 assertFalse(server.getIds().hasMoreElements());
107 byte[] serverId = (byte[]) server.getIds().nextElement();
108 assertNotNull(server.getSession(serverId));
109 assertTrue(Arrays.equals(serverId, server.getSession(serverId).getId()));
156 SSLSessionContext server = s.c.serverContext.getServerSessionContext() local
168 SSLSessionContext server = c.serverContext.getServerSessionContext(); local
[all...] |
| /libcore/luni/src/test/java/libcore/net/ |
| NetworkSecurityPolicyTest.java | 97 try (CapturingServerSocket server = new CapturingServerSocket()) {
98 URL url = new URL("http://localhost:" + server.getPort() + "/test.txt");
104 server.assertDataTransmittedByClient();
110 try (CapturingServerSocket server = new CapturingServerSocket()) {
111 URL url = new URL("http://localhost:" + server.getPort() + "/test.txt");
117 server.assertNoDataTransmittedByClient();
125 try (CapturingServerSocket server = new CapturingServerSocket(serverReplyOnConnect)) {
126 URL url = new URL("ftp://localhost:" + server.getPort() + "/test.txt");
132 server.assertDataTransmittedByClient();
138 try (CapturingServerSocket server = new CapturingServerSocket(serverReplyOnConnect))
[all...] |
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestSSLEnginePair.java | 30 * a pair of connected and handshaked client and server SSLEngines for
35 public final SSLEngine server; field in class:TestSSLEnginePair
39 SSLEngine server,
42 this.server = server;
69 * Create a new connected server/client engine pair within a
96 SSLEngine server = c.serverContext.createSSLEngine(); local
98 server.setUseClientMode(false);
99 hooks.beforeBeginHandshake(client, server);
101 server.beginHandshake()
[all...] |
| /external/apache-harmony/x-net/src/test/impl/java.injected/org/apache/harmony/xnet/provider/jsse/ |
| SSLSocketImplTest.java | 67 Server server = null; local
70 server = new Server();
74 new InetSocketAddress("localhost", server.getPort()));
78 server.start();
93 while (!server.handshakeStarted()) {
102 server.close();
113 if (server != null) {
115 server.close()
133 Server server = null; local
197 Server server = null; local
264 Server server = null; local
330 Server server = null; local
620 private final ServerSocket server; field in class:SSLSocketImplTest.Server
678 Server server = null; local
797 Server server = null; local
912 Server server = null; local
974 Server server = null; local
1036 Server server = null; local
1098 Server server = null; local
1130 Server server = null; local
1162 Server server = null; local
1194 Server server = null; local
[all...] |
| /cts/apps/CtsVerifier/src/com/android/cts/verifier/security/ |
| KeyChainTest.java | 306 * Create a mock web server.
307 * The server authenticates itself to the client using the key pair and certificate from the
309 * the server trusts only the certificates installed in the credential storage of this
313 log("Starting web server");
325 MockWebServer server = new MockWebServer(); local
326 server.useHttps(needsClientAuth, false /* tunnelProxy */);
327 server.enqueue(new MockResponse().setBody("this response comes via HTTPS"));
328 server.play();
329 return server.getUrl("/");
333 * Open a new connection to the server
[all...] |
| /cts/hostsidetests/services/activitymanager/src/android/server/cts/ |
| ActivityManagerActivityVisiblityTests.java | 17 package android.server.cts;
|
| ActivityManagerAppConfigurationTests.java | 16 package android.server.cts;
|
| DisplaySizeTest.java | 17 package android.server.cts;
55 forceStopPackage("android.server.app");
63 startActivity("android.server.app", "TestActivity");
|
| /external/autotest/client/cros/ |
| dhcp_test_base.py | 8 device to shill and a DHCP test server on the end that doesn't look like a real
175 raise error.TestFail('Could not start DHCP test server.')
203 server is bound to. The server itself is bound the the broadcast
209 def server(self): member in class:DhcpTestBase
211 Returns a reference to the DHCP test server. Use this to add handlers
237 ipconfig matches the DHCP options provided to the server.
239 @param dhcp_options dict of properties the DHCP server should provide.
240 @param custom_fields dict of custom DHCP parameters to add to server.
249 # Build up the handling rules for the server and start the test
[all...] |
| /external/autotest/client/cros/multimedia/ |
| multimedia_xmlrpc_server.py | 6 """XML RPC server for multimedia testing."""
87 help=('restart the XML RPC server without clearing '
105 server = xmlrpc_server.XmlRpcServer( variable
107 server.register_delegate(MultimediaXmlRpcDelegate(res))
108 server.run()
|
| /external/autotest/contrib/ |
| generate_rpm_mapping.py | 20 python generate_rpm_mapping.py --csv mapping_file.csv --server cautotest
35 from autotest_lib.server.cros.dynamic_suite import frontend_wrappers
458 parser.add_argument('--server', type=str, dest='server', default=None,
459 help='AFE server that the script will be talking to. '
461 'server in global_config.ini')
465 server=options.server) variable
466 logging.info('Connected to %s', AFE.server)
|
| /external/autotest/frontend/server/ |
| models.py | 5 """Django model for server database.
17 class Server(dbmodels.Model, model_logic.ModelExtensions):
18 """Models a server."""
42 """Metadata for class Server."""
47 """A string representation of the Server object.
62 """Get a list of role names of the server.
64 @return: A list of role names of the server.
70 """Get a dictionary with all server details.
80 @return: A dictionary with all server details.
97 # Valid roles for a server
114 server = dbmodels.ForeignKey(Server, related_name='roles') variable in class:ServerRole
126 server = dbmodels.ForeignKey(Server, related_name='attributes') variable in class:ServerAttribute
[all...] |
| /external/autotest/site_utils/rpm_control_system/ |
| frontend_server.py | 21 from autotest_lib.server import frontend
49 This class is the frontend server of the RPM Infrastructure. All clients
50 will send their power state requests to this central server who will
52 server.
55 to this frontend server who will send the result back to the client.
57 All calls to this server are blocking.
63 heap. If a dispatcher server shuts down this allows us to
68 server.
101 to the appropriate dispatcher server.
136 # Dispatcher Server is not reachable. Unregister it and retry
370 server = MultiThreadedXMLRPCServer((address, port), allow_none=True) variable
[all...] |
| /external/avahi/avahi-core/ |
| avahi-test.c | 45 static AvahiServer *server = NULL; variable
127 server = s;
128 avahi_log_debug("server state: %i", state);
131 avahi_log_debug("Server startup complete. Host name is <%s>. Service cookie is %u", avahi_server_get_host_name_fqdn(s), avahi_server_get_local_service_cookie(s));
157 group = avahi_s_entry_group_new(server, entry_group_callback, NULL);
169 if (avahi_server_add_service(server, group, AVAHI_IF_UNSPEC, AVAHI_PROTO_UNSPEC, 0, service_name, "_http._tcp", NULL, NULL, 80, "foo", NULL) < 0) {
174 if (avahi_server_add_service(server, group, AVAHI_IF_UNSPEC, AVAHI_PROTO_UNSPEC, 0, service_name, "_ftp._tcp", NULL, NULL, 21, "foo", NULL) < 0) {
179 if (avahi_server_add_service(server, group, AVAHI_IF_UNSPEC, AVAHI_PROTO_UNSPEC, 0,service_name, "_webdav._tcp", NULL, NULL, 80, "foo", NULL) < 0) {
184 if (avahi_server_add_dns_server_address(server, group, AVAHI_IF_UNSPEC, AVAHI_PROTO_UNSPEC, 0, NULL, AVAHI_DNS_SERVER_RESOLVE, avahi_address_parse("192.168.50.1", AVAHI_PROTO_UNSPEC, &a), 53) < 0) {
185 avahi_log_error("Failed to add new DNS Server address")
[all...] |
| cache.h | 66 AvahiServer *server; member in struct:AvahiCache
80 AvahiCache *avahi_cache_new(AvahiServer *server, AvahiInterface *interface);
|
| multicast-lookup.c | 58 AvahiServer *server; member in struct:AvahiMulticastLookupEngine
114 avahi_querier_add_for_all(e->server, interface, protocol, l->key, &tv);
121 l->all_for_now_event = avahi_time_event_new(e->server->time_event_queue, &tv, all_for_now_callback, l);
132 avahi_querier_remove_for_all(l->engine->server, l->interface, l->protocol, l->key);
266 avahi_interface_monitor_walk(e->server->monitor, interface, protocol, scan_interface_callback, &cbdata);
331 e->server = s;
|
| resolve-service.c | 39 AvahiServer *server; member in struct:AvahiSServiceResolver
150 avahi_server_set_errno(r->server, AVAHI_ERR_TIMEOUT);
163 r->time_event = avahi_time_event_new(r->server->time_event_queue, &tv, time_event_callback, r);
225 r->record_browser_a = avahi_s_record_browser_new(r->server, r->interface, r->protocol, k, r->user_flags & ~(AVAHI_LOOKUP_NO_TXT|AVAHI_LOOKUP_NO_ADDRESS), record_browser_callback, r);
231 r->record_browser_aaaa = avahi_s_record_browser_new(r->server, r->interface, r->protocol, k, r->user_flags & ~(AVAHI_LOOKUP_NO_TXT|AVAHI_LOOKUP_NO_ADDRESS), record_browser_callback, r);
379 AvahiServer *server,
395 assert(server);
399 AVAHI_CHECK_VALIDITY_RETURN_NULL(server, AVAHI_IF_VALID(interface), AVAHI_ERR_INVALID_INTERFACE);
400 AVAHI_CHECK_VALIDITY_RETURN_NULL(server, AVAHI_PROTO_VALID(protocol), AVAHI_ERR_INVALID_PROTOCOL);
401 AVAHI_CHECK_VALIDITY_RETURN_NULL(server, AVAHI_PROTO_VALID(aprotocol), AVAHI_ERR_INVALID_PROTOCOL)
[all...] |
| /external/avahi/avahi-daemon/ |
| dbus-protocol.c | 64 Server *server = NULL; variable
71 assert(server);
110 AVAHI_LLIST_REMOVE(Client, clients, server->clients, c);
113 assert(server->n_clients >= 1);
114 server->n_clients --;
120 assert(server);
123 for (client = server->clients; client; client = client->clients_next)
130 if (server->n_clients >= server->n_clients_max
[all...] |
| /external/chromium-trace/catapult/catapult_build/ |
| dev_server.py | 81 if hasattr(self.app.server, 'please_exit'):
82 self.app.server.please_exit(exit_code)
179 def server(self): member in class:DevServerApp
182 @server.setter
183 def server(self, server): member in class:DevServerApp
184 self._server = server
243 assert self.server is not None
259 def _AddPleaseExitMixinToServer(server):
268 server.running = Fals
[all...] |
| /external/curl/lib/ |
| socks_gssapi.c | 119 gss_name_t server = GSS_C_NO_NAME; local
144 (gss_OID) GSS_C_NULL_OID, &server);
155 GSS_C_NT_HOSTBASED_SERVICE, &server);
163 gss_release_name(&gss_status, &server);
173 server,
185 gss_release_name(&gss_status, &server);
202 gss_release_name(&gss_status, &server);
214 gss_release_name(&gss_status, &server);
240 gss_release_name(&gss_status, &server);
247 failf(data, "User was rejected by the SOCKS5 server (%d %d)."
[all...] |
| /external/dbus/dbus/ |
| dbus-server-socket.c | 2 /* dbus-server-socket.c Server implementation for sockets
26 #include "dbus-server-socket.h"
42 * Opaque object representing a Socket server implementation.
61 socket_finalize (DBusServer *server)
63 DBusServerSocket *socket_server = (DBusServerSocket*) server;
66 _dbus_server_finalize_base (server);
81 dbus_free (server);
86 handle_new_client_fd_and_unlock (DBusServer *server,
96 HAVE_LOCK_CHECK (server);
162 DBusServer *server = data; local
286 DBusServer *server; local
395 DBusServer *server; local
[all...] |
| /external/dbus/test/ |
| corrupt.c | 38 DBusServer *server; member in struct:__anon8786
67 new_conn_cb (DBusServer *server,
85 f->server = dbus_server_listen (addr, &f->e);
87 g_assert (f->server != NULL);
89 dbus_server_set_new_connection_function (f->server,
91 dbus_server_setup_with_g_main (f->server, NULL);
103 dbus_server_get_address (f->server), &f->e);
219 g_error ("failed to steal fd from server connection");
227 /* Now spin on the client connection: the server just sent it complete
296 g_error ("failed to steal fd from server connection")
[all...] |
| /external/jacoco/org.jacoco.examples/src/org/jacoco/examples/ |
| ExecutionDataServer.java | 29 * This example starts a socket server to collect coverage from agents that run
35 private static final String DESTFILE = "jacoco-server.exec";
42 * Start the server as a standalone program.
50 final ServerSocket server = new ServerSocket(PORT, 0, local
53 final Handler handler = new Handler(server.accept(), fileWriter);
|
