| /external/deqp/framework/platform/lnx/X11/ |
| tcuLnxX11Xcb.cpp | 62 xcb_connection_t* connection = m_display.getConnection(); local
64 m_window = xcb_generate_id(connection);
65 m_colormap = xcb_generate_id(connection);
74 connection, // Connection
89 connection,
96 xcb_alloc_color_reply_t* rep = xcb_alloc_color_reply(connection, xcb_alloc_color(connection, m_colormap, 65535, 0, 0), NULL);
98 xcb_flush (connection);
|
| /external/jacoco/org.jacoco.core/src/org/jacoco/core/runtime/ |
| URLStreamHandlerRuntime.java | 73 // final URLConnection connection = url.openConnection();
78 // connection.equals(args);
133 return connection;
137 private final URLConnection connection = new URLConnection(null) { field in class:URLStreamHandlerRuntime
|
| /external/jacoco/org.jacoco.examples/src/org/jacoco/examples/ |
| MBeanClient.java | 41 // Open connection to the coverage agent:
44 final MBeanServerConnection connection = jmxc local
48 .newProxyInstance(connection, new ObjectName(
61 // Close connection:
|
| /external/libbrillo/brillo/http/ |
| http_connection_fake.cc | 18 Connection::Connection(const std::string& url,
21 : http::Connection(transport), request_(url, method) {
22 VLOG(1) << "fake::Connection created: " << method;
25 Connection::~Connection() {
26 VLOG(1) << "fake::Connection destroyed";
29 bool Connection::SendHeaders(const HeaderList& headers,
35 bool Connection::SetRequestData(StreamPtr stream,
41 bool Connection::FinishRequest(brillo::ErrorPtr* /* error */)
65 auto connection = std::static_pointer_cast<Connection>(shared_from_this()); local
[all...] |
| /external/libmicrohttpd/src/examples/ |
| mhd2spdy.c | 79 struct SPDY_Connection *connection; local
202 connection = glob_opt.spdy_connections_head;
203 while(NULL != connection)
205 connection_for_delete = connection;
206 connection = connection_for_delete->next;
244 " connection to the requested server. If the\n"
|
| /external/nanohttpd/core/src/test/java/fi/iki/elonen/integration/ |
| ShutdownTest.java | 70 fail("Connection should be closed!");
77 HttpURLConnection connection = (HttpURLConnection) new URL("http://localhost:8092/").openConnection(); local
79 connection.addRequestProperty("Connection", "keep-alive");
80 InputStream in = connection.getInputStream();
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| Http2ConnectionTest.java | 67 connection(peer, HTTP_2); method
87 FramedConnection connection = connection(peer, HTTP_2); local
88 Ping ping = connection.ping();
96 assertEquals(0x4f4b6f6b, pingFrame.payload2); // connection.ping() sets this.
115 FramedConnection connection = connection(peer, HTTP_2);
118 assertEquals(65535, connection.peerSettings.getInitialWindowSize(-1));
130 // This stream was created *after* the connection settings were adjusted.
131 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, true)
[all...] |
| /external/python/cpython2/Modules/_sqlite/ |
| cursor.h | 29 #include "connection.h"
35 pysqlite_Connection* connection; member in struct:__anon32733
|
| /frameworks/support/browser/src/main/java/androidx/browser/customtabs/ |
| CustomTabsClient.java | 63 * @param connection {@link CustomTabsServiceConnection} to use when binding. This will
70 String packageName, CustomTabsServiceConnection connection) {
73 return context.bindService(intent, connection,
128 * implementation. Since service connection is asynchronous, the return code is not the return
141 CustomTabsServiceConnection connection = new CustomTabsServiceConnection() { local
148 // likely to get killed, but is preferable to keeping the connection around.
156 return bindCustomTabsService(applicationContext, packageName, connection);
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| OldJarURLConnectionTest.java | 162 JarURLConnection connection = (JarURLConnection) url.openConnection(); local
164 connection.connect();
171 connection.getJarFile();
231 JarURLConnection connection = (JarURLConnection) url.openConnection(); local
232 connection.setUseCaches(false);
233 connection.getInputStream();
234 InputStream in = connection.getInputStream();
235 JarFile jarFile1 = connection.getJarFile();
236 JarEntry jarEntry1 = connection.getJarEntry();
239 JarFile jarFile2 = connection.getJarFile()
[all...] |
| URLStreamHandlerFactoryTest.java | 60 URLConnection connection = url.openConnection(); local
61 assertTrue(connection instanceof Handler.HandlerURLConnection);
93 URLConnection connection = new URL("http://android.com/").openConnection(); local
94 assertTrue(connection instanceof Handler.HandlerURLConnection);
105 // creating a connection should use the platform's default stream handler
110 // set the property and get another connection. The property should not be honored
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/hfpclient/connserv/ |
| HfpClientConference.java | 21 import android.telecom.Connection;
38 Connection.CAPABILITY_SUPPORT_HOLD | Connection.CAPABILITY_HOLD | (manage
39 ? Connection.CAPABILITY_MANAGE_CONFERENCE : 0));
50 public void onMerge(Connection connection) {
51 Log.d(TAG, "onMerge " + connection);
52 addConnection(connection);
56 public void onSeparate(Connection connection) {
[all...] |
| /cts/hostsidetests/devicepolicy/app/ManagedProfile/src/com/android/cts/managedprofile/ |
| DummyConnectionService.java | 20 import android.telecom.Connection;
30 * A simple connection service that hangs up automatically for incoming and outgoing call.
38 public Connection onCreateOutgoingConnection(PhoneAccountHandle connectionManagerPhoneAccount,
40 final DummyConnection connection = new DummyConnection(); local
41 connection.setAddress(request.getAddress(), TelecomManager.PRESENTATION_ALLOWED);
42 connection.setVideoState(request.getVideoState());
43 hangUpAsync(connection);
44 return connection;
48 public Connection onCreateIncomingConnection(PhoneAccountHandle connectionManagerPhoneAccount,
50 final DummyConnection connection = new DummyConnection() local
[all...] |
| /cts/hostsidetests/numberblocking/app/src/com/android/cts/numberblocking/hostside/ |
| CallBlockingTest.java | 24 import android.telecom.Connection;
116 public static class DummyConnection extends Connection {
128 public Connection onCreateIncomingConnection(
130 final Connection connection = new DummyConnection(); local
131 connection.setVideoState(request.getVideoState());
134 connection.setAddress(address, TelecomManager.PRESENTATION_ALLOWED);
135 return connection;
|
| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| CtsSelfManagedConnectionService.java | 21 import android.telecom.Connection;
59 void onDestroyed(SelfManagedConnection connection) {
60 mConnections.remove(connection);
93 public Connection onCreateOutgoingConnection(PhoneAccountHandle connectionManagerAccount,
100 public Connection onCreateIncomingConnection(PhoneAccountHandle connectionManagerPhoneAccount,
119 public Connection onCreateIncomingHandoverConnection(PhoneAccountHandle fromPhoneAccountHandle,
126 public Connection onCreateOutgoingHandoverConnection(PhoneAccountHandle fromPhoneAccountHandle,
152 mConnections.forEach(connection -> {
153 connection.setDisconnected(new DisconnectCause(DisconnectCause.LOCAL));
154 connection.destroy()
164 SelfManagedConnection connection = new SelfManagedConnection(isIncoming, local
[all...] |
| HandoverTest.java | 147 SelfManagedConnection connection = TestUtils.waitForAndGetConnection( local
157 completeHandoverAndVerify(call, connection);
189 SelfManagedConnection connection = TestUtils.waitForAndGetConnection( local
201 completeHandoverAndVerify(call, connection);
218 * @param connection
220 private void completeHandoverAndVerify(final Call call, SelfManagedConnection connection) {
221 // Make the connection active, indicating that the user has accepted the handover.
222 connection.setActive();
228 // Also expect the connection to be informed of handover completion.
229 connection.getHandoverCompleteCounter().waitForCount(1, WAIT_FOR_STATE_CHANGE_TIMEOUT_MS)
[all...] |
| RemoteConnectionTest.java | 27 import android.telecom.Connection;
70 assertConnectionState(mConnection, Connection.STATE_ACTIVE);
71 assertRemoteConnectionState(mRemoteConnectionObject, Connection.STATE_ACTIVE);
72 assertConnectionState(mRemoteConnection, Connection.STATE_ACTIVE);
76 assertConnectionState(mConnection, Connection.STATE_HOLDING);
77 assertRemoteConnectionState(mRemoteConnectionObject, Connection.STATE_HOLDING);
78 assertConnectionState(mRemoteConnection, Connection.STATE_HOLDING);
82 assertConnectionState(mConnection, Connection.STATE_ACTIVE);
83 assertRemoteConnectionState(mRemoteConnectionObject, Connection.STATE_ACTIVE);
84 assertConnectionState(mRemoteConnection, Connection.STATE_ACTIVE)
[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();
|
| /external/ksoap2/ksoap2-j2se/src/main/java/org/ksoap2/transport/ |
| HttpTransportSE.java | 19 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
75 * timeout for connection and Read Timeouts (milliseconds)
91 * timeout for connection and Read Timeouts (milliseconds)
128 * a list of HeaderProperties to be http header properties when establishing the connection
153 ServiceConnection connection = getServiceConnection(); local
154 System.out.println("connection:" + connection);
156 connection.setRequestProperty("User-Agent", USER_AGENT);
163 connection.setRequestProperty("SOAPAction", soapAction);
167 connection.setRequestProperty("Content-Type", CONTENT_TYPE_SOAP_XML_CHARSET_UTF_8)
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| ConnectionPool.java | 38 * {@link Connection}. This class implements the policy of which connections to
49 * connection alive in the pool before closing it. Default is 5 minutes.
81 * thread running per connection pool. We use a thread pool executor because it can shrink to
134 for (RealConnection connection : connections) {
135 if (connection.allocations.isEmpty()) total++;
159 for (RealConnection connection : connections) {
160 if (connection.isMultiplexed()) total++;
170 /** Returns a recycled connection to {@code address}, or null if no such connection exists. */
173 for (RealConnection connection : connections)
214 RealConnection connection = i.next(); local
244 RealConnection connection = i.next(); local
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| StreamAllocation.java | 43 * potentially slow to establish so it is necessary to be able to cancel a connection
46 * connections. Each connection has its own allocation limit, which defines how many
47 * concurrent streams that connection can carry. HTTP/1.x connections can carry 1 stream
51 * connection for better behavior and locality.
58 * <li>{@link #noNewStreams()} prevents the connection from being used for new streams in the
59 * future. Use this after a {@code Connection: close} header, or when the connection may be
65 * <li>{@link #release()} removes the call's hold on the connection. Note that this won't
66 * immediately free the connection if there is a stream still lingering. That happens when a
72 * stream but not the other streams sharing its connection. But if the TLS handshake is still i
81 private RealConnection connection; field in class:StreamAllocation
210 public synchronized RealConnection connection() { method in class:StreamAllocation
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| CookiesTest.java | 279 HttpURLConnection connection = new OkUrlFactory(client).open(server.getUrl("/")); local
281 connection.getRequestProperties());
283 connection.setRequestProperty("Foo", "foo");
284 connection.setDoOutput(true);
285 connection.getOutputStream().write(5);
286 connection.getOutputStream().close();
287 connection.getInputStream().close();
293 "Content-type", "User-Agent", "Connection", "Host");
302 assertContainsAll(connection.getRequestProperties().keySet(), "Foo");
303 assertContainsAll(connection.getRequestProperties().keySet()
354 URLConnection connection = new OkUrlFactory(client).open(server.getUrl(path)); local
[all...] |
| /external/okhttp/okhttp-urlconnection/src/test/java/com/squareup/okhttp/ |
| OkUrlFactoryTest.java | 68 HttpURLConnection connection = factory.open(server.getUrl("/")); local
69 assertResponseHeader(connection, "NETWORK 200");
70 assertResponseBody(connection, "Isla Sorna");
76 HttpURLConnection connection = factory.open(server.getUrl("/")); local
77 assertResponseHeader(connection, "NETWORK 404");
78 connection.getErrorStream().close();
148 HttpURLConnection connection = factory.open(server.getUrl("/a")); local
149 connection.setInstanceFollowRedirects(false);
150 assertResponseBody(connection, "A");
151 assertResponseCode(connection, 302)
168 HttpURLConnection connection = factory.open(server.url("\/a").url()); local
174 HttpURLConnection connection = factory.open(server.url("\/b").url()); local
[all...] |
| /external/volley/src/main/java/com/android/volley/toolbox/ |
| HurlStack.java | 93 HttpURLConnection connection = openConnection(parsedUrl, request); local
95 connection.addRequestProperty(headerName, map.get(headerName));
97 setConnectionParametersForRequest(connection, request);
99 int responseCode = connection.getResponseCode();
102 // Signal to the caller that something was wrong with the connection.
107 return new HttpResponse(responseCode, convertHeaders(connection.getHeaderFields()));
110 return new HttpResponse(responseCode, convertHeaders(connection.getHeaderFields()),
111 connection.getContentLength(), inputStreamFromConnection(connection));
145 * @param connection
162 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); local
179 HttpURLConnection connection = createConnection(url); local
[all...] |
| /external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/ |
| RoomParametersFetcher.java | 75 Log.e(TAG, "Room connection error: " + errorMessage);
175 HttpURLConnection connection = (HttpURLConnection) new URL(url).openConnection(); local
176 connection.setConnectTimeout(TURN_HTTP_TIMEOUT_MS);
177 connection.setReadTimeout(TURN_HTTP_TIMEOUT_MS);
178 int responseCode = connection.getResponseCode();
181 + url + " : " + connection.getHeaderField(null));
183 InputStream responseStream = connection.getInputStream();
185 connection.disconnect();
|
