Home
last modified time | relevance | path

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

12345678910>>...36

/external/chromium_org/net/quic/test_tools/
Dquic_connection_peer.cc21 void QuicConnectionPeer::SendAck(QuicConnection* connection) { in SendAck() argument
22 connection->SendAck(); in SendAck()
27 QuicConnection* connection, in SetReceiveAlgorithm() argument
29 connection->received_packet_manager_.receive_algorithm_.reset( in SetReceiveAlgorithm()
35 QuicConnection* connection, in SetSendAlgorithm() argument
37 connection->sent_packet_manager_.send_algorithm_.reset(send_algorithm); in SetSendAlgorithm()
41 QuicAckFrame* QuicConnectionPeer::CreateAckFrame(QuicConnection* connection) { in CreateAckFrame() argument
42 return connection->CreateAckFrame(); in CreateAckFrame()
47 QuicConnection* connection) { in GetVisitor() argument
48 return connection->visitor_; in GetVisitor()
[all …]
Dquic_connection_peer.h37 static void SendAck(QuicConnection* connection);
39 static void SetReceiveAlgorithm(QuicConnection* connection,
42 static void SetSendAlgorithm(QuicConnection* connection,
45 static QuicAckFrame* CreateAckFrame(QuicConnection* connection);
48 QuicConnection* connection);
50 static QuicPacketCreator* GetPacketCreator(QuicConnection* connection);
52 static QuicPacketGenerator* GetPacketGenerator(QuicConnection* connection);
55 QuicConnection* connection);
58 QuicConnection* connection);
60 static QuicTime::Delta GetNetworkTimeout(QuicConnection* connection);
[all …]
/external/chromium_org/third_party/tlslite/tests/
Dtlstest.py100 connection = connect()
101 connection.handshakeClientAnonymous()
102 testConnClient(connection)
103 connection.close()
106 connection = connect()
107 connection.handshakeClientCert(serverName=address[0])
108 testConnClient(connection)
109 assert(isinstance(connection.session.serverCertChain, X509CertChain))
110 assert(connection.session.serverName == address[0])
111 connection.close()
[all …]
/external/chromium_org/components/webdata/common/
Dweb_database_migration_unittest.cc149 void CheckNoBackupData(const sql::Connection& connection, in CheckNoBackupData() argument
156 EXPECT_FALSE(connection.DoesTableExist("keywords_backup")); in CheckNoBackupData()
235 static int VersionFromConnection(sql::Connection* connection) { in VersionFromConnection() argument
237 sql::Statement s(connection->GetUniqueStatement( in VersionFromConnection()
266 sql::Connection connection; in LoadDatabase() local
267 ASSERT_TRUE(connection.Open(GetDatabasePath())); in LoadDatabase()
268 ASSERT_TRUE(connection.Execute(contents.data())); in LoadDatabase()
275 sql::Connection connection; in TEST_F() local
276 ASSERT_TRUE(connection.Open(GetDatabasePath())); in TEST_F()
277 const std::string& expected_schema = RemoveQuotes(connection.GetSchema()); in TEST_F()
[all …]
/external/chromium_org/sync/syncable/
Ddirectory_backing_store_unittest.cc57 void SetUpVersion67Database(sql::Connection* connection);
58 void SetUpVersion68Database(sql::Connection* connection);
59 void SetUpVersion69Database(sql::Connection* connection);
60 void SetUpVersion70Database(sql::Connection* connection);
61 void SetUpVersion71Database(sql::Connection* connection);
62 void SetUpVersion72Database(sql::Connection* connection);
63 void SetUpVersion73Database(sql::Connection* connection);
64 void SetUpVersion74Database(sql::Connection* connection);
65 void SetUpVersion75Database(sql::Connection* connection);
66 void SetUpVersion76Database(sql::Connection* connection);
[all …]
/external/chromium_org/net/server/
Dhttp_server.cc33 HttpConnection* connection = FindConnection(connection_id); in AcceptWebSocket() local
34 if (connection == NULL) in AcceptWebSocket()
37 DCHECK(connection->web_socket_.get()); in AcceptWebSocket()
38 connection->web_socket_->Accept(request); in AcceptWebSocket()
43 HttpConnection* connection = FindConnection(connection_id); in SendOverWebSocket() local
44 if (connection == NULL) in SendOverWebSocket()
46 DCHECK(connection->web_socket_.get()); in SendOverWebSocket()
47 connection->web_socket_->Send(data); in SendOverWebSocket()
51 HttpConnection* connection = FindConnection(connection_id); in SendRaw() local
52 if (connection == NULL) in SendRaw()
[all …]
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
DConnectionPool.java92 Connection connection = i.previous();
93 if (!connection.isAlive() || connection.isExpired(keepAliveDurationNs)) {
95 expiredConnections.add(connection);
97 } else if (connection.isIdle()) {
104 Connection connection = i.previous();
105 if (connection.isIdle()) {
106 expiredConnections.add(connection);
161 for (Connection connection : connections) { in getSpdyConnectionCount()
162 if (connection.isSpdy()) total++; in getSpdyConnectionCount()
170 for (Connection connection : connections) { in getHttpConnectionCount()
[all …]
/external/chromium_org/content/public/android/javatests/src/org/chromium/content/browser/
DBindingManagerImplTest.java178 final MockChildProcessConnection connection = new MockChildProcessConnection(1); in testBindingRemovalOnLowEnd() local
179 manager.addNewConnection(connection.getPid(), connection); in testBindingRemovalOnLowEnd() local
180 assertTrue(connection.isInitialBindingBound()); in testBindingRemovalOnLowEnd()
181 assertFalse(connection.isStrongBindingBound()); in testBindingRemovalOnLowEnd()
189 manager.setInForeground(connection.getPid(), true); in testBindingRemovalOnLowEnd()
190 assertTrue(connection.isStrongBindingBound()); in testBindingRemovalOnLowEnd()
191 assertTrue(connection.isInitialBindingBound()); in testBindingRemovalOnLowEnd()
194 manager.setInForeground(connection.getPid(), false); in testBindingRemovalOnLowEnd()
195 assertFalse(connection.isStrongBindingBound()); in testBindingRemovalOnLowEnd()
203 assertFalse(connection.isInitialBindingBound()); in testBindingRemovalOnLowEnd()
[all …]
/external/chromium_org/chrome/browser/nacl_host/test/
Ddebug_stub_browser_tests.py12 def GetTargetArch(connection): argument
14 reply = connection.RspRequest('qXfer:features:read:target.xml:0,fff')
31 def GetProgCtrString(connection, arch): argument
33 registers = connection.RspRequest('g')
48 def TestContinue(connection): argument
49 result = connection.RspRequest('vCont;c')
56 def TestBreakpoint(connection): argument
59 arch = GetTargetArch(connection)
60 registers = connection.RspRequest('g')
61 pc = GetProgCtrString(connection, arch)
[all …]
/external/ksoap2/ksoap2-j2se/src/main/java/org/ksoap2/transport/
DHttpsServiceConnectionSE.java41 private HttpsURLConnection connection; field in HttpsServiceConnectionSE
54 connection = (HttpsURLConnection) new URL(HttpsTransportSE.PROTOCOL, host, port, file) in HttpsServiceConnectionSE()
60 connection.setConnectTimeout(timeout); in updateConnectionParameters()
61 …connection.setReadTimeout(timeout); // even if we connect fine we want to time out if we cant read… in updateConnectionParameters()
62 connection.setUseCaches(false); in updateConnectionParameters()
63 connection.setDoOutput(true); in updateConnectionParameters()
64 connection.setDoInput(true); in updateConnectionParameters()
68 connection.connect(); in connect()
72 connection.disconnect(); in disconnect()
76 Map properties = connection.getHeaderFields(); in getResponseProperties()
[all …]
DServiceConnectionSE.java39 private HttpURLConnection connection; field in ServiceConnectionSE
65 connection = (proxy == null) in ServiceConnectionSE()
68 connection.setUseCaches(false); in ServiceConnectionSE()
69 connection.setDoOutput(true); in ServiceConnectionSE()
70 connection.setDoInput(true); in ServiceConnectionSE()
71 connection.setConnectTimeout(timeout); in ServiceConnectionSE()
72 …connection.setReadTimeout(timeout); // even if we connect fine we want to time out if we cant read… in ServiceConnectionSE()
76 connection.connect(); in connect()
80 connection.disconnect(); in disconnect()
84 Map properties = connection.getHeaderFields(); in getResponseProperties()
[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 …]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/
DSpdyConnectionTest.java75 SpdyConnection connection = connection(peer, SPDY3); in clientCreatesStreamAndServerReplies() local
76 SpdyStream stream = connection.newStream(headerEntries("b", "banana"), true, true); in clientCreatesStreamAndServerReplies()
82 assertEquals(0, connection.openStreamCount()); in clientCreatesStreamAndServerReplies()
102 SpdyConnection connection = connection(peer, SPDY3); in headersOnlyStreamIsClosedAfterReplyHeaders() local
103 SpdyStream stream = connection.newStream(headerEntries("a", "android"), false, false); in headersOnlyStreamIsClosedAfterReplyHeaders()
104 assertEquals(1, connection.openStreamCount()); in headersOnlyStreamIsClosedAfterReplyHeaders()
106 assertEquals(0, connection.openStreamCount()); in headersOnlyStreamIsClosedAfterReplyHeaders()
118 SpdyConnection connection = connection(peer, SPDY3); in clientCreatesStreamAndServerRepliesWithFin() local
119 connection.newStream(headerEntries("b", "banana"), false, true); in clientCreatesStreamAndServerRepliesWithFin()
120 assertEquals(1, connection.openStreamCount()); in clientCreatesStreamAndServerRepliesWithFin()
[all …]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/
DURLConnectionTest.java109 private HttpURLConnection connection; field in URLConnectionTest
137 connection = client.open(server.getUrl("/")); in requestHeaders()
138 connection.addRequestProperty("D", "e"); in requestHeaders()
139 connection.addRequestProperty("D", "f"); in requestHeaders()
140 assertEquals("f", connection.getRequestProperty("D")); in requestHeaders()
141 assertEquals("f", connection.getRequestProperty("d")); in requestHeaders()
142 Map<String, List<String>> requestHeaders = connection.getRequestProperties(); in requestHeaders()
156 connection.setRequestProperty(null, "j"); in requestHeaders()
161 connection.addRequestProperty(null, "k"); in requestHeaders()
165 connection.setRequestProperty("NullValue", null); in requestHeaders()
[all …]
/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/chromium_org/content/browser/indexed_db/
Dindexed_db_dispatcher_host.cc159 int32 IndexedDBDispatcherHost::Add(IndexedDBConnection* connection, in Add() argument
163 connection->Close(); in Add()
164 delete connection; in Add()
167 int32 ipc_database_id = database_dispatcher_host_->map_.Add(connection); in Add()
168 Context()->ConnectionOpened(origin_url, connection); in Add()
313 IndexedDBPendingConnection connection(callbacks, in OnIDBFactoryOpen() local
320 params.name, connection, request_context_, origin_url, indexed_db_path); in OnIDBFactoryOpen()
441 IndexedDBConnection* connection = map_.Lookup(ipc_database_id); in CloseAll() local
442 if (connection && connection->IsConnected()) { in CloseAll()
443 connection->database()->Abort( in CloseAll()
[all …]
/external/chromium_org/content/public/android/java/src/org/chromium/content/browser/
DBindingManagerImpl.java57 final ChildProcessConnection connection = mConnection; in removeInitialBinding() local
58 if (connection == null || !connection.isInitialBindingBound()) return; in removeInitialBinding()
63 if (connection.isInitialBindingBound()) { in removeInitialBinding()
64 connection.removeInitialBinding(); in removeInitialBinding()
72 ChildProcessConnection connection = mConnection; in addStrongBinding() local
73 if (connection == null) return; in addStrongBinding()
75 connection.addStrongBinding(); in addStrongBinding()
80 final ChildProcessConnection connection = mConnection; in removeStrongBinding() local
83 if (connection == null || !connection.isStrongBindingBound()) return; in removeStrongBinding()
90 if (connection.isStrongBindingBound()) { in removeStrongBinding()
[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/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 …]
/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/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/
DSpdyStream.java55 private final SpdyConnection connection; field in SpdyStream
75 SpdyStream(int id, SpdyConnection connection, boolean outFinished, boolean inFinished, in SpdyStream() argument
77 if (connection == null) throw new NullPointerException("connection == null"); in SpdyStream()
80 this.connection = connection; in SpdyStream()
82 connection.peerSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE); in SpdyStream()
84 connection.okHttpSettings.getInitialWindowSize(DEFAULT_INITIAL_WINDOW_SIZE)); in SpdyStream()
121 return connection.client == streamIsClient; in isLocallyInitiated()
125 return connection; in getConnection()
196 connection.writeSynReply(id, outFinished, responseHeaders); in reply()
199 connection.flush(); in reply()
[all …]
/external/chromium_org/third_party/tlslite/scripts/
Dtls.py162 def printGoodConnection(connection, seconds): argument
164 print(" Version: %s" % connection.getVersionName())
165 print(" Cipher: %s %s" % (connection.getCipherName(),
166 connection.getCipherImplementation()))
167 if connection.session.srpUsername:
168 print(" Client SRP username: %s" % connection.session.srpUsername)
169 if connection.session.clientCertChain:
171 connection.session.clientCertChain.getFingerprint())
172 if connection.session.serverCertChain:
174 connection.session.serverCertChain.getFingerprint())
[all …]
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/
DHttpEngine.java78 private Connection connection; field in HttpEngine
160 Connection connection, RouteSelector routeSelector, RetryableSink requestBodyOut, in HttpEngine() argument
165 this.connection = connection; in HttpEngine()
170 if (connection != null) { in HttpEngine()
171 connection.setOwner(this); in HttpEngine()
172 this.route = connection.getRoute(); in HttpEngine()
210 if (connection == null) { in sendRequest()
215 if (connection.getOwner() != this && !connection.isSpdy()) throw new AssertionError(); in sendRequest()
217 transport = (Transport) connection.newTransport(this); in sendRequest()
227 if (connection != null) { in sendRequest()
[all …]

12345678910>>...36