v1.2.11 (#58)

node/app/db_console.go

@@ -886,11 +886,11 @@ func logoVersion(width int) string {
 		out += "                     #######################################        ########\n"
 		out += "                          #############################                ##\n"
 		out += " \n"
-		out += "                         Quilibrium Node - v1.2.10 – Dawn\n"
+		out += "                        Quilibrium Node - v1.2.11 – Dawn\n"
 		out += " \n"
 		out += "                                   DB Console\n"
 	} else {
-		out = "Quilibrium Node - v1.2.10 – Dawn - DB Console\n"
+		out = "Quilibrium Node - v1.2.11 – Dawn - DB Console\n"
 	}
 	return out
 }

node/consensus/ceremony/ceremony_data_clock_consensus_engine.go

@@ -83,6 +83,7 @@ type CeremonyDataClockConsensusEngine struct {
 	stagedLobbyStateTransitions *protobufs.CeremonyLobbyStateTransition
 	minimumPeersRequired        int
 	statsClient                 protobufs.NodeStatsClient
+	currentReceivingSyncPeers   int
 
 	frameChan                      chan *protobufs.ClockFrame
 	executionEngines               map[string]execution.ExecutionEngine
@@ -219,18 +220,19 @@ func NewCeremonyDataClockConsensusEngine(
 			0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
 			0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
 		},
-		lastFrameReceivedAt:   time.Time{},
+		currentReceivingSyncPeers: 0,
-		frameProverTrie:       &tries.RollingFrecencyCritbitTrie{},
+		lastFrameReceivedAt:       time.Time{},
-		inclusionProver:       inclusionProver,
+		frameProverTrie:           &tries.RollingFrecencyCritbitTrie{},
-		syncingStatus:         SyncStatusNotSyncing,
+		inclusionProver:           inclusionProver,
-		peerAnnounceMap:       map[string]*protobufs.CeremonyPeerListAnnounce{},
+		syncingStatus:             SyncStatusNotSyncing,
-		peerMap:               map[string]*peerInfo{},
+		peerAnnounceMap:           map[string]*protobufs.CeremonyPeerListAnnounce{},
-		uncooperativePeersMap: map[string]*peerInfo{},
+		peerMap:                   map[string]*peerInfo{},
-		minimumPeersRequired:  minimumPeersRequired,
+		uncooperativePeersMap:     map[string]*peerInfo{},
-		frameProver:           frameProver,
+		minimumPeersRequired:      minimumPeersRequired,
-		masterTimeReel:        masterTimeReel,
+		frameProver:               frameProver,
-		dataTimeReel:          dataTimeReel,
+		masterTimeReel:            masterTimeReel,
-		statsClient:           statsClient,
+		dataTimeReel:              dataTimeReel,
+		statsClient:               statsClient,
 	}
 
 	logger.Info("constructing consensus engine")

node/consensus/ceremony/peer_messaging.go

@@ -30,6 +30,28 @@ func (e *CeremonyDataClockConsensusEngine) GetCompressedSyncFrames(
 		zap.Uint64("to_frame_number", request.ToFrameNumber),
 	)
 
+	if e.currentReceivingSyncPeers > 4 {
+		e.logger.Info(
+			"currently processing maximum sync requests, returning",
+		)
+
+		if err := server.SendMsg(
+			&protobufs.ClockFramesResponse{
+				Filter:          request.Filter,
+				FromFrameNumber: 0,
+				ToFrameNumber:   0,
+				ClockFrames:     []*protobufs.ClockFrame{},
+			},
+		); err != nil {
+			return errors.Wrap(err, "get compressed sync frames")
+		}
+
+		return nil
+	}
+
+	e.currentReceivingSyncPeers++
+	defer func() { e.currentReceivingSyncPeers-- }()
+
 	from := request.FromFrameNumber
 	parent := request.ParentSelector
 

node/consensus/consensus_engine.go

@@ -55,9 +55,9 @@ func GetMinimumVersionCutoff() time.Time {
 }
 
 func GetMinimumVersion() []byte {
-	return []byte{0x01, 0x02, 0x0A}
+	return []byte{0x01, 0x02, 0x0B}
 }
 
 func GetVersion() []byte {
-	return []byte{0x01, 0x02, 0x0A}
+	return []byte{0x01, 0x02, 0x0B}
 }

node/main.go

@@ -306,5 +306,5 @@ func printLogo() {
 
 func printVersion() {
 	fmt.Println(" ")
-	fmt.Println("                         Quilibrium Node - v1.2.10 – Dawn")
+	fmt.Println("                        Quilibrium Node - v1.2.11 – Dawn")
 }