/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
H A D | ConnectionPool.java | 45 * connection alive in the pool before closing it. Default is 5 minutes. 120 // See whether we should continue checking the connection pool. 148 Connection connection = i.previous(); 149 if (!connection.isAlive() || connection.isExpired(keepAliveDurationNs)) { 151 expiredConnections.add(connection); 153 } else if (connection.isIdle()) { 160 Connection connection = i.previous(); 161 if (connection.isIdle()) { 162 expiredConnections.add(connection); 273 recycle(Connection connection) argument 309 share(Connection connection) argument [all...] |
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
H A D | ResponseCacheAdapterTest.java | 75 private HttpURLConnection connection; field in class:ResponseCacheAdapterTest 83 if (connection != null) { 84 connection.disconnect(); 105 connection = client.open(serverUrl); 106 connection.setRequestProperty("key1", "value1"); 108 executeGet(connection); 131 connection = client.open(serverUrl); 132 connection.setRequestProperty("key1", "value1"); 134 executeGet(connection); 172 connection 251 executeGet(HttpURLConnection connection) argument 257 executePost(HttpURLConnection connection) argument [all...] |
/external/qemu/distrib/sdl-1.2.15/src/audio/esd/ |
H A D | SDL_esdaudio.c | 122 int connection; local 129 connection = SDL_NAME(esd_open_sound)(NULL); 130 if ( connection >= 0 ) { 132 SDL_NAME(esd_close)(connection); 298 /* Open a connection to the ESD audio server */ 301 SDL_SetError("Couldn't open ESD connection");
|
/external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/ |
H A D | ShadowSQLiteCursor.java | 228 private void fillRows(String sql, Connection connection) throws SQLException { argument 231 Statement statement = connection.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
|
/external/smack/src/org/jivesoftware/smack/ |
H A D | ChatManager.java | 96 private Connection connection; field in class:ChatManager 98 ChatManager(Connection connection) { argument 99 this.connection = connection; 113 connection.addPacketListener(new PacketListener() { 260 message.setFrom(connection.getUser()); 262 connection.sendPacket(message); 266 return connection.createPacketCollector(new AndFilter(new ThreadFilter(chat.getThreadID()),
|
H A D | PrivacyListManager.java | 49 private Connection connection;
field in class:PrivacyListManager 55 // Create a new PrivacyListManager on every established connection. In the init()
57 // instance when the connection is closed.
59 public void connectionCreated(Connection connection) {
60 new PrivacyListManager(connection);
69 * @param connection the XMPP connection.
71 private PrivacyListManager(Connection connection) {
argument 72 this.connection = connection;
164 getInstanceFor(Connection connection) argument [all...] |
/external/smack/src/org/jivesoftware/smack/util/ |
H A D | PacketParserUtils.java | 282 public static IQ parseIQ(XmlPullParser parser, Connection connection) throws Exception { argument 359 connection.sendPacket(iqPacket); 585 * exception will shut down the entire connection. ClassCastExceptions will occur
|
/external/smack/src/org/jivesoftware/smackx/ |
H A D | ChatStateManager.java | 42 * needs to be called in order for the listeners to be registered appropriately with the connection. 61 * @param connection the connection to return the ChatStateManager 62 * @return the ChatStateManager related the the connection. 64 public static ChatStateManager getInstance(final Connection connection) { argument 65 if(connection == null) { 69 ChatStateManager manager = managers.get(connection); 71 manager = new ChatStateManager(connection); 73 managers.put(connection, manager); 80 private final Connection connection; field in class:ChatStateManager 92 ChatStateManager(Connection connection) argument [all...] |
H A D | Gateway.java | 33 private Connection connection; field in class:Gateway 41 Gateway(Connection connection, String entityJID){ argument 42 this.connection = connection; 43 this.roster = connection.getRoster(); 44 this.sdManager = ServiceDiscoveryManager.getInstanceFor(connection); 48 Gateway(Connection connection, String entityJID, DiscoverInfo info, Identity identity){ argument 49 this(connection, entityJID); 82 packet.setFrom(connection.getUser()); 86 connection [all...] |
/external/smack/src/org/jivesoftware/smackx/filetransfer/ |
H A D | FaultTolerantNegotiator.java | 47 private Connection connection; field in class:FaultTolerantNegotiator 51 public FaultTolerantNegotiator(Connection connection, StreamNegotiator primary, argument 55 this.connection = connection; 71 final Packet initiateIncomingStream(Connection connection, StreamInitiation initiation) { argument 77 PacketCollector collector = connection.createPacketCollector( 80 connection.sendPacket(super.createInitiationAccept(initiation, getNamespaces()));
|
/external/smack/src/org/jivesoftware/smackx/muc/ |
H A D | RoomListenerMultiplexor.java | 47 // connection is no longer referenced by any object. 51 private Connection connection; field in class:RoomListenerMultiplexor 56 * Returns a new or existing RoomListenerMultiplexor for a given connection. 58 * @param conn the connection to monitor for room invitations. 59 * @return a new or existing RoomListenerMultiplexor for a given connection. 70 // connection and this could prevent the GC from collecting the monitor 74 // Return the InvitationsMonitor that monitors the connection 83 private RoomListenerMultiplexor(Connection connection, RoomMultiplexFilter filter, argument 85 if (connection == null) { 94 this.connection [all...] |
/external/smack/src/org/jivesoftware/smackx/ping/ |
H A D | PingManager.java | 68 public void connectionCreated(Connection connection) { 69 new PingManager(connection); 75 private Connection connection; field in class:PingManager 91 private PingManager(Connection connection) { argument 92 ServiceDiscoveryManager sdm = ServiceDiscoveryManager.getInstanceFor(connection); 94 this.connection = connection; 101 connection.addPacketListener(new PacketListener() { 116 connection.sendPacket(pong); 120 connection 149 getInstanceFor(Connection connection) argument [all...] |
/external/smack/src/org/jivesoftware/smackx/workgroup/agent/ |
H A D | AgentRoster.java | 53 private Connection connection;
field in class:AgentRoster 65 * @param connection an XMPP connection.
67 AgentRoster(Connection connection, String workgroupJID) {
argument 68 this.connection = connection;
75 connection.addPacketListener(new AgentStatusListener(), rosterFilter);
77 connection.addPacketListener(new PresencePacketListener(),
83 connection.sendPacket(request);
94 connection [all...] |
H A D | Offer.java | 40 private Connection connection;
field in class:Offer 57 * @param conn the XMPP connection with which the issuing session was created.
72 this.connection = conn;
88 connection.sendPacket(acceptPacket);
98 connection.sendPacket(rejectPacket);
|
/external/chromium_org/content/browser/indexed_db/ |
H A D | indexed_db_factory_impl.cc | 415 const IndexedDBPendingConnection& connection, 440 connection.callbacks->OnError( 451 connection.callbacks->OnError(error); 467 connection.callbacks->OnError(error); 479 connection.callbacks->OnDataLoss(data_loss, data_loss_message); 481 database->OpenConnection(connection); 414 Open(const base::string16& name, const IndexedDBPendingConnection& connection, net::URLRequestContext* request_context, const GURL& origin_url, const base::FilePath& data_directory) argument
|
H A D | indexed_db_transaction.h | 77 IndexedDBDatabaseCallbacks* connection() const { return callbacks_.get(); } function in class:content::IndexedDBTransaction
|
/external/chromium_org/content/browser/renderer_host/pepper/ |
H A D | pepper_renderer_connection.cc | 36 BrowserMessageFilter* connection, 65 BrowserMessageFilter* connection, 70 connection_(connection), 64 PendingHostCreator(BrowserPpapiHostImpl* host, BrowserMessageFilter* connection, int routing_id, int sequence_id, size_t nested_msgs_size) argument
|
/external/chromium_org/content/child/ |
H A D | browser_font_resource_trusted.cc | 11 #include "ppapi/proxy/connection.h" 250 ppapi::proxy::Connection connection, 254 : PluginResource(connection, instance), 249 BrowserFontResource_Trusted( ppapi::proxy::Connection connection, PP_Instance instance, const PP_BrowserFont_Trusted_Description& desc, const ppapi::Preferences& prefs) argument
|
/external/chromium_org/content/public/android/java/src/org/chromium/content/browser/ |
H A D | BindingManagerImpl.java | 35 * bindings of the connection. The reference to ChildProcessConnection is cleared when the 36 * connection goes away, but ManagedConnection itself is kept (until overwritten by a new entry 56 final ChildProcessConnection connection = mConnection; 57 if (connection == null || !connection.isInitialBindingBound()) return; 62 if (connection.isInitialBindingBound()) { 63 connection.removeInitialBinding(); 71 ChildProcessConnection connection = mConnection; 72 if (connection == null) return; 74 connection 114 ManagedConnection(ChildProcessConnection connection) argument 210 addNewConnection(int pid, ChildProcessConnection connection) argument [all...] |
/external/chromium_org/dbus/ |
H A D | exported_object.cc | 178 DBusConnection* connection, 294 void ExportedObject::OnUnregistered(DBusConnection* connection) { argument 298 DBusConnection* connection, 302 return self->HandleMessage(connection, raw_message); 305 void ExportedObject::OnUnregisteredThunk(DBusConnection *connection, argument 308 return self->OnUnregistered(connection); 177 HandleMessage( DBusConnection* connection, DBusMessage* raw_message) argument 297 HandleMessageThunk( DBusConnection* connection, DBusMessage* raw_message, void* user_data) argument
|
/external/chromium_org/extensions/browser/api/hid/ |
H A D | hid_api.cc | 35 scoped_refptr<HidConnection> connection) { 154 scoped_refptr<HidConnection> connection = local 156 if (!connection.get()) { 161 new HidConnectionResource(extension_->id(), connection)); 162 SetResult(PopulateHidConnection(connection_id, connection)); 207 scoped_refptr<device::HidConnection> connection = resource->connection(); local 208 connection->Read(base::Bind(&HidReceiveFunction::OnFinished, this)); 254 resource->connection()->Write( 285 scoped_refptr<device::HidConnection> connection local 34 PopulateHidConnection(int connection_id, scoped_refptr<HidConnection> connection) argument [all...] |
/external/chromium_org/mojo/services/view_manager/ |
H A D | connection_manager.cc | 17 ViewManagerServiceImpl* connection, 21 connection_id_(connection->id()), 57 void ConnectionManager::AddConnection(ViewManagerServiceImpl* connection) { argument 58 DCHECK_EQ(0u, connection_map_.count(connection->id())); 59 connection_map_[connection->id()] = connection; 62 void ConnectionManager::RemoveConnection(ViewManagerServiceImpl* connection) { argument 63 connection_map_.erase(connection->id()); 64 connections_created_by_connect_.erase(connection); 70 i->second->OnViewManagerServiceImplDestroyed(connection 16 ScopedChange( ViewManagerServiceImpl* connection, ConnectionManager* connection_manager, bool is_delete_view) argument 84 ViewManagerServiceImpl* connection = GetConnection(kWindowManagerConnection); local 136 ViewManagerServiceImpl* connection = GetConnection(kWindowManagerConnection); local 225 ViewManagerServiceImpl* connection = local [all...] |
/external/chromium_org/mojo/services/window_manager/ |
H A D | window_manager_app.cc | 134 void WindowManagerApp::AddConnection(WindowManagerServiceImpl* connection) { argument 135 DCHECK(connections_.find(connection) == connections_.end()); 136 connections_.insert(connection); 139 void WindowManagerApp::RemoveConnection(WindowManagerServiceImpl* connection) { argument 140 DCHECK(connections_.find(connection) != connections_.end()); 141 connections_.erase(connection); 176 ApplicationConnection* connection) { 177 connection->AddService(&window_manager_service_factory_); 178 connection->AddService(view_manager_client_factory_.get()); 175 ConfigureIncomingConnection( ApplicationConnection* connection) argument
|
/external/chromium_org/net/quic/ |
H A D | quic_dispatcher.cc | 70 DLOG(DFATAL) << "Version mismatch, connection ID (" << connection_id_ 160 QuicConnection* connection) { 161 return new QuicPerConnectionPacketWriter(writer, connection); 171 QuicConnection* connection) const { 174 connection); 236 // session for it. All initial packets for a new connection are required to 268 session->connection()->ProcessUdpPacket( 286 QuicConnection* connection = it->second->connection(); local 288 connection 158 Create( QuicServerPacketWriter* writer, QuicConnection* connection) argument [all...] |
/external/chromium_org/net/quic/test_tools/ |
H A D | quic_connection_peer.cc | 21 void QuicConnectionPeer::SendAck(QuicConnection* connection) { argument 22 connection->SendAck(); 27 QuicConnection* connection, 29 connection->received_packet_manager_.receive_algorithm_.reset( 35 QuicConnection* connection, 37 connection->sent_packet_manager_.send_algorithm_.reset(send_algorithm); 41 QuicAckFrame* QuicConnectionPeer::CreateAckFrame(QuicConnection* connection) { argument 42 return connection->CreateAckFrame(); 47 QuicConnection* connection) { 48 return connection 26 SetReceiveAlgorithm( QuicConnection* connection, ReceiveAlgorithmInterface* receive_algorithm) argument 34 SetSendAlgorithm( QuicConnection* connection, SendAlgorithmInterface* send_algorithm) argument 46 CreateStopWaitingFrame( QuicConnection* connection) argument 52 GetVisitor( QuicConnection* connection) argument 58 GetPacketCreator( QuicConnection* connection) argument 65 GetPacketGenerator( QuicConnection* connection) argument 71 GetSentPacketManager( QuicConnection* connection) argument 77 GetReceivedPacketManager( QuicConnection* connection) argument 83 GetNetworkTimeout( QuicConnection* connection) argument 89 IsSavedForRetransmission( QuicConnection* connection, QuicPacketSequenceNumber sequence_number) argument 98 IsRetransmission( QuicConnection* connection, QuicPacketSequenceNumber sequence_number) argument 107 GetSentEntropyHash( QuicConnection* connection, QuicPacketSequenceNumber sequence_number) argument 118 PacketEntropy( QuicConnection* connection, QuicPacketSequenceNumber sequence_number) argument 125 ReceivedEntropyHash( QuicConnection* connection, QuicPacketSequenceNumber sequence_number) argument 133 IsServer(QuicConnection* connection) argument 138 SetIsServer(QuicConnection* connection, bool is_server) argument 145 SetSelfAddress(QuicConnection* connection, const IPEndPoint& self_address) argument 151 SetPeerAddress(QuicConnection* connection, const IPEndPoint& peer_address) argument 157 SwapCrypters(QuicConnection* connection, QuicFramer* framer) argument 163 GetHelper( QuicConnection* connection) argument 169 GetFramer(QuicConnection* connection) argument 174 GetFecGroup(QuicConnection* connection, int fec_group) argument 181 GetAckAlarm(QuicConnection* connection) argument 186 GetPingAlarm(QuicConnection* connection) argument 191 GetResumeWritesAlarm( QuicConnection* connection) argument 197 GetRetransmissionAlarm( QuicConnection* connection) argument 203 GetSendAlarm(QuicConnection* connection) argument 208 GetTimeoutAlarm(QuicConnection* connection) argument 213 GetWriter(QuicConnection* connection) argument 218 SetWriter(QuicConnection* connection, QuicPacketWriter* writer, bool owns_writer) argument 229 CloseConnection(QuicConnection* connection) argument 234 GetConnectionClosePacket( QuicConnection* connection) argument 240 SetSupportedVersions(QuicConnection* connection, QuicVersionVector versions) argument [all...] |