- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for getMaxTimeout (0.1 sec)
-
internal/config/drive/drive.go
func (c *Config) Update(updated Config) error { configLk.Lock() defer configLk.Unlock() c.MaxTimeout = getMaxTimeout(updated.MaxTimeout) return nil } // GetMaxTimeout - returns the per call drive operation timeout func (c *Config) GetMaxTimeout() time.Duration { return c.GetOPTimeout() } // GetOPTimeout - returns the per call drive operation timeout
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Nov 11 14:51:43 UTC 2024 - 3K bytes - Viewed (0) -
cmd/bitrot-streaming.go
buf := globalBytePoolCap.Load().Get() rb := ringbuffer.NewBuffer(buf[:cap(buf)]).SetBlocking(true) bw := &streamingBitrotWriter{ iow: ioutil.NewDeadlineWriter(rb.WriteCloser(), globalDriveConfig.GetMaxTimeout()), closeWithErr: rb.CloseWithError, h: h, shardSize: shardSize, canClose: &sync.WaitGroup{}, byteBuf: buf, } bw.canClose.Add(1) go func() {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jan 17 19:19:30 UTC 2025 - 6.2K bytes - Viewed (0)