- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,044 for socket (0.37 sec)
-
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
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 14.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/JSSETest.kt
// System.setProperty("jdk.tls.server.enableSessionTicketExtension", "true") platform.assumeJdk9() } @Test fun testTlsv13Works() { // https://docs.oracle.com/en/java/javase/14/security/java-secure-socket-extension-jsse-reference-guide.html // TODO test jdk.tls.client.enableSessionTicketExtension // TODO check debugging information enableTls() server.enqueue(MockResponse(body = "abc"))
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 5.5K bytes - Viewed (0) -
kotlin-js-store/yarn.lock
integrity sha512-V4GrkLy+HeF1F/en3SpUaM+7XxYXpuMUWLGde1kSSh5nQMN4hLrbPIkD+otwh6q9R6NOQBN4AMaOZ2zVjui82g== dependencies: "@socket.io/component-emitter" "~3.1.0" debug "~4.3.1" socket.io@^4.4.1: version "4.5.4" resolved "https://registry.yarnpkg.com/socket.io/-/socket.io-4.5.4.tgz#a4513f06e87451c17013b8d13fdfaf8da5a86a90"Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 87.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractor.java
*/ public void setConnectionTimeout(final Integer connectionTimeout) { this.connectionTimeout = connectionTimeout; } /** * Sets the socket timeout. * @param soTimeout The socket timeout in milliseconds. */ public void setSoTimeout(final Integer soTimeout) { this.soTimeout = soTimeout; } /**Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 12.2K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java
import org.apache.http.conn.HttpClientConnectionManager; import org.apache.http.conn.routing.HttpRoutePlanner; import org.apache.http.conn.socket.ConnectionSocketFactory; import org.apache.http.conn.socket.LayeredConnectionSocketFactory; import org.apache.http.conn.socket.PlainConnectionSocketFactory; import org.apache.http.conn.ssl.NoopHostnameVerifier; import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Nov 23 12:19:14 UTC 2025 - 53.7K bytes - Viewed (0) -
okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/ConscryptSocketAdapter.kt
matchesSocket(sslSocket) -> Conscrypt.getApplicationProtocol(sslSocket) else -> null // No TLS extensions if the socket class is custom. } override fun configureTlsExtensions( sslSocket: SSLSocket, hostname: String?, protocols: List<Protocol>, ) { // No TLS extensions if the socket class is custom. if (matchesSocket(sslSocket)) { // Enable session tickets.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessRpcClient.java
* @throws IOException if connection fails */ private void testConnection() throws IOException { // For now, just test basic connectivity to RPC endpoint try (java.net.Socket socket = new java.net.Socket()) { socket.connect(new java.net.InetSocketAddress(serverAddress, WITNESS_RPC_PORT), WITNESS_RPC_TIMEOUT_MS); } catch (IOException e) {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 12.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Address.kt
* address also includes the SSL socket factory, hostname verifier, and certificate pinner. * * HTTP requests that share the same [Address] may also share the same [Connection]. */ class Address( uriHost: String, uriPort: Int, /** Returns the service that will be used to resolve IP addresses for hostnames. */ @get:JvmName("dns") val dns: Dns, /** Returns the socket factory for new connections. */
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 7.3K bytes - Viewed (0) -
internal/http/listener.go
} // TCPOptions specify customizable TCP optimizations on raw socket type TCPOptions struct { UserTimeout int // this value is expected to be in milliseconds // When the net.Conn is a remote drive this value is honored, we close the connection to remote peer proactively. DriveOPTimeout func() time.Duration SendBufSize int // SO_SNDBUF size for the socket connection, NOTE: this sets server and client connectionRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 5.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.connection import java.net.Socket import java.util.concurrent.ConcurrentLinkedQueue import java.util.concurrent.TimeUnit import okhttp3.Address import okhttp3.ConnectionPool import okhttp3.Route import okhttp3.internal.closeQuietly
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Oct 08 03:50:05 UTC 2025 - 11.1K bytes - Viewed (0)