| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
| test_handshake_hybi00.py | 51 'Connection': 'Upgrade',
66 'Connection': 'UPGRADE',
78 'Connection: Upgrade\r\n'
88 'Connection: Upgrade\r\n'
101 'Connection': 'Upgrade',
113 'Connection: Upgrade\r\n'
123 'Connection: Upgrade\r\n'
136 'Connection': 'Upgrade',
147 'Connection: Upgrade\r\n'
159 'Connection': 'Upgrade'
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| httpserver.cc | 65 Connection* connection = new Connection(connection_id, this); local
66 connections_.insert(ConnectionMap::value_type(connection_id, connection));
67 connection->BeginProcess(stream);
74 if (Connection* connection = Find(connection_id)) {
75 connection->Respond(transaction);
79 // connection still exists.
85 if (Connection* connection = Find(connection_id))
123 Connection* connection = it->second; local
[all...] |
| /external/mockwebserver/src/test/java/com/google/mockwebserver/ |
| MockWebServerTest.java | 105 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); local
106 connection.setRequestProperty("Accept-Language", "en-US");
107 InputStream in = connection.getInputStream();
109 assertEquals(HttpURLConnection.HTTP_OK, connection.getResponseCode());
125 URLConnection connection = server.getUrl("/").openConnection(); local
126 InputStream in = connection.getInputStream();
153 URLConnection connection = server.getUrl("/").openConnection(); local
154 InputStream in = connection.getInputStream();
166 URLConnection connection = server.getUrl("/").openConnection(); local
167 InputStream in = connection.getInputStream()
[all...] |
| /libcore/luni/src/test/java/tests/api/javax/net/ssl/ |
| HttpsURLConnectionTest.java | 59 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
61 connection.getCipherSuite();
75 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
77 connection.getLocalCertificates();
127 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
129 connection.getLocalPrincipal();
145 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
147 connection.getPeerPrincipal();
168 HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); local
170 connection.getServerCertificates()
[all...] |
| /external/smack/src/org/jivesoftware/smackx/entitycaps/ |
| EntityCapsManager.java | 20 import org.jivesoftware.smack.Connection;
83 private static Map<Connection, EntityCapsManager> instances = Collections
84 .synchronizedMap(new WeakHashMap<Connection, EntityCapsManager>());
92 * Map of Full JID -> DiscoverInfo/null. In case of c2s connection the
94 * link-local connection the key is formed as user@host (no resource) In
100 Connection.addConnectionCreationListener(new ConnectionCreationListener() {
101 public void connectionCreated(Connection connection) {
102 if (connection instanceof XMPPConnection)
103 new EntityCapsManager(connection);
232 Connection connection = weakRefConnection.get(); local
439 Connection connection = weakRefConnection.get(); local
[all...] |
| /packages/apps/Email/src/com/android/email/mail/store/ |
| ImapStore.java | 372 // TODO: There is nothing that ever closes this connection. Trouble is, it's not exactly
375 ImapConnection connection = getConnection(); local
378 // Establish a connection to the IMAP server; if necessary
380 connection.executeSimpleCommand(ImapConstants.NOOP);
385 List<ImapResponse> responses = connection.executeSimpleCommand(imapCommand);
422 connection.close();
425 // We do NOT want this connection pooled, or we will continue to send NOOP and SELECT
427 connection.destroyResponses();
428 connection = null;
431 if (connection != null)
441 ImapConnection connection = new ImapConnection(this, mUsername, mPassword); local
500 ImapConnection connection = null; local
[all...] |
| /frameworks/base/services/input/ |
| InputDispatcher.cpp | 78 // Amount of time to allow touch events to be streamed out to a connection before requiring
599 commandEntry->connection.clear();
925 sp<Connection> connection = mConnectionsByFd.valueAt(connectionIndex); local
1019 sp<Connection> connection = mConnectionsByFd.valueAt(connectionIndex); local
1667 sp<Connection> connection = mConnectionsByFd.valueAt(connectionIndex); local
2115 sp<Connection> connection = d->mConnectionsByFd.valueAt(connectionIndex); local
3203 const sp<Connection>& connection = mConnectionsByFd.valueAt(i); local
3276 sp<Connection> connection = new Connection(inputChannel, inputWindowHandle, monitor); local
3322 sp<Connection> connection = mConnectionsByFd.valueAt(connectionIndex); local
3350 sp<Connection> connection = mConnectionsByFd.valueAt(connectionIndex); local
3424 sp<Connection> connection = commandEntry->connection; local
3477 sp<Connection> connection = commandEntry->connection; local
3523 startDispatchCycleLocked(now(), connection); local
[all...] |
| /external/chromium_org/content/browser/resources/media/ |
| webrtc_internals.js | 11 /** A map from peer connection id to the PeerConnectionRecord. */
14 /** A simple class to store the updates and stats data for a peer connection. */
35 * Adds the initilization info of the peer connection.
36 * @param {string} url The URL of the web page owning the peer connection.
37 * @param {Array} servers STUN servers used by the peer connection.
109 * A helper function for getting a peer connection element id.
112 * of the peer connection.
113 * @return {string} The peer connection element id.
123 * @param {!PeerConnectionUpdateEntry} data The peer connection update data.
134 * Helper for adding a peer connection update
[all...] |
| /external/chromium/chrome/browser/debugger/ |
| devtools_remote_listen_socket.cc | 103 ListenSocket *connection) {
104 connection->AddRef();
105 message_listener_->OnAcceptConnection(connection);
110 void DevToolsRemoteListenSocket::DidRead(ListenSocket* connection,
151 void DevToolsRemoteListenSocket::DidClose(ListenSocket *connection) {
153 connection->Release();
|
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| p2ptransportchannel.h | 28 // P2PTransportChannel wraps up the state management of the connection between
32 // Bob are used to make a connection, repeat to make many connections).
65 // P2PTransportChannel manages the candidates and connection process to keep
98 const Connection* best_connection() const { return best_connection_; }
117 void SwitchBestConnectionTo(Connection* conn);
123 Connection* GetBestConnectionOnNetwork(talk_base::Network* network);
128 bool FindConnection(cricket::Connection* connection) const;
133 bool IsPingable(Connection* conn);
134 Connection* FindNextPingableConnection()
[all...] |
| /external/smack/src/org/jivesoftware/smackx/commands/ |
| AdHocCommandManager.java | 53 * Pass in a Connection instance to
54 * {@link #getAddHocCommandsManager(org.jivesoftware.smack.Connection)} in order to
71 * Map a Connection with it AdHocCommandManager. This map have a key-value
72 * pair for every active connection.
74 private static Map<Connection, AdHocCommandManager> instances =
75 new ConcurrentHashMap<Connection, AdHocCommandManager>();
78 * Register the listener for all the connection creations. When a new
79 * connection is created a new AdHocCommandManager is also created and
80 * related to that connection.
83 Connection.addConnectionCreationListener(new ConnectionCreationListener() {
109 private Connection connection; field in class:AdHocCommandManager
[all...] |
| /external/smack/src/org/jivesoftware/smackx/filetransfer/ |
| Socks5TransferNegotiator.java | 21 import org.jivesoftware.smack.Connection;
44 private Connection connection;
field in class:Socks5TransferNegotiator
48 Socks5TransferNegotiator(Connection connection) {
49 this.connection = connection;
50 this.manager = Socks5BytestreamManager.getBytestreamManager(this.connection);
76 Packet streamInitiation = initiateIncomingStream(this.connection, initiation);
|
| /hardware/samsung_slsi/exynos5/mobicore/daemon/ClientLib/ |
| Device.cpp | 46 Device::Device(uint32_t deviceId, Connection *connection)
49 this->connection = connection;
78 delete connection;
105 void Device::createNewSession(uint32_t sessionId, Connection *connection)
107 Session *session = new Session(sessionId, pMcKMod, connection);
|
| /external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/net/ |
| JarURLConnectionTest.java | 96 JarURLConnection connection = null; local
97 connection = (JarURLConnection) url.openConnection();
99 connection.connect();
106 connection.getJarFile();
159 JarURLConnection connection = (JarURLConnection) url.openConnection(); local
160 connection.setUseCaches(false);
161 InputStream in = connection.getInputStream();
162 JarFile jarFile1 = connection.getJarFile();
163 JarEntry jarEntry1 = connection.getJarEntry();
168 JarFile jarFile2 = connection.getJarFile()
[all...] |
| /external/chromium_org/ppapi/proxy/ |
| host_resolver_resource_base.cc | 36 HostResolverResourceBase::HostResolverResourceBase(Connection connection,
39 : PluginResource(connection, instance),
107 new NetAddressResource(connection(), pp_instance(), *iter));
|
| ext_crx_file_system_private_resource.h | 25 #include "ppapi/proxy/connection.h"
42 ExtCrxFileSystemPrivateResource(Connection connection, PP_Instance instance);
|
| file_system_resource.h | 12 #include "ppapi/proxy/connection.h"
28 FileSystemResource(Connection connection,
|
| flash_menu_resource.h | 24 FlashMenuResource(Connection connection, PP_Instance instance);
|
| host_resolver_private_resource.h | 21 HostResolverPrivateResource(Connection connection,
|
| /external/chromium_org/remoting/host/ |
| client_session.cc | 45 scoped_ptr<protocol::ConnectionToClient> connection,
50 connection_(connection.Pass()),
74 // later and set them only when connection is authenticated.
198 protocol::ConnectionToClient* connection) {
200 DCHECK_EQ(connection_.get(), connection);
220 // Disconnect the session if the connection was rejected by the host.
226 // Create the desktop environment. Drop the connection if it could not be
284 protocol::ConnectionToClient* connection) {
286 DCHECK_EQ(connection_.get(), connection);
313 protocol::ConnectionToClient* connection,
[all...] |
| /frameworks/base/core/java/android/hardware/usb/ |
| UsbRequest.java | 61 public boolean initialize(UsbDeviceConnection connection, UsbEndpoint endpoint) {
63 return native_init(connection, endpoint.getAddress(), endpoint.getAttributes(),
177 private native boolean native_init(UsbDeviceConnection connection, int ep_address,
|
| /frameworks/base/media/java/android/mtp/ |
| MtpDevice.java | 28 * device and objects stored on it, as well as open the connection and transfer data.
52 * The connection will be closed when you call {@link #close()}
53 * The connection will also be closed if this method fails.
55 * @param connection an open {@link android.hardware.usb.UsbDeviceConnection} for the device
58 public boolean open(UsbDeviceConnection connection) {
59 boolean result = native_open(mDevice.getDeviceName(), connection.getFileDescriptor());
61 connection.close();
|
| /external/apache-http/src/org/apache/http/impl/conn/ |
| IdleConnectionHandler.java | 44 * A helper class for connection managers to track idle connections.
66 * Registers the given connection with this handler. The connection will be held until
69 * @param connection the connection to add
73 public void add(HttpConnection connection, long validDuration, TimeUnit unit) {
78 log.debug("Adding connection at: " + timeAdded);
81 connectionToTimes.put(connection, new TimeValues(timeAdded, validDuration, unit));
85 * Removes the given connection from the list of connections to be closed when idle.
86 * This will return true if the connection is still valid, and fals
[all...] |
| /external/chromium_org/content/browser/indexed_db/ |
| indexed_db_database_unittest.cc | 45 virtual void OnSuccess(scoped_ptr<IndexedDBConnection> connection,
47 connection_ = connection.Pass();
50 IndexedDBConnection* connection() { return connection_.get(); } function in class:content::MockOpenCallbacks
93 EXPECT_FALSE(backing_store->HasOneRef()); // db, connection count > 0
103 EXPECT_FALSE(backing_store->HasOneRef()); // local and connection
105 db->Close(request1->connection());
107 EXPECT_FALSE(backing_store->HasOneRef()); // local and connection
109 db->Close(request2->connection());
152 EXPECT_EQ(database, request->connection()->database());
157 request->connection(),
[all...] |
| /external/chromium_org/net/tools/quic/ |
| quic_client.cc | 64 session()->connection()->SendConnectionClosePacket(
147 return session_->connection()->connected();
166 session_->connection()->connected();
172 session()->connection()->SendConnectionClose(QUIC_PEER_GOING_AWAY);
229 session_->connection()->OnCanWrite();
244 return session_.get() && session_->connection() &&
245 session_->connection()->connected();
269 QuicGuid our_guid = session_->connection()->guid();
283 session_->connection()->ProcessUdpPacket(
|
