| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/dummy/ |
| connection.py | 2 # Analogue of `multiprocessing.connection` which uses queues instead of sockets
4 # multiprocessing/dummy/connection.py
49 return Connection(*self._backlog_queue.get())
60 return Connection(_in, _out)
65 return Connection(a, b), Connection(b, a)
68 class Connection(object):
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/dummy/ |
| connection.py | 2 # Analogue of `multiprocessing.connection` which uses queues instead of sockets
4 # multiprocessing/dummy/connection.py
49 return Connection(*self._backlog_queue.get())
60 return Connection(_in, _out)
65 return Connection(a, b), Connection(b, a)
68 class Connection(object):
|
| /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...] |
| httpserver.h | 86 // Stop processing the connection indicated by connection_id.
97 class Connection : private IHttpNotify {
99 Connection(int connection_id, HttpServer* server);
100 virtual ~Connection();
120 Connection* Find(int connection_id);
123 friend class Connection;
124 typedef std::map<int,Connection*> ConnectionMap;
|
| /external/chromium_org/ppapi/proxy/ |
| net_address_resource.h | 21 NetAddressResource(Connection connection,
24 NetAddressResource(Connection connection,
27 NetAddressResource(Connection connection,
|
| broker_resource.h | 8 #include "ppapi/proxy/connection.h"
19 BrokerResource(Connection connection, PP_Instance instance);
|
| browser_font_singleton_resource.h | 8 #include "ppapi/proxy/connection.h"
21 BrowserFontSingletonResource(Connection connection, PP_Instance instance);
|
| plugin_proxy_delegate.h | 41 Connection connection,
|
| /external/ganymed-ssh2/examples/ |
| PortForwarding.java | 8 import ch.ethz.ssh2.Connection;
34 /* Create a connection instance */
36 Connection conn = new Connection(hostname);
54 * Whenever a connection is made to this port (127.0.0.1:8080), the connection is forwarded
55 * over the secure channel, and a connection is made to www.ethz.ch:80 from the remote
74 * 8080 on the remote side (the ssh server), and whenever a connection is made to this port, the
75 * connection is forwarded over the secure channel, and a connection is made t
[all...] |
| /external/smack/src/org/jivesoftware/smackx/ |
| XHTMLManager.java | 24 import org.jivesoftware.smack.Connection;
43 // Enable the XHTML support on every established connection
46 Connection.addConnectionCreationListener(new ConnectionCreationListener() {
47 public void connectionCreated(Connection connection) {
48 XHTMLManager.setServiceEnabled(connection, true);
96 * Enables or disables the XHTML support on a given connection.<p>
101 * @param connection the connection where the service will be enabled or disabled
104 public synchronized static void setServiceEnabled(Connection connection, boolean enabled)
[all...] |
| /external/apache-harmony/sql/src/test/java/org/apache/harmony/sql/tests/javax/sql/ |
| Impl_PooledConnection.java | 20 import java.sql.Connection;
33 public Connection getConnection() throws SQLException {
|
| /external/chromium/chrome/browser/history/ |
| download_database.h | 15 class Connection;
56 virtual sql::Connection& GetDB() = 0;
|
| /external/chromium_org/chrome/browser/predictors/ |
| predictor_table_base.cc | 9 #include "sql/connection.h"
21 void PredictorTableBase::Initialize(sql::Connection* db) {
31 sql::Connection* PredictorTableBase::DB() {
|
| /external/chromium_org/components/webdata/common/ |
| web_database.h | 13 #include "sql/connection.h"
55 sql::Connection* GetSQLConnection();
62 sql::Connection db_;
|
| /external/chromium_org/sync/engine/net/ |
| server_connection_manager.h | 141 class Connection {
143 explicit Connection(ServerConnectionManager* scm);
144 virtual ~Connection();
214 // Factory method to create an Connection object we can use for
216 virtual Connection* MakeConnection();
270 // Helper to check terminated flags and build a Connection object, installing
273 Connection* MakeActiveConnection();
275 // Called by Connection objects as they are destroyed to allow the
277 void OnConnectionDestroyed(Connection* connection);
[all...] |
| /frameworks/native/services/surfaceflinger/ |
| EventThread.cpp | 57 sp<EventThread::Connection> EventThread::createEventConnection() const {
58 return new Connection(const_cast<EventThread*>(this));
62 const sp<EventThread::Connection>& connection) {
64 mDisplayEventConnections.add(connection);
70 const wp<EventThread::Connection>& connection) {
72 mDisplayEventConnections.remove(connection);
76 const sp<EventThread::Connection>& connection) {
335 sp<Connection> connection = local
[all...] |
| /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/importer/ |
| safari_importer.h | 36 class Connection;
96 bool OpenDatabase(sql::Connection* db);
99 void ImportFaviconURLs(sql::Connection* db, FaviconMap* favicon_map);
102 void LoadFaviconData(sql::Connection* db,
|
| /external/chromium_org/chrome/browser/extensions/activity_log/ |
| counting_policy.h | 47 virtual bool InitDatabase(sql::Connection* db) OVERRIDE;
48 virtual bool FlushDatabase(sql::Connection* db) OVERRIDE;
64 bool CleanOlderThan(sql::Connection* db, const base::Time& cutoff);
68 bool CleanStringTables(sql::Connection* db);
|
| /external/chromium_org/chrome/browser/history/ |
| history_database.h | 17 #include "sql/connection.h"
34 // Encapsulates the SQL connection for the history database. This class holds
35 // the database connection and has methods the history system (including full
72 // underlying database connection.
74 const sql::Connection::ErrorCallback& error_callback) {
184 virtual sql::Connection& GetDB() OVERRIDE;
204 sql::Connection::ErrorCallback error_callback_;
205 sql::Connection db_;
|
| /external/chromium_org/chrome/utility/importer/ |
| safari_importer.h | 32 class Connection;
87 bool OpenDatabase(sql::Connection* db);
90 void ImportFaviconURLs(sql::Connection* db, FaviconMap* favicon_map);
93 void LoadFaviconData(sql::Connection* db,
|
| /external/chromium_org/sql/test/ |
| scoped_error_ignorer.h | 11 #include "sql/connection.h"
15 // sql::Connection and sql::Statement treat most SQLite errors as
47 // Storage for callback passed to Connection::SetErrorIgnorer().
48 Connection::ErrorIgnorerCallback callback_;
|
| /libcore/luni/src/main/java/java/sql/ |
| Driver.java | 36 * Returns whether the driver thinks that it can open a connection to the
41 * @return {@code true} if the driver thinks that is can open a connection
51 * Attempts to make a database connection to a data source specified by a
58 * connection. The properties consist of name/value pairs of
59 * strings. Normally, a connection to a database requires at
62 * @return the connection to the database.
66 public Connection connect(String url, Properties info) throws SQLException;
86 * the client of the driver must supply in order to establish a connection
|
| /hardware/samsung_slsi/exynos5/mobicore/daemon/Daemon/Server/ |
| Server.cpp | 5 * Connection server.
102 Connection *connection = (*iterator); local
103 int peerSocket = connection->socketDescriptor;
135 LOG_V(" Server: new connection attempt.");
150 Connection *connection = new Connection(clientSock, &clientAddr); local
151 peerConnections.push_back(connection);
152 LOG_I(" Server: new socket connection established and start listening.")
164 Connection *connection = (*iterator); local
[all...] |
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| p2ptransportchannel.cc | 45 // well on a 28.8K modem, which is the slowest connection on which the voice
51 // If there is a current writable connection, then we will also try hard to
77 int CompareConnectionCandidates(cricket::Connection* a,
78 cricket::Connection* b) {
97 int CompareConnections(cricket::Connection *a, cricket::Connection *b) {
108 // Wraps the comparison connection into a less than operator that puts higher
112 bool operator()(const cricket::Connection *ca,
113 const cricket::Connection *cb) {
114 cricket::Connection* a = const_cast<cricket::Connection*>(ca)
410 Connection* connection = port->GetConnection(remote_candidate.address()); local
[all...] |
