Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 409 for slop (0.04 sec)

  1. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

            int activeCrawlerNum = 0;
            try {
                while (startedCrawlerNum < crawlerList.size()) {
                    // Force to stop crawl
                    if (systemHelper.isForceStop()) {
                        for (final Crawler crawler : crawlerList) {
                            crawler.stop();
                        }
                        break;
                    }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      /**
       * Degrades this connection such that new streams can neither be created locally, nor accepted
       * from the remote peer. Existing streams are not impacted. This is intended to permit an endpoint
       * to gracefully stop accepting new requests without harming previously established streams.
       */
      @Throws(IOException::class)
      fun shutdown(statusCode: ErrorCode) {
        writer.withLock {
          val lastGoodStreamId: Int
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  3. internal/config/scanner/scanner.go

    	case "fast":
    		cfg.Delay, cfg.MaxWait, cfg.Cycle = 1, 100*time.Millisecond, time.Minute
    	case "default":
    		cfg.Delay, cfg.MaxWait, cfg.Cycle = 2, time.Second, time.Minute
    	case "slow":
    		cfg.Delay, cfg.MaxWait, cfg.Cycle = 10, 15*time.Second, time.Minute
    	case "slowest":
    		cfg.Delay, cfg.MaxWait, cfg.Cycle = 100, 15*time.Second, 30*time.Minute
    	default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/collect/ImmutableTableTest.java

        assertThat(copy.columnKeySet()).containsExactlyElementsIn(original.columnKeySet()).inOrder();
      }
    
      @J2ktIncompatible
      @GwtIncompatible // Mind-bogglingly slow in GWT
      @AndroidIncompatible // slow
      public void testOverflowCondition() {
        // See https://github.com/google/guava/issues/1322 for details.
        ImmutableTable.Builder<Integer, Integer, String> builder = ImmutableTable.builder();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  5. src/main/webapp/js/search.js

            value = $moreLink.attr("href"),
            $info;
        if (value !== "") {
          $info = $(value + " .info");
          if ($info.length > 0) {
            $moreLink.fadeOut(500, function() {
              $info.slideDown("slow");
            });
          }
        }
        return false;
      });
    
      if (typeof $.fn.suggestor === "function") {
        $("#query").suggestor({
          ajaxinfo: {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Mar 30 05:45:24 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/SocketChannelTest.kt

    import org.junit.jupiter.api.extension.RegisterExtension
    import org.junit.jupiter.params.ParameterizedTest
    import org.junit.jupiter.params.provider.MethodSource
    
    @Suppress("UsePropertyAccessSyntax")
    @Timeout(6)
    @Tag("slow")
    class SocketChannelTest {
      @JvmField @RegisterExtension
      val platform = PlatformRule()
    
      @JvmField @RegisterExtension
      val clientTestRule =
        OkHttpClientTestRule().apply {
          recordFrames = true
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. internal/pubsub/pubsub.go

    	numSubscribers int32
    	maxSubscribers int32
    
    	// not atomics:
    	subs []*Sub[T]
    	sync.RWMutex
    }
    
    // Publish message to the subscribers.
    // Note that publish is always non-blocking send so that we don't block on slow receivers.
    // Hence receivers should use buffered channel so as not to miss the published events.
    func (ps *PubSub[T, M]) Publish(item T) {
    	ps.RLock()
    	defer ps.RUnlock()
    	for _, sub := range ps.subs {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  8. cmd/data-scanner.go

    		select {
    		case <-ctx.Done():
    			if !timer.Stop() {
    				<-timer.C
    				if d.isScanner {
    					globalScannerMetrics.incTime(scannerMetricYield, wantSleep)
    				}
    			}
    			return
    		case <-timer.C:
    			if d.isScanner {
    				globalScannerMetrics.incTime(scannerMetricYield, wantSleep)
    			}
    			return
    		case <-cycle:
    			if !timer.Stop() {
    				// We expired.
    				<-timer.C
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  9. logger/logger.go

    		}
    	case elapsed > l.SlowThreshold && l.SlowThreshold != 0 && l.LogLevel >= Warn:
    		sql, rows := fc()
    		slowLog := fmt.Sprintf("SLOW SQL >= %v", l.SlowThreshold)
    		if rows == -1 {
    			l.Printf(l.traceWarnStr, utils.FileWithLineNum(), slowLog, float64(elapsed.Nanoseconds())/1e6, "-", sql)
    		} else {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Nov 07 02:19:41 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/AbstractService.java

       * #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override the
       * method to cancel pending work and then call {@link #notifyStopped} to stop the service.
       *
       * <p>This method should return promptly; prefer to do work on a different thread where it is
       * convenient. It is invoked exactly once on service shutdown, even when {@link #stopAsync} is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
Back to top