Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 104 for timeouts (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. cmd/common-main.go

    	ctxt.SFTP = ctx.StringSlice("sftp")
    	ctxt.Interface = ctx.String("interface")
    	ctxt.UserTimeout = ctx.Duration("conn-user-timeout")
    	ctxt.SendBufSize = ctx.Int("send-buf-size")
    	ctxt.RecvBufSize = ctx.Int("recv-buf-size")
    	ctxt.IdleTimeout = ctx.Duration("idle-timeout")
    	ctxt.UserTimeout = ctx.Duration("conn-user-timeout")
    
    	if conf := ctx.String("config"); len(conf) > 0 {
    		err = mergeServerCtxtFromConfigFile(conf, ctxt)
    	} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

     *   <li>All delays and timeouts must use one of the constants {@code SHORT_DELAY_MS}, {@code
     *       SMALL_DELAY_MS}, {@code MEDIUM_DELAY_MS}, {@code LONG_DELAY_MS}. The idea here is that a
     *       SHORT is always discriminable from zero time, and always allows enough time for the small
     *       amounts of computation (creating a thread, calling a few methods, etc) needed to reach a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

     *   <li>All delays and timeouts must use one of the constants {@code SHORT_DELAY_MS}, {@code
     *       SMALL_DELAY_MS}, {@code MEDIUM_DELAY_MS}, {@code LONG_DELAY_MS}. The idea here is that a
     *       SHORT is always discriminable from zero time, and always allows enough time for the small
     *       amounts of computation (creating a thread, calling a few methods, etc) needed to reach a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.31.md

      - The "JoinConfiguration.discovery.timeout" field has been replaced by "JoinConfiguration.timeouts.discovery".
      - The "ClusterConfiguration.timeoutForControlPlane" field has been replaced by "{Init|Join}Configuration.timeouts.controlPlaneComponentHealthCheck".
      Please use the command "kubeadm config migrate" to migrate your existing v1beta3 configuration to v1beta4.
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Oct 23 12:18:32 UTC 2024
    - 315.4K bytes
    - Viewed (0)
Back to top