Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for immediately (0.14 sec)

  1. cmd/object-multipart-handlers.go

    			Status:    http.StatusText(http.StatusOK),
    		})
    	}
    
    	// Remove the transitioned object whose object version is being overwritten.
    	if !globalTierConfigMgr.Empty() {
    		// Schedule object for immediate transition if eligible.
    		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CompleteMultipartUpload)
    		os.Sweep()
    	}
    }
    
    // AbortMultipartUploadHandler - Abort multipart upload
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    		if disk == nil {
    			continue
    		}
    		wg.Add(1)
    		go func(disk StorageAPI) {
    			defer wg.Done()
    			disk.Delete(ctx, bucket, prefix, DeleteOptions{
    				Recursive: true,
    				Immediate: false,
    			})
    		}(disk)
    	}
    	wg.Wait()
    }
    
    // Remove the old multipart uploads on the given disk.
    func (er erasureObjects) cleanupStaleUploadsOnDisk(ctx context.Context, disk StorageAPI) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  3. cmd/object-handlers.go

    		RespElements: extractRespElements(w),
    		UserAgent:    r.UserAgent(),
    		Host:         handlers.GetSourceIP(r),
    	})
    
    	if !remoteCallRequired && !globalTierConfigMgr.Empty() {
    		// Schedule object for immediate transition if eligible.
    		objInfo.ETag = origETag
    		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CopyObject)
    		// Remove the transitioned object whose object version is being overwritten.
    		os.Sweep()
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    	for index := range disks {
    		g.Go(func() error {
    			if disks[index] == nil {
    				return nil
    			}
    			return disks[index].Delete(ctx, bucket, prefix, DeleteOptions{
    				Recursive: true,
    				Immediate: true,
    			})
    		}, index)
    	}
    
    	// return errors if any during deletion
    	return reduceWriteQuorumErrs(ctx, g.Wait(), objectOpIgnoredErrs, writeQuorum)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
Back to top