Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for LocalDisksPaths (0.33 sec)

  1. cmd/speedtest.go

    	perf := &dperf.DrivePerf{
    		Serial:    opts.Serial,
    		BlockSize: opts.BlockSize,
    		FileSize:  opts.FileSize,
    	}
    
    	localPaths := globalEndpoints.LocalDisksPaths()
    	var ignoredPaths []string
    	paths := func() (tmpPaths []string) {
    		for _, lp := range localPaths {
    			if _, err := Lstat(pathJoin(lp, minioMetaBucket, formatConfigFile)); err == nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Jan 28 18:04:17 GMT 2024
    - 9K bytes
    - Viewed (0)
  2. cmd/tier-journal.go

    // journal only to process existing journal entries made from previous versions.
    func (t *TierJournal) Init(ctx context.Context) error {
    	for _, diskPath := range globalEndpoints.LocalDisksPaths() {
    		t.diskPath = diskPath
    
    		go t.deletePending(ctx)  // for existing journal entries from previous MinIO versions
    		go t.processEntries(ctx) // for newer journal entries circa free-versions
    		return nil
    	}
    
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  3. cmd/endpoint.go

    	if host == "" {
    		host = sortIPs(localIP4.ToSlice())[0]
    	}
    	return fmt.Sprintf("%s://%s", getURLScheme(globalIsTLS), net.JoinHostPort(host, globalMinioPort))
    }
    
    // LocalDisksPaths returns the disk paths of the local disks
    func (l EndpointServerPools) LocalDisksPaths() []string {
    	var disks []string
    	for _, ep := range l {
    		for _, endpoint := range ep.Endpoints {
    			if endpoint.IsLocal {
    				disks = append(disks, endpoint.Path)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
Back to top