Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewDeadlineWorker (0.09 sec)

  1. cmd/xl-storage-disk-id-check.go

    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricMakeVolBulk, volumes...)
    	if err != nil {
    		return err
    	}
    	defer done(0, &err)
    
    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.MakeVolBulk(ctx, volumes...) })
    }
    
    func (p *xlStorageDiskIDCheck) MakeVol(ctx context.Context, volume string) (err error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  2. cmd/erasure.go

    		go func(disk StorageAPI) {
    			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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    				if err != nil {
    					return nil
    				}
    				modTime = fi.ModTime
    				wait()
    			}
    			if time.Since(modTime) < globalAPIConfig.getStaleUploadsExpiry() {
    				return nil
    			}
    			w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    			return w.Run(func() error {
    				wait := deleteMultipartCleanupSleeper.Timer(ctx)
    				pathUUID := mustGetUUID()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
Back to top