Add RWLocks to protect node context from data race

node/node.go

@@ -93,7 +93,7 @@ func (status StatusReport) TimeSinceLastRound() time.Duration {
 
 // AlgorandFullNode specifies and implements a full Algorand node.
 type AlgorandFullNode struct {
-	mu        deadlock.Mutex
+	mu        deadlock.RWMutex
 	ctx       context.Context
 	cancelCtx context.CancelFunc
 	config    config.Local
@@ -786,13 +786,16 @@ func (node *AlgorandFullNode) checkForParticipationKeys() {
 	defer node.monitoringRoutinesWaitGroup.Done()
 	ticker := time.NewTicker(node.config.ParticipationKeysRefreshInterval)
 	for {
+		node.mu.RLock()
+		done := node.ctx.Done()
+		node.mu.RUnlock()
 		select {
 		case <-ticker.C:
 			err := node.loadParticipationKeys()
 			if err != nil {
 				node.log.Errorf("Could not refresh participation keys: %v", err)
 			}
-		case <-node.ctx.Done():
+		case <-done:
 			ticker.Stop()
 			return
 		}
@@ -1037,10 +1040,13 @@ func (node *AlgorandFullNode) txPoolGaugeThread() {
 	ticker := time.NewTicker(10 * time.Second)
 	defer ticker.Stop()
 	for true {
+		node.mu.RLock()
+		done := node.ctx.Done()
+		node.mu.RUnlock()
 		select {
 		case <-ticker.C:
 			txPoolGuage.Set(float64(node.transactionPool.PendingCount()), nil)
-		case <-node.ctx.Done():
+		case <-done:
 			return
 		}
 	}
@@ -1074,8 +1080,11 @@ func (node *AlgorandFullNode) OnNewBlock(block bookkeeping.Block, delta ledgerco
 func (node *AlgorandFullNode) oldKeyDeletionThread() {
 	defer node.monitoringRoutinesWaitGroup.Done()
 	for {
+		node.mu.RLock()
+		done := node.ctx.Done()
+		node.mu.RUnlock()
 		select {
-		case <-node.ctx.Done():
+		case <-done:
 			return
 		case <-node.oldKeyDeletionNotify:
 		}