Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for encodeDirObject (0.1 sec)

  1. cmd/erasure-server-pool.go

    		return ObjectInfo{}, err
    	}
    	if err := checkCopyObjArgs(ctx, dstBucket, dstObject); err != nil {
    		return ObjectInfo{}, err
    	}
    
    	srcObject = encodeDirObject(srcObject)
    	dstObject = encodeDirObject(dstObject)
    
    	cpSrcDstSame := isStringEqual(pathJoin(srcBucket, srcObject), pathJoin(dstBucket, dstObject))
    
    	if !dstOpts.NoLock {
    		ns := z.NewNSLock(dstBucket, dstObject)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. cmd/erasure-healing_test.go

    	// Remove the object backend files from the first disk.
    	z := obj.(*erasureServerPools)
    	er := z.serverPools[0].sets[0]
    	firstDisk := er.getDisks()[0]
    	err = firstDisk.DeleteVol(context.Background(), pathJoin(bucket, encodeDirObject(object)), true)
    	if err != nil {
    		t.Fatalf("Failed to delete a file - %v", err)
    	}
    
    	// Heal the object
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. cmd/xl-storage.go

    		// With immediate purge also attempt deleting for `__XL_DIR__` folder/directory objects.
    		targetPath2 = pathutil.Join(s.drivePath, minioMetaTmpDeletedBucket, mustGetUUID())
    		renameAll(encodeDirObject(filePath), targetPath2, pathutil.Join(s.drivePath, minioMetaBucket))
    	}
    
    	// ENOSPC is a valid error from rename(); remove instead of rename in that case
    	if errors.Is(err, errDiskFull) || isSysErrNoSpace(err) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top