decrease relayer message queue priority

MixinNetwork · May 21, 2024 · 48d3287 · 48d3287
1 parent 4f5af0d
commit 48d3287
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/p2p/handle.go b/p2p/handle.go
@@ -456,7 +456,7 @@ func (me *Peer) relayOrHandlePeerMessage(relayerId crypto.Hash, msg *PeerMessage
 	if peer != nil {
 		rk := crypto.Blake3Hash(append(msg.Data, to[:]...))
 		rk = crypto.Blake3Hash(append(rk[:], relayerId[:]...))
-		success, _ := peer.offer(MsgPriorityHigh, &ChanMsg{rk[:], data})
+		success, _ := peer.offer(MsgPriorityNormal, &ChanMsg{rk[:], data})
 		if !success {
 			return fmt.Errorf("peer.offer(%s) consumer timeout", peer.IdForNetwork)
 		}
@@ -468,7 +468,7 @@ func (me *Peer) relayOrHandlePeerMessage(relayerId crypto.Hash, msg *PeerMessage
 	}
 	rk := crypto.Blake3Hash(append(msg.Data, to[:]...))
 	rk = crypto.Blake3Hash(append(rk[:], relayerId[:]...))
-	success, _ := peer.offer(MsgPriorityHigh, &ChanMsg{rk[:], data})
+	success, _ := peer.offer(MsgPriorityNormal, &ChanMsg{rk[:], data})
 	if !success {
 		return fmt.Errorf("peer.offer(%s) relayer timeout", peer.IdForNetwork)
 	}

diff --git a/p2p/peer.go b/p2p/peer.go
@@ -198,7 +198,7 @@ func (me *Peer) ListenConsumers() error {
 					continue
 				}
 				key := crypto.Blake3Hash(append(msg, p.IdForNetwork[:]...))
-				me.sendHighToPeer(p.IdForNetwork, PeerMessageTypeConsumers, key[:], msg)
+				me.sendToPeer(p.IdForNetwork, PeerMessageTypeConsumers, key[:], msg, MsgPriorityNormal)
 			}
 
 			<-ticker.C