Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for getMaxTimeout (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to Top