Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 523 for kuwait (0.04 sec)

  1. cmd/bucket-metadata-sys.go

    			}
    			sys.RemoveStaleBuckets(diskBuckets)
    
    			for i := range buckets {
    				wait := sleeper.Timer(ctx)
    
    				bucket := buckets[i].Name
    				updated := false
    
    				meta, err := loadBucketMetadata(ctx, sys.objAPI, bucket)
    				if err != nil {
    					internalLogIf(ctx, err, logger.WarningKind)
    					wait() // wait to proceed to next entry.
    					continue
    				}
    
    				sys.Lock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  2. buildscripts/verify-healing-empty-erasure-set.sh

    	export MC_HOST_myminio="http://minio:minio123@127.0.0.1:$((start_port + 1))"
    
    	timeout 15m /tmp/mc ready myminio || fail
    
    	# Wait for all drives to be online and formatted
    	while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].state | select(. != "ok")' | wc -l) -gt 0 ]; do sleep 1; done
    	# Wait for all drives to be healed
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

        }
        return new ListenableFutureAdapter<>(future, executor);
      }
    
      /**
       * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This will wait on the
       * future to finish, and when it completes, run the listeners. This implementation will wait on
       * the source future indefinitely, so if the source future never completes, the adapter will never
       * complete either.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

              connectResult = launchTcpConnect()
              nextTcpConnectAtNanos = now + connectDelayNanos
              awaitTimeoutNanos = connectDelayNanos
            }
    
            // Wait for an in-flight connect to complete or fail.
            if (connectResult == null) {
              connectResult = awaitTcpConnect(awaitTimeoutNanos, TimeUnit.NANOSECONDS) ?: continue
            }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

          Future<?> possiblyIgnoredError = executorService.submit(executeTask);
          returnValue += (int) listenerLatch.getCount();
          listenerLatch.await();
        }
        return returnValue;
      }
    
      @Benchmark
      int executeThenAdd_multiThreaded(int reps) throws InterruptedException {
        Runnable addTask =
            new Runnable() {
              @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  6. cmd/background-heal-ops.go

    	// while counting the number of concurrent connections
    	return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers())
    }
    
    func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) {
    	// No need to wait run at full speed.
    	if maxIO <= 0 {
    		return
    	}
    
    	const waitTick = 100 * time.Millisecond
    
    	tmpMaxWait := maxWait
    
    	for currentIO() >= maxIO {
    		if tmpMaxWait > 0 {
    			if tmpMaxWait < waitTick {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  7. docs/ja/docs/advanced/websockets.md

    /// note | 技術詳細
    
    `from starlette.websockets import WebSocket` を使用しても構いません.
    
    **FastAPI** は開発者の利便性のために、同じ `WebSocket` を提供します。しかし、こちらはStarletteから直接提供されるものです。
    
    ///
    
    ## メッセージの送受信
    
    WebSocketルートでは、 `await` を使ってメッセージの送受信ができます。
    
    {* ../../docs_src/websockets/tutorial001.py hl[48:52] *}
    
    バイナリやテキストデータ、JSONデータを送受信できます。
    
    ## 試してみる
    
    ファイル名が `main.py` である場合、以下の方法でアプリケーションを実行します。
    
    <div class="termy">
    
    ```console
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  8. src/test/java/jcifs/smb/SmbFileIntegrationTest.java

    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.testcontainers.containers.GenericContainer;
    import org.testcontainers.containers.output.Slf4jLogConsumer;
    import org.testcontainers.containers.wait.strategy.Wait;
    import org.testcontainers.junit.jupiter.Container;
    import org.testcontainers.junit.jupiter.Testcontainers;
    import org.testcontainers.utility.MountableFile;
    
    import jcifs.CIFSContext;
    import jcifs.Configuration;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 56K bytes
    - Viewed (0)
  9. docs/de/docs/advanced/events.md

    with open("file.txt") as file:
        file.read()
    ```
    
    In neueren Versionen von Python gibt es auch einen **asynchronen Kontextmanager**. Sie würden ihn mit `async with` verwenden:
    
    ```Python
    async with lifespan(app):
        await do_stuff()
    ```
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 9K bytes
    - Viewed (0)
  10. schema/schema.go

    		schemaCacheKey = fmt.Sprintf("%p-%s", modelType, specialTableName)
    	}
    
    	// Load exist schema cache, return if exists
    	if v, ok := cacheStore.Load(schemaCacheKey); ok {
    		s := v.(*Schema)
    		// Wait for the initialization of other goroutines to complete
    		<-s.initialized
    		return s, s.err
    	}
    
    	var tableName string
    	modelValue := reflect.New(modelType)
    	if specialTableName != "" {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Tue Aug 19 06:35:49 UTC 2025
    - 12.9K bytes
    - Viewed (0)
Back to top