Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 43 for Quorum (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/erasure-metadata.go

    	return 0, 0, InvalidRange{}
    }
    
    func findFileInfoInQuorum(ctx context.Context, metaArr []FileInfo, modTime time.Time, etag string, quorum int) (FileInfo, error) {
    	// with less quorum return error.
    	if quorum < 1 {
    		return FileInfo{}, InsufficientReadQuorum{Err: errErasureReadQuorum, Type: RQInsufficientOnlineDrives}
    	}
    	metaHashes := make([]string, len(metaArr))
    	h := sha256.New()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.3K bytes
    - Click Count (0)
  2. cmd/erasure-healing-common.go

    // occurs >= quorum, else return timeSentinel
    func commonTime(modTimes []time.Time, quorum int) time.Time {
    	if modTime, count := commonTimeAndOccurrence(modTimes, 0); count >= quorum {
    		return modTime
    	}
    
    	return timeSentinel
    }
    
    func commonETag(etags []string, quorum int) string {
    	if etag, count := commonETags(etags); count >= quorum {
    		return etag
    	}
    	return ""
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  3. internal/dsync/lock-args_gen.go

    				return
    			}
    		case "Quorum":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "Quorum")
    					return
    				}
    				z.Quorum = nil
    			} else {
    				if z.Quorum == nil {
    					z.Quorum = new(int)
    				}
    				*z.Quorum, err = dc.ReadInt()
    				if err != nil {
    					err = msgp.WrapError(err, "Quorum")
    					return
    				}
    			}
    		default:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  4. cmd/local-locker_gen.go

    				return
    			}
    		case "Owner":
    			z.Owner, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "Owner")
    				return
    			}
    		case "Quorum":
    			z.Quorum, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Quorum")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.6K bytes
    - Click Count (0)
  5. 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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  6. cmd/metacache-entries_test.go

    			wantOk:       true,
    		},
    		{
    			name:         "one zero, below quorum",
    			m:            metaCacheEntries{inputSerialized[0], inputSerialized[0], inputSerialized[0], metaCacheEntry{}},
    			r:            metadataResolutionParams{dirQuorum: 4, objQuorum: 4, strict: false},
    			wantSelected: nil,
    			wantOk:       false,
    		},
    		{
    			name:         "one zero, below quorum, strict",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 31.6K bytes
    - Click Count (0)
  7. 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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
  8. 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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.9K bytes
    - Click Count (1)
  9. internal/http/headers.go

    	// Header indicates if the etag should be preserved by client
    	MinIOSourceETag = "x-minio-source-etag"
    
    	// Writes expected write quorum
    	MinIOWriteQuorum = "x-minio-write-quorum"
    
    	// Reads expected read quorum
    	MinIOReadQuorum = "x-minio-read-quorum"
    
    	// Indicates if we are using default storage class and there was problem loading config
    	// if this header is set to "true"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  10. cmd/erasure-healing-common_test.go

    	// This test uses two FileInfo values that represent the same object but
    	// have different parities. They occur in equal number of drives, but only
    	// one has read quorum. commonParity should pick the parity corresponding to
    	// the FileInfo which has read quorum.
    	fi1 := FileInfo{
    		Volume:         "mybucket",
    		Name:           "myobject",
    		VersionID:      "",
    		IsLatest:       true,
    		Deleted:        false,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 22.4K bytes
    - Click Count (0)
Back to Top