Home
last modified time | relevance | path

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

12345678910>>...40

/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 CreateStopWaitingFrame() argument
48 return connection->CreateStopWaitingFrame(); in CreateStopWaitingFrame()
[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);
51 QuicConnection* connection);
53 static QuicPacketCreator* GetPacketCreator(QuicConnection* connection);
55 static QuicPacketGenerator* GetPacketGenerator(QuicConnection* connection);
58 QuicConnection* connection);
61 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.cc147 void CheckNoBackupData(const sql::Connection& connection, in CheckNoBackupData() argument
154 EXPECT_FALSE(connection.DoesTableExist("keywords_backup")); in CheckNoBackupData()
229 static int VersionFromConnection(sql::Connection* connection) { in VersionFromConnection() argument
231 sql::Statement s(connection->GetUniqueStatement( in VersionFromConnection()
260 sql::Connection connection; in LoadDatabase() local
261 ASSERT_TRUE(connection.Open(GetDatabasePath())); in LoadDatabase()
262 ASSERT_TRUE(connection.Execute(contents.data())); in LoadDatabase()
269 sql::Connection connection; in TEST_F() local
270 ASSERT_TRUE(connection.Open(GetDatabasePath())); in TEST_F()
271 const std::string& expected_schema = RemoveQuotes(connection.GetSchema()); in TEST_F()
[all …]
/external/chromium_org/components/proximity_auth/
Dconnection_unittest.cc62 void(const Connection& connection,
66 void(const Connection& connection, const WireMessage& message));
68 void(const Connection& connection,
89 StrictMock<MockConnection> connection; in TEST() local
90 EXPECT_FALSE(connection.IsConnected()); in TEST()
92 connection.SetStatus(Connection::CONNECTED); in TEST()
93 EXPECT_TRUE(connection.IsConnected()); in TEST()
95 connection.SetStatus(Connection::DISCONNECTED); in TEST()
96 EXPECT_FALSE(connection.IsConnected()); in TEST()
98 connection.SetStatus(Connection::IN_PROGRESS); in TEST()
[all …]
Dbluetooth_connection_unittest.cc118 void BeginConnecting(MockBluetoothConnection* connection) { in BeginConnecting() argument
119 EXPECT_EQ(Connection::DISCONNECTED, connection->status()); in BeginConnecting()
122 EXPECT_CALL(*connection, SetStatusProxy(Connection::IN_PROGRESS)); in BeginConnecting()
123 EXPECT_CALL(*adapter_, AddObserver(connection)); in BeginConnecting()
124 EXPECT_CALL(*connection, ConnectToService(&device_, uuid_, _, _)); in BeginConnecting()
125 connection->Connect(); in BeginConnecting()
127 EXPECT_EQ(Connection::IN_PROGRESS, connection->status()); in BeginConnecting()
133 void Connect(MockBluetoothConnection* connection) { in Connect() argument
134 EXPECT_EQ(Connection::DISCONNECTED, connection->status()); in Connect()
138 EXPECT_CALL(*connection, SetStatusProxy(Connection::IN_PROGRESS)); in Connect()
[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.cc44 HttpConnection* connection = FindConnection(connection_id); in AcceptWebSocket() local
45 if (connection == NULL) in AcceptWebSocket()
47 DCHECK(connection->web_socket()); in AcceptWebSocket()
48 connection->web_socket()->Accept(request); in AcceptWebSocket()
53 HttpConnection* connection = FindConnection(connection_id); in SendOverWebSocket() local
54 if (connection == NULL) in SendOverWebSocket()
56 DCHECK(connection->web_socket()); in SendOverWebSocket()
57 connection->web_socket()->Send(data); in SendOverWebSocket()
61 HttpConnection* connection = FindConnection(connection_id); in SendRaw() local
62 if (connection == NULL) in SendRaw()
[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/okhttp/okhttp/src/main/java/com/squareup/okhttp/
DConnectionPool.java148 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);
218 for (Connection connection : connections) { in getSpdyConnectionCount()
219 if (connection.isSpdy()) total++; in getSpdyConnectionCount()
227 for (Connection connection : connections) { in getHttpConnectionCount()
[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.java110 private HttpURLConnection connection; field in URLConnectionTest
138 connection = client.open(server.getUrl("/")); in requestHeaders()
139 connection.addRequestProperty("D", "e"); in requestHeaders()
140 connection.addRequestProperty("D", "f"); in requestHeaders()
141 assertEquals("f", connection.getRequestProperty("D")); in requestHeaders()
142 assertEquals("f", connection.getRequestProperty("d")); in requestHeaders()
143 Map<String, List<String>> requestHeaders = connection.getRequestProperties(); in requestHeaders()
157 connection.setRequestProperty(null, "j"); in requestHeaders()
162 connection.addRequestProperty(null, "k"); in requestHeaders()
166 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()
315 IndexedDBPendingConnection connection(callbacks, in OnIDBFactoryOpen() local
322 params.name, connection, request_context_, origin_url, indexed_db_path); in OnIDBFactoryOpen()
443 IndexedDBConnection* connection = map_.Lookup(ipc_database_id); in CloseAll() local
444 if (connection && connection->IsConnected()) { in CloseAll()
445 connection->database()->Abort( in CloseAll()
[all …]
/external/chromium_org/content/public/android/java/src/org/chromium/content/browser/
DBindingManagerImpl.java56 final ChildProcessConnection connection = mConnection; in removeInitialBinding() local
57 if (connection == null || !connection.isInitialBindingBound()) return; in removeInitialBinding()
62 if (connection.isInitialBindingBound()) { in removeInitialBinding()
63 connection.removeInitialBinding(); in removeInitialBinding()
71 ChildProcessConnection connection = mConnection; in addStrongBinding() local
72 if (connection == null) return; in addStrongBinding()
74 connection.addStrongBinding(); in addStrongBinding()
79 final ChildProcessConnection connection = mConnection; in removeStrongBinding() local
82 if (connection == null || !connection.isStrongBindingBound()) return; in removeStrongBinding()
89 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 …]

12345678910>>...40