Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 28 for PathJoin (0.21 sec)

  1. cmd/erasure-healing.go

    			for i, disk := range latestDisks {
    				if disk == OfflineDisk {
    					continue
    				}
    				checksumInfo := copyPartsMetadata[i].Erasure.GetChecksumInfo(partNumber)
    				partPath := pathJoin(object, srcDataDir, fmt.Sprintf("part.%d", partNumber))
    				readers[i] = newBitrotReader(disk, copyPartsMetadata[i].Data, bucket, partPath, tillOffset, checksumAlgo,
    					checksumInfo.Hash, erasure.ShardSize())
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.8K bytes
    - Viewed (0)
  2. cmd/format-erasure.go

    		return nil, err
    	}
    
    	tmpOld := pathJoin(export, minioMetaTmpDeletedBucket, mustGetUUID())
    	if err := renameAll(pathJoin(export, minioMetaMultipartBucket),
    		tmpOld, export); err != nil && err != errFileNotFound {
    		bootLogIf(GlobalContext, fmt.Errorf("unable to rename (%s -> %s) %w, drive may be faulty please investigate",
    			pathJoin(export, minioMetaMultipartBucket),
    			tmpOld,
    			osErrToFileErr(err)))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    			scannerSleeper.Sleep(ctx, dataScannerSleepPerFolder)
    		}
    
    		var existingFolders, newFolders []cachedFolder
    		var foundObjects bool
    		err := readDirFn(pathJoin(f.root, folder.name), func(entName string, typ os.FileMode) error {
    			// Parse
    			entName = pathClean(pathJoin(folder.name, entName))
    			if entName == "" || entName == folder.name {
    				if f.dataUsageScannerDebug {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:43:17 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  4. cmd/object-api-utils_test.go

    }
    
    func BenchmarkPathJoinOld(b *testing.B) {
    	b.Run("PathJoin", func(b *testing.B) {
    		b.ResetTimer()
    		b.ReportAllocs()
    
    		for i := 0; i < b.N; i++ {
    			pathJoinOld("volume", "path/path/path")
    		}
    	})
    }
    
    func BenchmarkPathJoin(b *testing.B) {
    	b.Run("PathJoin", func(b *testing.B) {
    		b.ResetTimer()
    		b.ReportAllocs()
    
    		for i := 0; i < b.N; i++ {
    			pathJoin("volume", "path/path/path")
    		}
    	})
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  5. cmd/metacache-walk.go

    	}
    
    	// Fast exit track to check if we are listing an object with
    	// a trailing slash, this will avoid to list the object content.
    	if HasSuffix(opts.BaseDir, SlashSeparator) {
    		metadata, err := s.readMetadata(ctx, pathJoin(volumeDir,
    			opts.BaseDir[:len(opts.BaseDir)-1]+globalDirSuffix,
    			xlStorageFormatFile))
    		diskHealthCheckOK(ctx, err)
    		if err == nil {
    			// if baseDir is already a directory object, consider it
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  6. cmd/admin-heal-ops.go

    	respBytes []byte, apiErr APIError, errMsg string,
    ) {
    	if h.forceStarted {
    		_, apiErr = ahs.stopHealSequence(pathJoin(h.bucket, h.object))
    		if apiErr.Code != "" {
    			return respBytes, apiErr, ""
    		}
    	} else {
    		oh, exists := ahs.getHealSequence(pathJoin(h.bucket, h.object))
    		if exists && !oh.hasEnded() {
    			errMsg = "Heal is already running on the given path " +
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 09 18:04:41 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  7. cmd/object-api-utils.go

    }
    
    // pathsJoinPrefix - like pathJoin retains trailing SlashSeparator
    // for all elements, prepends them with 'prefix' respectively.
    func pathsJoinPrefix(prefix string, elem ...string) (paths []string) {
    	paths = make([]string, len(elem))
    	for i, e := range elem {
    		paths[i] = pathJoin(prefix, e)
    	}
    	return paths
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 36.3K bytes
    - Viewed (0)
  8. cmd/common-main.go

    	}
    	return ekvs, nil
    }
    
    func readFromSecret(sp string) (string, error) {
    	// Supports reading path from docker secrets, filename is
    	// relative to /run/secrets/ position.
    	if isFile(pathJoin("/run/secrets/", sp)) {
    		sp = pathJoin("/run/secrets/", sp)
    	}
    	credBuf, err := os.ReadFile(sp)
    	if err != nil {
    		if os.IsNotExist(err) { // ignore if file doesn't exist.
    			return "", nil
    		}
    		return "", err
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 31.5K bytes
    - Viewed (0)
  9. cmd/metacache-set.go

    }
    
    const metacachePrefix = ".metacache"
    
    func metacachePrefixForID(bucket, id string) string {
    	return pathJoin(bucketMetaPrefix, bucket, metacachePrefix, id)
    }
    
    // objectPath returns the object path of the cache.
    func (o *listPathOptions) objectPath(block int) string {
    	return pathJoin(metacachePrefixForID(o.Bucket, o.ID), "block-"+strconv.Itoa(block)+".s2")
    }
    
    func (o *listPathOptions) SetFilter() {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 22:18:44 UTC 2024
    - 30.4K bytes
    - Viewed (0)
  10. cmd/erasure-object_test.go

    		})
    		switch statErr.(type) {
    		case VersionNotFound:
    		default:
    			t.Fatalf("Object %s is not removed", test.bucket+SlashSeparator+test.object)
    		}
    	}
    
    	if _, err = os.ReadFile(pathJoin(fsDirs[0], bucketName, "dir/obj1", "xl.meta")); err == nil {
    		t.Fatalf("xl.meta still present after removal")
    	}
    }
    
    func TestErasureDeleteObjectsErasureSet(t *testing.T) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
Back to top