Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for startTime (0.45 sec)

  1. src/test/java/org/codelibs/fess/ds/DataStoreTest.java

            private final AtomicLong executeTime = new AtomicLong(0);
            private final AtomicBoolean committed = new AtomicBoolean(false);
            private final long startTime = System.currentTimeMillis();
    
            @Override
            public void store(DataStoreParams paramMap, Map<String, Object> dataMap) {
                documentCount.incrementAndGet();
            }
    
            @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 13K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackTest.java

        }
    
        public void test_execution_time_tracking() {
            // Test execution time tracking
            IndexUpdateCallback callback = new IndexUpdateCallback() {
                private long startTime = System.currentTimeMillis();
                private long totalTime = 0;
    
                @Override
                public void store(DataStoreParams paramMap, Map<String, Object> dataMap) {
                    try {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImplTest.java

            @Override
            public void store(final DataStoreParams paramMap, final Map<String, Object> dataMap) {
                // Simplified store for testing
                systemHelper.calibrateCpuLoad();
                final long startTime = systemHelper.getCurrentTimeAsLong();
    
                // Required check
                final Object urlObj = dataMap.get(fessConfig.getIndexFieldUrl());
                if (urlObj == null) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 24.5K bytes
    - Viewed (0)
  4. guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/LocalCache.java

      private V load(K key) throws ExecutionException {
        long startTime = ticker.read();
        V calculatedValue;
        try {
          calculatedValue = loader.load(key);
          put(key, calculatedValue);
        } catch (RuntimeException e) {
          statsCounter.recordLoadException(ticker.read() - startTime);
          throw new UncheckedExecutionException(e);
        } catch (Exception e) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/exec/CrawlerTest.java

                    // Ignore
                }
            });
            testThread.start();
    
            long startTime = System.currentTimeMillis();
            method.invoke(crawler, testThread);
            long endTime = System.currentTimeMillis();
    
            assertTrue("Thread should have been joined", endTime - startTime >= 100);
        }
    
        // Test destroyContainer private static method via reflection
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 30.5K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        long startTime = stopwatch.instant;
        while (permits > 0) {
          int nextPermitsToAcquire = max(1, random.nextInt(permits));
          permits -= nextPermitsToAcquire;
          rateLimiter.acquire(nextPermitsToAcquire);
        }
        rateLimiter.acquire(1); // to repay for any pending debt
        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        long startTime = stopwatch.instant;
        while (permits > 0) {
          int nextPermitsToAcquire = max(1, random.nextInt(permits));
          permits -= nextPermitsToAcquire;
          rateLimiter.acquire(nextPermitsToAcquire);
        }
        rateLimiter.acquire(1); // to repay for any pending debt
        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

                }
            }
    
            final SuggestCreator creator = ComponentUtil.getComponent(SuggestCreator.class);
            final LocalDateTime startTime = LocalDateTime.now();
            int ret = creator.create();
            if (ret == 0) {
                ret = creator.purge(startTime);
            }
            return ret;
        }
    
        private int create() {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 11K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

            final int multiprocessCrawlingCount = ComponentUtil.getFessConfig().getCrawlingThreadCount();
    
            final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
            final long startTime = systemHelper.getCurrentTimeAsLong();
    
            final IndexUpdateCallback indexUpdateCallback = ComponentUtil.getComponent(IndexUpdateCallback.class);
    
            final List<String> sessionIdList = new ArrayList<>();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/helper/DocumentHelper.java

            if (client == null) {
                throw new CrawlingAccessException("CrawlerClient is null for " + url);
            }
    
            final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
            final long startTime = systemHelper.getCurrentTimeAsLong();
            try (final ResponseData responseData = client.execute(RequestDataBuilder.newRequestData().get().url(url).build())) {
                if (responseData.getRedirectLocation() != null) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 17.2K bytes
    - Viewed (0)
Back to top