Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 462 for slop (0.06 sec)

  1. .teamcity/src/main/kotlin/model/CIBuildModel.kt

        val extraParameters: String = ""
    ) {
        per_commit(
            displayName = "Performance Regression Test",
            timeout = 420,
            channel = "commits"
        ),
        per_day(
            displayName = "Slow Performance Regression Test",
            timeout = 420,
            channel = "commits"
        ),
        per_week(
            displayName = "Performance Experiment",
            timeout = 420,
            channel = "experiments"
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Oct 16 06:14:14 UTC 2024
    - 22.9K bytes
    - Viewed (0)
  2. src/bufio/bufio.go

    		}
    	}
    	b.err = io.ErrNoProgress
    }
    
    func (b *Reader) readErr() error {
    	err := b.err
    	b.err = nil
    	return err
    }
    
    // Peek returns the next n bytes without advancing the reader. The bytes stop
    // being valid at the next read call. If Peek returns fewer than n bytes, it
    // also returns an error explaining why the read is short. The error is
    // [ErrBufferFull] if n is larger than b's buffer size.
    //
    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. guava-testlib/src/com/google/common/collect/testing/google/MultisetNavigationTester.java

            c = Multisets.immutableEntry(entries.get(2), sortedMultiset.count(entries.get(2)));
          }
        }
      }
    
      /** Resets the contents of sortedMultiset to have entries a, c, for the navigation tests. */
      // Needed to stop Eclipse whining
      private void resetWithHole() {
        List<E> container = new ArrayList<>();
        container.addAll(nCopies(a.getCount(), a.getElement()));
        container.addAll(nCopies(c.getCount(), c.getElement()));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  4. cmd/bucket-metadata-sys.go

    	const bucketMetadataRefresh = 15 * time.Minute
    
    	sleeper := newDynamicSleeper(2, 150*time.Millisecond, false)
    
    	t := time.NewTimer(bucketMetadataRefresh)
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-t.C:
    			buckets, err := sys.objAPI.ListBuckets(ctx, BucketOptions{NoMetadata: true})
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

        e: IOException?,
      ) {
        var noNewExchangesEvent = false
        lock.withLock {
          if (e is StreamResetException) {
            when {
              e.errorCode == ErrorCode.REFUSED_STREAM -> {
                // Stop using this connection on the 2nd REFUSED_STREAM error.
                refusedStreamCount++
                if (refusedStreamCount > 1) {
                  noNewExchangesEvent = !noNewExchanges
                  noNewExchanges = true
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  6. internal/kms/config.go

    		client.Endpoints = endpoints
    
    		// Keep the default key in the KES cache to prevent availability issues
    		// when MinIO restarts
    		go func() {
    			timer := time.NewTicker(10 * time.Second)
    			defer timer.Stop()
    			defaultKey := env.Get(EnvKESDefaultKey, "")
    			for {
    				select {
    				case <-ctx.Done():
    					return
    				case <-timer.C:
    					client.DescribeKey(ctx, defaultKey)
    				}
    			}
    		}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  7. cmd/tier.go

    		return time.Duration(r.Float64() * 5 * float64(time.Second))
    	}
    
    	// To avoid all MinIO nodes reading the tier config object at the same
    	// time.
    	t := time.NewTimer(tierCfgRefresh + randInterval())
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-t.C:
    			err := config.Reload(ctx, objAPI)
    			if err != nil {
    				tierLogIf(ctx, err)
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/exec/Crawler.java

                System.exit(exitCode);
            }
        }
    
        private static void destroyContainer() {
            if (running.getAndSet(false)) {
                TimeoutManager.getInstance().stop();
                if (logger.isDebugEnabled()) {
                    logger.debug("Destroying LaContainer...");
                }
                SingletonLaContainerFactory.destroy();
                logger.info("Destroyed LaContainer.");
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

            }
            generatorList.forEach(g -> {
                try {
                    g.destroy();
                } catch (final Exception e) {
                    logger.warn("Failed to stop thumbnail generator.", e);
                }
            });
        }
    
        public String getThumbnailPathOption() {
            return "-D" + Constants.FESS_THUMBNAIL_PATH + "=" + baseDir.getAbsolutePath();
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  10. src/archive/tar/reader.go

    			}
    
    			// Set the final guess at the format.
    			if format.has(FormatUSTAR) && format.has(FormatPAX) {
    				format.mayOnlyBe(FormatUSTAR)
    			}
    			hdr.Format = format
    			return hdr, nil // This is a file, so stop
    		}
    	}
    }
    
    // handleRegularFile sets up the current file reader and padding such that it
    // can only read the following logical data section. It will properly handle
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
Back to top