Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 65 for dquorum (0.05 sec)

  1. cmd/metacache-set.go

    				return entries, io.EOF
    			}
    			partN++
    			retries = 0
    		}
    	}
    }
    
    // getListQuorum interprets list quorum values and returns appropriate
    // acceptable quorum expected for list operations
    func getListQuorum(quorum string, driveCount int) int {
    	switch quorum {
    	case "disk":
    		return 1
    	case "reduced":
    		return 2
    	case "optimal":
    		return (driveCount + 1) / 2
    	case "auto":
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    	reqInfo := &logger.ReqInfo{API: "BackgroundHeal"}
    	ctx, cancelCtx := context.WithCancel(logger.SetReqInfo(GlobalContext, reqInfo))
    
    	hs := madmin.HealOpts{
    		// Remove objects that do not have read-quorum
    		Remove: healDeleteDangling,
    	}
    
    	return &healSequence{
    		startTime:   UTCNow(),
    		clientToken: bgHealingUUID,
    		// run-background heal with reserved bucket
    		bucket:   minioReservedBucket,
    		settings: hs,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  3. cmd/erasure-encode.go

    // Encode reads from the reader, erasure-encodes the data and writes to the writers.
    func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) {
    	writer := &multiWriter{
    		writers:     writers,
    		writeQuorum: quorum,
    		errs:        make([]error, len(writers)),
    	}
    
    	for {
    		var blocks [][]byte
    		n, err := io.ReadFull(src, buf)
    		if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. cmd/prepare-storage.go

    			return nil, err
    		}
    
    		return format, nil
    	}
    
    	// Return error when quorum unformatted disks - indicating we are
    	// waiting for first server to be online.
    	unformattedDisks := quorumUnformattedDisks(sErrs)
    	if unformattedDisks && !firstDisk {
    		return nil, errNotFirstDisk
    	}
    
    	// Return error when quorum unformatted disks but waiting for rest
    	// of the servers to be online.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  5. cmd/local-locker.go

    	Group           bool   // indicates if it was a group lock.
    	Owner           string // Owner represents the UUID of the owner who originally requested the lock.
    	Quorum          int    // Quorum represents the quorum required for this lock to be active.
    	idx             int    `msg:"-"` // index of the lock in the lockMap.
    }
    
    // isWriteLock returns whether the lock is a write or read lock.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  6. cmd/erasure-metadata_test.go

    			if succModTimes != nil {
    				fis[i].SuccessorModTime = succModTimes[i]
    				fis[i].IsLatest = succModTimes[i].IsZero()
    			}
    			if numVersions != nil {
    				fis[i].NumVersions = numVersions[i]
    			}
    			quorum--
    			if quorum == 0 {
    				break
    			}
    		}
    		return fis
    	}
    
    	commonSuccModTime := time.Date(2023, time.August, 25, 0, 0, 0, 0, time.UTC)
    	succModTimesInQuorum := make([]time.Time, 16)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.4K bytes
    - Viewed (0)
  7. cmd/admin-handlers_test.go

    			Group:  true,
    			Quorum: 3,
    		}
    		lris = append(lris, lri)
    		locksHeld[resource] = []lockRequesterInfo{lri}
    	}
    
    	// Add a few concurrent read locks to the mix
    	for i := range 50 {
    		resource := fmt.Sprintf("bucket/get-object-%d", i)
    		lri := lockRequesterInfo{
    			Name:   resource,
    			UID:    mustGetUUID(),
    			Owner:  owners[i%len(owners)],
    			Quorum: 2,
    		}
    		lris = append(lris, lri)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  8. docs/minio-limits.md

    | Minimum number of drives per server when server count is 4      | 01            |
    | Maximum number of drives per server                             | no-limit      |
    | Read quorum                                                     | N/2           |
    | Write quorum                                                    | N/2+1         |
    
    ## Limits of S3 API
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 6K bytes
    - Viewed (0)
  9. cmd/erasure-multipart.go

    		return fi, nil, errErasureReadQuorum
    	}
    
    	if writeQuorum < 0 {
    		return fi, nil, errErasureWriteQuorum
    	}
    
    	quorum := readQuorum
    	if write {
    		quorum = writeQuorum
    	}
    
    	// List all online disks.
    	_, modTime, etag := listOnlineDisks(storageDisks, partsMetadata, errs, quorum)
    
    	if write {
    		err = reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum)
    	} else {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  10. cmd/erasure-object_test.go

    				t.Errorf("Expected %s, got %s", tt.expectedError, err)
    			}
    			if tt.expectedReadQuorum != actualReadQuorum {
    				t.Errorf("Expected Read Quorum %d, got %d", tt.expectedReadQuorum, actualReadQuorum)
    			}
    			if tt.expectedWriteQuorum != actualWriteQuorum {
    				t.Errorf("Expected Write Quorum %d, got %d", tt.expectedWriteQuorum, actualWriteQuorum)
    			}
    		})
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
Back to top