Add comment to make code more readable.

kev1n80 · kev1n80 · commit a3ce86a63fe0 · 2021-06-02T13:49:47.000Z
diff --git a/diskqueue.go b/diskqueue.go
@@ -421,6 +421,8 @@ func (d *diskQueue) writeOne(data []byte) error {
 		return fmt.Errorf("invalid message write size (%d) minMsgSize=%d maxMsgSize=%d", dataLen, d.minMsgSize, d.maxMsgSize)
 	}
 
+	// add all data to writeBuf before writing to file
+	// this causes everything to be written to file or nothing
 	d.writeBuf.Reset()
 	err = binary.Write(&d.writeBuf, binary.BigEndian, dataLen)
 	if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -421,6 +421,8 @@ func (d *diskQueue) writeOne(data []byte) error {`
`421`	`421`	`return fmt.Errorf("invalid message write size (%d) minMsgSize=%d maxMsgSize=%d", dataLen, d.minMsgSize, d.maxMsgSize)`
`422`	`422`	`}`
`423`	`423`
	`424`	`+ // add all data to writeBuf before writing to file`
	`425`	`+ // this causes everything to be written to file or nothing`
`424`	`426`	`d.writeBuf.Reset()`
`425`	`427`	`err = binary.Write(&d.writeBuf, binary.BigEndian, dataLen)`
`426`	`428`	`if err != nil {`