Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 481 for Timers (0.09 sec)

  1. cmd/data-scanner-metric.go

    func (p *scannerMetrics) incTime(s scannerMetric, d time.Duration) {
    	atomic.AddUint64(&p.operations[s], 1)
    	if s < scannerMetricLastRealtime {
    		p.latency[s].add(d)
    	}
    }
    
    // timeILM times an ILM action.
    // lifecycle.NoneAction is ignored.
    // Use for s < scannerMetricLastRealtime
    func (p *scannerMetrics) timeILM(a lifecycle.Action) func(versions uint64) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  2. cmd/storage-rest-server.go

    			return
    		}
    
    		// Indicate we are ready to write.
    		doneCh <- err
    
    		// Wait for channel to be closed so we don't race on writes.
    		<-doneCh
    
    		// Clear so we can be called multiple times without crashing.
    		doneCh = nil
    	}, &closeNotifier{rc: r.Body, done: bodyDoneCh}
    }
    
    // keepHTTPResponseAlive can be used to avoid timeouts with long storage
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  3. src/main/webapp/js/admin/adminlte.min.js

    ig.allowDuplicates&&(l+="-"+Math.floor(1e3*Math.random()),s+="-"+Math.floor(1e3*Math.random()));var r='<li class="nav-item" role="presentation"><a href="#" class="btn-iframe-close" data-widget="iframe-close" data-type="only-this"><i class="fas fa-times"></i></a><a class="nav-link" data-toggle="row" id="'+s+'" href="#'+l+'" role="tab" aria-controls="'+l+'" aria-selected="false">'+e+"</a></li>";n.default(me).append(unescape(escape(r)));var d='<div class="tab-pane fade" id="'+l+'" role="tabpanel" a...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 45.3K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

            setState(finalState);
            return true;
          }
    
          /**
           * Blocks until the task is complete or the timeout expires. Throws a {@link TimeoutException}
           * if the timer expires, otherwise behaves like {@link #get()}.
           */
          V get(long nanos)
              throws TimeoutException, CancellationException, ExecutionException, InterruptedException {
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jan 30 16:59:10 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/DiscreteDomain.java

        this.supportsFastOffset = supportsFastOffset;
      }
    
      /**
       * Returns, conceptually, "origin + distance", or equivalently, the result of calling {@link
       * #next} on {@code origin} {@code distance} times.
       */
      C offset(C origin, long distance) {
        C current = origin;
        checkNonnegative(distance, "distance");
        for (long i = 0; i < distance; i++) {
          current = next(current);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 17:34:21 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  6. docs/fr/docs/alternatives.md

    /// check | A inspiré **FastAPI** à
    
    Trouvez un moyen d'avoir une performance folle.
    
    C'est pourquoi **FastAPI** est basé sur Starlette, car il s'agit du framework le plus rapide disponible (testé par des benchmarks tiers).
    
    ///
    
    ### <a href="https://falconframework.org/" class="external-link" target="_blank">Falcon</a>
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sat Nov 09 16:39:20 UTC 2024
    - 27.5K bytes
    - Viewed (0)
  7. 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
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  8. 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> {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  9. cmd/erasure.go

    				w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    				return w.Run(func() error {
    					wait := deleteCleanupSleeper.Timer(ctx)
    					removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir))
    					wait()
    					return nil
    				})
    			})
    		}(disk)
    	}
    	wg.Wait()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  10. src/archive/zip/writer_test.go

    			w, _ := zw.CreateHeader(&FileHeader{
    				Name:   "foo",
    				Method: Deflate,
    			})
    			w.Write(bigBuf)
    		}
    		zw.Close()
    	}
    
    	b.ReportAllocs()
    	// Run once and then reset the timer.
    	// This effectively discards the very large initial flate setup cost,
    	// as well as the initialization of bigBuf.
    	runOnce(&bytes.Buffer{})
    	b.ResetTimer()
    
    	b.RunParallel(func(pb *testing.PB) {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jan 28 04:20:09 UTC 2025
    - 14.4K bytes
    - Viewed (0)
Back to top