Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 836 for rocket (0.04 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

      override val route: Route,
      /** The low-level TCP socket. */
      private val rawSocket: JavaNetSocket,
      /**
       * The application layer socket. Either an [SSLSocket] layered over [rawSocket], or [rawSocket]
       * itself if this connection does not use SSL.
       */
      private val javaNetSocket: JavaNetSocket,
      private val handshake: Handshake?,
      private val protocol: Protocol,
      private val socket: BufferedSocket,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  2. okhttp/src/androidMain/kotlin/okhttp3/internal/platform/AndroidPlatform.kt

        ).filter { it.isSupported() }
    
      @Throws(IOException::class)
      override fun connectSocket(
        socket: Socket,
        address: InetSocketAddress,
        connectTimeout: Int,
      ) {
        try {
          socket.connect(address, connectTimeout)
        } catch (e: ClassCastException) {
          // On android 8.0, socket.connect throws a ClassCastException due to a bug
          // see https://issuetracker.google.com/issues/63649622
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu May 29 16:52:38 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  3. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  4. docs/bucket/notifications/README.md

    notify_webhook        publish bucket notifications to webhook endpoints
    notify_amqp           publish bucket notifications to AMQP endpoints
    notify_kafka          publish bucket notifications to Kafka endpoints
    notify_mqtt           publish bucket notifications to MQTT endpoints
    notify_nats           publish bucket notifications to NATS endpoints
    notify_nsq            publish bucket notifications to NSQ endpoints
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
  5. src/main/java/jcifs/util/transport/Transport.java

                    final boolean closed = msg != null && msg.equals("Socket closed");
    
                    if (closed) {
                        log.trace("Remote closed connection");
                    } else if (timeout) {
                        log.debug("socket timeout in non peek state", ex);
                    } else {
                        log.debug("recv failed", ex);
                    }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  6. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt

          RecordedRequest(
            "",
            headersOf(),
            listOf(),
            0L,
            Buffer(),
            0,
            Socket(),
          )
        recordedRequest = RecordedRequest("", headersOf(), listOf(), 0L, Buffer(), 0, Socket())
        var requestUrl: HttpUrl? = recordedRequest.requestUrl
        var requestLine: String = recordedRequest.requestLine
        var method: String? = recordedRequest.method
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  7. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/RecordedRequest.kt

        sequenceNumber: Int,
        socket: Socket,
        failure: IOException? = null,
      ) {
        this.requestLine = requestLine
        this.headers = headers
        this.chunkSizes = chunkSizes
        this.bodySize = bodySize
        this.body = body
        this.sequenceNumber = sequenceNumber
        this.failure = failure
    
        if (socket is SSLSocket) {
          try {
            this.handshake = socket.session.handshake()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

                 * because we might close the socket during a
                 * request. However the chances are slim and the
                 * retry code should ensure the overall request
                 * is serviced. The alternative complicates things
                 * more than I think is worth it.
                 */
    
                if (socket != null) {
                    socket.close();
                    socket = null;
                }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 17.6K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/SpecificHostSocketFactory.kt

      }
    
      override fun createSocket(): Socket =
        object : Socket() {
          override fun connect(
            endpoint: SocketAddress?,
            timeout: Int,
          ) {
            val requested = (endpoint as InetSocketAddress)
            val inetSocketAddress = hostMapping[requested.address] ?: defaultAddress ?: requested
            Platform.get().log("Socket connection to: $inetSocketAddress was: $requested")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/FallbackTestClientSocketFactory.kt

      override fun configureSocket(sslSocket: SSLSocket): SSLSocket = TlsFallbackScsvDisabledSSLSocket(sslSocket)
    
      private class TlsFallbackScsvDisabledSSLSocket(
        socket: SSLSocket,
      ) : DelegatingSSLSocket(socket) {
        override fun setEnabledCipherSuites(suites: Array<String>) {
          val enabledCipherSuites = mutableListOf<String>()
          for (suite in suites) {
            if (suite != TLS_FALLBACK_SCSV) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2K bytes
    - Viewed (0)
Back to top