Search Options

Results per page
Sort
Preferred Languages
Advance

Results 571 - 580 of 700 for count1 (0.03 sec)

  1. cmd/bucket-replication.go

    // checkOld can be set to an expected value.
    // If the worker count changed
    func (p *ReplicationPool) ResizeLrgWorkers(n, checkOld int) {
    	p.mu.Lock()
    	defer p.mu.Unlock()
    
    	if (checkOld > 0 && len(p.lrgworkers) != checkOld) || n == len(p.lrgworkers) || n < 1 {
    		// Either already satisfied or worker count changed while we waited for the lock.
    		return
    	}
    	for len(p.lrgworkers) < n {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 118.2K bytes
    - Viewed (0)
  2. CHANGELOG/CHANGELOG-1.18.md

    - Kube-apiserver metrics will now include request counts, latencies, and response sizes for /healthz, /livez, and /readyz requests. ([#83598](https://github.com/kubernetes/kubernetes/pull/83598), [@jktomer](https://github.com/jktomer)) [SIG API Machinery]
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Wed Jun 16 17:18:28 UTC 2021
    - 373.2K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/ldap/LdapManager.java

                return context;
            }
    
            /**
             * Increments the counter.
             */
            public void inc() {
                counter++;
            }
    
            @Override
            public void close() {
                if (counter > 1) {
                    counter--;
                } else {
                    try {
                        if (context != null) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 86.3K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    	} else {
    		tags["invalid"] = "1"
    		tags["d:p"] = fmt.Sprintf("%d:%d", er.setDriveCount-er.defaultParityCount, er.defaultParityCount)
    	}
    
    	// count the number of offline disks
    	offline := 0
    	for i := range len(errs) {
    		var found bool
    		switch {
    		case errors.Is(errs[i], errDiskNotFound):
    			found = true
    		default:
    			for p := range dataErrsByPart {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  5. src/test/java/jcifs/internal/smb1/AndXServerMessageBlockTest.java

                return 0;
            }
    
            @Override
            protected int readParameterWordsWireFormat(byte[] src, int srcIndex) {
                return 34; // Return proper word count for extended response
            }
        }
    
        @BeforeEach
        void setUp() {
            MockitoAnnotations.openMocks(this);
            when(mockConfig.isUseBatching()).thenReturn(true);
        }
    
        @Test
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 19.4K bytes
    - Viewed (0)
  6. internal/s3select/sql/funceval.go

    	errNonTimestampArg   = errors.New("Expected a timestamp argument")
    )
    
    func (e *FuncExpr) getFunctionName() FuncName {
    	switch {
    	case e.SFunc != nil:
    		return FuncName(strings.ToUpper(e.SFunc.FunctionName))
    	case e.Count != nil:
    		return aggFnCount
    	case e.Cast != nil:
    		return sqlFnCast
    	case e.Substring != nil:
    		return sqlFnSubstring
    	case e.Extract != nil:
    		return sqlFnExtract
    	case e.Trim != nil:
    		return sqlFnTrim
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.2K bytes
    - Viewed (0)
  7. src/test/java/jcifs/util/AuthenticationRateLimiterTest.java

            rateLimiter.recordFailure(username, ip);
    
            assertTrue(rateLimiter.checkAttempt(username, ip));
            rateLimiter.recordFailure(username, ip);
    
            // Success should reset counter
            assertTrue(rateLimiter.checkAttempt(username, ip));
            rateLimiter.recordSuccess(username, ip);
    
            // Should be able to fail 3 more times before lockout
            for (int i = 0; i < 3; i++) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/collect/MultimapsCollectionTest.java

        CollectionSize.ANY,
        ALLOWS_NULL_VALUES,
        SUPPORTS_REMOVE,
        CollectionFeature.SUPPORTS_ITERATOR_REMOVE,
        MultisetTestSuiteBuilder.NoRecurse.NO_ENTRY_SET, // Cannot create entries with count > 1
      };
    
      static final Supplier<TreeSet<String>> STRING_TREESET_FACTORY =
          new Supplier<TreeSet<String>>() {
            @Override
            public TreeSet<String> get() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Sep 24 22:52:18 UTC 2025
    - 28.4K bytes
    - Viewed (0)
  9. docs/es/docs/advanced/events.md

    ///
    
    ## Sub Aplicaciones { #sub-applications }
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  10. docs/en/docs/how-to/custom-docs-ui-assets.md

    Let's say that you want to use a different <abbr title="Content Delivery Network">CDN</abbr>, for example you want to use `https://unpkg.com/`.
    
    This could be useful if for example you live in a country that restricts some URLs.
    
    ### Disable the automatic docs { #disable-the-automatic-docs }
    
    The first step is to disable the automatic docs, as by default, those use the default CDN.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 7.8K bytes
    - Viewed (0)
Back to top