Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for PathJoin (0.06 sec)

  1. cmd/xl-storage.go

    			return err
    		}
    
    		return s.writeAllMeta(ctx, volume, pathJoin(path, xlStorageFormatFile), buf, true)
    	}
    
    	if opts.UndoWrite && opts.OldDataDir != "" {
    		return renameAll(pathJoin(filePath, opts.OldDataDir, xlStorageFormatFileBackup), pathJoin(filePath, xlStorageFormatFile), filePath)
    	}
    
    	return s.deleteFile(volumeDir, pathJoin(volumeDir, path, xlStorageFormatFile), true, false)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  2. cmd/background-newdisks-heal-ops.go

    	}
    	globalBackgroundHealState.updateHealStatus(h)
    	return h.disk.WriteAll(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    		htrackerBytes)
    }
    
    // delete the tracker on disk.
    func (h *healingTracker) delete(ctx context.Context) error {
    	return h.disk.Delete(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    		DeleteOptions{
    			Recursive: false,
    			Immediate: false,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    			if !metaArr[index].IsValid() {
    				continue
    			}
    			if !metaArr[index].Erasure.Equal(fi.Erasure) {
    				continue
    			}
    			checksumInfo := metaArr[index].Erasure.GetChecksumInfo(partNumber)
    			partPath := pathJoin(object, metaArr[index].DataDir, fmt.Sprintf("part.%d", partNumber))
    			readers[index] = newBitrotReader(disk, metaArr[index].Data, bucket, partPath, tillOffset,
    				checksumInfo.Algorithm, checksumInfo.Hash, erasure.ShardSize())
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  6. cmd/bucket-lifecycle.go

    	sz, _ := oi.GetActualSize()
    	return madmin.TraceInfo{
    		TraceType: madmin.TraceILM,
    		Time:      startTime,
    		NodeName:  globalLocalNodeName,
    		FuncName:  event,
    		Duration:  duration,
    		Path:      pathJoin(oi.Bucket, oi.Name),
    		Bytes:     sz,
    		Error:     err,
    		Message:   getSource(4),
    		Custom:    metadata,
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  7. cmd/data-usage-cache.go

    		// drive timeout by default is 2 minutes, we do not need to wait longer.
    		ctx, cancel := context.WithTimeout(ctx, timeout)
    		defer cancel()
    
    		r, err := store.GetObjectNInfo(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, name), nil, http.Header{}, ObjectOptions{NoLock: true})
    		if err != nil {
    			switch err.(type) {
    			case ObjectNotFound, BucketNotFound:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  8. cmd/storage-datatypes.go

    //     hang-around in-case we need some form of recovery.
    type RenameDataResp struct {
    	Sign       []byte `msg:"s"`
    	OldDataDir string `msg:"od"` // contains '<uuid>', it is designed to be passed as value to Delete(bucket, pathJoin(object, dataDir))
    }
    
    const (
    	checkPartUnknown int = iota
    
    	// Changing the order can cause a data loss
    	// when running two nodes with incompatible versions
    	checkPartSuccess
    	checkPartDiskNotFound
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  9. cmd/erasure-metadata.go

    			if mErrs[index] != nil {
    				continue
    			}
    			index := index
    			ng.Go(func() error {
    				if disks[index] == nil {
    					return errDiskNotFound
    				}
    				return disks[index].Delete(ctx, bucket, pathJoin(prefix, xlStorageFormatFile), DeleteOptions{
    					Recursive: true,
    				})
    			}, index)
    		}
    		ng.Wait()
    	}
    
    	return evalDisks(disks, mErrs), err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
Back to top