Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for listPathRaw (0.12 sec)

  1. cmd/metacache-set.go

    	finished func(errs []error)
    }
    
    // listPathRaw will list a path on the provided drives.
    // See listPathRawOptions on how results are delivered.
    // Directories are always returned.
    // Cache will be bypassed.
    // Context cancellation will be respected but may take a while to effectuate.
    func listPathRaw(ctx context.Context, opts listPathRawOptions) (err error) {
    	disks := opts.disks
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    			waitForLowHTTPReq()
    		}
    
    		// How to resolve partial results.
    		resolver := metadataResolutionParams{
    			dirQuorum: 1,
    			objQuorum: 1,
    			bucket:    bucket,
    		}
    
    		err = listPathRaw(ctx, listPathRawOptions{
    			disks:          disks,
    			fallbackDisks:  fallbackDisks,
    			bucket:         bucket,
    			recursive:      true,
    			forwardTo:      forwardTo,
    			minDisks:       1,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  3. cmd/erasure-healing.go

    			}
    
    			if err := healEntry(bucket, *entry, scanMode); err != nil {
    				cancel()
    				return
    			}
    		},
    		finished: nil,
    	}
    
    	if err := listPathRaw(ctx, lopts); err != nil {
    		return fmt.Errorf("listPathRaw returned %w: opts(%#v)", err, lopts)
    	}
    
    	return nil
    }
    
    // listAllBuckets lists all buckets from all disks. It also
    // returns the occurrence of each buckets in all disks
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-rebalance.go

    		dirQuorum: listingQuorum, // make sure to capture all quorum ratios
    		objQuorum: listingQuorum, // make sure to capture all quorum ratios
    		bucket:    bucketName,
    	}
    
    	err := listPathRaw(ctx, listPathRawOptions{
    		disks:          disks,
    		bucket:         bucketName,
    		recursive:      true,
    		forwardTo:      "",
    		minDisks:       listingQuorum,
    		reportNotFound: false,
    		agreed:         fn,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    						entry, ok := entries.resolve(&resolver)
    						if ok {
    							send(*entry)
    						}
    					},
    					finished: nil,
    				}
    
    				if err := listPathRaw(ctx, lopts); err != nil {
    					cancelCause(fmt.Errorf("listPathRaw returned %w: opts(%#v)", err, lopts))
    					return
    				}
    			}()
    		}
    	}
    
    	// Convert and filter merged entries.
    	merged := make(chan metaCacheEntry, 100)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-decom.go

    	resolver := metadataResolutionParams{
    		dirQuorum: listingQuorum, // make sure to capture all quorum ratios
    		objQuorum: listingQuorum, // make sure to capture all quorum ratios
    		bucket:    bi.Name,
    	}
    
    	err := listPathRaw(ctx, listPathRawOptions{
    		disks:          disks,
    		bucket:         bi.Name,
    		path:           bi.Prefix,
    		recursive:      true,
    		forwardTo:      "",
    		minDisks:       listingQuorum,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  7. cmd/data-scanner.go

    					bucket: bucket,
    				}, madmin.HealItemBucket)
    			}
    
    			resolver.bucket = bucket
    
    			foundObjs := false
    			ctx, cancel := context.WithCancel(ctx)
    
    			err := listPathRaw(ctx, listPathRawOptions{
    				disks:          f.disks,
    				bucket:         bucket,
    				path:           prefix,
    				recursive:      true,
    				reportNotFound: true,
    				minDisks:       f.disksQuorum,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top