fixup! raft: add MaxInflightBytes to Config

etcd-io · Nov 10, 2022 · e1cb79e · e1cb79e
1 parent a3265af
commit e1cb79e
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/raft/raft.go b/raft/raft.go
@@ -238,6 +238,11 @@ func (c *Config) validate() error {
 	if c.MaxInflightMsgs <= 0 {
 		return errors.New("max inflight messages must be greater than 0")
 	}
+	if c.MaxInflightBytes == 0 {
+		c.MaxInflightBytes = noLimit
+	} else if c.MaxInflightBytes < c.MaxSizePerMsg {
+		return errors.New("max inflight bytes must be >= max message size")
+	}
 
 	if c.Logger == nil {
 		c.Logger = getLogger()