| /external/clang/test/CodeGenCXX/ |
| incomplete-member-function-pointer.cpp | 4 struct connection { struct
7 void (connection::*a)(fake_tuple) = &connection::bar;
9 void (connection::*b)(fake_tuple) = &connection::bar;
|
| /hardware/samsung_slsi/exynos5/mobicore/daemon/Daemon/Server/public/ |
| ConnectionHandler.h | 5 * Interface for connection handlers used by Server.
36 #include "Connection.h"
46 * Handle connection activities.
47 * The connection handler shall process pending connection activities.
49 * @param [in] connection Reference to the connection which has data to process.
52 Connection *connection
56 * Connection has been closed
[all...] |
| /external/smack/src/org/jivesoftware/smack/ |
| ConnectionCreationListener.java | 24 * Implementors of this interface will be notified when a new {@link Connection}
25 * has been created. The newly created connection will not be actually connected to
26 * the server. Use {@link Connection#addConnectionCreationListener(ConnectionCreationListener)}
34 * Notification that a new connection has been created. The new connection
37 * @param connection the newly created connection.
39 public void connectionCreated(Connection connection);
|
| BOSHPacketReader.java | 39 * Listens for XML traffic from the BOSH connection manager and parses it into
46 private BOSHConnection connection; field in class:BOSHPacketReader
50 * HTTP responses, parse the packets and notifies the connection.
52 * @param connection the corresponding connection for the received packets.
54 public BOSHPacketReader(BOSHConnection connection) {
55 this.connection = connection;
59 * Parse the received packets and notify the corresponding connection.
67 if (connection.sessionID == null)
[all...] |
| ReconnectionManager.java | 23 * Handles the automatic reconnection process. Every time a connection is dropped without
38 // Holds the connection to the server
39 private Connection connection;
field in class:ReconnectionManager
47 // Create a new PrivacyListManager on every established connection. In the init()
49 // instance when the connection is closed.
50 Connection.addConnectionCreationListener(new ConnectionCreationListener() {
51 public void connectionCreated(Connection connection) {
52 connection.addConnectionListener(new ReconnectionManager(connection));
[all...] |
| PacketReader.java | 23 import org.jivesoftware.smack.Connection.ListenerWrapper;
40 * @see Connection#createPacketCollector
41 * @see Connection#addPacketListener
49 private XMPPConnection connection; field in class:PacketReader
55 protected PacketReader(final XMPPConnection connection) {
56 this.connection = connection;
62 * first connection and when reconnecting due to an abruptly disconnection.
73 readerThread.setName("Smack Packet Reader (" + connection.connectionCounterValue + ")");
82 "Smack Listener Processor (" + connection.connectionCounterValue + ")")
[all...] |
| /hardware/samsung_slsi/exynos5/mobicore/daemon/Daemon/ |
| MobiCoreDriverDaemon.h | 50 Connection *conn;
56 Connection *conn,
98 Connection *connection
102 Connection *connection
128 Connection *connection,
153 Connection *connection
[all...] |
| /external/smack/src/org/jivesoftware/smackx/pubsub/ |
| CollectionNode.java | 22 import org.jivesoftware.smack.Connection;
26 CollectionNode(Connection connection, String nodeId)
28 super(connection, nodeId);
|
| /external/chromium/app/sql/ |
| diagnostic_error_delegate.h | 9 #include "app/sql/connection.h"
28 virtual int OnError(int error, Connection* connection,
31 << ", errno " << connection->GetLastErrno()
32 << ": " << connection->GetErrorMessage();
|
| /external/chromium/chrome/browser/webdata/ |
| web_database_migration_unittest.cc | 188 static int VersionFromConnection(sql::Connection* connection) {
190 sql::Statement s(connection->GetUniqueStatement(
221 sql::Connection connection; local
222 ASSERT_TRUE(connection.Open(GetDatabasePath()));
223 ASSERT_TRUE(connection.Execute(contents.data()));
237 sql::Connection connection; local
238 ASSERT_TRUE(connection.Open(GetDatabasePath()))
298 sql::Connection connection; local
328 sql::Connection connection; local
347 sql::Connection connection; local
375 sql::Connection connection; local
396 sql::Connection connection; local
423 sql::Connection connection; local
441 sql::Connection connection; local
463 sql::Connection connection; local
477 sql::Connection connection; local
500 sql::Connection connection; local
540 sql::Connection connection; local
572 sql::Connection connection; local
610 sql::Connection connection; local
644 sql::Connection connection; local
662 sql::Connection connection; local
681 sql::Connection connection; local
702 sql::Connection connection; local
746 sql::Connection connection; local
763 sql::Connection connection; local
807 sql::Connection connection; local
865 sql::Connection connection; local
946 sql::Connection connection; local
988 sql::Connection connection; local
1260 sql::Connection connection; local
1285 sql::Connection connection; local
1312 sql::Connection connection; local
1341 sql::Connection connection; local
1373 sql::Connection connection; local
1398 sql::Connection connection; local
[all...] |
| /hardware/samsung_slsi/exynos5/mobicore/daemon/Daemon/Server/ |
| NetlinkServer.cpp | 5 * Connection server.
91 // This buffer will be taken over by the connection it was routed to
103 // Read the incomming message and route it to the connection based
130 /* First cleanup the connection list */
133 NetlinkConnection *connection = findConnection(hash); local
135 if (connection == NULL) {
136 //LOG_I("%s: Cound't find the connection, creating a new one", __FUNCTION__);
137 connection = new NetlinkConnection(this, serverSock, pid, seq);
138 // Add the new connection
139 insertConnection(hash, connection);
237 NetlinkConnection *connection = NULL; local
[all...] |
| /external/smack/src/org/jivesoftware/smackx/ping/ |
| ServerPingTask.java | 22 import org.jivesoftware.smack.Connection;
28 // reference to connection so that it can be GCed.
29 private WeakReference<Connection> weakConnection;
34 protected ServerPingTask(Connection connection) {
35 this.weakConnection = new WeakReference<Connection>(connection);
39 Connection connection = weakConnection.get(); local
40 if (connection == null)
[all...] |
| /external/qemu/android/ |
| adb-server.h | 30 * connection - An opaque pointer defining the connection between the host and
32 * host <-> guest connection.
34 typedef void (*adbguest_connect)(void* opaque, void* connection);
41 * connection - An opaque pointer defining the connection between the host and
43 * host <-> guest connection.
47 void* connection,
56 * connection - An opaque pointer defining the connection between the host an
[all...] |
| /libcore/luni/src/main/java/libcore/net/http/ |
| HttpConnectionPool.java | 65 // First try to reuse an existing HTTP connection.
69 HttpConnection connection = connections.remove(connections.size() - 1); local
74 if (connection.isEligibleForRecycling()) {
76 Socket socket = connection.getSocket();
78 return connection;
84 * We couldn't find a reusable connection, so we need to create a new
85 * connection. We're careful not to do so while holding a lock!
90 public void recycle(HttpConnection connection) {
91 Socket socket = connection.getSocket();
97 connection.closeSocketAndStreams()
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/testdata/handlers/sub/ |
| no_wsh_at_the_end.py | 40 request.connection.write(
|
| plain_wsh.py | 36 request.connection.write('sub/plain_wsh.py is called for %s, %s' %
|
| wrong_handshake_sig_wsh.py | 40 request.connection.write(
|
| wrong_transfer_sig_wsh.py | 40 request.connection.write(
|
| /frameworks/volley/src/com/android/volley/toolbox/ |
| HurlStack.java | 102 HttpURLConnection connection = openConnection(parsedUrl, request); local
104 connection.addRequestProperty(headerName, map.get(headerName));
106 setConnectionParametersForRequest(connection, request);
109 int responseCode = connection.getResponseCode();
112 // Signal to the caller that something was wrong with the connection.
116 connection.getResponseCode(), connection.getResponseMessage());
118 response.setEntity(entityFromConnection(connection));
119 for (Entry<String, List<String>> header : connection.getHeaderFields().entrySet()) {
130 * @param connection
162 HttpURLConnection connection = createConnection(url); local
[all...] |
| /external/chromium/net/server/ |
| http_server.cc | 24 int HttpServer::Connection::lastId_ = 0;
73 Connection* connection = FindConnection(connection_id); local
74 if (connection == NULL)
94 connection->is_web_socket_ = true;
95 connection->socket_->Send(base::StringPrintf(
98 "Connection: Upgrade\r\n"
104 connection->socket_->Send(reinterpret_cast<char*>(digest.a), 16);
109 Connection* connection = FindConnection(connection_id) local
122 Connection* connection = FindConnection(connection_id); local
130 Connection* connection = FindConnection(connection_id); local
140 Connection* connection = FindConnection(connection_id); local
155 Connection* connection = FindConnection(connection_id); local
166 Connection* connection = FindConnection(connection_id); local
182 Connection* connection = FindConnection(connection_id); local
363 Connection* connection = new Connection(this, socket); local
371 Connection* connection = FindConnection(socket); local
419 Connection* connection = FindConnection(socket); local
[all...] |
| /external/chromium/chrome/browser/sync/syncable/ |
| directory_backing_store_unittest.cc | 9 #include "app/sql/connection.h"
75 sql::Connection connection; local
76 ASSERT_TRUE(connection.Open(GetDatabasePath()));
77 ASSERT_TRUE(connection.BeginTransaction());
78 ASSERT_TRUE(connection.Execute(
190 ASSERT_TRUE(connection.CommitTransaction());
200 sql::Connection connection; local
201 ASSERT_TRUE(connection.Open(GetDatabasePath()))
304 sql::Connection connection; local
426 sql::Connection connection; local
536 sql::Connection connection; local
642 sql::Connection connection; local
746 sql::Connection connection; local
851 sql::Connection connection; local
957 sql::Connection connection; local
990 sql::Connection connection; local
1020 sql::Connection connection; local
1038 sql::Connection connection; local
1053 sql::Connection connection; local
1072 sql::Connection connection; local
1103 sql::Connection connection; local
1118 sql::Connection connection; local
1127 sql::Connection connection; local
1143 sql::Connection connection; local
1153 sql::Connection connection; local
1181 sql::Connection connection; local
1203 sql::Connection connection; local
1220 sql::Connection connection; local
1281 sql::Connection connection; local
[all...] |
| /external/okhttp/src/main/java/com/squareup/okhttp/ |
| ConnectionPool.java | 20 * {@link com.squareup.okhttp.Connection}. This class implements the policy of
31 * connection alive in the pool before closing it. Default is 5 minutes.
65 private final LinkedList<Connection> connections = new LinkedList<Connection>();
72 List<Connection> expiredConnections = new ArrayList<Connection>(MAX_CONNECTIONS_TO_CLEANUP);
75 for (ListIterator<Connection> i = connections.listIterator(connections.size());
77 Connection connection = i.previous();
78 if (!connection.isAlive() || connection.isExpired(keepAliveDurationNs))
166 Connection connection = i.next(); local
[all...] |
| /external/valgrind/main/gdbserver_tests/ |
| mcmain_pic.stderrB.exp | 3 Remote connection closed
|
| nlpasssigalrm.stderrB.exp | 3 Remote connection closed
|
| /external/webkit/Source/WebKit2/Platform/CoreIPC/ |
| MessageSender.h | 30 #include "Connection.h"
51 Connection* connection = static_cast<T*>(this)->connection(); local
52 ASSERT(connection);
54 return connection->sendMessage(messageID, argumentEncoder);
57 template<typename U> bool sendSync(const U& message, const typename U::Reply& reply, double timeout = Connection::NoTimeout)
62 template<typename U> bool sendSync(const U& message, const typename U::Reply& reply, uint64_t destinationID, double timeout = Connection::NoTimeout)
64 Connection* connection = static_cast<T*>(this)->connection() local
[all...] |
