meh

mreiferson · mreiferson · commit 2898aecbe503 · 2015-10-18T09:56:10.000-07:00
diff --git a/nsqd/topic.go b/nsqd/topic.go
@@ -148,7 +148,7 @@ func (t *Topic) Pub(data [][]byte, crc []uint32) error {
 	if atomic.LoadInt32(&t.exitFlag) == 1 {
 		return errors.New("exiting")
 	}
-	// TODO: health
+	// TODO: (WAL) health
 	startIdx, endIdx, err := t.wal.Append(data, crc)
 	if err != nil {
 		return err

Original file line number	Diff line number	Diff line change
`@@ -148,7 +148,7 @@ func (t *Topic) Pub(data [][]byte, crc []uint32) error {`
`148`	`148`	`if atomic.LoadInt32(&t.exitFlag) == 1 {`
`149`	`149`	`return errors.New("exiting")`
`150`	`150`	`}`
`151`		`- // TODO: health`
	`151`	`+ // TODO: (WAL) health`
`152`	`152`	`startIdx, endIdx, err := t.wal.Append(data, crc)`
`153`	`153`	`if err != nil {`
`154`	`154`	`return err`