Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetMaxTimeout (0.2 sec)

  1. internal/config/drive/drive.go

    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 {
    	configLk.RLock()
    	defer configLk.RUnlock()
    
    	return getMaxTimeout(c.MaxTimeout)
    }
    
    // LookupConfig - lookup config and override with valid environment settings if any.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  2. cmd/xl-storage-disk-id-check.go

    	// reduce checks by a second.
    	if globalDriveConfig.GetMaxTimeout() <= checkEvery {
    		checkEvery = globalDriveConfig.GetMaxTimeout() - time.Second
    		if checkEvery <= 0 {
    			checkEvery = globalDriveConfig.GetMaxTimeout()
    		}
    	}
    
    	// if disk max timeout is smaller than skipIfSuccessBefore window
    	// reduce the skipIfSuccessBefore by a second.
    	if globalDriveConfig.GetMaxTimeout() <= skipIfSuccessBefore {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 32.7K bytes
    - Viewed (0)
  3. cmd/bitrot-streaming.go

    	r, w := io.Pipe()
    	h := algo.New()
    
    	bw := &streamingBitrotWriter{
    		iow:          ioutil.NewDeadlineWriter(w, globalDriveConfig.GetMaxTimeout()),
    		closeWithErr: w.CloseWithError,
    		h:            h,
    		shardSize:    shardSize,
    		canClose:     &sync.WaitGroup{},
    	}
    	bw.canClose.Add(1)
    	go func() {
    		defer bw.canClose.Done()
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    			fi, err := disk.ReadVersion(ctx, "", minioMetaMultipartBucket, uploadIDPath, "", ReadOptions{})
    			if err != nil {
    				return nil
    			}
    			w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    			return w.Run(func() error {
    				wait := deleteMultipartCleanupSleeper.Timer(ctx)
    				if time.Since(fi.ModTime) > expiry {
    					pathUUID := mustGetUUID()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 42.4K bytes
    - Viewed (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)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 10:02:39 GMT 2024
    - 16K bytes
    - Viewed (1)
  6. cmd/xl-storage.go

    	}
    	return buf, stat.ModTime().UTC(), err
    }
    
    func (s *xlStorage) readMetadata(ctx context.Context, itemPath string) ([]byte, error) {
    	return xioutil.WithDeadline[[]byte](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) ([]byte, error) {
    		buf, _, err := s.readMetadataWithDMTime(ctx, itemPath)
    		return buf, err
    	})
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 82.4K bytes
    - Viewed (0)
Back to top