Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for diskID (0.04 sec)

  1. cmd/erasure-multipart.go

    	var uploadIDs []string
    	var disk StorageAPI
    	disks := er.getOnlineLocalDisks()
    	if len(disks) == 0 {
    		// If no local, get non-healing disks.
    		var ok bool
    		if disks, ok = er.getOnlineDisksWithHealing(false); !ok {
    			disks = er.getOnlineDisks()
    		}
    	}
    
    	for _, disk = range disks {
    		if disk == nil {
    			continue
    		}
    		if !disk.IsOnline() {
    			continue
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 47.1K bytes
    - Viewed (0)
  2. cmd/metrics.go

    		float64(totalDisks.Sum()),
    	)
    
    	for _, disk := range server.Disks {
    		// Total disk usage by the disk
    		ch <- prometheus.MustNewConstMetric(
    			prometheus.NewDesc(
    				prometheus.BuildFQName(diskNamespace, "storage", "used"),
    				"Total disk storage used on the drive",
    				[]string{"disk"}, nil),
    			prometheus.GaugeValue,
    			float64(disk.UsedSpace),
    			disk.DrivePath,
    		)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:06:31 UTC 2025
    - 16.7K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    	})
    }
    
    func readAllRawFileInfo(ctx context.Context, disks []StorageAPI, bucket, object string, readData bool) ([]RawFileInfo, []error) {
    	rawFileInfos := make([]RawFileInfo, len(disks))
    	g := errgroup.WithNErrs(len(disks))
    	for index := range disks {
    		g.Go(func() (err error) {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			rf, err := disks[index].ReadXL(ctx, bucket, object, readData)
    			if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  4. cmd/data-scanner-metric.go

    }
    
    // currentPathUpdater provides a lightweight update function for keeping track of
    // current objects for each disk.
    // Returns a function that can be used to update the current object
    // and a function to call to when processing finished.
    func (p *scannerMetrics) currentPathUpdater(disk, initial string) (update func(path string), done func()) {
    	initialPtr := unsafe.Pointer(&initial)
    	tracker := &currentPathTracker{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Oct 01 06:06:01 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  5. cmd/erasure-multipart-conditional_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	existingETag := objInfo.ETag
    
    	// Simulate read quorum failure by taking enough disks offline
    	// With 16 disks (EC 8+8), read quorum is 9. Taking 8 disks offline leaves only 8,
    	// which is below read quorum.
    	erasureDisks := xl.getDisks()
    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  6. cmd/erasure-object-conditional_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	existingETag := objInfo.ETag
    
    	// Simulate read quorum failure by taking enough disks offline
    	// With 16 disks (EC 8+8), read quorum is 9. Taking 8 disks offline leaves only 8,
    	// which is below read quorum.
    	erasureDisks := xl.getDisks()
    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  7. docs/debugging/reorder-disks/go.mod

    module github.com/minio/minio/docs/debugging/reorder-disks
    
    go 1.21
    
    toolchain go1.24.8
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 128 bytes
    - Viewed (0)
  8. compat/maven-compat/src/test/java/org/apache/maven/repository/LegacyRepositorySystemTest.java

            //
            // The request has not set any local or remote repositories as the system scoped dependency being resolved
            // should only
            // give us the dependency off the disk and nothing more.
            //
            request = new ArtifactResolutionRequest()
                    .setArtifact(artifact)
                    .setResolveRoot(true)
                    .setResolveTransitively(true);
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Dec 16 13:41:14 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  9. impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/ApplyTest.java

        @DisplayName("Modification Behavior")
        class ModificationBehaviorTests {
    
            @Test
            @DisplayName("should save modifications to disk")
            void shouldSaveModificationsToDisk() {
                assertTrue(applyGoal.shouldSaveModifications(), "Apply goal should save modifications to disk");
            }
        }
    
        @Nested
        @DisplayName("Execution")
        class ExecutionTests {
    
            @Test
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Nov 18 10:39:17 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  10. README.md

    - Support for query parameters, headers, body (String or stream), compression, SSL configuration, proxies, and timeouts
    - Automatic in-memory or on-disk caching of request/response bodies
    - Synchronous and asynchronous (callback) execution
    - Minimal dependencies (only Apache Commons IO)
    
    ## Installation
    
    ### Maven
    
    Registered: Sat Dec 20 09:13:53 UTC 2025
    - Last Modified: Thu Nov 20 13:34:13 UTC 2025
    - 2.5K bytes
    - Viewed (0)
Back to top