| /external/curl/docs/cmdline-opts/ |
| keepalive-time.d | 6 This option sets the time a connection needs to remain idle before sending
|
| /external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| GenericAttachingConnector.java | 116 Connection connection = transportService.attach(address, timeout, 0); local
117 return Bootstrap.virtualMachineManager().createVirtualMachine(connection);
|
| TargetVM.java | 30 import com.sun.jdi.connect.spi.Connection;
41 private Connection connection; field in class:TargetVM
53 TargetVM(VirtualMachineImpl vm, Connection connection) {
55 this.connection = connection;
118 byte b[] = connection.readPacket();
130 connection.close();
295 connection.writePacket(packet.toByteArray())
[all...] |
| VirtualMachineManagerImpl.java | 222 Connection connection,
225 if (!connection.isOpen()) {
226 throw new IllegalStateException("connection is not open");
231 vm = new VirtualMachineImpl(this, connection, process,
240 public VirtualMachine createVirtualMachine(Connection connection) throws IOException {
241 return createVirtualMachine(connection, null);
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
| Internal.java | 59 public abstract void put(ConnectionPool pool, RealConnection connection);
61 public abstract boolean connectionBecameIdle(ConnectionPool pool, RealConnection connection);
|
| /external/skia/tools/skiaserve/urlhandlers/ |
| BreakHandler.cpp | 22 int BreakHandler::handle(Request* request, MHD_Connection* connection,
83 return SendData(connection, stream.detachAsData().get(), "application/json");
|
| /external/skqp/tools/skiaserve/urlhandlers/ |
| BreakHandler.cpp | 22 int BreakHandler::handle(Request* request, MHD_Connection* connection,
83 return SendData(connection, stream.detachAsData().get(), "application/json");
|
| /external/swiftshader/include/vulkan/ |
| vk_icd.h | 80 * contains the platform-specific connection and surface information.
101 MirConnection *connection; member in struct:__anon39860
125 xcb_connection_t *connection; member in struct:__anon39863
|
| /external/vulkan-headers/include/vulkan/ |
| vk_icd.h | 80 * contains the platform-specific connection and surface information.
101 MirConnection *connection; member in struct:__anon49080
125 xcb_connection_t *connection; member in struct:__anon49083
|
| /development/samples/ToyVpn/src/com/example/android/toyvpn/ |
| ToyVpnService.java | 47 private static class Connection extends Pair<Thread, ParcelFileDescriptor> {
48 public Connection(Thread thread, ParcelFileDescriptor pfd) {
54 private final AtomicReference<Connection> mConnection = new AtomicReference<>();
67 // Create the intent to "configure" the connection (just start ToyVpnClient).
118 private void startConnection(final ToyVpnConnection connection) {
120 final Thread thread = new Thread(connection, "ToyVpnThread");
124 connection.setConfigureIntent(mConfigureIntent);
125 connection.setOnEstablishListener(tunInterface -> {
129 setConnection(new Connection(thread, tunInterface));
141 private void setConnection(final Connection connection)
[all...] |
| /external/libchrome/dbus/ |
| exported_object.cc | 191 DBusConnection* connection,
303 void ExportedObject::OnUnregistered(DBusConnection* connection) {
307 DBusConnection* connection,
311 return self->HandleMessage(connection, raw_message);
314 void ExportedObject::OnUnregisteredThunk(DBusConnection *connection,
317 return self->OnUnregistered(connection);
|
| /external/webrtc/webrtc/p2p/base/ |
| p2ptransportchannel.h | 11 // P2PTransportChannel wraps up the state management of the connection between
15 // Bob are used to make a connection, repeat to make many connections).
63 // P2PTransportChannel manages the candidates and connection process to keep
105 const Connection* best_connection() const { return best_connection_; }
171 Connection* FindNextPingableConnection();
174 const std::vector<Connection*>& connections() const { return connections_; }
190 // A transport channel is weak if the current best connection is either
191 // not receiving or not writable, or if there is no best connection at all.
196 void SwitchBestConnectionTo(Connection* conn);
202 Connection* GetBestConnectionOnNetwork(rtc::Network* network) const
[all...] |
| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| RemoteConferenceTest.java | 25 import android.telecom.Connection;
51 public static final int CONF_CAPABILITIES = Connection.CAPABILITY_SEPARATE_FROM_CONFERENCE |
52 Connection.CAPABILITY_DISCONNECT_FROM_CONFERENCE | Connection.CAPABILITY_HOLD |
53 Connection.CAPABILITY_MERGE_CONFERENCE | Connection.CAPABILITY_SWAP_CONFERENCE;
84 assertConnectionState(mConnection1, Connection.STATE_ACTIVE);
85 assertConnectionState(mConnection2, Connection.STATE_ACTIVE);
86 assertConnectionState(mRemoteConnection1, Connection.STATE_ACTIVE);
87 assertConnectionState(mRemoteConnection2, Connection.STATE_ACTIVE)
[all...] |
| /external/libevent/ |
| evrpc.c | 503 static int evrpc_schedule_request(struct evhttp_connection *connection,
539 struct evhttp_connection *connection; local
555 while ((connection = TAILQ_FIRST(&pool->connections)) != NULL) {
556 TAILQ_REMOVE(&pool->connections, connection, next);
557 evhttp_connection_free(connection);
574 * Add a connection to the RPC pool. A request scheduled on the pool
575 * may use any available connection.
580 struct evhttp_connection *connection)
582 EVUTIL_ASSERT(connection->http_server == NULL);
583 TAILQ_INSERT_TAIL(&pool->connections, connection, next)
639 struct evhttp_connection *connection; local
720 struct evhttp_connection *connection = ctx->evcon; local
[all...] |
| /external/antlr/runtime/Ruby/lib/antlr3/debug/ |
| socket.rb | 31 @connection = nil
45 log!( "waiting for incoming connection on port %i\n", @port )
47 @connection, addr = @socket.accept
49 log!( "Accepted connection from %s:%s\n", host, port )
51 @connection.setsockopt( Socket::SOL_TCP, Socket::TCP_NODELAY, 1 )
61 @connection and @connection.close
73 @connection.printf( message, *interpolation_arguments )
74 @connection.flush
78 line = @connection.readlin
[all...] |
| /external/apache-http/android/src/android/net/http/ |
| RequestQueue.java | 57 /* default simultaneous connection count */
61 * This class maintains active connection threads
144 Connection connection = mThreads[i].mConnection; local
145 if (connection != null) connection.setCanPersist(false);
157 Connection connection = ct.mConnection; local
158 if (connection != null && connection.mHost.equals(host))
[all...] |
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/framework/jdwp/ |
| PacketDispatcher.java | 40 * events through established JDWP connection and supports timeout for these
143 // if eventQueue is empty and connection is already closed
163 // if eventQueue is empty and connection is already
176 * This method is called when connection is closed. It notifies all the
188 * through connection and returns replies.
273 // if connection is already closed reraise the exception
302 // write this package to connection
303 connection.writePacket(command.toBytesArray());
306 // if connection is already closed reraise the exception
324 // if connection is already closed reraise the exceptio
448 private TransportWrapper connection; field in class:PacketDispatcher
[all...] |
| /external/libbrillo/brillo/http/ |
| http_transport_fake.cc | 35 std::shared_ptr<http::Connection> Transport::CreateConnection(
42 std::shared_ptr<http::Connection> connection; local
46 return connection;
57 connection =
58 std::make_shared<http::fake::Connection>(url, method, shared_from_this());
59 CHECK(connection) << "Unable to create Connection object";
60 if (!connection->SendHeaders(headers_copy, error))
61 connection.reset()
[all...] |
| /external/python/cpython2/Lib/multiprocessing/ |
| connection.py | 4 # multiprocessing/connection.py
141 Accept a connection on the bound socket or named pipe of `self`.
143 Returns a `Connection` object.
163 Returns a connection to the address of a `Listener`
185 Returns pair of connection objects at either end of a pipe
191 c1 = _multiprocessing.Connection(os.dup(s1.fileno()))
192 c2 = _multiprocessing.Connection(os.dup(s2.fileno()))
197 c1 = _multiprocessing.Connection(fd1, writable=False)
198 c2 = _multiprocessing.Connection(fd2, readable=False)
207 Returns pair of connection objects at either end of a pip
[all...] |
| /development/samples/USB/AdbTest/src/com/android/adb/ |
| AdbTestActivity.java | 132 UsbDeviceConnection connection = mManager.openDevice(device); local
133 if (connection != null) {
135 if (connection.claimInterface(intf, false)) {
138 mDeviceConnection = connection;
146 connection.close();
|
| AdbDevice.java | 48 public AdbDevice(AdbTestActivity activity, UsbDeviceConnection connection,
51 mDeviceConnection = connection;
52 mSerial = connection.getSerial();
|
| /frameworks/av/media/bufferpool/1.0/ |
| Accessor.cpp | 20 #include "Connection.h"
101 ALOGD("connection %lld closed on death", (long long)it->first);
118 sp<Connection> connection; local
122 ResultStatus status = connect(&connection, &connectionId, &fmqDesc, false);
124 _hidl_cb(status, connection, connectionId, *fmqDesc);
164 sp<Connection> *connection, ConnectionId *pConnectionId,
167 ResultStatus status = mImpl->connect(this, connection, pConnectionId, fmqDescPtr);
|
| /frameworks/av/media/bufferpool/2.0/ |
| Accessor.cpp | 20 #include "Connection.h"
101 ALOGD("connection %lld closed on death", (long long)it->first);
124 sp<Connection> connection; local
131 observer, false, &connection, &connectionId, &msgId, &fmqDesc, &invDesc);
133 _hidl_cb(status, connection, connectionId, msgId, *fmqDesc, *invDesc);
185 sp<Connection> *connection, ConnectionId *pConnectionId,
191 this, observer, connection, pConnectionId, pMsgId,
|
| /external/autotest/site_utils/ |
| log_socket_server.py | 39 chunk = self.connection.recv(4)
43 chunk = self.connection.recv(slen)
45 chunk = chunk + self.connection.recv(slen - len(chunk))
|
| /external/autotest/site_utils/stats/ |
| mysql_stats.py | 56 """Maintains a db connection and a cursor."""
67 """Establishes a MySQL connection and creates a cursor."""
72 """Attempts to close the connection, then reconnects."""
100 def GetStatus(connection, status):
103 @param connection: MySQLdb cursor to query with.
107 connection.Execute('SHOW GLOBAL STATUS LIKE "%s";' % status)
108 output = connection.Fetchall()[0][1]
121 @param conn: The mysql connection object.
157 @param conn: The mysql connection object.
|
