Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 58 for pathJoin (0.1 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  2. cmd/prepare-storage.go

    	tmpID := mustGetUUID()
    	tmpOld := pathJoin(diskPath, minioMetaTmpBucket+"-old", tmpID)
    	if err := renameAll(pathJoin(diskPath, minioMetaTmpBucket),
    		tmpOld, diskPath); err != nil && !errors.Is(err, errFileNotFound) {
    		storageLogIf(GlobalContext, fmt.Errorf("unable to rename (%s -> %s) %w, drive may be faulty, please investigate",
    			pathJoin(diskPath, minioMetaTmpBucket),
    			tmpOld,
    			osErrToFileErr(err)))
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  3. cmd/erasure-healing_test.go

    	}
    
    	err = firstDisk.Delete(context.Background(), 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(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), []byte{})
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  4. cmd/os-reliable_test.go

    	}
    
    	if err = mkdirAll(pathJoin(path, "testvolume1"), 0o777, ""); err != nil {
    		t.Fatal(err)
    	}
    	if err = renameAll("", "foo", ""); err != errInvalidArgument {
    		t.Fatal(err)
    	}
    	if err = renameAll("foo", "", ""); err != errInvalidArgument {
    		t.Fatal(err)
    	}
    	if err = renameAll(pathJoin(path, "testvolume1"), pathJoin(path, "testvolume2"), ""); err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 13 15:14:36 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 6K bytes
    - Viewed (0)
  6. 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)
  7. 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
    	}
    
    	return
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  8. cmd/batch-handlers.go

    		if retry && !s3Type {
    			if _, err := c.StatObject(ctx, tgtBucket, pathJoin(tgtPrefix, srcObject), miniogo.StatObjectOptions{
    				VersionID: srcObjInfo.VersionID,
    				Internal: miniogo.AdvancedGetOptions{
    					ReplicationProxyRequest: "false",
    				},
    			}); isErrMethodNotAllowed(ErrorRespToObjectError(err, tgtBucket, pathJoin(tgtPrefix, srcObject))) {
    				return nil
    			}
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. cmd/untar.go

    			if o.ignoreDirs {
    				continue
    			}
    			name = trimLeadingSlash(pathJoin(name, slashSeparator))
    		case tar.TypeReg, tar.TypeChar, tar.TypeBlock, tar.TypeFifo, tar.TypeGNUSparse: // = regular
    			name = trimLeadingSlash(path.Clean(name))
    		default:
    			// ignore symlink'ed
    			continue
    		}
    		if o.prefixAll != "" {
    			name = pathJoin(o.prefixAll, name)
    		}
    
    		// Do small files async
    		n++
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (2)
Back to top