Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 228 for Pairing (0.22 sec)

  1. docs/distributed/decom-encrypted.sh

    ./mc ls -r --versions myminio/versioned/ >expanded_ns_versions.txt
    
    ./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 1
    done
    
    kill $pid_1
    kill $pid_2
    
    sleep 5
    
    (minio server --address ":9001" http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/removed.log) &
    pid=$!
    
    Shell Script
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

                // so when oldFuture completes it is safe to allow the next submitted task to
                // proceed. Doing this immediately here lets the next task run without waiting for
                // the cancelled task's executor to run the noop AsyncCallable.
                //
                // ---
                //
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/server_test.go

    	if f.testWG != nil {
    		defer f.testWG.Done()
    	}
    	args := f.Called(ambientPods)
    	return args.Error(0)
    }
    
    // Custom "wait group with timeout" for waiting for fakeServer calls in a goroutine to finish
    type WaitGroup struct {
    	count int32
    	done  chan struct{}
    }
    
    func NewWaitGroup() *WaitGroup {
    	return &WaitGroup{
    		done: make(chan struct{}),
    	}
    }
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  4. cmd/bootstrap-peer-server.go

    			retries++
    			// after 20 retries start logging that servers are not reachable yet
    			if retries >= 20 {
    				logger.Info(fmt.Sprintf("Waiting for at least %d remote servers with valid configuration to be online", len(clnts)/2))
    				if len(offlineEndpoints) > 0 {
    					logger.Info(fmt.Sprintf("Following servers are currently offline or unreachable %s", offlineEndpoints))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.30.md

      - [Changes by Kind](#changes-by-kind)
        - [Deprecation](#deprecation)
        - [API Change](#api-change)
        - [Feature](#feature)
        - [Documentation](#documentation)
        - [Failing Test](#failing-test)
        - [Bug or Regression](#bug-or-regression)
        - [Other (Cleanup or Flake)](#other-cleanup-or-flake)
        - [Uncategorized](#uncategorized)
      - [Dependencies](#dependencies)
        - [Added](#added)
    Plain Text
    - Registered: Fri May 03 09:05:14 GMT 2024
    - Last Modified: Wed Apr 17 17:56:15 GMT 2024
    - 227.9K bytes
    - Viewed (0)
  6. docs/metrics/prometheus/list.md

    | `minio_s3_requests_total`                     | Total number S3 requests.                                |
    | `minio_s3_requests_waiting_total`             | Number of S3 requests in the waiting queue.              |
    | `minio_s3_requests_ttfb_seconds_distribution` | Distribution of the time to first byte across API calls. |
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 43.4K bytes
    - Viewed (2)
  7. docs/zh/docs/deployment/deta.md

    ## 使用 CLI 登录
    
    现在,使用 CLI 登录 Deta:
    
    <div class="termy">
    
    ```console
    $ deta login
    
    Please, log in from the web page. Waiting..
    Logged in successfully.
    ```
    
    </div>
    
    这个命令会打开浏览器并自动验证身份。
    
    ## 使用 Deta 部署
    
    接下来,使用 Deta CLI 部署应用:
    
    <div class="termy">
    
    ```console
    $ deta new
    
    Plain Text
    - Registered: Sun Mar 31 07:19:09 GMT 2024
    - Last Modified: Sun Jan 28 18:06:55 GMT 2024
    - 5.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        // being resumed. To avoid a flake in this scenario, calculate how long that thread actually
        // waited and assert based on that time. Empirically, the race where the thread ends up waiting
        // for 5.5 seconds happens about 2% of the time.
        boolean longWait = TimeUnit.NANOSECONDS.toSeconds(thread.timeSpentBlocked) >= 5;
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  9. licenses/go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc/LICENSE

          means any form of electronic, verbal, or written communication sent
          to the Licensor or its representatives, including but not limited to
          communication on electronic mailing lists, source code control systems,
          and issue tracking systems that are managed by, or on behalf of, the
          Licensor for the purpose of discussing and improving the Work, but
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Dec 15 21:30:37 GMT 2023
    - 11.1K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/SocksProxy.kt

      fun connectionCount(): Int = connectionCount.get()
    
      fun shutdown() {
        serverSocket!!.close()
        executor.shutdown()
        if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
          throw IOException("Gave up waiting for executor to shut down")
        }
      }
    
      private fun service(from: Socket) {
        val name = "SocksProxy ${from.remoteSocketAddress}"
        threadName(name) {
          try {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 7.7K bytes
    - Viewed (0)
Back to top