Searched defs:connection (Results 251 - 275 of 329) sorted by relevance

<<11121314

/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/
H A DHttpConnection.java44 * A socket connection that can be used to send HTTP/1.1 messages. This class
75 private final Connection connection; field in class:HttpConnection
83 public HttpConnection(ConnectionPool pool, Connection connection, Socket socket) argument
86 this.connection = connection;
93 * Configure this connection to put itself back into the connection pool when
102 pool.recycle(connection);
107 * Configure this connection to close itself when the HTTP response body is
116 connection
[all...]
H A DHttpEngine.java78 private Connection connection; field in class:HttpEngine
151 * @param connection the connection used for an intermediate response
153 * redirect. This engine assumes ownership of the connection and must
160 Connection connection, RouteSelector routeSelector, RetryableSink requestBodyOut,
165 this.connection = connection;
170 if (connection != null) {
171 connection.setOwner(this);
172 this.route = connection
159 HttpEngine(OkHttpClient client, Request request, boolean bufferRequestBody, Connection connection, RouteSelector routeSelector, RetryableSink requestBodyOut, Response priorResponse) argument
[all...]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/
H A DJavaApiConverterTest.java115 private HttpURLConnection connection; field in class:JavaApiConverterTest
123 if (connection != null) {
124 connection.disconnect();
165 connection = httpUrlConnectionFactory.open(serverUrl);
167 HttpsURLConnection httpsUrlConnection = (HttpsURLConnection) connection;
171 connection.setRequestProperty("snake", "bird");
172 connection.connect();
173 Response response = JavaApiConverter.createOkResponse(serverUrl.toURI(), connection);
193 HttpsURLConnection httpsURLConnection = (HttpsURLConnection) connection;
/external/smack/src/org/jivesoftware/smack/
H A DRoster.java59 private Connection connection; field in class:Roster
98 Roster(final Connection connection, RosterStorage persistentStorage){ argument
99 this(connection);
106 * @param connection an XMPP connection.
108 Roster(final Connection connection) { argument
109 this.connection = connection;
111 if(!connection.getConfiguration().isRosterVersioningAvailable()){
121 connection
[all...]
/external/wpa_supplicant_8/wpa_supplicant/dbus/
H A Ddbus_new_helpers.c362 * @connection: DBus connection on which message was received
375 static DBusHandlerResult message_handler(DBusConnection *connection, argument
420 dbus_connection_send(connection, reply, NULL);
424 wpa_dbus_flush_all_changed_properties(connection);
432 * @connection: DBus connection
453 static void free_dbus_object_desc_cb(DBusConnection *connection, void *obj_dsc) argument
481 obj_desc->connection = iface->con;
550 obj_desc->connection
[all...]
/external/chromium_org/content/public/android/java/src/org/chromium/content/browser/
H A DChildProcessLauncher.java63 // unbound for a short time. If a new connection to the same service is bound at that point,
103 Log.d(TAG, "Allocator allocated a connection, sandbox: " + mInSandbox +
109 public void free(ChildProcessConnection connection) { argument
111 int slot = connection.getServiceNumber();
112 if (mChildProcessConnections[slot] != connection) {
115 Log.e(TAG, "Unable to find connection to free in slot: " + slot +
122 Log.d(TAG, "Allocator freed a connection, sandbox: " + mInSandbox +
150 // We should guarantee this is called before allocating connection.
166 public void onChildProcessDied(ChildProcessConnection connection) {
167 if (connection
214 freeConnection(ChildProcessConnection connection) argument
394 triggerConnectionSetup( final ChildProcessConnection connection, String[] commandLine, int childProcessId, FileDescriptorInfo[] filesToBeMapped, int callbackType, final long clientContext) argument
[all...]
/external/chromium_org/content/public/android/javatests/src/org/chromium/content/browser/input/
H A DImeTest.java756 private void expectUpdateStateCall(final TestAdapterInputConnection connection) { argument
757 connection.mImeUpdateQueue.clear();
760 private void assertUpdateStateCall(final TestAdapterInputConnection connection, int maxms) argument
762 while (connection.mImeUpdateQueue.size() == 0 && maxms > 0) {
770 assertTrue(connection.mImeUpdateQueue.size() > 0);
846 private void commitText(final AdapterInputConnection connection, final CharSequence text, argument
851 connection.commitText(text, newCursorPosition);
856 private void setSelection(final AdapterInputConnection connection, final int start, argument
861 connection.setSelection(start, end);
866 private void setComposingRegion(final AdapterInputConnection connection, fina argument
876 setComposingText(final AdapterInputConnection connection, final CharSequence text, final int newCursorPosition) argument
886 finishComposingText(final AdapterInputConnection connection) argument
895 deleteSurroundingText(final AdapterInputConnection connection, final int before, final int after) argument
[all...]
/external/chromium_org/dbus/
H A Dobject_proxy.cc455 DBusConnection* connection,
549 DBusConnection* connection,
553 return self->HandleMessage(connection, raw_message);
454 HandleMessage( DBusConnection* connection, DBusMessage* raw_message) argument
548 HandleMessageThunk( DBusConnection* connection, DBusMessage* raw_message, void* user_data) argument
/external/chromium_org/extensions/browser/api/bluetooth_low_energy/
H A Dbluetooth_low_energy_event_router.cc133 << "There is no Bluetooth low energy connection manager. "
237 // There is a connection object but it's no longer active. Simply remove it.
1233 scoped_ptr<BluetoothGattConnection> connection) {
1234 VLOG(2) << "GATT connection created.";
1235 DCHECK(connection.get());
1237 DCHECK_EQ(device_address, connection->GetDeviceAddress());
1243 persistent, extension_id, connection.Pass());
1256 VLOG(2) << "GATT connection terminated.";
1262 VLOG(1) << "The connection was removed before disconnect completed, id: "
1281 VLOG(2) << "Failed to create GATT connection
1228 OnCreateGattConnection( bool persistent, const std::string& extension_id, const std::string& device_address, const base::Closure& callback, scoped_ptr<BluetoothGattConnection> connection) argument
[all...]
/external/chromium_org/mojo/services/view_manager/
H A Dview_manager_service_impl.cc270 // This connection no longer knows about the view. Unparent any views that
367 ViewManagerServiceImpl* connection = local
369 success = connection && connection->DeleteViewImpl(this, view);
494 // Only allow a node to be the root for one connection.
502 // Never message the originating connection.
521 ViewManagerServiceImpl* connection = local
523 if (!connection)
524 connection = connection_manager_->GetConnection(view_id.connection_id);
525 if (connection) {
558 ViewManagerServiceImpl* connection = local
[all...]
/external/chromium_org/net/dns/
H A Dmdns_client_impl.cc56 MDnsConnection* connection)
58 connection_(connection),
185 // in the connection.
324 // TODO(noamsml): On connection error, recreate connection and flush cache.
54 SocketHandler( scoped_ptr<DatagramServerSocket> socket, MDnsConnection* connection) argument
/external/chromium_org/net/http/
H A Dhttp_stream_factory_impl_unittest.cc246 scoped_ptr<ClientSocketHandle> connection)
248 connection_(connection.Pass()) {}
254 ClientSocketHandle* connection() { return connection_.get(); } function in class:net::__anon9322::WebSocketBasicHandshakeStream
266 scoped_ptr<ClientSocketHandle> connection,
268 return new WebSocketBasicHandshakeStream(connection.Pass());
593 // First connection attempt fails
598 // Second connection attempt succeeds
1297 // Make sure that there was an alternative connection
245 WebSocketBasicHandshakeStream( scoped_ptr<ClientSocketHandle> connection) argument
H A Dhttp_stream_parser.cc178 HttpStreamParser::HttpStreamParser(ClientSocketHandle* connection, argument
194 connection_(connection),
310 // connection is closed after seeing just a 1xx response code.
643 // When the connection is closed, there are numerous ways to interpret it.
646 // number of bytes at connection close, the response is successful.
649 // than promised by the header at connection close, it may indicate that
650 // the connection was closed prematurely, or it may indicate that the
659 // when the connection is closed, the response is successful.
662 // processed when the connection is closed, it may indicate that the
663 // connection wa
[all...]
/external/chromium_org/net/quic/
H A Dquic_session.cc102 QuicSession::QuicSession(QuicConnection* connection, const QuicConfig& config) argument
103 : connection_(connection),
202 connection()->SendConnectionCloseWithDetails(
208 connection()->SendConnectionCloseWithDetails(
217 // update the connection level flow controller if needed.
258 // This is a window update that applies to the connection, rather than an
261 << "Received connection level flow control window update with "
302 // cause the connection to request resumption before yielding to other
306 // If we are connection level flow control blocked, then only allow the
349 // they don't get blocked by connection leve
[all...]
/external/chromium_org/net/server/
H A Dweb_socket.cc48 HttpConnection* connection,
51 if (connection->read_buf()->GetSize() <
54 return new WebSocketHixie76(server, connection, request, pos);
118 HttpConnection* connection,
121 : WebSocket(server, connection) {
127 connection->id(),
136 connection->id(),
143 key3_.assign(connection->read_buf()->StartOfBuffer() + *pos,
183 HttpConnection* connection,
193 connection
47 Create(HttpServer* server, HttpConnection* connection, const HttpServerRequestInfo& request, size_t* pos) argument
117 WebSocketHixie76(HttpServer* server, HttpConnection* connection, const HttpServerRequestInfo& request, size_t* pos) argument
182 Create(HttpServer* server, HttpConnection* connection, const HttpServerRequestInfo& request, size_t* pos) argument
241 WebSocketHybi17(HttpServer* server, HttpConnection* connection, const HttpServerRequestInfo& request, size_t* pos) argument
274 CreateWebSocket(HttpServer* server, HttpConnection* connection, const HttpServerRequestInfo& request, size_t* pos) argument
418 WebSocket(HttpServer* server, HttpConnection* connection) argument
[all...]
/external/chromium_org/net/tools/flip_server/
H A Dspdy_interface.cc35 SpdySM::SpdySM(SMConnection* connection, argument
43 connection_(connection),
44 client_output_list_(connection->output_list()),
45 client_output_ordering_(connection),
64 VLOG(2) << ACCEPTOR_CLIENT_IDENT << "SpdySM: Initializing server connection.";
83 LOG(ERROR) << "SpdySM: Could not create server connection";
102 << "SpdySM: Making new server connection on index: " << server_idx;
107 VLOG(2) << ACCEPTOR_CLIENT_IDENT << "SpdySM: Reusing connection on "
/external/chromium_org/net/websockets/
H A Dwebsocket_basic_handshake_stream.cc345 scoped_ptr<ClientSocketHandle> connection,
351 : state_(connection.release(), using_proxy),
476 return state_.connection()->GetLoadTimingInfo(IsConnectionReused(),
506 WebSocketTransportClientSocketPool::UnlockEndpoint(state_.connection());
551 // Most net errors happen during connection, so they are not seen by this
344 WebSocketBasicHandshakeStream( scoped_ptr<ClientSocketHandle> connection, WebSocketStream::ConnectDelegate* connect_delegate, bool using_proxy, std::vector<std::string> requested_sub_protocols, std::vector<std::string> requested_extensions, std::string* failure_message) argument
/external/chromium_org/ppapi/proxy/
H A Dfile_io_resource.cc106 FileIOResource::FileIOResource(Connection connection, PP_Instance instance) argument
107 : PluginResource(connection, instance),
H A Dppapi_proxy_test.cc291 Connection connection,
290 CreateBrowserFont( Connection connection, PP_Instance instance, const PP_BrowserFont_Trusted_Description& desc, const Preferences& prefs) argument
/external/chromium_org/remoting/host/
H A Dchromoting_host_unittest.cc184 scoped_ptr<protocol::ConnectionToClient> connection = local
187 protocol::ConnectionToClient* connection_ptr = connection.get();
196 connection.Pass(),
375 MockConnectionToClient* connection = get_connection(connection_index); local
378 EXPECT_CALL(*connection, Disconnect())
437 scoped_ptr<MockSession> session_unowned1_; // Not owned by a connection.
440 scoped_ptr<MockSession> session_unowned2_; // Not owned by a connection.
524 // When a video packet is received on the first connection, disconnect it,
532 // When a video packet is received on the second connection, shut down the
550 // When a video packet is received, connect the second connection
[all...]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/
H A DSpdyConnectionTest.java75 SpdyConnection connection = connection(peer, SPDY3);
76 SpdyStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
82 assertEquals(0, connection.openStreamCount());
102 SpdyConnection connection = connection(peer, SPDY3);
103 SpdyStream stream = connection.newStream(headerEntries("a", "android"), false, false);
104 assertEquals(1, connection.openStreamCount());
106 assertEquals(0, connection.openStreamCount());
118 SpdyConnection connection
1556 private SpdyConnection connection(MockSpdyPeer peer, Variant variant) throws IOException { method in class:SpdyConnectionTest
[all...]
/external/smack/src/org/jivesoftware/smackx/packet/
H A DVCard.java76 * vCard.save(connection);
505 * Save this vCard for the user connected by 'connection'. Connection should be authenticated
510 * @param connection the Connection to use.
513 public void save(Connection connection) throws XMPPException { argument
514 checkAuthenticated(connection, true);
517 setFrom(connection.getUser());
518 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(getPacketID()));
519 connection.sendPacket(this);
537 public void load(Connection connection) throws XMPPException { argument
538 checkAuthenticated(connection, tru
547 load(Connection connection, String user) argument
554 doLoad(Connection connection, String user) argument
602 checkAuthenticated(Connection connection, boolean checkForAnonymous) argument
[all...]
/external/smack/src/org/jivesoftware/smackx/workgroup/agent/
H A DAgentSession.java57 private Connection connection; field in class:AgentSession
83 * @param connection a connection instance which must have already gone through
87 public AgentSession(String workgroupJID, Connection connection) { argument
88 // Login must have been done before passing in connection.
89 if (!connection.isAuthenticated()) {
94 this.connection = connection;
95 this.transcriptManager = new TranscriptManager(connection);
96 this.transcriptSearchManager = new TranscriptSearchManager(connection);
[all...]
/external/chromium_org/content/browser/indexed_db/
H A Dindexed_db_database.cc40 // in-progress connection.
44 scoped_ptr<IndexedDBConnection> connection,
48 connection_(connection.Pass()),
52 // Takes ownership of the connection object.
66 // PendingSuccessCall has a IndexedDBConnection* because the connection is now
67 // owned elsewhere, but we need to cancel the success call if that connection
72 IndexedDBConnection* connection,
74 : callbacks_(callbacks), connection_(connection), version_(version) {}
76 IndexedDBConnection* connection() const { return connection_; } function in class:content::IndexedDBDatabase::PendingSuccessCall
200 scoped_ptr<IndexedDBConnection> connection(
43 PendingUpgradeCall(scoped_refptr<IndexedDBCallbacks> callbacks, scoped_ptr<IndexedDBConnection> connection, int64 transaction_id, int64 version) argument
71 PendingSuccessCall(scoped_refptr<IndexedDBCallbacks> callbacks, IndexedDBConnection* connection, int64 version) argument
1316 VersionChangeOperation( int64 version, scoped_refptr<IndexedDBCallbacks> callbacks, scoped_ptr<IndexedDBConnection> connection, IndexedDBTransaction* transaction) argument
1365 scoped_ptr<IndexedDBConnection> connection; local
1458 CreateTransaction( int64 transaction_id, IndexedDBConnection* connection, const std::vector<int64>& object_store_ids, blink::WebIDBTransactionMode mode) argument
1490 OpenConnection( const IndexedDBPendingConnection& connection) argument
1584 RunVersionChangeTransaction( scoped_refptr<IndexedDBCallbacks> callbacks, scoped_ptr<IndexedDBConnection> connection, int64 transaction_id, int64 requested_version) argument
1615 RunVersionChangeTransactionFinal( scoped_refptr<IndexedDBCallbacks> callbacks, scoped_ptr<IndexedDBConnection> connection, int64 transaction_id, int64 requested_version) argument
1691 IndexedDBConnection* connection = *it++; local
1710 Close(IndexedDBConnection* connection, bool forced) argument
[all...]
H A Dindexed_db_dispatcher_host.cc159 int32 IndexedDBDispatcherHost::Add(IndexedDBConnection* connection, argument
163 connection->Close();
164 delete connection;
167 int32 ipc_database_id = database_dispatcher_host_->map_.Add(connection);
168 Context()->ConnectionOpened(origin_url, connection);
315 IndexedDBPendingConnection connection(callbacks,
322 params.name, connection, request_context_, origin_url, indexed_db_path);
443 IndexedDBConnection* connection = map_.Lookup(ipc_database_id); local
444 if (connection && connection
455 IndexedDBConnection* connection = map_.Lookup(iter->first); local
506 IndexedDBConnection* connection = local
531 IndexedDBConnection* connection = local
544 IndexedDBConnection* connection = local
568 IndexedDBConnection* connection = local
579 IndexedDBConnection* connection = local
590 IndexedDBConnection* connection = map_.Lookup(ipc_object_id); local
603 IndexedDBConnection* connection = local
643 IndexedDBConnection* connection = local
700 IndexedDBConnection* connection = local
720 IndexedDBConnection* connection = local
733 IndexedDBConnection* connection = local
755 IndexedDBConnection* connection = local
774 IndexedDBConnection* connection = local
796 IndexedDBConnection* connection = local
813 IndexedDBConnection* connection = local
826 IndexedDBConnection* connection = local
849 IndexedDBConnection* connection = local
877 IndexedDBConnection* connection = local
[all...]

Completed in 3694 milliseconds

<<11121314