- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 210 for socketio (0.16 sec)
-
okhttp/src/main/kotlin/okhttp3/ConnectionSpec.kt
} /** * Returns `true` if the socket, as currently configured, supports this connection spec. In * order for a socket to be compatible the enabled cipher suites and protocols must intersect. * * For cipher suites, at least one of the [required cipher suites][cipherSuites] must match the * socket's enabled cipher suites. If there are no required cipher suites the socket must have at * least one cipher suite enabled.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 13.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
* ``` * * If any other extension or parameter is specified, then [unknownValues] will be true. Such * responses should be refused as their web socket extensions will not be understood. * * Note that [java.util.zip.Deflater] is hardcoded to use 15 bits (32 KiB) for * `client_max_window_bits` and [java.util.zip.Inflater] is hardcoded to use 15 bits (32 KiB) for
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
): RealConnection { val result = RealConnection.newTestConnection( taskRunner = taskRunner, connectionPool = pool, route = route, socket = Socket(), idleAtNs = idleAtNanos, ) result.withLock { pool.put(result) } return result } fun newConnectionPool( taskRunner: TaskRunner = this.taskRunner,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CipherSuiteTest.kt
applyConnectionSpec(connectionSpec, socket, false) assertArrayEquals(arrayOf("TLS_A", "TLS_C"), socket.enabledCipherSuites) } @Test fun applyIntersectionRetainsSslPrefixes() { val socket = FakeSslSocket() socket.enabledProtocols = arrayOf("TLSv1") socket.supportedCipherSuites = arrayOf("TLS_A", "TLS_B", "TLS_C", "TLS_D", "TLS_E") socket.enabledCipherSuites = arrayOf("TLS_A", "TLS_B", "TLS_C")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionSpecTest.kt
) assertThat(tlsSpec.isCompatible(socket)).isTrue() applyConnectionSpec(tlsSpec, socket, isFallback = false) assertThat(socket.enabledProtocols).containsExactly( TlsVersion.TLS_1_2.javaName, ) assertThat(socket.enabledCipherSuites.toList()) .containsExactlyInAnyOrder( CipherSuite.TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256.javaName,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.7K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/testdata/endpoint/emptyfilter_output.yaml
portValue: 9080 healthCheckConfig: {} healthStatus: HEALTHY loadBalancingWeight: 1 metadata: filterMetadata: envoy.transport_socket_match: tlsMode: istio istio: workload: details-v1;default;details;v1;Kubernetes loadBalancingWeight: 1 locality: {} policy: overprovisioningFactor: 140
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 12 02:25:59 GMT 2022 - 17.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/RetryConnectionTest.kt
assertThat(attempt1).isNotNull() assertThat(attempt1!!.isTlsFallback).isTrue() socket.close() // COMPATIBLE_TLS is used here. socket = createSocketWithEnabledProtocols(*enabledSocketTlsVersions) connectionSpecs[attempt1.connectionSpecIndex].apply(socket, attempt1.isTlsFallback) assertEnabledProtocols(socket, TlsVersion.TLS_1_2, TlsVersion.TLS_1_1, TlsVersion.TLS_1_0)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.3K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
do { this.socket = new Socket(); if ( this.localAddr != null ) this.socket.bind(new InetSocketAddress(this.localAddr, this.localPort)); this.socket.connect(new InetSocketAddress(this.address.getHostAddress(), 139), tc.getConfig().getConnTimeout()); this.socket.setSoTimeout(tc.getConfig().getSoTimeout());
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Wed Jan 18 23:47:00 GMT 2023 - 67K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(c1.socket().isClosed).isFalse() assertThat(c2.socket().isClosed).isFalse() // Add a third connection val c3 = factory.newConnection(pool, routeC1, 75L) // The third connection bounces the first. assertThat(pool.closeConnections(100L)).isEqualTo(0L) assertThat(pool.connectionCount()).isEqualTo(2) assertThat(c1.socket().isClosed).isTrue()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
docs/bigdata/README.md
fs.s3a.max.total.tasks=2048 # Maximum number of parallel tasks fs.s3a.multipart.size=512M # Size of each multipart chunk fs.s3a.multipart.threshold=512M # Size before using multipart uploads fs.s3a.socket.recv.buffer=65536 # Read socket buffer hint fs.s3a.socket.send.buffer=65536 # Write socket buffer hint fs.s3a.threads.max=2048 # Maximum number of threads for S3A ``` The rest of the other optimization options are discussed in the links below
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 14.7K bytes - Viewed (0)