Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for encodeDirObject (0.13 sec)

  1. cmd/global-heal.go

    					return
    				}
    				if wildcard.Match("multipart/*", entry.name) {
    					return
    				}
    			}
    
    			// erasureObjects layer needs object names to be encoded
    			encodedEntryName := encodeDirObject(entry.name)
    
    			var result healEntryResult
    			fivs, err := entry.fileInfoVersions(bucket)
    			if err != nil {
    				res, err := er.HealObject(ctx, bucket, encodedEntryName, "",
    					madmin.HealOpts{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  2. cmd/utils.go

    // For ex. "prefix/" is stored as "prefix__XLDIR__"
    func encodeDirObject(object string) string {
    	if HasSuffix(object, slashSeparator) {
    		return strings.TrimSuffix(object, slashSeparator) + globalDirSuffix
    	}
    	return object
    }
    
    // Reverse process of encodeDirObject()
    func decodeDirObject(object string) string {
    	if HasSuffix(object, globalDirSuffix) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance.go

    					continue
    				}
    
    				for try := 0; try < 3; try++ {
    					// GetObjectReader.Close is called by rebalanceObject
    					gr, err := set.GetObjectNInfo(ctx,
    						bucket,
    						encodeDirObject(version.Name),
    						nil,
    						http.Header{},
    						ObjectOptions{
    							VersionID:    versionID,
    							NoDecryption: true,
    							NoLock:       true,
    							NoAuditLog:   true,
    						})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom.go

    						if !ignore {
    							stopFn(version.Size, err)
    							failure = err != nil
    							decomLogIf(ctx, err)
    						}
    						break
    					}
    					gr, err := set.GetObjectNInfo(ctx,
    						bi.Name,
    						encodeDirObject(version.Name),
    						nil,
    						http.Header{},
    						ObjectOptions{
    							VersionID:    versionID,
    							NoDecryption: true,
    							NoLock:       true,
    							NoAuditLog:   true,
    						})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  5. cmd/batch-expire.go

    					select {
    					case <-ctx.Done():
    						done = true
    					default:
    					}
    					stopFn := globalBatchJobsMetrics.trace(batchJobMetricExpire, ri.JobID, attempts)
    					_, err := api.DeleteObject(ctx, exp.Bucket, encodeDirObject(exp.Name), ObjectOptions{
    						DeletePrefix:       true,
    						DeletePrefixObject: true, // use prefix delete on exact object (this is an optimization to avoid fan-out calls)
    					})
    					if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  6. cmd/erasure-healing.go

    		}
    
    		// - Remove any remaining parts from outdated disks from before transition.
    		if partsMetadata[i].IsRemote() {
    			rmDataDir := partsMetadata[i].DataDir
    			disk.Delete(ctx, bucket, pathJoin(encodeDirObject(object), rmDataDir), DeleteOptions{
    				Immediate: true,
    				Recursive: true,
    			})
    		}
    
    		for i, v := range result.Before.Drives {
    			if v.Endpoint == disk.Endpoint().String() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  7. cmd/data-scanner.go

    			if lcEvent.Action.DeleteAll() {
    				numVersions = uint64(obj.NumVersions)
    			}
    			timeILM(numVersions)
    		}
    	}()
    
    	dobj, err = objLayer.DeleteObject(ctx, obj.Bucket, encodeDirObject(obj.Name), opts)
    	if err != nil {
    		if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    			traceFn(ILMExpiry, nil, nil)
    			return false
    		}
    		// Assume it is still there.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top