Merge pull request #22 from wziww/master

mreiferson · web-flow · commit f9543b6f692a · 2020-12-28T21:31:50.000-08:00
add minMsgSize log info
diff --git a/diskqueue.go b/diskqueue.go
@@ -369,7 +369,7 @@ func (d *diskQueue) writeOne(data []byte) error {
 	dataLen := int32(len(data))
 
 	if dataLen < d.minMsgSize || dataLen > d.maxMsgSize {
-		return fmt.Errorf("invalid message write size (%d) maxMsgSize=%d", dataLen, d.maxMsgSize)
+		return fmt.Errorf("invalid message write size (%d) minMsgSize=%d maxMsgSize=%d", dataLen, d.minMsgSize, d.maxMsgSize)
 	}
 
 	d.writeBuf.Reset()

Original file line number	Diff line number	Diff line change
`@@ -369,7 +369,7 @@ func (d *diskQueue) writeOne(data []byte) error {`
`369`	`369`	`dataLen := int32(len(data))`
`370`	`370`
`371`	`371`	`if dataLen < d.minMsgSize \|\| dataLen > d.maxMsgSize {`
`372`		`- return fmt.Errorf("invalid message write size (%d) maxMsgSize=%d", dataLen, d.maxMsgSize)`
	`372`	`+ return fmt.Errorf("invalid message write size (%d) minMsgSize=%d maxMsgSize=%d", dataLen, d.minMsgSize, d.maxMsgSize)`
`373`	`373`	`}`
`374`	`374`
`375`	`375`	`d.writeBuf.Reset()`