This commit is contained in:
decanus
2019-06-10 21:38:38 -07:00
parent 352cf14834
commit c69b9747f4

View File

@@ -114,6 +114,7 @@ func (n *Node) AppendMessage(group state.GroupID, data []byte) (state.MessageID,
}
if n.mode == BATCH {
// @TODO this if flawed cause we never retransmit
n.payloads.AddMessages(group, p, &m)
log.Printf("[%x] sending MESSAGE (%x -> %x): %x\n", group[:4], n.ID[:4], p[:4], id[:4])
}