- Sort Score
- Num 10 results
- Language All
Results 1 - 5 of 5 for getMaxTimeout (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Nov 11 14:51:43 GMT 2024 - 3K bytes - Click Count (0) -
cmd/storage-rest-client.go
return toStorageErr(err) } func (client *storageRESTClient) WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) error { ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout()) defer cancel() _, err := storageWriteMetadataRPC.Call(ctx, client.gridConn, &MetadataHandlerParams{ DiskID: *client.diskID.Load(), OrigVolume: origvolume, Volume: volume,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 08 02:38:41 GMT 2025 - 30.4K bytes - Click Count (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() {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jan 17 19:19:30 GMT 2025 - 6.2K bytes - Click Count (0) -
cmd/xl-storage.go
return xioutil.WithDeadline[[]byte](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) ([]byte, error) { data, _, err := s.readAllDataWithDMTime(ctx, volume, volumeDir, filePath) return data, err }) } func (s *xlStorage) moveToTrash(filePath string, recursive, immediatePurge bool) (err error) { w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout()) return w.Run(func() (err error) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0) -
cmd/erasure.go
defer wg.Done() drivePath := disk.Endpoint().Path readDirFn(pathJoin(drivePath, minioMetaTmpDeletedBucket), func(ddir string, typ os.FileMode) error { w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout()) return w.Run(func() error { wait := deleteCleanupSleeper.Timer(ctx) removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir)) wait() return nil }) }) }(disk)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 16.1K bytes - Click Count (0)