"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "server/etcdserver/quota.go" between
etcd-3.5.6.tar.gz and etcd-3.5.7.tar.gz

About: etcd is a distributed reliable key-value store for the most critical data of a distributed system (written in "Go").

quota.go  (etcd-3.5.6)	:	quota.go  (etcd-3.5.7)
skipping to change at line 128		skipping to change at line 128
"enabled backend quota",		"enabled backend quota",
zap.String("quota-name", name),		zap.String("quota-name", name),
zap.Int64("quota-size-bytes", s.Cfg.QuotaBackendBytes),		zap.Int64("quota-size-bytes", s.Cfg.QuotaBackendBytes),
zap.String("quota-size", humanize.Bytes(uint64(s.Cfg.Quot aBackendBytes))),		zap.String("quota-size", humanize.Bytes(uint64(s.Cfg.Quot aBackendBytes))),
)		)
})		})
return &backendQuota{s, s.Cfg.QuotaBackendBytes}		return &backendQuota{s, s.Cfg.QuotaBackendBytes}
}		}
func (b *backendQuota) Available(v interface{}) bool {		func (b *backendQuota) Available(v interface{}) bool {
		cost := b.Cost(v)
		// if there are no mutating requests, it's safe to pass through
		if cost == 0 {
		return true
		}
// TODO: maybe optimize backend.Size()		// TODO: maybe optimize backend.Size()
return b.s.Backend().Size()+int64(b.Cost(v)) < b.maxBackendBytes		return b.s.Backend().Size()+int64(cost) < b.maxBackendBytes
}		}
func (b *backendQuota) Cost(v interface{}) int {		func (b *backendQuota) Cost(v interface{}) int {
switch r := v.(type) {		switch r := v.(type) {
case *pb.PutRequest:		case *pb.PutRequest:
return costPut(r)		return costPut(r)
case *pb.TxnRequest:		case *pb.TxnRequest:
return costTxn(r)		return costTxn(r)
case *pb.LeaseGrantRequest:		case *pb.LeaseGrantRequest:
return leaseOverhead		return leaseOverhead
End of changes. 2 change blocks.
1 lines changed or deleted		6 lines changed or added

---