- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 3,326 for connections (0.21 sec)
-
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
// which can satisfy a larger policy val connection = routePlanner.plans.first().connection val http2Connection = connectHttp2(peer, connection, 5) setPolicy(pool, address, ConnectionPool.AddressPolicy(5)) assertThat(pool.connectionCount()).isEqualTo(1) // Decrease the connection's max so that another connection is needed
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 12.7K bytes - Viewed (0) -
manifests/addons/dashboards/lib/queries.libsonnet
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 7.7K bytes - Viewed (0) -
src/net/http/httptest/server.go
// Force-close any idle connections (those between // requests) and new connections (those which connected // but never sent a request). StateNew connections are // super rare and have only been seen (in // previously-flaky tests) in the case of // socket-late-binding races from the http Client // dialing this server and then getting an idle // connection before the dial completed. There is thus
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/kubelet/prober/scale_test.go
t.Logf("UNKNOWN state for %v", result) default: } } }() wg.Wait() // log the number of connections received in each pod for debugging test failures. for _, pod := range fakePods { n := pod.connections() t.Logf("Number of connections %d", n) } }) } } func newProbe(handler v1.ProbeHandler) *v1.Probe { return &v1.Probe{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 8.2K bytes - Viewed (0) -
src/database/sql/sql.go
// ErrConnDone is returned by any operation that is performed on a connection // that has already been returned to the connection pool. var ErrConnDone = errors.New("sql: connection is already closed") // Conn returns a single connection by either opening a new connection // or returning an existing connection from the connection pool. Conn will // block until either a connection is returned or ctx is canceled.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
import okhttp3.internal.ws.RealWebSocket import okio.BufferedSink import okio.BufferedSource /** * A connection to a remote web server capable of carrying 1 or more concurrent streams. * * Connections are shared in a connection pool. Accesses to the connection's state must be guarded * by holding a lock on the connection. */ class RealConnection( val taskRunner: TaskRunner, val connectionPool: RealConnectionPool,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 15.4K bytes - Viewed (0) -
src/crypto/tls/tls.go
type Dialer struct { // NetDialer is the optional dialer to use for the TLS connections' // underlying TCP connections. // A nil NetDialer is equivalent to the net.Dialer zero value. NetDialer *net.Dialer // Config is the TLS configuration to use for new connections. // A nil configuration is equivalent to the zero // configuration; see the documentation of Config for the // defaults. Config *Config }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 12.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnectionTest.groovy
def connection = new TestConnection() given: connectCompletion.create(_) >> connection when: connectionBuilder.connect() connectionBuilder.addOutgoing(Worker) then: def e = thrown(GradleException) e.message == "Cannot add outgoing message transmitter after connection established." cleanup: connection?.stop()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4K bytes - Viewed (0) -
istioctl/pkg/kubeinject/testdata/mesh-config.yaml
# process should be kept alive after an occasional reload. drainDuration: 2s # # The mode used to redirect inbound connections to Envoy. This setting # has no effect on outbound traffic: iptables REDIRECT is always used for # outbound connections. # If "REDIRECT", use iptables REDIRECT to NAT and redirect to Envoy. # The "REDIRECT" mode loses source addresses during redirection.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 2.2K bytes - Viewed (0) -
internal/http/server.go
// DefaultShutdownTimeout - default shutdown timeout to gracefully shutdown server. DefaultShutdownTimeout = 5 * time.Second // DefaultIdleTimeout for idle inactive connections DefaultIdleTimeout = 30 * time.Second // DefaultReadHeaderTimeout for very slow inactive connections DefaultReadHeaderTimeout = 30 * time.Second // DefaultMaxHeaderBytes - default maximum HTTP header size in bytes. DefaultMaxHeaderBytes = 1 * humanize.MiByte )
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 09 21:25:16 UTC 2024 - 7.7K bytes - Viewed (0)