Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 175 for timeouts (0.14 sec)

  1. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        FUTURE(Timeout.SMALL, Timeout.MAX),
        SMALL(Timeout.SMALL),
        FINITE(Timeout.MIN, Timeout.MINUS_SMALL, Timeout.ZERO, Timeout.SMALL),
        INFINITE(Timeout.LARGE, Timeout.MAX);
    
        final ImmutableList<Timeout> timeouts;
    
        TimeoutsToUse(Timeout... timeouts) {
          this.timeouts = ImmutableList.copyOf(timeouts);
        }
      }
    
      /** Possible outcomes of calling any of the methods under test. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  2. internal/dsync/drwmutex.go

    	drwMutexInfinite = 1<<63 - 1
    )
    
    // Timeouts are timeouts for specific operations.
    type Timeouts struct {
    	// Acquire - tolerance limit to wait for lock acquisition before.
    	Acquire time.Duration
    
    	// RefreshCall - timeout for the refresh call
    	RefreshCall time.Duration
    
    	// UnlockCall - timeout for the unlock call
    	UnlockCall time.Duration
    
    	// ForceUnlockCall - timeout for the force unlock call
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        FUTURE(Timeout.SMALL, Timeout.MAX),
        SMALL(Timeout.SMALL),
        FINITE(Timeout.MIN, Timeout.MINUS_SMALL, Timeout.ZERO, Timeout.SMALL),
        INFINITE(Timeout.LARGE, Timeout.MAX);
    
        final ImmutableList<Timeout> timeouts;
    
        TimeoutsToUse(Timeout... timeouts) {
          this.timeouts = ImmutableList.copyOf(timeouts);
        }
      }
    
      /** Possible outcomes of calling any of the methods under test. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

          Future<V> future, long timeout, TimeUnit unit) throws ExecutionException, TimeoutException {
        boolean interrupted = false;
        try {
          long remainingNanos = unit.toNanos(timeout);
          long end = System.nanoTime() + remainingNanos;
    
          while (true) {
            try {
              // Future treats negative timeouts just like zero.
              return future.get(remainingNanos, NANOSECONDS);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

          Future<V> future, long timeout, TimeUnit unit) throws ExecutionException, TimeoutException {
        boolean interrupted = false;
        try {
          long remainingNanos = unit.toNanos(timeout);
          long end = System.nanoTime() + remainingNanos;
    
          while (true) {
            try {
              // Future treats negative timeouts just like zero.
              return future.get(remainingNanos, NANOSECONDS);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  6. internal/dsync/dsync_test.go

    	var clnts []NetLocker
    	for i := 0; i < len(nodes); i++ {
    		clnts = append(clnts, newClient(nodes[i].URL))
    	}
    
    	ds = &Dsync{
    		GetLockers: func() ([]NetLocker, string) { return clnts, uuid.New().String() },
    		Timeouts: Timeouts{
    			Acquire:         testDrwMutexAcquireTimeout,
    			RefreshCall:     testDrwMutexRefreshCallTimeout,
    			UnlockCall:      testDrwMutexUnlockCallTimeout,
    			ForceUnlockCall: testDrwMutexForceUnlockCallTimeout,
    		},
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  7. architecture/tests/integration.md

    - **Focus**:
      1. Configuration of Envoy proxies by Pilot.
      1. Communication between Pilot and Envoy proxies.
      1. Validation of service discovery.
      1. Testing of traffic management policies (e.g., routing, retries, timeouts).
      1. Validation of load balancing configurations.
      1. Specific `istioctl proxy-config` commands being tested: `bootstrap`, `cluster`, `endpoint`, `listener`, `route`, `all`.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 00:57:44 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  8. cmd/namespace-lock.go

    // Lock - block until write lock is taken or timeout has occurred.
    func (di *distLockInstance) GetLock(ctx context.Context, timeout *dynamicTimeout) (LockContext, error) {
    	lockSource := getSource(2)
    	start := UTCNow()
    
    	newCtx, cancel := context.WithCancel(ctx)
    	if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{
    		Timeout:       timeout.Timeout(),
    		RetryInterval: timeout.RetryInterval(),
    	}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  9. docs/metrics/prometheus/list.md

    | `minio_node_drive_errors_timeout`      | Total number of drive timeout errors since server start             |
    | `minio_node_drive_errors_ioerror`      | Total number of drive I/O errors since server start                 |
    | `minio_node_drive_errors_availability` | Total number of drive I/O errors, timeouts since server start       |
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:48:51 UTC 2024
    - 43.3K bytes
    - Viewed (0)
  10. cmd/storage-rest-server.go

    }
    
    func (c *closeNotifier) Close() error {
    	if c.done != nil {
    		xioutil.SafeClose(c.done)
    		c.done = nil
    	}
    	return c.rc.Close()
    }
    
    // keepHTTPReqResponseAlive can be used to avoid timeouts with long storage
    // operations, such as bitrot verification or data usage scanning.
    // Every 10 seconds a space character is sent.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
Back to top