From be7fc977c4ab93b67af1b014f02066ccde8ab8c8 Mon Sep 17 00:00:00 2001
From: Chen Kai <281165273grape@gmail.com>
Date: Thu, 18 Apr 2024 16:55:55 +0800
Subject: [PATCH] fix:make offered content async gossip

Signed-off-by: Chen Kai <281165273grape@gmail.com>
---
 portalnetwork/beacon/beacon_network.go   | 20 ++++++++++++++------
 portalnetwork/history/history_network.go | 21 +++++++++++++++------
 2 files changed, 29 insertions(+), 12 deletions(-)

diff --git a/portalnetwork/beacon/beacon_network.go b/portalnetwork/beacon/beacon_network.go
index f097697f7a..0a2316400a 100644
--- a/portalnetwork/beacon/beacon_network.go
+++ b/portalnetwork/beacon/beacon_network.go
@@ -240,12 +240,20 @@ func (bn *BeaconNetwork) processContentLoop(ctx context.Context) {
 				bn.log.Error("validate content failed", "err", err)
 				continue
 			}
-			gossippedNum, err := bn.portalProtocol.Gossip(&contentElement.Node, contentElement.ContentKeys, contentElement.Contents)
-			bn.log.Trace("gossippedNum", "gossippedNum", gossippedNum)
-			if err != nil {
-				bn.log.Error("gossip failed", "err", err)
-				continue
-			}
+			go func(ctx context.Context) {
+				select {
+				case <-ctx.Done():
+					return
+				default:
+					var gossippedNum int
+					gossippedNum, err = bn.portalProtocol.Gossip(&contentElement.Node, contentElement.ContentKeys, contentElement.Contents)
+					bn.log.Trace("gossippedNum", "gossippedNum", gossippedNum)
+					if err != nil {
+						bn.log.Error("gossip failed", "err", err)
+						return
+					}
+				}
+			}(ctx)
 		}
 	}
 }
diff --git a/portalnetwork/history/history_network.go b/portalnetwork/history/history_network.go
index dc0293a976..6d72a12f0f 100644
--- a/portalnetwork/history/history_network.go
+++ b/portalnetwork/history/history_network.go
@@ -508,12 +508,21 @@ func (h *HistoryNetwork) processContentLoop(ctx context.Context) {
 				h.log.Error("validate content failed", "err", err)
 				continue
 			}
-			gossippedNum, err := h.portalProtocol.Gossip(&contentElement.Node, contentElement.ContentKeys, contentElement.Contents)
-			h.log.Trace("gossippedNum", "gossippedNum", gossippedNum)
-			if err != nil {
-				h.log.Error("gossip failed", "err", err)
-				continue
-			}
+
+			go func(ctx context.Context) {
+				select {
+				case <-ctx.Done():
+					return
+				default:
+					var gossippedNum int
+					gossippedNum, err = h.portalProtocol.Gossip(&contentElement.Node, contentElement.ContentKeys, contentElement.Contents)
+					h.log.Trace("gossippedNum", "gossippedNum", gossippedNum)
+					if err != nil {
+						h.log.Error("gossip failed", "err", err)
+						return
+					}
+				}
+			}(ctx)
 		}
 	}
 }