Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 70 for dquorum (0.08 sec)

  1. 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
    }
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  2. cmd/erasure-errors.go

    package cmd
    
    import "errors"
    
    // errErasureReadQuorum - did not meet read quorum.
    var errErasureReadQuorum = errors.New("Read failed. Insufficient number of drives online")
    
    // errErasureWriteQuorum - did not meet write quorum.
    var errErasureWriteQuorum = errors.New("Write failed. Insufficient number of drives online")
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 04 23:10:08 UTC 2022
    - 1.2K bytes
    - Viewed (0)
  3. cmd/metrics-v3-cluster-erasure-set.go

    		"Overall write quorum across pools and sets")
    	erasureSetOverallHealthMD = NewGaugeMD(erasureSetOverallHealth,
    		"Overall health across pools and sets (1=healthy, 0=unhealthy)")
    	erasureSetReadQuorumMD = NewGaugeMD(erasureSetReadQuorum,
    		"Read quorum for the erasure set in a pool", poolIDL, setIDL)
    	erasureSetWriteQuorumMD = NewGaugeMD(erasureSetWriteQuorum,
    		"Write quorum for the erasure set in a pool", poolIDL, setIDL)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 14 07:25:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  4. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (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)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jul 25 21:02:50 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  6. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.9K bytes
    - Viewed (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.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  8. 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"
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 28 15:31:56 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  9. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  10. cmd/admin-handlers_test.go

    			return "READ"
    		}
    		exp = append(exp, madmin.LockEntry{
    			Resource:   lri.Name,
    			Type:       lockType(lri),
    			ServerList: owners,
    			Owner:      lri.Owner,
    			ID:         lri.UID,
    			Quorum:     lri.Quorum,
    			Timestamp:  time.Unix(0, lri.Timestamp),
    		})
    	}
    
    	testCases := []struct {
    		peerLocks []*PeerLocks
    		expected  madmin.LockEntries
    	}{
    		{
    			peerLocks: peerLocks,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
Back to top