mod init

Author: xDarksome

ballot_protocol.go

@@ -1,10 +1,7 @@
 package scp
 
 import (
-	"fmt"
 	"time"
-
-	"github.com/sirupsen/logrus"
 )
 
 type SlotsLoader interface {
@@ -103,8 +100,6 @@ func (b *ballotProtocol) receive(m *Message) {
 		b.commitVoted(m)
 	case AcceptCommit:
 		b.commitAccepted(m)
-	default:
-		logrus.Errorf("unexpected message type: %d", m.Type)
 	}
 }
 
@@ -276,7 +271,7 @@ func (b *ballotProtocol) externalize(s Slot) {
 	}
 
 	b.ledger.PersistSlot(s)
-	fmt.Println("\n", b.id, "externalized", s.Index, string(s.Value))
+	//fmt.Println("\n", b.id, "externalized", s.Index, string(s.Value))
 	b.reinit(s.Index + 1)
 }
 

go.mod

@@ -0,0 +1,3 @@
+module github.com/xdarksome/scp
+
+require github.com/google/btree v1.0.0

go.sum

@@ -0,0 +1,2 @@
+github.com/google/btree v1.0.0 h1:0udJVsspx3VBr5FwtLhQQtuAsVc79tTq0ocGIPAU6qo=
+github.com/google/btree v1.0.0/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=

main.go

@@ -1,7 +1,5 @@
 package scp
 
-import "github.com/sirupsen/logrus"
-
 type Value []byte
 
 type Slot struct {
@@ -80,8 +78,6 @@ func (c *Consensus) InputMessage(m *Message) {
 		c.nominationProtocol.inputMessages <- m
 	case VotePrepare, AcceptPrepare, VoteCommit, AcceptCommit:
 		c.ballotProtocol.inputMessages <- m
-	default:
-		logrus.Errorf("unknown message type: %d", m.Type)
 	}
 }
 

nomination_protocol.go

@@ -1,9 +1,5 @@
 package scp
 
-import (
-	"github.com/sirupsen/logrus"
-)
-
 type Validator interface {
 	ValidateValue(Value) bool
 }
@@ -66,8 +62,6 @@ func (n *nominationProtocol) receive(m *Message) {
 		n.nominateVoted(m)
 	case AcceptNominate:
 		n.nominateAccepted(m)
-	default:
-		logrus.Errorf("unexpected message type: %d", m.Type)
 	}
 }
 
@@ -93,11 +87,9 @@ func (n *nominationProtocol) reinit(m protocolMessage) {
 }
 
 func (n *nominationProtocol) nominateVoted(m *Message) {
-	//fmt.Println(n.id, "see", m.NodeID, "has voted nominate", m.SlotIndex, string(m.Value))
 	nominate := n.nominates.Find(m.Value)
 	if nominate == nil {
 		if !n.validator.ValidateValue(m.Value) {
-			//logrus.Warnf("invalid nominate from %s", m.NodeID)
 			return
 		}
 		nominate = n.nominates.Create(m.Value, n.quorumSlices)