Searched defs:connection (Results 201 - 225 of 329) sorted by relevance

1234567891011>>

/external/chromium_org/third_party/libevent/
H A Devrpc.c379 static int evrpc_schedule_request(struct evhttp_connection *connection,
411 struct evhttp_connection *connection; local
421 while ((connection = TAILQ_FIRST(&pool->connections)) != NULL) {
422 TAILQ_REMOVE(&pool->connections, connection, next);
423 evhttp_connection_free(connection);
438 * Add a connection to the RPC pool. A request scheduled on the pool
439 * may use any available connection.
444 struct evhttp_connection *connection) {
445 assert(connection->http_server == NULL);
446 TAILQ_INSERT_TAIL(&pool->connections, connection, nex
443 evrpc_pool_add_connection(struct evrpc_pool *pool, struct evhttp_connection *connection) argument
495 struct evhttp_connection *connection; local
508 evrpc_schedule_request(struct evhttp_connection *connection, struct evrpc_request_wrapper *ctx) argument
[all...]
/external/chromium_org/third_party/webrtc/base/
H A Dhttpserver.cc48 Connection* connection = new Connection(connection_id, this); local
49 connections_.insert(ConnectionMap::value_type(connection_id, connection));
50 connection->BeginProcess(stream);
57 if (Connection* connection = Find(connection_id)) {
58 connection->Respond(transaction);
62 // connection still exists.
68 if (Connection* connection = Find(connection_id)) {
69 connection->InitiateClose(force);
106 Connection* connection = it->second; local
108 SignalConnectionClosed(this, connection_id, connection
[all...]
/external/dnsmasq/src/
H A Ddbus.c261 DBusHandlerResult message_handler(DBusConnection *connection, argument
272 dbus_connection_send (connection, reply, NULL);
281 dbus_connection_send (connection, reply, NULL);
305 DBusConnection *connection = NULL; local
311 if (!(connection = dbus_bus_get (DBUS_BUS_SYSTEM, &dbus_error)))
314 dbus_connection_set_exit_on_disconnect(connection, FALSE);
315 dbus_connection_set_watch_functions(connection, add_watch, remove_watch,
318 dbus_bus_request_name (connection, DNSMASQ_SERVICE, 0, &dbus_error);
322 if (!dbus_connection_register_object_path(connection, DNSMASQ_PATH,
326 daemon->dbus = connection;
363 DBusConnection *connection = (DBusConnection *)daemon->dbus; local
395 DBusConnection *connection = (DBusConnection *)daemon->dbus; local
[all...]
/external/kernel-headers/original/uapi/sound/
H A Dasound_fm.h59 unsigned char connection; /* 0 for serial, 1 for parallel */ member in struct:snd_dm_fm_voice
/external/lldb/source/Core/
H A DCommunication.cpp92 error_ptr->SetErrorString("Invalid connection.");
106 // multi-threaded environments. So lets not nuke our connection class
109 // access the connection we have to take a lock.
139 "%p Communication::Read (dst = %p, dst_len = %" PRIu64 ", timeout = %u usec) connection = %p",
159 error_ptr->SetErrorString("Invalid connection.");
200 error_ptr->SetErrorString("Invalid connection.");
213 "%p Communication::Write (src = %p, src_len = %" PRIu64 ") connection = %p",
223 error_ptr->SetErrorString("Invalid connection.");
373 case eConnectionStatusNoConnection: // No connection
374 case eConnectionStatusLostConnection: // Lost connection whil
408 SetConnection(Connection *connection) argument
[all...]
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/
H A DHttpURLConnectionImpl.java63 * currently connected. Instead, it indicates whether a connection has ever been
64 * attempted. Once a connection has been attempted, certain properties (request
93 * connected yet, or if the most recent connection was HTTP (and not HTTPS).
111 // Calling disconnect() before a connection exists should have no effect.
121 // connection will close its streams directly. If it doesn't, the worst
188 "Cannot access request header fields after connection is set");
286 private HttpEngine newHttpEngine(String method, Connection connection, argument
315 return new HttpEngine(engineClient, request, bufferRequestBody, connection, null, requestBody,
369 Connection connection = httpEngine.close();
370 httpEngine = newHttpEngine(retryMethod, connection, (RetryableSin
[all...]
H A DRouteSelector.java42 * Selects routes to connect to an origin server. Each connection requires a
144 * failure on a connection returned by this route selector.
146 public void connectFailed(Connection connection, IOException failure) { argument
147 // If this is a recycled connection, don't count its failure against the route.
148 if (connection.recycleCount() > 0) return;
150 Route failedRoute = connection.getRoute();
152 // Tell the proxy selector when we fail to connect on a fresh connection.
196 // Try each of the ProxySelector choices until one connection succeeds. If none succeed
197 // then we'll try a direct connection below.
207 // Finally try a direct connection
[all...]
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/
H A DSpdyStream.java49 * available bytes in {@code connection.bytesLeftInWriteWindow}.
55 private final SpdyConnection connection; field in class:SpdyStream
75 SpdyStream(int id, SpdyConnection connection, boolean outFinished, boolean inFinished, argument
77 if (connection == null) throw new NullPointerException("connection == null");
80 this.connection = connection;
82 connection.peerSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE);
84 connection.okHttpSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE));
121 return connection
[all...]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/
H A DHttpOverSpdyTest.java83 protected HttpURLConnection connection; field in class:HttpOverSpdyTest
106 connection = client.open(server.getUrl("/foo"));
107 assertContent("ABCDE", connection, Integer.MAX_VALUE);
108 assertEquals(200, connection.getResponseCode());
109 assertEquals("Sweet", connection.getResponseMessage());
121 connection = client.open(server.getUrl("/foo"));
122 assertEquals(-1, connection.getInputStream().read());
133 connection = client.open(server.getUrl("/foo"));
134 connection.setDoOutput(true);
135 connection
429 assertContent(String expected, HttpURLConnection connection, int limit) argument
[all...]
H A DRouteSelectorTest.java114 Connection connection = routeSelector.next("GET");
116 routeDatabase.failed(connection.getRoute());
305 Connection connection = routeSelector.next("GET");
306 routeSelector.connectFailed(connection, new IOException("Non SSL exception"));
319 Connection connection = routeSelector.next("GET");
320 routeSelector.connectFailed(connection, new SSLHandshakeException("SSL exception"));
422 private void assertConnection(Connection connection, Address address, Proxy proxy, argument
424 assertEquals(address, connection.getRoute().getAddress());
425 assertEquals(proxy, connection.getRoute().getProxy());
426 assertEquals(socketAddress, connection
[all...]
/external/qemu/android/
H A Dadb-qemud.c40 /* Waiting on a connection from ADB host. */
82 * connection - An opaque pointer that identifies connection with the ADB host.
85 _adb_on_host_connected(void* opaque, void* connection) argument
91 adb_client, adb_client->opaque, connection);
102 D("Unexpected ADB host connection while state is %d", adb_client->state);
109 * connection - An opaque pointer that identifies connection with the ADB host.
112 _adb_on_host_disconnect(void* opaque, void* connection) argument
117 adb_client, adb_client->opaque, connection);
128 _adb_on_host_data(void* opaque, void* connection, const void* buff, int size) argument
[all...]
/external/qemu/distrib/sdl-1.2.15/src/audio/pulse/
H A DSDL_pulseaudio.c223 pa_simple *connection; local
235 connection = SDL_NAME(pa_simple_new)(
246 if ( connection != NULL ) {
248 SDL_NAME(pa_simple_free)(connection);
518 SDL_SetError("Could not setup connection to PulseAudio");
/external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/
H A DShadowSQLiteDatabase.java32 * Implemented as a wrapper around an embedded SQL database, accessed via JDBC. The JDBC connection is
38 private static Connection connection; field in class:ShadowSQLiteDatabase
67 connection = DatabaseConfig.getMemoryConnection();
94 PreparedStatement insert = connection.prepareStatement(sqlInsertString.sql, Statement.RETURN_GENERATED_KEYS);
128 Statement statement = connection.createStatement(DatabaseConfig.getResultSetType(), ResultSet.CONCUR_READ_ONLY);
158 PreparedStatement statement = connection.prepareStatement(sqlUpdateString.sql);
176 return connection.prepareStatement(sql).executeUpdate();
190 connection.createStatement().execute(scrubbedSql);
268 return (connection != null);
277 connection
[all...]
/external/robolectric/src/test/java/com/xtremelabs/robolectric/shadows/
H A DSQLiteCursorTest.java25 private Connection connection; field in class:SQLiteCursorTest
31 connection = DatabaseConfig.getMemoryConnection();
33 Statement statement = connection.createStatement();
44 connection.close();
214 PreparedStatement statement = connection.prepareStatement(sql);
234 PreparedStatement statement = connection.prepareStatement(sql);
335 connection.createStatement().executeUpdate(insert);
340 Statement statement = connection.createStatement(DatabaseConfig.getResultSetType(), ResultSet.CONCUR_READ_ONLY);
348 Statement statement = connection.createStatement();
/external/smack/src/org/jivesoftware/smack/
H A DBOSHConnection.java54 * Creates a connection to a XMPP server via HTTP binding.
78 * Holds the initial configuration used while creating the connection.
105 * The session ID for the BOSH session with the connection manager.
121 * Create a HTTP Binding connection to a XMPP server.
125 * @param host the hostname or IP address of the connection manager
127 * @param port the port of the connection manager
140 * Create a HTTP Binding connection to a XMPP server.
142 * @param config The configuration which is used for this connection.
224 String errorMessage = "Timeout reached for the connection to "
410 // If DEBUG_ENABLED was set to true AFTER the connection wa
693 private final BOSHConnection connection; field in class:BOSHConnection.BOSHConnectionListener
695 BOSHConnectionListener(BOSHConnection connection) argument
[all...]
H A DSASLAuthentication.java37 * to the connection and establishing a session with the server.</p>
39 * <p>Once TLS has been negotiated (i.e. the connection has been secured) it is possible to
51 * the connection. If no resource is passed in {@link #authenticate(String, String, String)}
52 * then the server will assign a resource for the connection. In case a resource is passed
54 * the connection.</p>
69 private Connection connection; field in class:SASLAuthentication
78 * the connection.
178 SASLAuthentication(Connection connection) { argument
180 this.connection = connection;
[all...]
/external/smack/src/org/jivesoftware/smackx/
H A DServiceDiscoveryManager.java64 private Connection connection; field in class:ServiceDiscoveryManager
70 // Create a new ServiceDiscoveryManager on every established connection
73 public void connectionCreated(Connection connection) {
74 new ServiceDiscoveryManager(connection);
82 * service manager will respond to any service discovery request that the connection may
85 * @param connection the connection to which a ServiceDiscoveryManager is going to be created.
87 public ServiceDiscoveryManager(Connection connection) { argument
88 this.connection = connection;
99 getInstanceFor(Connection connection) argument
[all...]
/external/smack/src/org/jivesoftware/smackx/bytestreams/ibb/
H A DInBandBytestreamManager.java94 * connection
98 public void connectionCreated(Connection connection) {
100 manager = InBandBytestreamManager.getByteStreamManager(connection);
103 connection.addConnectionListener(new AbstractConnectionListener() {
131 /* stores one InBandBytestreamManager for each XMPP connection */
134 /* XMPP connection */
135 private final Connection connection; field in class:InBandBytestreamManager
164 /* maximum block size allowed for this connection */
180 * @param connection the XMPP connection
183 getByteStreamManager(Connection connection) argument
199 InBandBytestreamManager(Connection connection) argument
[all...]
H A DInBandBytestreamSession.java58 /* XMPP connection */
59 private final Connection connection; field in class:InBandBytestreamSession
86 * @param connection the XMPP connection
90 protected InBandBytestreamSession(Connection connection, Open byteStreamRequest, argument
92 this.connection = connection;
174 this.connection.sendPacket(confirmClose);
210 SyncPacketSend.getReply(this.connection, close);
219 InBandBytestreamManager.getByteStreamManager(this.connection)
[all...]
/external/smack/src/org/jivesoftware/smackx/bytestreams/socks5/
H A DSocks5BytestreamManager.java88 * connection
93 public void connectionCreated(final Connection connection) {
95 manager = Socks5BytestreamManager.getBytestreamManager(connection);
98 connection.addConnectionListener(new AbstractConnectionListener() {
109 managers.put(connection, manager);
129 /* stores one Socks5BytestreamManager for each XMPP connection */
132 /* XMPP connection */
133 private final Connection connection; field in class:Socks5BytestreamManager
177 * @param connection the XMPP connection o
181 getBytestreamManager(Connection connection) argument
199 Socks5BytestreamManager(Connection connection) argument
[all...]
/external/smack/src/org/jivesoftware/smackx/commands/
H A DAdHocCommandManager.java72 * pair for every active connection.
78 * Register the listener for all the connection creations. When a new
79 * connection is created a new AdHocCommandManager is also created and
80 * related to that connection.
84 public void connectionCreated(Connection connection) {
85 new AdHocCommandManager(connection);
92 * <code>connection</code>.
94 * @param connection the XMPP connection.
95 * @return the AdHocCommandManager associated with the connection
97 getAddHocCommandsManager(Connection connection) argument
109 private Connection connection; field in class:AdHocCommandManager
127 AdHocCommandManager(Connection connection) argument
[all...]
/external/smack/src/org/jivesoftware/smackx/entitycaps/
H A DEntityCapsManager.java92 * Map of Full JID -&gt; DiscoverInfo/null. In case of c2s connection the
94 * link-local connection the key is formed as user@host (no resource) In
101 public void connectionCreated(Connection connection) {
102 if (connection instanceof XMPPConnection)
103 new EntityCapsManager(connection);
225 private EntityCapsManager(Connection connection) { argument
226 this.weakRefConnection = new WeakReference<Connection>(connection);
227 this.sdm = ServiceDiscoveryManager.getInstanceFor(connection);
232 Connection connection = weakRefConnection.get();
233 instances.put(connection, thi
330 getInstanceFor(Connection connection) argument
[all...]
/external/smack/src/org/jivesoftware/smackx/filetransfer/
H A DFileTransfer.java232 // the connection was likely terminated abrubtly if these are not equal
236 this.error = Error.connection;
346 * The remote user did not respond or the connection timed out.
348 no_response("The remote user did not respond or the connection timed out."),
353 connection("An error occured over the socket connected to send the file."), enum constant in enum:FileTransfer.Error
H A DFileTransferNegotiator.java82 * Returns the file transfer negotiator related to a particular connection.
83 * When this class is requested on a particular connection the file transfer
86 * @param connection The connection for which the transfer manager is desired
90 final Connection connection) {
91 if (connection == null) {
94 if (!connection.isConnected()) {
98 if (transferObject.containsKey(connection)) {
99 return transferObject.get(connection);
103 connection);
89 getInstanceFor( final Connection connection) argument
117 setServiceEnabled(final Connection connection, final boolean isEnabled) argument
148 isServiceEnabled(final Connection connection) argument
207 private final Connection connection; field in class:FileTransferNegotiator
213 FileTransferNegotiator(final Connection connection) argument
221 configureConnection(final Connection connection) argument
245 cleanup(final Connection connection) argument
[all...]
/external/smack/src/org/jivesoftware/smackx/pubsub/
H A DNode.java61 * Construct a node associated to the supplied connection with the specified
64 * @param connection The connection the node is associated with
67 Node(Connection connection, String nodeName) argument
69 con = connection;
151 * bare jid portion of this one must match the jid for the connection.
174 * connection.

Completed in 4183 milliseconds

1234567891011>>