Full Replication Logic Pt 2

api.go

@@ -57,7 +57,6 @@ type Storage interface {
 }
 
 type Communication interface {
-
 	// Nodes returns all nodes that participate in the epoch.
 	Nodes() []NodeID
 

blacklist.go

@@ -69,7 +69,7 @@ func (bl *Blacklist) String() string {
 		if i > 0 {
 			buf = append(buf, ',')
 		}
-		buf = append(buf, fmt.Sprintf("{type=%d, NodeIndex=%d}", u.Type, u.NodeIndex)...)
+		buf = append(buf, u.String()...)
 	}
 	buf = append(buf, "])"...)
 	return string(buf)

block_scheduler_test.go

@@ -18,24 +18,6 @@ const (
 	defaultWaitDuration = 500 * time.Millisecond
 )
 
-func waitNoReceive(t *testing.T, ch <-chan struct{}) {
-	select {
-	case <-ch:
-		t.Fatal("channel unexpectedly signaled")
-	case <-time.After(defaultWaitDuration):
-		// good
-	}
-}
-
-func waitReceive(t *testing.T, ch <-chan struct{}) {
-	select {
-	case <-ch:
-		// good
-	case <-time.After(defaultWaitDuration):
-		t.Fatal("timed out waiting for signal")
-	}
-}
-
 func TestBlockVerificationScheduler(t *testing.T) {
 	t.Run("Schedules immediately when no dependencies", func(t *testing.T) {
 		scheduler := simplex.NewScheduler(testutil.MakeLogger(t), defaultMaxDeps)