Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 452 for sockets (0.38 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top