| /external/python/cpython3/Lib/sqlite3/ |
| dump.py | 10 def _iterdump(connection):
16 directly but instead called from the Connection method, iterdump().
19 cu = connection.cursor()
|
| /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/syzkaller/vendor/golang.org/x/net/http2/ |
| errors.go | 57 // entire connection.
60 func (e ConnectionError) Error() string { return fmt.Sprintf("connection error: %s", ErrCode(e)) }
63 // HTTP/2 connection.
84 // or the connection, as appropriate. For streams, [...]; for the
85 // connection, a GOAWAY frame with a FLOW_CONTROL_ERROR code."
88 func (goAwayFlowError) Error() string { return "connection exceeded flow control window size" }
103 return fmt.Sprintf("http2: connection error: %v: %v", e.Code, e.Reason)
|
| /cts/tests/app/app/src/android/app/stubs/ |
| CommandReceiver.java | 100 ServiceConnection connection = addServiceConnection(targetPackage); local
102 context.bindService(bindIntent, connection, flags | Context.BIND_AUTO_CREATE);
160 ServiceConnection connection = new ServiceConnection() { local
169 sServiceMap.put(packageName, connection);
170 return connection;
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| NettyServerHandler.java | 199 final Http2Connection connection = new DefaultHttp2Connection(true); local
200 WeightedFairQueueByteDistributor dist = new WeightedFairQueueByteDistributor(connection);
203 new DefaultHttp2RemoteFlowController(connection, dist);
204 connection.remote().flowController(controller);
208 // Create the local flow controller configured to auto-refill the connection window.
209 connection.local().flowController(
210 new DefaultHttp2LocalFlowController(connection, DEFAULT_WINDOW_UPDATE_RATIO, true));
212 Http2ConnectionEncoder encoder = new DefaultHttp2ConnectionEncoder(connection, frameWriter);
213 Http2ConnectionDecoder decoder = new DefaultHttp2ConnectionDecoder(connection, encoder,
223 connection,
348 final Http2Connection connection = encoder().connection(); local
[all...] |
| AbstractNettyHandler.java | 34 * shutdown the connection) as well as sending the initial connection window at startup.
55 // Extract the connection window from the settings if it was set.
63 // Sends the connection preface if we haven't already.
70 // Sends connection preface if we haven't already.
79 // There was no embedded Http2Exception, assume it's a connection error. Subclasses are
80 // responsible for storing the appropriate status and shutting down the connection.
92 * Sends initial connection window to the remote endpoint if necessary.
96 Http2Stream connectionStream = connection().connectionStream();
97 int currentSize = connection().local().flowController().windowSize(connectionStream)
[all...] |
| NettyHandlerSettings.java | 70 .initialWindowSize(handler.connection().connectionStream());
|
| /external/opencensus-java/exporters/trace/instana/src/main/java/io/opencensus/exporter/trace/instana/ |
| InstanaExporterHandler.java | 195 HttpURLConnection connection = (HttpURLConnection) agentEndpoint.openConnection(); local
196 connection.setRequestMethod("POST");
197 connection.setDoOutput(true);
198 outputStream = connection.getOutputStream();
201 inputStream = connection.getInputStream();
202 if (connection.getResponseCode() != 200) {
206 Status.UNKNOWN.withDescription("Response " + connection.getResponseCode()));
|
| /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();
|
| /cts/tests/inputmethod/src/android/view/inputmethod/cts/util/ |
| WindowFocusStealer.java | 96 * Establishes a connection to the service.
100 * @throws TimeoutException when failed to establish the connection within {@code timeout}
106 final ServiceConnection connection = new ServiceConnection() { local
117 context.bindService(intent, connection, Context.BIND_AUTO_CREATE);
133 context.unbindService(connection);
|
| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| IncomingCallTest.java | 27 import android.telecom.Connection;
51 final Connection connection3 = verifyConnectionForIncomingCall();
52 Collection<Connection> connections = CtsConnectionService.getAllConnectionsFromTelecom();
126 public Connection onCreateIncomingConnection(
129 Connection connection = super.onCreateIncomingConnection(
132 connection.setAudioModeIsVoip(true);
134 return connection;
|
| CtsConnectionService.java | 23 import android.telecom.Connection;
43 * sConnectionService: Contains the connection service object provided by the current test in
45 * Telecom framework to the test connection service.
46 * sTelecomConnectionService: Contains the connection service object registered to the Telecom
48 * test connection service to the Telecom framework. After Telecom
54 // This is the connection service implemented by the test
56 // This is the connection service registered with Telecom
86 public Connection onCreateOutgoingConnection(PhoneAccountHandle connectionManagerPhoneAccount,
99 public Connection onCreateIncomingConnection(PhoneAccountHandle connectionManagerPhoneAccount,
112 public void onConference(Connection connection1, Connection connection2)
[all...] |
| /external/libbrillo/brillo/http/ |
| http_transport_curl.h | 21 class Connection;
43 std::shared_ptr<http::Connection> CreateConnection(
54 RequestID StartAsyncTransfer(http::Connection* connection,
91 void OnTransferComplete(http::curl::Connection* connection,
95 // on a connection.
96 void CleanAsyncConnection(http::curl::Connection* connection);
120 // A map to find a corresponding Connection* using a request ID
[all...] |
| 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...] |
| /cts/hostsidetests/numberblocking/app/src/com/android/cts/numberblocking/hostside/ |
| CallBlockingTest.java | 24 import android.telecom.Connection;
119 public static class DummyConnection extends Connection {
131 public Connection onCreateIncomingConnection(
133 final Connection connection = new DummyConnection(); local
134 connection.setVideoState(request.getVideoState());
137 connection.setAddress(address, TelecomManager.PRESENTATION_ALLOWED);
138 return connection;
|
| /cts/tests/tests/networksecurityconfig/src/android/security/net/config/cts/ |
| TestUtils.java | 96 fail("Connection to " + host + ":" + port + " succeeded");
110 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); local
112 connection.getInputStream();
113 fail("Connection to " + host + ":" + port + " succeeded");
121 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); local
122 connection.getInputStream();
142 fail("Connection to " + host + ":" + port + " succeeded");
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| BasicPoolEntry.java | 44 * Basic implementation of a connection pool entry.
63 * @param op the connection operator
64 * @param route the planned route for the connection
79 return super.connection;
|
| /external/curl/docs/cmdline-opts/ |
| pinnedpubkey.d | 11 When negotiating a TLS or SSL connection, the server sends a certificate
14 abort the connection before sending or receiving any data.
|
| proxy-pinnedpubkey.d | 11 When negotiating a TLS or SSL connection, the server sends a certificate
14 abort the connection before sending or receiving any data.
|
| /external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| GenericListeningConnector.java | 149 Connection connection; local
151 connection = transportService.accept(listener, timeout, 0);
161 connection = transportService.accept(listener, timeout, 0);
164 return Bootstrap.virtualMachineManager().createVirtualMachine(connection);
|
| /external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/ |
| AbstractResponseCache.java | 35 @Override public CacheRequest put(URI uri, URLConnection connection) throws IOException {
|
| /external/pdfium/fxjs/xfa/ |
| cjx_execute.cpp | 21 void CJX_Execute::connection(CFXJSE_Value* pValue, function in class:CJX_Execute
|
| /external/sl4a/InterpreterForAndroid/src/com/googlecode/android_scripting/ |
| UrlDownloaderTask.java | 146 URLConnection connection = null; local
148 connection = mUrl.openConnection();
153 int contentLength = connection.getContentLength();
168 int bytesCopied = IoUtils.copy(connection.getInputStream(), mProgressReportingOutputStream);
|
| /external/libbrillo/brillo/glib/ |
| dbus.h | 56 DCHECK(object_) << "referencing an empty connection";
83 // Proxy has reference semantics and represents a connection to on object on
84 // the bus. A proxy object is constructed with a connection to a bus, a name
96 Proxy(const BusConnection& connection,
102 // Equivalent to Proxy(connection, name, path, interface, false).
103 Proxy(const BusConnection& connection,
109 Proxy(const BusConnection& connection,
138 BRILLO_PRIVATE static value_type GetGProxy(const BusConnection& connection,
145 const BusConnection& connection,
163 // supplied \param object at \param service_path on the \param connection
[all...] |
| /external/apache-harmony/sql/src/test/java/org/apache/harmony/sql/tests/java/sql/ |
| TestHelper_Driver4.java | 20 import java.sql.Connection;
74 public Connection connect(String url, Properties info) throws SQLException {
104 // It all checks out - so return a connection
105 Connection connection = new TestHelper_Connection1(); local
106 return connection;
|
