- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 83 for timeout (0.2 sec)
-
cmd/dynamic-timeouts.go
// We are hitting the timeout relatively few times, // so decrease the timeout towards 25 % of maximum time spent. max = max * 125 / 100 timeout := atomic.LoadInt64(&dt.timeout) if max < time.Duration(timeout) { // Move 50% toward the max. timeout = (int64(max) + timeout) / 2 } if timeout < dt.minimum { timeout = dt.minimum } atomic.StoreInt64(&dt.timeout, timeout) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Aug 19 23:21:05 GMT 2022 - 4.5K bytes - Viewed (0) -
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
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
} // GetLock tries to get a write lock on lm before the timeout occurs. func (lm *LRWMutex) GetLock(ctx context.Context, id string, source string, timeout time.Duration) (locked bool) { const isWriteLock = true return lm.lockLoop(ctx, id, source, timeout, isWriteLock) } // RLock holds a read lock on lm. //
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/http/transports.go
return tr } } // NewHTTPTransportWithTimeout allows setting a timeout for response headers func (s ConnSettings) NewHTTPTransportWithTimeout(timeout time.Duration) *http.Transport { tr := s.getDefaultTransport(0) // Settings specific to this transport. tr.ResponseHeaderTimeout = timeout return tr } // NewHTTPTransportWithClientCerts returns a new http configuration used for
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jan 30 00:50:37 GMT 2024 - 5.9K bytes - Viewed (0) -
internal/grid/grid_test.go
connRemoteLocal := remote.Connection(localHost) t.Run("testStreamRoundtrip", func(t *testing.T) { defer timeout(5 * time.Second)() testStreamRoundtrip(t, local, remote) assertNoActive(t, connRemoteLocal) assertNoActive(t, connLocalToRemote) }) t.Run("testStreamCancel", func(t *testing.T) { defer timeout(5 * time.Second)() testStreamCancel(t, local, remote) assertNoActive(t, connRemoteLocal)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/ioutil/ioutil.go
} } // DeadlineWorker implements the deadline/timeout resiliency pattern. type DeadlineWorker struct { timeout time.Duration } // NewDeadlineWorker constructs a new DeadlineWorker with the given timeout. // To return values, use the WithDeadline helper instead. func NewDeadlineWorker(timeout time.Duration) *DeadlineWorker { dw := &DeadlineWorker{ timeout: timeout, } return dw }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
internal/config/drive/drive.go
type Config struct { // MaxTimeout - maximum timeout for a drive operation MaxTimeout time.Duration `json:"maxTimeout"` } // Update - updates the config with latest values func (c *Config) Update(new Config) error { configLk.Lock() defer configLk.Unlock() c.MaxTimeout = getMaxTimeout(new.MaxTimeout) return nil } // GetMaxTimeout - returns the max timeout value. func (c *Config) GetMaxTimeout() time.Duration {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 2.5K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
t.Stop() return fmt.Errorf("unable to retrieve Kubernetes resource2 %s: %v", "", err) case <-ctx.Done(): printVerbosef(cmd, "timeout") // I think this means the timeout has happened: t.Stop() errTmpl := "timeout expired before resource %s became effective on %s" var errMsg string if proxyFlag != "" { errMsg = fmt.Sprintf(errTmpl, targetResource, proxyFlag)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 17 12:24:17 GMT 2024 - 10.1K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
if !drwm1.GetRLock(ctx1, cancel1, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") drwm2 := NewDRWMutex(ds, "simplelock") ctx2, cancel2 := context.WithCancel(context.Background()) if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 9.7K bytes - Viewed (0) -
cni/test/install_cni.go
if !chainedCNIPlugin { installConfig.InstallConfig.ChainedCNIPlugin = false } startInstallServer(ctx, &installConfig, t) } // checkResult checks if resultFile is equal to expectedFile at each tick until timeout func checkResult(result, expected string) error { resultFile, err := os.ReadFile(result) if err != nil { return fmt.Errorf("couldn't read result: %v", err) } expectedFile, err := os.ReadFile(expected)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0)