- Sort Score
- Num 10 results
- Language All
Results 121 - 130 of 452 for sockets (0.38 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
helm-releases/minio-2.0.0.tgz
"minio-trusted-certs" or --set trustedCertsSecret=minio-trusted-certs ``` Create buckets after install ---------- Install the chart, specifying the buckets you want to create after install: ```bash helm install --set buckets[0].name=bucket1,buckets[0].policy=none,buckets[0].purge=false minio/minio ``` Description of the configuration parameters used above - - `buckets[].name` - name of the bucket to create, must be a string with length > 0 - `buckets[].policy` - can be one of none|download|upload|public - `buckets[].purge`...
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 26 07:36:46 GMT 2021 - 13.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/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")
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 8.2K bytes - Click Count (0) -
helm/minio/values.yaml
## you can define additional policies with custom supported actions and resources policies: [] ## writeexamplepolicy policy grants creation or deletion of buckets with name ## starting with example. In addition, grants objects write permissions on buckets starting with ## example. # - name: writeexamplepolicy # statements: # - effect: Allow # this is the default # resources:
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 19.7K bytes - Click Count (1) -
mockwebserver/src/test/java/mockwebserver3/RecordedRequestTest.kt
@Test fun testIPv4() { val socket = MockWebServerSocket( FakeSocket( localAddress = InetAddress.getByAddress("127.0.0.1", byteArrayOf(127, 0, 0, 1)), localPort = 80, ), ) val request = RecordedRequest(DEFAULT_REQUEST_LINE_HTTP_1, headers, emptyList(), 0, ByteString.EMPTY, 0, 0, socket) assertThat(request.url.toString()).isEqualTo("http://127.0.0.1/")
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Aug 02 20:36:00 GMT 2025 - 5.3K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/RecordedRequestFactory.kt
) private fun requestUrl( socket: MockWebServerSocket, requestLine: RequestLine, headers: Headers, ): HttpUrl { val hostAndPort = headers[":authority"] ?: headers["Host"] ?: when (val inetAddress = socket.localAddress) { is Inet6Address -> "[${inetAddress.hostAddress}]:${socket.localPort}" else -> "${inetAddress.hostAddress}:${socket.localPort}" }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jul 29 12:43:16 GMT 2025 - 3.3K bytes - Click Count (0) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
socket?.closeQuietly() } } } private fun doSsl(socket: Socket): SSLSocket { val sslSocket = sslSocketFactory.createSocket( socket, socket.inetAddress.hostAddress, socket.port, true, ) as SSLSocket sslSocket.useClientMode = false Platform.get().configureTlsExtensions(sslSocket, null, listOf(Protocol.HTTP_2)) sslSocket.startHandshake()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 6.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/RetryConnectionTest.kt
val attempt1 = attempt0.nextConnectionSpec(connectionSpecs, socket) assertThat(attempt1).isNotNull() assertThat(attempt1!!.isTlsFallback).isTrue() socket.close() // COMPATIBLE_TLS is used here. socket = createSocketWithEnabledProtocols(*enabledSocketTlsVersions) connectionSpecs[attempt1.connectionSpecIndex].apply(socket, attempt1.isTlsFallback)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 4.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
} override fun flushRequest() { socket.sink.flush() } override fun finishRequest() { socket.sink.flush() } /** Returns bytes of a request header for sending on an HTTP transport. */ fun writeRequest( headers: Headers, requestLine: String, ) { check(state == STATE_IDLE) { "state: $state" } socket.sink.writeUtf8(requestLine).writeUtf8("\r\n")
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 17.6K bytes - Click Count (7) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/MockSocketHandler.kt
} override fun handle(socket: Socket) { val task = serviceSocketTask(socket.asBufferedSocket()) results.add(task) task.run() } /** Returns a task that processes both request and response from [socket]. */ private fun serviceSocketTask(socket: BufferedSocket): FutureTask<Void> { return FutureTask<Void> { socket.source.use { socket.sink.use { while (true) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 3.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/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()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 8.2K bytes - Click Count (0)