Home
last modified time | relevance | path

Searched refs:connection (Results 1 – 25 of 480) sorted by relevance

12345678910>>...20

/external/chromium/chrome/browser/webdata/
Dweb_database_migration_unittest.cc188 static int VersionFromConnection(sql::Connection* connection) { in VersionFromConnection() argument
190 sql::Statement s(connection->GetUniqueStatement( in VersionFromConnection()
221 sql::Connection connection; in LoadDatabase() local
222 ASSERT_TRUE(connection.Open(GetDatabasePath())); in LoadDatabase()
223 ASSERT_TRUE(connection.Execute(contents.data())); in LoadDatabase()
237 sql::Connection connection; in MigrateVersion28Assertions() local
238 ASSERT_TRUE(connection.Open(GetDatabasePath())); in MigrateVersion28Assertions()
241 EXPECT_EQ(kCurrentTestedVersionNumber, VersionFromConnection(&connection)); in MigrateVersion28Assertions()
244 EXPECT_FALSE(connection.DoesColumnExist("keywords", "supports_instant")); in MigrateVersion28Assertions()
245 EXPECT_TRUE(connection.DoesColumnExist("keywords", "instant_url")); in MigrateVersion28Assertions()
[all …]
/external/chromium/chrome/browser/sync/syncable/
Ddirectory_backing_store_unittest.cc75 sql::Connection connection; in SetUpVersion67Database() local
76 ASSERT_TRUE(connection.Open(GetDatabasePath())); in SetUpVersion67Database()
77 ASSERT_TRUE(connection.BeginTransaction()); in SetUpVersion67Database()
78 ASSERT_TRUE(connection.Execute( in SetUpVersion67Database()
190 ASSERT_TRUE(connection.CommitTransaction()); in SetUpVersion67Database()
200 sql::Connection connection; in SetUpVersion68Database() local
201 ASSERT_TRUE(connection.Open(GetDatabasePath())); in SetUpVersion68Database()
202 ASSERT_TRUE(connection.BeginTransaction()); in SetUpVersion68Database()
203 ASSERT_TRUE(connection.Execute( in SetUpVersion68Database()
300 ASSERT_TRUE(connection.CommitTransaction()); in SetUpVersion68Database()
[all …]
/external/chromium/net/server/
Dhttp_server.cc73 Connection* connection = FindConnection(connection_id); in AcceptWebSocket() local
74 if (connection == NULL) in AcceptWebSocket()
94 connection->is_web_socket_ = true; in AcceptWebSocket()
95 connection->socket_->Send(base::StringPrintf( in AcceptWebSocket()
104 connection->socket_->Send(reinterpret_cast<char*>(digest.a), 16); in AcceptWebSocket()
109 Connection* connection = FindConnection(connection_id); in SendOverWebSocket() local
110 if (connection == NULL) in SendOverWebSocket()
113 DCHECK(connection->is_web_socket_); in SendOverWebSocket()
116 connection->socket_->Send(&message_start, 1); in SendOverWebSocket()
117 connection->socket_->Send(data); in SendOverWebSocket()
[all …]
/external/okhttp/src/main/java/com/squareup/okhttp/
DConnectionPool.java77 Connection connection = i.previous();
78 if (!connection.isAlive() || connection.isExpired(keepAliveDurationNs)) {
80 expiredConnections.add(connection);
82 } else if (connection.isIdle()) {
89 Connection connection = i.previous();
90 if (connection.isIdle()) {
91 expiredConnections.add(connection);
147 for (Connection connection : connections) { in getSpdyConnectionCount()
148 if (connection.isSpdy()) total++; in getSpdyConnectionCount()
156 for (Connection connection : connections) { in getHttpConnectionCount()
[all …]
/external/smack/src/org/jivesoftware/smack/
DBOSHPacketReader.java46 private BOSHConnection connection; field in BOSHPacketReader
54 public BOSHPacketReader(BOSHConnection connection) { in BOSHPacketReader() argument
55 this.connection = connection; in BOSHPacketReader()
67 if (connection.sessionID == null) { in responseReceived()
68 … connection.sessionID = body.getAttribute(BodyQName.create(BOSHConnection.BOSH_URI, "sid")); in responseReceived()
70 if (connection.authID == null) { in responseReceived()
71 … connection.authID = body.getAttribute(BodyQName.create(BOSHConnection.BOSH_URI, "authid")); in responseReceived()
84 connection.processPacket(PacketParserUtils.parseMessage(parser)); in responseReceived()
86 connection.processPacket(PacketParserUtils.parseIQ(parser, connection)); in responseReceived()
88 connection.processPacket(PacketParserUtils.parsePresence(parser)); in responseReceived()
[all …]
DPacketReader.java49 private XMPPConnection connection; field in PacketReader
55 protected PacketReader(final XMPPConnection connection) { in PacketReader() argument
56 this.connection = connection; in PacketReader()
73 readerThread.setName("Smack Packet Reader (" + connection.connectionCounterValue + ")"); in init()
82 "Smack Listener Processor (" + connection.connectionCounterValue + ")"); in init()
118 connection.connectionID = connectionID; in startup()
128 for (ConnectionListener listener : connection.getConnectionListeners()) { in shutdown()
149 connection.recvListeners.clear(); in cleanup()
150 connection.collectors.clear(); in cleanup()
162 parser.setInput(connection.reader); in resetParser()
[all …]
DPacketWriter.java45 private XMPPConnection connection; field in PacketWriter
54 protected PacketWriter(XMPPConnection connection) { in PacketWriter() argument
56 this.connection = connection; in PacketWriter()
65 this.writer = connection.writer; in init()
73 writerThread.setName("Smack Packet Writer (" + connection.connectionCounterValue + ")"); in init()
86 connection.firePacketInterceptors(packet); in sendPacket()
101 connection.firePacketSendingListeners(packet); in sendPacket()
136 connection.interceptors.clear(); in cleanup()
137 connection.sendListeners.clear(); in cleanup()
212 if (!(done || connection.isSocketClosed())) { in writePackets()
[all …]
DReconnectionManager.java39 private Connection connection; field in ReconnectionManager
51 public void connectionCreated(Connection connection) { in Connection.addConnectionCreationListener()
52 connection.addConnectionListener(new ReconnectionManager(connection)); in Connection.addConnectionCreationListener() argument
57 private ReconnectionManager(Connection connection) { in ReconnectionManager() argument
58 this.connection = connection; in ReconnectionManager()
68 return !done && !connection.isConnected() in isReconnectionAllowed()
69 && connection.isReconnectionAllowed(); in isReconnectionAllowed()
145 connection.connect(); in reconnect()
168 for (ConnectionListener listener : connection.connectionListeners) { in notifyReconnectionFailed()
181 for (ConnectionListener listener : connection.connectionListeners) { in notifyAttemptToReconnectIn()
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/internal/net/www/protocol/https/
DHttpsURLConnectionTest.java142 HttpsURLConnection connection = (HttpsURLConnection) url in testHttpsConnection() local
146 SSLSocket peerSocket = (SSLSocket) doInteraction(connection, ss); in testHttpsConnection()
149 checkConnectionStateParameters(connection, peerSocket); in testHttpsConnection()
152 connection.connect(); in testHttpsConnection()
182 HttpsURLConnection connection = (HttpsURLConnection) url in testHttpsPersistentConnection() local
187 connection, ss); in testHttpsPersistentConnection()
190 checkConnectionStateParameters(connection, peerSocket); in testHttpsPersistentConnection()
193 connection.connect(); in testHttpsPersistentConnection()
220 HttpsURLConnection connection = (HttpsURLConnection) url in testHttpsConnection_Not_Found_Response() local
224 doInteraction(connection, ss, NOT_FOUND_CODE); in testHttpsConnection_Not_Found_Response()
[all …]
/external/smack/src/org/jivesoftware/smackx/bytestreams/ibb/
DInBandBytestreamManager.java98 public void connectionCreated(Connection connection) { in Connection.addConnectionCreationListener()
100 manager = InBandBytestreamManager.getByteStreamManager(connection); in Connection.addConnectionCreationListener()
103 connection.addConnectionListener(new AbstractConnectionListener() { in Connection.addConnectionCreationListener()
135 private final Connection connection; field in InBandBytestreamManager
183 public static synchronized InBandBytestreamManager getByteStreamManager(Connection connection) { in getByteStreamManager() argument
184 if (connection == null) in getByteStreamManager()
186 InBandBytestreamManager manager = managers.get(connection); in getByteStreamManager()
188 manager = new InBandBytestreamManager(connection); in getByteStreamManager()
189 managers.put(connection, manager); in getByteStreamManager()
199 private InBandBytestreamManager(Connection connection) { in InBandBytestreamManager() argument
[all …]
/external/okhttp/src/test/java/com/squareup/okhttp/internal/http/
DURLConnectionTest.java282 HttpURLConnection connection = client.open(url); in connectRetriesUntilConnectedOrFailed() local
284 connection.connect(); in connectRetriesUntilConnectedOrFailed()
313 HttpURLConnection connection = client.open(server.getUrl("/def")); in testRequestBodySurvivesRetries() local
314 connection.setDoOutput(true); in testRequestBodySurvivesRetries()
315 transferKind.setForRequest(connection, 4); in testRequestBodySurvivesRetries()
316 connection.getOutputStream().write("body".getBytes("UTF-8")); in testRequestBodySurvivesRetries()
317 assertContent("abc", connection); in testRequestBodySurvivesRetries()
325 HttpURLConnection connection = client.open(server.getUrl("/")); in getErrorStreamOnSuccessfulRequest() local
326 assertNull(connection.getErrorStream()); in getErrorStreamOnSuccessfulRequest()
332 HttpURLConnection connection = client.open(server.getUrl("/")); in getErrorStreamOnUnsuccessfulRequest() local
[all …]
/external/smack/src/org/jivesoftware/smackx/carbons/
DCarbonManager.java53 public void connectionCreated(Connection connection) { in Connection.addConnectionCreationListener() argument
54 new CarbonManager(connection); in Connection.addConnectionCreationListener()
59 private Connection connection; field in CarbonManager
62 private CarbonManager(Connection connection) { in CarbonManager() argument
63 ServiceDiscoveryManager sdm = ServiceDiscoveryManager.getInstanceFor(connection); in CarbonManager()
65 this.connection = connection; in CarbonManager()
66 instances.put(connection, this); in CarbonManager()
76 public static CarbonManager getInstanceFor(Connection connection) { in getInstanceFor() argument
77 CarbonManager carbonManager = instances.get(connection); in getInstanceFor()
80 carbonManager = new CarbonManager(connection); in getInstanceFor()
[all …]
/external/smack/src/org/jivesoftware/smackx/
DGatewayManager.java41 private Connection connection; field in GatewayManager
54 private GatewayManager(Connection connection) throws XMPPException{ in GatewayManager() argument
55 this.connection = connection; in GatewayManager()
56 this.roster = connection.getRoster(); in GatewayManager()
57 sdManager = ServiceDiscoveryManager.getInstanceFor(connection); in GatewayManager()
65 DiscoverItems items = sdManager.discoverItems(connection.getHost()); in loadLocalGateways()
87 gateways.put(itemJID, new Gateway(connection,itemJID)); in discoverGateway()
88 if(itemJID.contains(connection.getHost())){ in discoverGateway()
90 new Gateway(connection,itemJID,info,identity)); in discoverGateway()
94 new Gateway(connection,itemJID,info,identity)); in discoverGateway()
[all …]
DChatStateManager.java64 public static ChatStateManager getInstance(final Connection connection) { in getInstance() argument
65 if(connection == null) { in getInstance()
69 ChatStateManager manager = managers.get(connection); in getInstance()
71 manager = new ChatStateManager(connection); in getInstance()
73 managers.put(connection, manager); in getInstance()
80 private final Connection connection; field in ChatStateManager
92 private ChatStateManager(Connection connection) { in ChatStateManager() argument
93 this.connection = connection; in ChatStateManager()
97 connection.getChatManager().addOutgoingMessageInterceptor(outgoingInterceptor, in init()
99 connection.getChatManager().addChatListener(incomingInterceptor); in init()
[all …]
DGateway.java33 private Connection connection; field in Gateway
41 Gateway(Connection connection, String entityJID){ in Gateway() argument
42 this.connection = connection; in Gateway()
43 this.roster = connection.getRoster(); in Gateway()
44 this.sdManager = ServiceDiscoveryManager.getInstanceFor(connection); in Gateway()
48 Gateway(Connection connection, String entityJID, DiscoverInfo info, Identity identity){ in Gateway() argument
49 this(connection, entityJID); in Gateway()
82 packet.setFrom(connection.getUser()); in refreshRegisterInfo()
86 connection.createPacketCollector(new PacketIDFilter(packet.getPacketID())); in refreshRegisterInfo()
87 connection.sendPacket(packet); in refreshRegisterInfo()
[all …]
/external/smack/src/org/jivesoftware/smackx/filetransfer/
DFileTransferNegotiator.java90 final Connection connection) { in getInstanceFor() argument
91 if (connection == null) { in getInstanceFor()
94 if (!connection.isConnected()) { in getInstanceFor()
98 if (transferObject.containsKey(connection)) { in getInstanceFor()
99 return transferObject.get(connection); in getInstanceFor()
103 connection); in getInstanceFor()
104 setServiceEnabled(connection, true); in getInstanceFor()
105 transferObject.put(connection, transfer); in getInstanceFor()
117 public static void setServiceEnabled(final Connection connection, in setServiceEnabled() argument
120 .getInstanceFor(connection); in setServiceEnabled()
[all …]
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/
Dtest_mux.py219 connection=_MockMuxConnection())
401 request.connection.put_bytes(add_channel_request)
406 request.connection.put_bytes(flow_control)
412 request.connection.put_bytes(add_channel_request)
417 request.connection.put_bytes(flow_control)
419 request.connection.put_bytes(
421 request.connection.put_bytes(
423 request.connection.put_bytes(
425 request.connection.put_bytes(
427 request.connection.put_bytes(
[all …]
/external/chromium/third_party/libjingle/source/talk/p2p/client/
Dsocketmonitor.cc123 Connection *connection = *it; in PollSocket() local
125 info.best_connection = p2p_channel->best_connection() == connection; in PollSocket()
127 (connection->read_state() == Connection::STATE_READABLE); in PollSocket()
129 (connection->write_state() == Connection::STATE_WRITABLE); in PollSocket()
131 (connection->write_state() == Connection::STATE_WRITE_TIMEOUT); in PollSocket()
132 info.new_connection = !connection->reported(); in PollSocket()
133 connection->set_reported(true); in PollSocket()
134 info.rtt = connection->rtt(); in PollSocket()
135 info.sent_total_bytes = connection->sent_total_bytes(); in PollSocket()
136 info.sent_bytes_second = connection->sent_bytes_second(); in PollSocket()
[all …]
/external/smack/src/org/jivesoftware/smackx/ping/
DPingManager.java68 public void connectionCreated(Connection connection) { in Connection.addConnectionCreationListener() argument
69 new PingManager(connection); in Connection.addConnectionCreationListener()
75 private Connection connection; field in PingManager
91 private PingManager(Connection connection) { in PingManager() argument
92 ServiceDiscoveryManager sdm = ServiceDiscoveryManager.getInstanceFor(connection); in PingManager()
94 this.connection = connection; in PingManager()
101 connection.addPacketListener(new PacketListener() { in init()
116 connection.sendPacket(pong); in init()
120 connection.addConnectionListener(new ConnectionListener() { in init()
145 instances.put(connection, this); in init()
[all …]
/external/okhttp/src/test/java/com/squareup/okhttp/internal/spdy/
DSpdyConnectionTest.java76 SpdyConnection connection = new SpdyConnection.Builder(true, peer.openSocket()).build(); in clientCreatesStreamAndServerReplies() local
77 SpdyStream stream = connection.newStream(Arrays.asList("b", "banana"), true, true); in clientCreatesStreamAndServerReplies()
81 assertEquals(0, connection.openStreamCount()); in clientCreatesStreamAndServerReplies()
99 SpdyConnection connection = new SpdyConnection.Builder(true, peer.openSocket()).build(); in headersOnlyStreamIsClosedAfterReplyHeaders() local
100 SpdyStream stream = connection.newStream(Arrays.asList("a", "android"), false, false); in headersOnlyStreamIsClosedAfterReplyHeaders()
101 assertEquals(1, connection.openStreamCount()); in headersOnlyStreamIsClosedAfterReplyHeaders()
103 assertEquals(0, connection.openStreamCount()); in headersOnlyStreamIsClosedAfterReplyHeaders()
115 SpdyConnection connection = new SpdyConnection.Builder(true, peer.openSocket()).build(); in clientCreatesStreamAndServerRepliesWithFin() local
116 connection.newStream(Arrays.asList("b", "banana"), false, true); in clientCreatesStreamAndServerRepliesWithFin()
117 assertEquals(1, connection.openStreamCount()); in clientCreatesStreamAndServerRepliesWithFin()
[all …]
/external/smack/src/de/measite/smack/
DAndroidDebugger.java33 private Connection connection = null; field in AndroidDebugger
43 public AndroidDebugger(Connection connection, Writer writer, Reader reader) { in AndroidDebugger() argument
44 this.connection = connection; in AndroidDebugger()
59 dateFormatter.format(new Date()) + " RCV (" + connection.hashCode() + in createDebug()
71 dateFormatter.format(new Date()) + " SENT (" + connection.hashCode() + in createDebug()
91 connection.hashCode() + in createDebug()
102 connection.hashCode() + in createDebug()
110 connection.hashCode() + in createDebug()
118 connection.hashCode() + in createDebug()
125 connection.hashCode() + in createDebug()
[all …]
/external/smack/asmack-master/static-src/custom/de/measite/smack/
DAndroidDebugger.java33 private Connection connection = null; field in AndroidDebugger
43 public AndroidDebugger(Connection connection, Writer writer, Reader reader) { in AndroidDebugger() argument
44 this.connection = connection; in AndroidDebugger()
59 dateFormatter.format(new Date()) + " RCV (" + connection.hashCode() + in createDebug()
71 dateFormatter.format(new Date()) + " SENT (" + connection.hashCode() + in createDebug()
91 connection.hashCode() + in createDebug()
102 connection.hashCode() + in createDebug()
110 connection.hashCode() + in createDebug()
118 connection.hashCode() + in createDebug()
125 connection.hashCode() + in createDebug()
[all …]
/external/smack/src/org/jivesoftware/smack/debugger/
DConsoleDebugger.java47 private Connection connection = null; field in ConsoleDebugger
57 public ConsoleDebugger(Connection connection, Writer writer, Reader reader) { in ConsoleDebugger() argument
58 this.connection = connection; in ConsoleDebugger()
73 dateFormatter.format(new Date()) + " RCV (" + connection.hashCode() + in createDebug()
85 dateFormatter.format(new Date()) + " SENT (" + connection.hashCode() + in createDebug()
105 connection.hashCode() + in createDebug()
116 connection.hashCode() + in createDebug()
124 connection.hashCode() + in createDebug()
132 connection.hashCode() + in createDebug()
139 connection.hashCode() + in createDebug()
[all …]
/external/webkit/LayoutTests/storage/indexeddb/
Dset_version_queue-expected.txt17 connection[1] received versionChangeEvent: version 0
19 connection[2] received versionChangeEvent: version 0
21 connection[3] received versionChangeEvent: version 0
23 PASS connection[0] got blocked event
25 Close the connection that received the block event:
27 Close another connection as well, to test 4.7.4-note:
32 connection[2] received versionChangeEvent: version 1
34 PASS connection[1] got blocked event
40 connection[1] received versionChangeEvent: version 2
42 PASS connection[2] got blocked event
[all …]
/external/okhttp/src/main/java/com/squareup/okhttp/internal/http/
DHttpEngine.java95 protected Connection connection; field in HttpEngine
148 Connection connection, RetryableOutputStream requestBodyOut) throws IOException { in HttpEngine() argument
151 this.connection = connection; in HttpEngine()
199 } else if (connection != null) { in sendRequest()
200 policy.connectionPool.recycle(connection); in sendRequest()
201 connection = null; in sendRequest()
247 if (connection == null) { in sendSocketRequest()
255 transport = (Transport) connection.newTransport(this); in sendSocketRequest()
266 if (connection != null) { in connect()
285 connection = routeSelector.next(); in connect()
[all …]

12345678910>>...20