Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 883 for wait (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/deadlineconn/deadlineconn_test.go

    			return
    		}
    		received := string(b)
    		if received != "message one\n" {
    			t.Errorf(`server: expected: "message one\n", got: %v`, received)
    			return
    		}
    
    		// Wait for more than read timeout to simulate processing.
    		time.Sleep(3 * time.Second)
    
    		_, terr = deadlineconn.Read(b)
    		if terr != nil {
    			t.Errorf("failed to read from client. %v", terr)
    			return
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Nov 11 17:15:17 GMT 2024
    - 4.8K bytes
    - Click Count (0)
  2. internal/lock/lock_nix.go

    }
    
    // TryLockedOpenFile - tries a new write lock, functionality
    // it is similar to LockedOpenFile with with syscall.LOCK_EX
    // mode but along with syscall.LOCK_NB such that the function
    // doesn't wait forever but instead returns if it cannot
    // acquire a write lock.
    func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
    	return lockedOpenFile(path, flag, perm, syscall.LOCK_NB)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 2.8K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java

          assertWithMessage("Loader should NOT have been called @#%s", i)
              .that(loader.wasCalled())
              .isFalse();
        }
    
        // wait for entries to expire, but don't call expireEntries
        ticker.advance(EXPIRING_TIME * 10, MILLISECONDS);
    
        // add a single unexpired entry
        cache.getUnchecked(KEY_PREFIX + 11);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 16:38:16 GMT 2026
    - 19.1K bytes
    - Click Count (0)
  4. internal/grid/debug.go

    			manager.debugMsg(debugShutdown)
    		}
    		for _, server := range t.Servers {
    			server.Close()
    		}
    		for _, listener := range t.Listeners {
    			listener.Close()
    		}
    	})
    }
    
    // WaitAllConnect will wait for all connections to be established.
    func (t *TestGrid) WaitAllConnect(ctx context.Context) {
    	for _, manager := range t.Managers {
    		for _, remote := range manager.Targets() {
    			if manager.HostName() == remote {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  5. helm/minio/templates/_helper_create_svcacct.txt

    # Special characters for example : ',",<,>,{,}
    MINIO_ACCESSKEY_SECRETKEY_TMP="/tmp/accessKey_and_secretKey_svcacct_tmp"
    
    # connectToMinio
    # Use a check-sleep-check loop to wait for MinIO service to be available
    connectToMinio() {
      SCHEME=$1
      ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts
      set -e ; # fail if we can't read the keys.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Mar 28 23:20:50 GMT 2024
    - 3.4K bytes
    - Click Count (0)
  6. impl/maven-cli/src/test/java/org/apache/maven/cling/transfer/ConsoleMavenTransferListenerTest.java

                    // start all threads at once
                    try {
                        startLatch.await();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
    
                    // wait for all thread to end
                    try {
                        endLatch.await();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Mar 21 04:56:21 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  7. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

            new Thread(() -> latch.countDown()).start();
          }
    
          future.addListener(listenerLatch::countDown, exec);
        }
    
        assertSame(Boolean.TRUE, future.get());
        // Wait for the listener latch to complete.
        listenerLatch.await(500, MILLISECONDS);
    
        exec.shutdown();
        exec.awaitTermination(500, MILLISECONDS);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        @Override
        public @Nullable Void call() throws InterruptedException {
          running = true;
          startLatch.countDown();
          stopLatch.await();
          running = false;
          return null;
        }
    
        void waitForStart() throws InterruptedException {
          startLatch.await();
        }
    
        void stop() {
          stopLatch.countDown();
        }
    
        boolean isRunning() {
          return running;
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 13.6K bytes
    - Click Count (0)
  9. docs/bucket/lifecycle/setup_ilm_transition.sh

    minio server --address 127.0.0.1:9004 "http://127.0.0.1:9003/tmp/multisiteb/data/disterasure/xl{1...4}" \
    	"http://127.0.0.1:9004/tmp/multisiteb/data/disterasure/xl{5...8}" >/tmp/siteb_2.log 2>&1 &
    
    # Wait to make sure all MinIO instances are up
    
    export MC_HOST_sitea=http://minioadmin:minioadmin@127.0.0.1:9001
    export MC_HOST_siteb=http://minioadmin:minioadmin@127.0.0.1:9004
    
    ./mc ready sitea
    ./mc ready siteb
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Oct 31 22:10:24 GMT 2024
    - 2.8K bytes
    - Click Count (0)
  10. helm/minio/templates/_helper_create_user.txt

    # Special characters for example : ',",<,>,{,}
    MINIO_ACCESSKEY_SECRETKEY_TMP="/tmp/accessKey_and_secretKey_tmp"
    
    # connectToMinio
    # Use a check-sleep-check loop to wait for MinIO service to be available
    connectToMinio() {
      SCHEME=$1
      ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts
      set -e ; # fail if we can't read the keys.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Dec 12 23:43:32 GMT 2023
    - 3.2K bytes
    - Click Count (0)
Back to Top