/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
H A D | HttpConnection.java | 44 * 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 D | HttpEngine.java | 78 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 D | JavaApiConverterTest.java | 115 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 D | Roster.java | 59 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 D | dbus_new_helpers.c | 362 * @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 D | ChildProcessLauncher.java | 63 // 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 D | ImeTest.java | 756 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 D | object_proxy.cc | 455 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 D | bluetooth_low_energy_event_router.cc | 133 << "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 D | view_manager_service_impl.cc | 270 // 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 D | mdns_client_impl.cc | 56 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 D | http_stream_factory_impl_unittest.cc | 246 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 D | http_stream_parser.cc | 178 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 D | quic_session.cc | 102 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 D | web_socket.cc | 48 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 D | spdy_interface.cc | 35 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 D | websocket_basic_handshake_stream.cc | 345 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 D | file_io_resource.cc | 106 FileIOResource::FileIOResource(Connection connection, PP_Instance instance) argument 107 : PluginResource(connection, instance),
|
H A D | ppapi_proxy_test.cc | 291 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 D | chromoting_host_unittest.cc | 184 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 D | SpdyConnectionTest.java | 75 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 D | VCard.java | 76 * 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 D | AgentSession.java | 57 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 D | indexed_db_database.cc | 40 // 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 D | indexed_db_dispatcher_host.cc | 159 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...] |