Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 691 - 700 of 1,029 for callEnd (0.05 seconds)

  1. cmd/data-scanner_test.go

    		Validity:    12 * time.Hour,
    		LockEnabled: true,
    	}
    
    	expiryWorker := func(wg *sync.WaitGroup, readyCh chan<- struct{}, taskCh <-chan expiryOp, gotExpired *[]ObjectToDelete) {
    		defer wg.Done()
    		// signal the calling goroutine that the worker is ready tor receive tasks
    		close(readyCh)
    		var expired []ObjectToDelete
    		for t := range taskCh {
    			switch v := t.(type) {
    			case noncurrentVersionsTask:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12K bytes
    - Click Count (0)
  2. src/main/webapp/js/admin/popper.min.js.map

    if (isBrowser && navigator.userAgent.indexOf(longerTimeoutBrowsers[i]) >= 0) {\n      return 1;\n    }\n  }\n  return 0;\n}());\n\nexport function microtaskDebounce(fn) {\n  let called = false\n  return () => {\n    if (called) {\n      return\n    }\n    called = true\n    window.Promise.resolve().then(() => {\n      called = false\n      fn()\n    })\n  }\n}\n\nexport function taskDebounce(fn) {\n  let scheduled = false;\n  return () => {\n    if (!scheduled) {\n      scheduled = true;\n      setTimeout(()...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Oct 26 01:49:09 GMT 2024
    - 120.9K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/graph/Graphs.java

        }
        return endpoints;
      }
    
      // NOTE: this should work as long as the delegate graph's implementation of edges() (like that of
      // AbstractGraph) derives its behavior from calling successors().
      private static final class TransposedGraph<N> extends ForwardingGraph<N> {
        private final Graph<N> graph;
    
        TransposedGraph(Graph<N> graph) {
          this.graph = graph;
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 11 01:10:31 GMT 2026
    - 24.4K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

        /*
         * The default RateLimiter configuration can save the unused permits of up to one second. This
         * is to avoid unnecessary stalls in situations like this: A RateLimiter of 1qps, and 4 threads,
         * all calling acquire() at these moments:
         *
         * T0 at 0 seconds
         * T1 at 1.05 seconds
         * T2 at 2 seconds
         * T3 at 3 seconds
         *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:05:27 GMT 2025
    - 21.8K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractConditionBean.java

        }
    
        @Override
        public void xsetPaging(boolean paging) {
            // Do nothing because this is unsupported on ConditionBean.
            // And it is possible that this method is called by PagingInvoker.
        }
    
        @Override
        public void enablePagingCountLater() {
            // nothing
        }
    
        @Override
        public void disablePagingCountLater() {
            // nothing
        }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 17.8K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractConditionBean.java

        }
    
        @Override
        public void xsetPaging(boolean paging) {
            // Do nothing because this is unsupported on ConditionBean.
            // And it is possible that this method is called by PagingInvoker.
        }
    
        @Override
        public void enablePagingCountLater() {
            // nothing
        }
    
        @Override
        public void disablePagingCountLater() {
            // nothing
        }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 17.8K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/ds/AbstractDataStoreTest.java

                assertEquals("Reader " + i + " should complete all iterations", iterations, trueCount[i] + falseCount[i]);
            }
        }
    
        /**
         * Test getName() method can be called concurrently without issues.
         */
        @Test
        public void test_getName_concurrentAccess() throws Exception {
            final int threadCount = 10;
            final Thread[] threads = new Thread[threadCount];
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 12.8K bytes
    - Click Count (1)
  8. android/guava/src/com/google/common/collect/FilteredEntryMultimap.java

      }
    
      @Override
      Collection<V> createValues() {
        return new FilteredMultimapValues<>(this);
      }
    
      @Override
      Iterator<Entry<K, V>> entryIterator() {
        throw new AssertionError("should never be called");
      }
    
      @Override
      Map<K, Collection<V>> createAsMap() {
        return new AsMap();
      }
    
      @Override
      Set<K> createKeySet() {
        return asMap().keySet();
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  9. docs/debugging/README.md

    Example:
    
    ```sh
    minio server /data
    ```
    
    Default trace is succinct only to indicate the API operations being called and the HTTP response status.
    
    ```sh
    mc admin trace myminio
    ```
    
    To trace entire HTTP request
    
    ```sh
    mc admin trace --verbose myminio
    ```
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 8.6K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/util/SearchEngineUtilTest.java

            // Note: In a real test environment, this would require proper SearchEngineClient setup
            // For now, we test that the method signature is correct and can be called
    
            AtomicInteger callbackCount = new AtomicInteger(0);
    
            try {
                // This will likely fail due to missing SearchEngineClient setup,
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 13.8K bytes
    - Click Count (0)
Back to Top