Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for Sweep (0.13 sec)

  1. cmd/tier-sweeper.go

    			ObjName:   os.RemoteObject,
    			VersionID: os.TransitionVersionID,
    			TierName:  os.TransitionTier,
    		}, true
    	}
    	return jentry{}, false
    }
    
    // Sweep removes the transitioned object if it's no longer referred to.
    func (os *objSweeper) Sweep() {
    	if je, ok := os.shouldRemoveRemoteObject(); ok {
    		globalExpiryState.enqueueTierJournalEntry(je)
    	}
    }
    
    type jentry struct {
    	ObjName   string
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 4.7K bytes
    - Viewed (0)
  2. cmd/object-handlers.go

    		objInfo.ETag = origETag
    		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CopyObject)
    		// Remove the transitioned object whose object version is being overwritten.
    		os.Sweep()
    	}
    }
    
    // PutObjectHandler - PUT Object
    // ----------
    // This implementation of the PUT operation adds an object to a bucket.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  3. cmd/object-multipart-handlers.go

    	if !globalTierConfigMgr.Empty() {
    		// Schedule object for immediate transition if eligible.
    		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CompleteMultipartUpload)
    		os.Sweep()
    	}
    }
    
    // AbortMultipartUploadHandler - Abort multipart upload
    func (api objectAPIHandlers) AbortMultipartUploadHandler(w http.ResponseWriter, r *http.Request) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  4. cmd/xl-storage.go

    				tier = oi.TransitionedObject.Tier
    			}
    			if sizeS.tiers != nil {
    				if st, ok := sizeS.tiers[tier]; ok {
    					sizeS.tiers[tier] = st.add(oi.tierStats())
    				}
    			}
    		}
    
    		// apply tier sweep action on free versions
    		for _, freeVersion := range fivs.FreeVersions {
    			oi := freeVersion.ToObjectInfo(item.bucket, item.objectPath(), versioned)
    			done = globalScannerMetrics.time(scannerMetricTierObjSweep)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  5. cmd/bucket-handlers.go

    		})
    	}
    
    	// Clean up transitioned objects from remote tier
    	for _, os := range oss {
    		if os == nil { // skip objects that weren't deleted due to invalid versionID etc.
    			continue
    		}
    		os.Sweep()
    	}
    }
    
    // PutBucketHandler - PUT Bucket
    // ----------
    // This implementation of the PUT operation creates a new bucket for authenticated request
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
Back to top