Searched defs:connection (Results 151 - 175 of 329) sorted by relevance

1234567891011>>

/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
H A DConnectionPool.java45 * 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 DResponseCacheAdapterTest.java75 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 DSDL_esdaudio.c122 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 DShadowSQLiteCursor.java228 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 DChatManager.java96 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 DPrivacyListManager.java49 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 DPacketParserUtils.java282 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 DChatStateManager.java42 * 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 DGateway.java33 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 DFaultTolerantNegotiator.java47 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 DRoomListenerMultiplexor.java47 // 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 DPingManager.java68 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 DAgentRoster.java53 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 DOffer.java40 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 Dindexed_db_factory_impl.cc415 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 Dindexed_db_transaction.h77 IndexedDBDatabaseCallbacks* connection() const { return callbacks_.get(); } function in class:content::IndexedDBTransaction
/external/chromium_org/content/browser/renderer_host/pepper/
H A Dpepper_renderer_connection.cc36 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 Dbrowser_font_resource_trusted.cc11 #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 DBindingManagerImpl.java35 * 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 Dexported_object.cc178 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 Dhid_api.cc35 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 Dconnection_manager.cc17 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 Dwindow_manager_app.cc134 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 Dquic_dispatcher.cc70 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 Dquic_connection_peer.cc21 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...]

Completed in 4571 milliseconds

1234567891011>>