Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewDeadlineWorker (0.06 sec)

  1. 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)
  2. 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