Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 515 for Timers (0.04 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

    import org.codelibs.core.io.CloseableUtil;
    import org.codelibs.core.io.FileUtil;
    import org.codelibs.core.io.InputStreamUtil;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.crawler.Constants;
    import org.codelibs.fess.crawler.builder.RequestDataBuilder;
    import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 23.3K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb/SmbTransportImplTest.java

    import static org.junit.jupiter.api.Assertions.assertThrows;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import java.lang.reflect.Field;
    import java.net.Socket;
    import java.util.concurrent.atomic.AtomicLong;
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.6K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/app/web/admin/failureurl/EditForm.java

        /**
         * The detailed error log or stack trace for the failure.
         * This field contains the full error information for debugging purposes.
         */
        public String errorLog;
    
        /**
         * The number of times this URL has failed.
         * This is a required field that tracks repeated failures for the same URL.
         */
        @Required
        @ValidateTypeFailure
        public String errorCount;
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/crawler/interval/FessIntervalController.java

     * Fess-specific interval control functionality for web crawling operations.
     * This controller manages delays and timing for various crawling states
     * including processing delays, queue waiting times, and new URL discovery.
     */
    public class FessIntervalController extends DefaultIntervalController {
    
        private static final Logger logger = LogManager.getLogger(FessIntervalController.class);
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Wed Nov 19 07:09:17 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  5. docs/es/docs/tutorial/dependencies/sub-dependencies.md

    query_or_cookie_extractor(["query_or_cookie_extractor"])
    
    read_query["/items/"]
    
    query_extractor --> query_or_cookie_extractor --> read_query
    ```
    
    ## Usando la misma dependencia múltiples veces { #using-the-same-dependency-multiple-times }
    
    Si una de tus dependencias se declara varias veces para la misma *path operation*, por ejemplo, múltiples dependencias tienen una sub-dependencia común, **FastAPI** sabrá llamar a esa sub-dependencia solo una vez por request.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import com.google.common.base.Suppliers;
    import com.google.common.collect.ImmutableList;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  7. samples/crawler/src/main/java/okhttp3/sample/Crawler.java

          } finally {
            currentThread.setName(originalName);
          }
        }
      }
    
      public void fetch(HttpUrl url) throws IOException {
        // Skip hosts that we've visited many times.
        AtomicInteger hostnameCount = new AtomicInteger();
        AtomicInteger previous = hostnames.putIfAbsent(url.host(), hostnameCount);
        if (previous != null) hostnameCount = previous;
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Jul 23 00:58:06 UTC 2025
    - 5K bytes
    - Viewed (0)
  8. .teamcity/src/main/kotlin/model/FunctionalTestBucketGenerator.kt

            // splitIntoBuckets() method expects us to split large element into N elements,
            // but we want to have a single bucket with N batches.
            // As a workaround, we repeat the bucket N times, and deduplicate the result at the end
            val resultIncludingDuplicates =
                splitIntoBuckets(
                    LinkedList(subProjectTestClassTimes),
                    SubprojectTestClassTime::totalTime,
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Thu Apr 10 15:09:32 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb/SmbClient.java

    import org.codelibs.core.io.CloseableUtil;
    import org.codelibs.core.io.FileUtil;
    import org.codelibs.core.io.InputStreamUtil;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.crawler.Constants;
    import org.codelibs.fess.crawler.builder.RequestDataBuilder;
    import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 23.4K bytes
    - Viewed (3)
  10. cmd/dynamic-timeouts.go

    		if timeout < dt.minimum {
    			timeout = dt.minimum
    		}
    		atomic.StoreInt64(&dt.timeout, timeout)
    	} else if failPct < dynamicTimeoutDecreaseThresholdPct {
    		// We are hitting the timeout relatively few times,
    		// so decrease the timeout towards 25 % of maximum time spent.
    		maxDur = maxDur * 125 / 100
    
    		timeout := atomic.LoadInt64(&dt.timeout)
    		if maxDur < time.Duration(timeout) {
    			// Move 50% toward the max.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.5K bytes
    - Viewed (0)
Back to top