Method run

conn/node_test.go:24–49

(wg *sync.WaitGroup)

)

func (n *Node) run(wg *sync.WaitGroup) {
	ticker := time.Tick(20 * time.Millisecond)

	for {
		select {
		case <-ticker:
			n.Raft().Tick()
		case rd := <-n.Raft().Ready():
			n.SaveToStorage(&rd.HardState, rd.Entries, &rd.Snapshot)
			for _, entry := range rd.CommittedEntries {
				if entry.Type == raftpb.EntryConfChange {
					var cc raftpb.ConfChange
					if err := cc.Unmarshal(entry.Data); err != nil {
						fmt.Printf("error in unmarshalling: %v\n", err)
					}
					n.Raft().ApplyConfChange(cc)
				} else if entry.Type == raftpb.EntryNormal {
					if bytes.HasPrefix(entry.Data, []byte("hey")) {
						wg.Done()
					}
				}
			}
			n.Raft().Advance()
		}
	}
}

func TestProposal(t *testing.T) {
	dir := t.TempDir()