Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for encodeDirObject (0.64 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)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    					stopFn := globalRebalanceMetrics.log(rebalanceMetricRebalanceObject, poolIdx, bucket, version.Name, version.VersionID)
    					gr, err := set.GetObjectNInfo(ctx,
    						bucket,
    						encodeDirObject(version.Name),
    						nil,
    						http.Header{},
    						ObjectOptions{
    							VersionID:    versionID,
    							NoDecryption: true,
    							NoLock:       true,
    							NoAuditLog:   true,
    						})
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K 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) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 31.3K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom.go

    							decomLogIf(ctx, err)
    							continue
    						}
    						stopFn(nil)
    						failure = false
    						break
    					}
    					gr, err := set.GetObjectNInfo(ctx,
    						bi.Name,
    						encodeDirObject(version.Name),
    						nil,
    						http.Header{},
    						ObjectOptions{
    							VersionID:    versionID,
    							NoDecryption: true,
    							NoLock:       true,
    							NoAuditLog:   true,
    						})
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.3K bytes
    - Viewed (1)
  5. 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 {
    				_, err := er.HealObject(ctx, bucket, encodedEntryName, "",
    					madmin.HealOpts{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
  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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K 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.String() {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  9. cmd/data-scanner.go

    				numVersions = uint64(obj.NumVersions)
    			}
    			globalScannerMetrics.timeILM(lcEvent.Action)(numVersions)
    		}
    	}()
    
    	dobj, err = objLayer.DeleteObject(ctx, obj.Bucket, encodeDirObject(obj.Name), opts)
    	if err != nil {
    		if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    			return false
    		}
    		// Assume it is still there.
    		ilmLogOnceIf(ctx, err, "non-transition-expiry")
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 47.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) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
Back to top