Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 1,170 for timeN (0.02 seconds)

  1. cmd/erasure-server-pool.go

    	defer timer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-timer.C:
    			z.mpCache.Range(func(id string, info MultipartInfo) bool {
    				if time.Since(info.Initiated) >= globalAPIConfig.getStaleUploadsExpiry() {
    					z.mpCache.Delete(id)
    					// No need to notify to peers, each node will delete its own cache.
    				}
    				return true
    			})
    
    			// Reset for the next interval
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  2. 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;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 12 00:25:21 GMT 2025
    - 26.5K bytes
    - Click Count (0)
  3. cmd/xl-storage.go

    func (s *xlStorage) readMetadataWithDMTime(ctx context.Context, itemPath string) ([]byte, time.Time, error) {
    	if contextCanceled(ctx) {
    		return nil, time.Time{}, ctx.Err()
    	}
    
    	if err := checkPathLength(itemPath); err != nil {
    		return nil, time.Time{}, err
    	}
    
    	f, err := OpenFile(itemPath, readMode, 0o666)
    	if err != nil {
    		return nil, time.Time{}, err
    	}
    	defer f.Close()
    	stat, err := f.Stat()
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  4. docs/en/docs/tutorial/bigger-applications.md

    <img src="/img/tutorial/bigger-applications/image01.png">
    
    ## Include the same router multiple times with different `prefix` { #include-the-same-router-multiple-times-with-different-prefix }
    
    You can also use `.include_router()` multiple times with the *same* router using different prefixes.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 10 08:55:32 GMT 2025
    - 18.6K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

          private val useCompression: Boolean = true,
          private val out: Buffer,
        ) {
          /**
           * In the scenario where the dynamic table size changes multiple times between transmission of
           * header blocks, we need to keep track of the smallest value in that interval.
           */
          private var smallestHeaderTableSizeSetting = Integer.MAX_VALUE
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon May 05 16:01:00 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/ImmutableTable.java

       * Object)} are even more convenient.
       *
       * <p>Builder instances can be reused - it is safe to call {@link #buildOrThrow} multiple times to
       * build multiple tables in series. Each table is a superset of the tables created before it.
       *
       * @since 11.0
       */
      @DoNotMock
      public static final class Builder<R, C, V> {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 17.4K bytes
    - Click Count (0)
  7. internal/cachevalue/cache_test.go

    		func(ctx context.Context) (time.Time, error) {
    			return time.Now(), nil
    		},
    	)
    
    	t1, _ := cache.Get()
    
    	t2, _ := cache.Get()
    
    	if !t1.Equal(t2) {
    		t.Fatalf("expected time to be equal: %s != %s", t1, t2)
    	}
    
    	time.Sleep(3 * time.Second)
    	t3, _ := cache.Get()
    
    	if t1.Equal(t3) {
    		t.Fatalf("expected time to be un-equal: %s == %s", t1, t3)
    	}
    }
    
    func BenchmarkCache(b *testing.B) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  8. 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;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 12 00:25:21 GMT 2025
    - 26.5K bytes
    - Click Count (0)
  9. guava/src/com/google/common/collect/Iterators.java

       * is polled. This amortizes the sorting cost over the iteration and requires less memory than
       * sorting all elements at once.
       *
       * <p>Retrieving a single element takes approximately O(log(M)) time, where M is the number of
       * iterators. (Retrieving all elements takes approximately O(N*log(M)) time, where N is the total
       * number of elements.)
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 16 12:42:11 GMT 2025
    - 51.4K bytes
    - Click Count (0)
  10. internal/http/listener_test.go

    		{[]string{"unknown-host:65432"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{true}},                            // 4
    		{[]string{"localhost:65432"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{false}},                              // 5
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
Back to Top