/external/chromium_org/third_party/libevent/ |
H A D | evrpc.c | 379 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 D | httpserver.cc | 48 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 D | dbus.c | 261 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 D | asound_fm.h | 59 unsigned char connection; /* 0 for serial, 1 for parallel */ member in struct:snd_dm_fm_voice
|
/external/lldb/source/Core/ |
H A D | Communication.cpp | 92 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 D | HttpURLConnectionImpl.java | 63 * 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 D | RouteSelector.java | 42 * 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 D | SpdyStream.java | 49 * 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 D | HttpOverSpdyTest.java | 83 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 D | RouteSelectorTest.java | 114 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 D | adb-qemud.c | 40 /* 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 D | SDL_pulseaudio.c | 223 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 D | ShadowSQLiteDatabase.java | 32 * 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 D | SQLiteCursorTest.java | 25 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 D | BOSHConnection.java | 54 * 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 D | SASLAuthentication.java | 37 * 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 D | ServiceDiscoveryManager.java | 64 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 D | InBandBytestreamManager.java | 94 * 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 D | InBandBytestreamSession.java | 58 /* 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 D | Socks5BytestreamManager.java | 88 * 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 D | AdHocCommandManager.java | 72 * 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 D | EntityCapsManager.java | 92 * Map of Full JID -> 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 D | FileTransfer.java | 232 // 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 D | FileTransferNegotiator.java | 82 * 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 D | Node.java | 61 * 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.
|