Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 171 for layered (0.06 sec)

  1. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

       * callback has returned. Synchronous calls become idle once [execute()][Call.execute] returns.
       * This means that if you are doing synchronous calls the network layer will not truly be idle
       * until every returned [Response] has been closed.
       */
      var idleCallback: Runnable? = null
        get() = this.withLock { field }
        set(value) {
          this.withLock { field = value }
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jun 20 14:10:53 UTC 2024
    - 9K bytes
    - Viewed (0)
  2. src/bufio/bufio.go

    // to the default size.
    // Calling b.Reset(b) (that is, resetting a [Reader] to itself) does nothing.
    func (b *Reader) Reset(r io.Reader) {
    	// If a Reader r is passed to NewReader, NewReader will return r.
    	// Different layers of code may do that, and then later pass r
    	// to Reset. Avoid infinite recursion in that case.
    	if b == r {
    		return
    	}
    	if b.buf == nil {
    		b.buf = make([]byte, defaultBufSize)
    	}
    	b.reset(b.buf, r)
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt

            }
            is SocketException -> {
              // Conscrypt, JDK 8 (>= 292), JDK 9
            }
            is ConnectionShutdownException -> {
              // It didn't fail until it reached the application layer.
            }
            else -> {
              assertThat(expected.message).isEqualTo("exhausted all routes")
            }
          }
        }
      }
    
      @Test
      fun invalidClientAuthEvents() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/informers.go

    			wasReady := kube.CheckPodReadyOrComplete(oldPod)
    			isReady := kube.CheckPodReadyOrComplete(newPod)
    			if wasReady != nil && isReady != nil && isAnnotated {
    				log.Infof("pod update event skipped: added/labeled by CNI plugin")
    				return nil
    			}
    
    			// netns == ""; at this point netns should have been added via the initial snapshot,
    			// or via the cni plugin. If it happens to get here before the cni plugin somehow,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  5. docs/en/docs/deployment/https.md

    * Certificates have a **lifetime**.
        * They **expire**.
        * And then they need to be **renewed**, **acquired again** from the third party.
    * The encryption of the connection happens at the **TCP level**.
        * That's one layer **below HTTP**.
        * So, the **certificate and encryption** handling is done **before HTTP**.
    * **TCP doesn't know about "domains"**. Only about IP addresses.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 12K bytes
    - Viewed (0)
  6. architecture/environments/operator.md

    step.
    1. Overlays in the user CR are applied to the rendered manifests. No values are ever defined in configuration profile
    CRs at this layer, so no merge is performed in this step.
    
    ## CLI
    
    The CLI `mesh` command is implemented in the [cmd/mesh](../operator/cmd/mesh/)
    subdirectory as a Cobra command with the following subcommands:
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 21:11:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  7. cmd/object-api-errors.go

    import (
    	"context"
    	"errors"
    	"fmt"
    	"io"
    )
    
    // Converts underlying storage error. Convenience function written to
    // handle all cases where we have known types of errors returned by
    // underlying storage layer.
    func toObjectErr(oerr error, params ...string) error {
    	if oerr == nil {
    		return nil
    	}
    
    	// Unwarp the error first
    	err := unwrapAll(oerr)
    
    	if err == context.Canceled {
    		return context.Canceled
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 09 02:05:14 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  8. cmd/global-heal.go

    					return
    				}
    				if wildcard.Match("tmp/.trash/*", entry.name) {
    					return
    				}
    				if wildcard.Match("multipart/*", entry.name) {
    					return
    				}
    			}
    
    			// erasureObjects layer needs object names to be encoded
    			encodedEntryName := encodeDirObject(entry.name)
    
    			var result healEntryResult
    			fivs, err := entry.fileInfoVersions(bucket)
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

        handler.windowUpdate(streamId, increment)
      }
    
      @Throws(IOException::class)
      override fun close() {
        source.close()
      }
    
      /**
       * Decompression of the header block occurs above the framing layer. This class lazily reads
       * continuation frames as they are needed by [Hpack.Reader.readHeaders].
       */
      internal class ContinuationSource(
        private val source: BufferedSource,
      ) : Source {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. okhttp-tls/src/main/kotlin/okhttp3/tls/HeldCertificate.kt

         * certificates). Set this to 1 so this certificate can sign intermediate certificates that can
         * themselves sign certificates. Add one for each additional layer of intermediates to permit.
         */
        fun certificateAuthority(maxIntermediateCas: Int) =
          apply {
            require(maxIntermediateCas >= 0) {
              "maxIntermediateCas < 0: $maxIntermediateCas"
            }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.6K bytes
    - Viewed (0)
Back to top