We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 17f2681 commit 678bbf4Copy full SHA for 678bbf4
net.go
@@ -7,6 +7,7 @@ import (
7
"fmt"
8
"hash/crc32"
9
"io"
10
+ "math"
11
"net"
12
"sync/atomic"
13
"time"
@@ -1093,8 +1094,8 @@ func (m *Memberlist) decryptRemoteState(bufConn io.Reader, streamLabel string) (
1093
1094
}
1095
1096
//Start reporting the size before you cross the limit
- if moreBytes > .6*maxPushStateBytes {
1097
- m.logger.Printf("[WARN] memberlist: Remote node state size is %d approaching limit (%d)", moreBytes, maxPushStateBytes)
+ if moreBytes > uint32(math.Floor(.06*maxPushStateBytes)) {
1098
+ m.logger.Printf("[INFO] memberlist: Remote node state size is %d limit is (%d)", moreBytes, maxPushStateBytes)
1099
1100
1101
// Read in the rest of the payload
0 commit comments