"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "server/etcdserver/util.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").

util.go  (etcd-3.5.6)	:	util.go  (etcd-3.5.7)
skipping to change at line 143		skipping to change at line 143
if time.Since(now) <= warningApplyDuration {		if time.Since(now) <= warningApplyDuration {
return		return
}		}
reqStringer := pb.NewLoggableTxnRequest(r)		reqStringer := pb.NewLoggableTxnRequest(r)
var resp string		var resp string
if !isNil(txnResponse) {		if !isNil(txnResponse) {
var resps []string		var resps []string
for _, r := range txnResponse.Responses {		for _, r := range txnResponse.Responses {
switch op := r.Response.(type) {		switch op := r.Response.(type) {
case *pb.ResponseOp_ResponseRange:		case *pb.ResponseOp_ResponseRange:
resps = append(resps, fmt.Sprintf("range_response		if op.ResponseRange != nil {
_count:%d", len(op.ResponseRange.Kvs)))		resps = append(resps, fmt.Sprintf("range_
		response_count:%d", len(op.ResponseRange.Kvs)))
		} else {
		resps = append(resps, "range_response:nil
		")
		}
default:		default:
// only range responses should be in a read only txn request		// only range responses should be in a read only txn request
}		}
}		}
resp = fmt.Sprintf("responses:<%s> size:%d", strings.Join(resps, " "), txnResponse.Size())		resp = fmt.Sprintf("responses:<%s> size:%d", strings.Join(resps, " "), txnResponse.Size())
}		}
warnOfExpensiveGenericRequest(lg, warningApplyDuration, now, reqStringer, "read-only txn ", resp, err)		warnOfExpensiveGenericRequest(lg, warningApplyDuration, now, reqStringer, "read-only txn ", resp, err)
}		}
func warnOfExpensiveReadOnlyRangeRequest(lg *zap.Logger, warningApplyDuration ti me.Duration, now time.Time, reqStringer fmt.Stringer, rangeResponse *pb.RangeRes ponse, err error) {		func warnOfExpensiveReadOnlyRangeRequest(lg *zap.Logger, warningApplyDuration ti me.Duration, now time.Time, reqStringer fmt.Stringer, rangeResponse *pb.RangeRes ponse, err error) {
End of changes. 1 change blocks.
2 lines changed or deleted		7 lines changed or added

---