Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 325 for timedOut (0.34 sec)

  1. cmd/bucket-quota.go

    	sys.Init(newObjectLayerFn())
    
    	dui, err := bucketStorageCache.GetWithCtx(ctx)
    	timedout := OperationTimedOut{}
    	if err != nil && !errors.Is(err, context.DeadlineExceeded) && !errors.As(err, &timedout) {
    		if len(dui.BucketsUsage) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. cmd/callhome.go

    	// Make sure only 1 callhome is running on the cluster.
    	locker := objAPI.NewNSLock(minioMetaBucket, "callhome/runCallhome.lock")
    	lkctx, err := locker.GetLock(ctx, callhomeLeaderLockTimeout)
    	if err != nil {
    		// lock timedout means some other node is the leader,
    		// cycle back return 'true'
    		return true
    	}
    
    	ctx = lkctx.Context()
    	defer locker.Unlock(lkctx)
    
    	// Perform callhome once and then keep running it at regular intervals.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  3. cmd/admin-server-info.go

    				} else {
    					if xnet.IsNetworkOrHostDown(err, false) {
    						network[nodeName] = string(madmin.ItemOffline)
    					} else if xnet.IsNetworkOrHostDown(err, true) {
    						network[nodeName] = "connection attempt timedout"
    					}
    				}
    			}
    		}
    	}
    
    	var memstats runtime.MemStats
    	runtime.ReadMemStats(&memstats)
    
    	gcStats := debug.GCStats{
    		// If stats.PauseQuantiles is non-empty, ReadGCStats fills
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (1)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

          throw InterruptedIOException()
        }
      }
    
      /**
       * The Okio timeout watchdog will call [timedOut] if the timeout is reached. In that case we close
       * the stream (asynchronously) which will notify the waiting thread.
       */
      internal inner class StreamTimeout : AsyncTimeout() {
        override fun timedOut() {
          closeLater(ErrorCode.CANCEL)
          connection.sendDegradedPingLater()
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  5. cmd/background-newdisks-heal-ops.go

    					if err := healFreshDisk(ctx, z, disk); err != nil {
    						globalBackgroundHealState.setDiskHealingStatus(disk, false)
    						timedout := OperationTimedOut{}
    						if !errors.Is(err, context.Canceled) && !errors.As(err, &timedout) && !errors.Is(err, errRetryHealing) {
    							printEndpointError(disk, err, false)
    						}
    						return
    					}
    					// Only upon success pop the healed disk.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

      internal val eventListener: EventListener = client.eventListenerFactory.create(this)
    
      private val timeout =
        object : AsyncTimeout() {
          override fun timedOut() {
            ******@****.***()
          }
        }.apply {
          timeout(client.callTimeoutMillis.toLong(), MILLISECONDS)
        }
    
      private val executed = AtomicBoolean()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  7. internal/logger/target/kafka/kafka.go

    	h.logChMu.RLock()
    	defer h.logChMu.RUnlock()
    	if h.logCh == nil {
    		// We are closing...
    		return nil
    	}
    
    	select {
    	case h.logCh <- entry:
    	case <-ctx.Done():
    		// return error only for context timedout.
    		if errors.Is(ctx.Err(), context.DeadlineExceeded) {
    			return ctx.Err()
    		}
    		return nil
    	default:
    		// log channel is full, do not wait and return
    		// an error immediately to the caller
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  8. internal/logger/target/http/http.go

    	defer func() {
    		if err != nil {
    			if xnet.IsNetworkOrHostDown(err, false) {
    				h.status.Store(statusOffline)
    			}
    			h.failedMessages.Add(int64(payloadCount))
    		} else {
    			h.status.Store(statusOnline)
    		}
    	}()
    
    	ctx, cancel := context.WithTimeout(ctx, timeout)
    	defer cancel()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  9. internal/dsync/drwmutex.go

    	drwMutexAcquireTimeout = 1 * time.Second // 1 second.
    
    	// dRWMutexRefreshTimeout - default timeout for the refresh call
    	drwMutexRefreshCallTimeout = 5 * time.Second
    
    	// dRWMutexUnlockTimeout - default timeout for the unlock call
    	drwMutexUnlockCallTimeout = 30 * time.Second
    
    	// dRWMutexForceUnlockTimeout - default timeout for the unlock call
    	drwMutexForceUnlockCallTimeout = 30 * time.Second
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

    import okio.buffer
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.Assertions.assertArrayEquals
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    
    @Timeout(5)
    @Tag("Slow")
    class Http2ConnectionTest {
      private val peer = MockHttp2Peer()
      private val taskFaker = TaskFaker()
    
      @AfterEach fun tearDown() {
        peer.close()
        taskFaker.close()
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
Back to top