Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 50 for PathJoin (0.05 sec)

  1. cmd/erasure-multipart.go

    				pathUUID := mustGetUUID()
    				targetPath := pathJoin(drivePath, minioMetaTmpDeletedBucket, pathUUID)
    				renameAll(pathJoin(drivePath, minioMetaMultipartBucket, uploadIDPath), targetPath, pathJoin(drivePath, minioMetaBucket))
    				wait()
    				return nil
    			})
    		})
    		// Get the modtime of the shaDir.
    		vi, err := disk.StatVol(ctx, pathJoin(minioMetaMultipartBucket, shaDir))
    		if err != nil {
    			return nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  2. cmd/erasure-healing_test.go

    	}
    
    	err = firstDisk.Delete(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    	if err != nil {
    		t.Errorf("Failure during deleting part.1 - %v", err)
    	}
    
    	err = firstDisk.WriteAll(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"), []byte{})
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  3. cmd/config.go

    	historyFile := pathJoin(minioConfigHistoryPrefix, uuidKV+kvPrefix)
    	data, err := readConfig(ctx, objAPI, historyFile)
    	if err != nil {
    		return nil, err
    	}
    
    	return decryptData(data, historyFile)
    }
    
    func saveServerConfigHistory(ctx context.Context, objAPI ObjectLayer, kv []byte) error {
    	uuidKV := mustGetUUID() + kvPrefix
    	historyFile := pathJoin(minioConfigHistoryPrefix, uuidKV)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  4. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  5. cmd/mrf.go

    		}
    		rc, err := localDrive.ReadFileStream(context.Background(), minioMetaBucket, pathJoin(healMRFDir, "list.bin"), 0, -1)
    		if err != nil {
    			continue
    		}
    		err = loadMRF(rc, m.opCh)
    		if err != nil {
    			continue
    		}
    		// finally delete the file after processing mrf entries
    		localDrive.Delete(GlobalContext, minioMetaBucket, pathJoin(healMRFDir, "list.bin"), DeleteOptions{})
    		break
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  6. cmd/batch-handlers.go

    		if retry && !s3Type {
    			if _, err := c.StatObject(ctx, tgtBucket, pathJoin(tgtPrefix, srcObject), minio.StatObjectOptions{
    				VersionID: srcObjInfo.VersionID,
    				Internal: minio.AdvancedGetOptions{
    					ReplicationProxyRequest: "false",
    				},
    			}); isErrMethodNotAllowed(ErrorRespToObjectError(err, tgtBucket, pathJoin(tgtPrefix, srcObject))) {
    				return nil
    			}
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  7. cmd/speedtest.go

    	localPaths := globalEndpoints.LocalDisksPaths()
    	var ignoredPaths []string
    	paths := func() (tmpPaths []string) {
    		for _, lp := range localPaths {
    			if _, err := Lstat(pathJoin(lp, minioMetaBucket, formatConfigFile)); err == nil {
    				tmpPaths = append(tmpPaths, pathJoin(lp, minioMetaTmpBucket))
    			} else {
    				// Use dperf on only formatted drives.
    				ignoredPaths = append(ignoredPaths, lp)
    			}
    		}
    		return tmpPaths
    	}()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  8. cmd/erasure.go

    			defer wg.Done()
    			drivePath := disk.Endpoint().Path
    			readDirFn(pathJoin(drivePath, minioMetaTmpDeletedBucket), func(ddir string, typ os.FileMode) error {
    				w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    				return w.Run(func() error {
    					wait := deleteCleanupSleeper.Timer(ctx)
    					removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir))
    					wait()
    					return nil
    				})
    			})
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  9. cmd/metacache-server-pool.go

    	// to `.minio.sys/tmp/` for deletion.
    	return readDirFn(pathJoin(epPath, minioMetaBucket, bucketMetaPrefix), func(name string, typ os.FileMode) error {
    		if typ == os.ModeDir {
    			tmpMetacacheOld := pathutil.Join(epPath, minioMetaTmpDeletedBucket, mustGetUUID())
    			if err := renameAll(pathJoin(epPath, minioMetaBucket, metacachePrefixForID(name, slashSeparator)),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  10. cmd/format-erasure_test.go

    	b, err := json.Marshal(m)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	if err = os.MkdirAll(pathJoin(rootPath, minioMetaBucket), os.FileMode(0o755)); err != nil {
    		t.Fatal(err)
    	}
    
    	if err = os.WriteFile(pathJoin(rootPath, minioMetaBucket, formatConfigFile), b, os.FileMode(0o644)); err != nil {
    		t.Fatal(err)
    	}
    
    	formatData, _, err := formatErasureMigrate(rootPath)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.7K bytes
    - Viewed (0)
Back to top