Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 120 for peers (0.02 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Headers.kt

        return result
      }
    
      class Builder {
        internal val namesAndValues: MutableList<String> = ArrayList(20)
    
        /**
         * Add a header line without any validation. Only appropriate for headers from the remote peer
         * or cache.
         */
        internal fun addLenient(line: String) =
          apply {
            val index = line.indexOf(':', 1)
            when {
              index != -1 -> {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      private var enqueuedClose = false
    
      /** The close code from the peer, or -1 if this web socket has not yet read a close frame. */
      private var receivedCloseCode = -1
    
      /** The close reason from the peer, or null if this web socket has not yet read a close frame. */
      private var receivedCloseReason: String? = null
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 21.6K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt

      }
    
      @Test
      fun serverTruncatesRequestOnLongPostHttp1() {
        // "java.net.SocketException: Socket closed" thrown reading response after
        // "java.net.SocketException: Connection reset by peer" writing request
        assumeNotWindows()
    
        serverTruncatesRequestOnLongPost(https = false)
      }
    
      @Test
      fun serverTruncatesRequestOnLongPostHttp2() {
        enableProtocol(Protocol.HTTP_2)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 11:54:15 GMT 2026
    - 10.7K bytes
    - Click Count (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/FakeSSLSession.kt

      @Suppress("UNCHECKED_CAST")
      @Throws(SSLPeerUnverifiedException::class)
      override fun getPeerCertificates(): Array<Certificate> =
        if (certificates.isEmpty()) {
          throw SSLPeerUnverifiedException("peer not authenticated")
        } else {
          certificates as Array<Certificate>
        }
    
      @Suppress("removal", "OVERRIDE_DEPRECATION")
      @Throws(
        SSLPeerUnverifiedException::class,
      )
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 3.2K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2.kt

    object Http2 {
      @JvmField
      val CONNECTION_PREFACE = "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n".encodeUtf8()
    
      /** The initial max frame size, applied independently writing to, or reading from the peer. */
      const val INITIAL_MAX_FRAME_SIZE = 0x4000 // 16384
    
      const val TYPE_DATA = 0x0
      const val TYPE_HEADERS = 0x1
      const val TYPE_PRIORITY = 0x2
      const val TYPE_RST_STREAM = 0x3
      const val TYPE_SETTINGS = 0x4
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.7K bytes
    - Click Count (0)
  6. src/main/java/jcifs/internal/smb2/rdma/RdmaNegotiateResponse.java

     */
    package jcifs.internal.smb2.rdma;
    
    /**
     * RDMA negotiation response parameters.
     *
     * Contains the negotiated parameters returned by the RDMA peer
     * during connection establishment.
     */
    public class RdmaNegotiateResponse {
    
        private int status;
        private int selectedVersion;
        private int creditsGranted;
        private int maxReceiveSize;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  7. internal/grid/handlers.go

    	HandlerClearUploadID:               peerPrefix,
    }
    
    const (
    	lockPrefix      = "lockR"
    	storagePrefix   = "storageR"
    	bootstrapPrefix = "bootstrap"
    	peerPrefix      = "peer"
    	peerPrefixS3    = "peerS3"
    	healPrefix      = "heal"
    )
    
    func init() {
    	// Static check if we exceed 255 handler ids.
    	// Extend the type to uint16 when hit.
    	if uint32(handlerLast) > 255 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  8. cmd/routers.go

    		commonGrid = globalGrid.Load()
    	)
    
    	// Register storage REST router only if its a distributed setup.
    	registerStorageRESTHandlers(router, endpointServerPools, commonGrid)
    
    	// Register peer REST router only if its a distributed setup.
    	registerPeerRESTHandlers(router, commonGrid)
    
    	// Register bootstrap REST router for distributed setups.
    	registerBootstrapRESTHandlers(commonGrid)
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jul 29 18:10:04 GMT 2024
    - 3.9K bytes
    - Click Count (0)
  9. CONTRIBUTING.md

    ```
    
    ### Create a Pull Request
    
    Pull requests can be created via GitHub. Refer to [this document](https://help.github.com/articles/creating-a-pull-request/) for detailed steps on how to create a pull request. After a Pull Request gets peer reviewed and approved, it will be merged.
    
    ## FAQs
    
    ### How does ``MinIO`` manage dependencies?
    
    ``MinIO`` uses `go mod` to manage its dependencies.
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Aug 05 18:35:53 GMT 2024
    - 2.9K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/CertificatePinner.kt

     * client.newCall(request).execute();
     * ```
     *
     * As expected, this fails with a certificate pinning exception:
     *
     * ```java
     * javax.net.ssl.SSLPeerUnverifiedException: Certificate pinning failure!
     * Peer certificate chain:
     *     sha256/afwiKY3RxoMmLkuRW1l7QsPZTJPwDS2pdDROQjXw8ig=: CN=publicobject.com, OU=PositiveSSL
     *     sha256/klO23nT2ehFDXCfx3eHTDRESMz3asj1muO+4aIdjiuY=: CN=COMODO RSA Secure Server CA
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 14.2K bytes
    - Click Count (1)
Back to Top