Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 431 - 440 of 676 for cdone (0.02 seconds)

  1. internal/kms/kes.go

    		Endpoint  string
    		ItemState madmin.ItemState
    	}
    
    	var wg sync.WaitGroup
    	results := make([]Result, len(c.client.Endpoints))
    	for i := range c.client.Endpoints {
    		wg.Add(1)
    		go func(i int) {
    			defer wg.Done()
    
    			client := kes.Client{
    				Endpoints:  []string{c.client.Endpoints[i]},
    				HTTPClient: c.client.HTTPClient,
    			}
    
    			var item madmin.ItemState
    			if _, err := client.Status(ctx); err == nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Aug 18 06:43:03 GMT 2024
    - 7.3K bytes
    - Click Count (0)
  2. docs/metrics/prometheus/README.md

      metrics_path: /minio/v2/metrics/bucket
      scheme: http
      static_configs:
      - targets: ['localhost:9000']
    ```
    
    ##### Node (optional)
    
    Optionally you can also collect per node metrics. This needs to be done on a per server instance.
    The scrape configurations should use all the servers under `targets` so that graphing systems like
    grafana can visualize them for all the nodes
    
    ```yaml
    scrape_configs:
    - job_name: minio-job
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/primitives/UnsignedBytesTest.java

        Random rnd = new Random(714958103);
        for (int trial = 0; trial < 100; trial++) {
          byte[] left = new byte[1 + rnd.nextInt(32)];
          rnd.nextBytes(left);
          byte[] right = left.clone();
          assertThat(comparator1.compare(left, right)).isEqualTo(0);
          assertThat(comparator2.compare(left, right)).isEqualTo(0);
          int i = rnd.nextInt(left.length);
          left[i] ^= (byte) (1 + rnd.nextInt(255));
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

            .receivedResponseAtMillis(System.currentTimeMillis())
            .build()
            .also {
              call.eventListener.satisfactionFailure(call, it)
            }
        }
    
        // If we don't need the network, we're done.
        if (networkRequest == null) {
          return cacheResponse!!
            .newBuilder()
            .cacheResponse(cacheResponse.stripBody())
            .build()
            .also {
              call.eventListener.cacheHit(call, it)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 10.3K bytes
    - Click Count (0)
  5. docs/distributed/decom-encrypted-kes.sh

    ./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1}
    
    until $(./mc admin decom status myminio/ | grep -q Complete); do
    	echo "waiting for decom to finish..."
    	sleep 1s
    done
    
    kill $pid_1
    kill $pid_2
    
    sleep 5s
    
    (minio server --address ":9001" http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/removed.log) &
    pid=$!
    
    sleep 30s
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon May 27 19:17:46 GMT 2024
    - 7.1K bytes
    - Click Count (1)
  6. samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt

    logFile = File("/tmp/key.log"), tlsVersions = tlsVersions, launch = launch)`
     * 3. Register with `client.eventListenerFactory(eventListenerFactory)`
     * 4. Launch wireshark if not done externally `val process = eventListenerFactory.launchWireShark()`
     */
    @SuppressSignatureCheck
    class WireSharkListenerFactory(
      private val logFile: File,
      private val tlsVersions: List<TlsVersion>,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat May 10 11:15:14 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  7. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * future.addListener(new Runnable() {
     *   public void run() {
     *     processedCount.incrementAndGet();
     *     inFlight.remove(name);
     *     lastProcessed.set(name);
     *     logger.info("Done with {0}", name);
     *   }
     * }, executor);
     * }
     *
     * <h3>How to get an instance</h3>
     *
     * <p>We encourage you to return {@code ListenableFuture} from your methods so that your users can
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  8. guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * future.addListener(new Runnable() {
     *   public void run() {
     *     processedCount.incrementAndGet();
     *     inFlight.remove(name);
     *     lastProcessed.set(name);
     *     logger.info("Done with {0}", name);
     *   }
     * }, executor);
     * }
     *
     * <h3>How to get an instance</h3>
     *
     * <p>We encourage you to return {@code ListenableFuture} from your methods so that your users can
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  9. api/maven-api-xml/src/main/java/org/apache/maven/api/xml/XmlService.java

     *   <li>{@code override}: Completely replaces the element</li>
     *   <li>{@code remove}: Removes the element</li>
     * </ul>
     *
     * <p>For complex XML structures, combining can also be done based on:</p>
     * <ul>
     *   <li>ID: Using the {@code combine.id} attribute</li>
     *   <li>Keys: Using the {@code combine.keys} attribute with comma-separated key names</li>
     * </ul>
     *
     * @since 4.0.0
     */
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Apr 03 13:33:59 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

    internal fun <T> Array<out T>?.toImmutableList(): List<T> =
      when {
        this.isNullOrEmpty() -> emptyList()
        this.size == 1 -> Collections.singletonList(this[0])
        else -> this.clone().asList().unmodifiable()
      }
    
    /** Closes this, ignoring any checked exceptions. */
    internal fun Socket.closeQuietly() {
      try {
        close()
      } catch (e: AssertionError) {
        throw e
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 10.2K bytes
    - Click Count (1)
Back to Top