Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2311 - 2320 of 2,609 for Fset (0.02 sec)

  1. cmd/xl-storage-meta-inline.go

    		_, buf, err = msgp.ReadBytesZC(buf)
    		if err != nil {
    			return fmt.Errorf("xlMetaInlineData: %w", err)
    		}
    	}
    
    	return nil
    }
    
    // repair will copy all seemingly valid data entries from a corrupted set.
    // This does not ensure that data is correct, but will allow all operations to complete.
    func (x *xlMetaInlineData) repair() {
    	data := *x
    	if len(data) == 0 {
    		return
    	}
    
    	if !data.versionOK() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

      }
    
      /**
       * Test to ensure we don't  throw a read timeout on responses that are progressing.  For this
       * case, we take a 4KiB body and throttle it to 1KiB/second.  We set the read timeout to two
       * seconds.  If our implementation is acting correctly, it will not throw, as it is progressing.
       */
      @ParameterizedTest
      @ArgumentsSource(ProtocolParamProvider::class)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  3. src/archive/zip/reader.go

    		// data. We previously tried failing here if f.CompressedSize64 != 0,
    		// but it turns out that a number of implementations (namely, the Java
    		// jar tool) don't properly set the storage method on directories
    		// resulting in a file with compressed size > 0 but uncompressed size ==
    		// 0. We still want to fail when a directory has associated uncompressed
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Sat Aug 03 01:05:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsElevateWordToLabelCA.java

        // ===================================================================================
        //                                                                     Aggregation Set
        //                                                                           =========
    
        public void filter(String name, EsAbstractConditionQuery.OperatorCall<BsElevateWordToLabelCQ> queryLambda,
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

                try {
                  chain.proceed(chain.request())
                } finally {
                  firstConnectLatch.countDown()
                }
              },
            )
            .build()
    
        // Set up a same-connection retry.
        serverIpv4.enqueue(
          MockResponse(socketPolicy = ResetStreamAtStart(ErrorCode.REFUSED_STREAM.httpCode)),
        )
        serverIpv4.enqueue(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt

              value = it[1],
            )
          },
        )
    
      /**
       * ```
       * RDNSequence ::= SEQUENCE OF RelativeDistinguishedName
       *
       * RelativeDistinguishedName ::= SET SIZE (1..MAX) OF AttributeTypeAndValue
       * ```
       */
      internal val rdnSequence: BasicDerAdapter<List<List<AttributeTypeAndValue>>> =
        attributeTypeAndValue.asSetOf().asSequenceOf()
    
      /**
       * ```
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  7. api/maven-api-toolchain/src/main/mdo/toolchains.mdo

            public void setSourceLevel(String sourceLevel) {
                if (sourceLevelSet) {
                    throw new IllegalStateException("Cannot reset sourceLevel attribute; it is already set to: " + sourceLevel);
                } else if (!(USER_LEVEL.equals(sourceLevel) || GLOBAL_LEVEL.equals(sourceLevel))) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Thu Aug 22 14:47:43 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  8. istioctl/pkg/metrics/metrics.go

    All metrics returned are from server-side reports. This means that latencies
    and error rates are from the perspective of the service itself and not of an
    individual client (or aggregate set of clients). Rates and latencies are
    calculated over a time interval of 1 minute.
    `,
    		Example: `  # Retrieve workload metrics for productpage-v1 workload
      istioctl experimental metrics productpage-v1
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  9. README.md

    ---
    
    ### 🚀 **Getting Started**
    
    Starting with Gradle is easy with these essential resources. Follow these to install Gradle, set up initial projects, and explore supported platforms:
    
    - **[Installing Gradle](https://docs.gradle.org/current/userguide/installation.html)**
    - **Build Projects for Popular Languages and Frameworks**:
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Nov 01 05:30:25 UTC 2024
    - 8K bytes
    - Viewed (0)
  10. internal/logger/target/kafka/kafka.go

    // Cancel - cancels the target
    func (h *Target) Cancel() {
    	// If queuestore is configured, cancel it's context to
    	// stop the replay go-routine.
    	if h.store != nil {
    		h.storeCtxCancel()
    	}
    
    	// Set logch to nil and close it.
    	// This will block all Send operations,
    	// and finish the existing ones.
    	// All future ones will be discarded.
    	h.logChMu.Lock()
    	xioutil.SafeClose(h.logCh)
    	h.logCh = nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top