- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 3,944 for connections (0.5 sec)
-
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/connection/InternalBuildActionAdapter.java
import java.io.File; /** * Adapter to create {@link org.gradle.tooling.internal.protocol.InternalBuildAction} * from an instance of {@link org.gradle.tooling.BuildAction}. * Used by consumer connections 1.8+. */ @SuppressWarnings("deprecation") public class InternalBuildActionAdapter<T> implements org.gradle.tooling.internal.protocol.InternalBuildAction<T>, InternalBuildActionVersion2<T> {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 19 19:46:37 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/hbone/dialer_test.go
t.Fatalf("err with %v: %v", n, err) } if string(buf[:n]) != "hello" { t.Fatalf("got unexpected buffer: %v", string(buf[:n])) } t.Logf("Read %v", string(buf[:n])) } // Make sure we can create multiple connections send() send() } func newHBONEServer(t *testing.T) string { s := NewServer() l, err := net.Listen("tcp", "0.0.0.0:0") if err != nil { t.Fatal(err) } go func() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 26 23:44:52 UTC 2023 - 2.5K bytes - Viewed (0) -
docs/contribute/debug_logging.md
$ adb logcat '*:E' 'okhttp.Http2:D' 'okhttp.TaskRunner:D' ``` ### HTTP/2 Frame Logging This logs inbound (`<<`) and outbound (`>>`) frames for HTTP/2 connections. ``` [2020-01-01 00:00:00] >> CONNECTION 505249202a20485454502f322e300d0a0d0a534d0d0a0d0a [2020-01-01 00:00:00] >> 0x00000000 6 SETTINGS [2020-01-01 00:00:00] >> 0x00000000 4 WINDOW_UPDATE
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 2.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/bbottema/javasocksproxyserver/TestRecordingProxyHandler.java
*/ package org.bbottema.javasocksproxyserver; import java.net.InetAddress; import java.net.Socket; import java.util.List; /** * Alternate implementation of {@link ProxyHandler} that records connections which would have been * made, but does not actually make them. * * Must live in same package as {@link Socks4Impl}. */ public final class TestRecordingProxyHandler extends ProxyHandler {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2K bytes - Viewed (0) -
pkg/kubelet/certificate/transport_test.go
f.cert.Store(cert) } func TestRotateShutsDownConnections(t *testing.T) { // This test fails if you comment out the t.closeAllConns() call in // transport.go and don't close connections on a rotate. stop := make(chan struct{}) defer close(stop) m := new(fakeManager) m.setCurrent(client1CertData.certificate) // The last certificate we've seen.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 18 08:52:58 UTC 2020 - 7.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/authenticatorfactory/requestheader.go
// the user.Info.Extra. All values of all matching headers will be added. ExtraHeaderPrefixes headerrequest.StringSliceProvider // CAContentProvider the options for verifying incoming connections using mTLS. Generally this points to CA bundle file which is used verify the identity of the front proxy. // It may produce different options at will. CAContentProvider dynamiccertificates.CAContentProvider
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 12 18:29:15 UTC 2021 - 1.7K bytes - Viewed (0) -
helm/minio/templates/_helper_create_policy.txt
connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections to minio are allowed to fail. echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" ; MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" ; $MC_COMMAND ; STATUS=$? ;
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Mar 21 06:38:06 UTC 2023 - 2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
private var trailers: Headers? = null /** Returns true if this connection is closed. */ val isClosed: Boolean get() = state == STATE_CLOSED override fun createRequestBody( request: Request, contentLength: Long, ): Sink { return when { request.body?.isDuplex() == true -> throw ProtocolException( "Duplex connections are not supported for HTTP/1", )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
* That may happen later by the connection pool thread. */ fun cancel() /** * Carries an exchange. This is usually a connection, but it could also be a connect plan for * CONNECT tunnels. Note that CONNECT tunnels are significantly less capable than connections. */ interface Carrier { val route: Route fun trackFailure(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt
} /** * Release any resources held by this dispatcher. Any requests that are currently being dispatched * should return immediately. Responses returned after shutdown will not be transmitted: their * socket connections have already been closed. */ open fun shutdown() {}
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 1.7K bytes - Viewed (0)