feat(scheduler): handle DownloadPieceFinishedRequest and DownloadPiec…

…eFailedRequest asynchronously (#3847) Signed-off-by: Gaius <[email protected]>
dragonflyoss · Feb 19, 2025 · 6f58ed0 · 6f58ed0
1 parent 832bd52
commit 6f58ed0
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/scheduler/service/service_v2.go b/scheduler/service/service_v2.go
@@ -1746,16 +1746,20 @@ func (v *V2) AnnouncePersistentCachePeer(stream schedulerv2.Scheduler_AnnouncePe
 			downloadPieceFinishedRequest := announcePersistentCachePeerRequest.DownloadPieceFinishedRequest
 
 			log.Info("receive DownloadPieceFinishedRequest")
-			if err := v.handleDownloadPersistentCachePieceFinishedRequest(ctx, req.GetPeerId(), downloadPieceFinishedRequest); err != nil {
-				log.Error(err)
-			}
+			go func() {
+				if err := v.handleDownloadPersistentCachePieceFinishedRequest(context.Background(), req.GetPeerId(), downloadPieceFinishedRequest); err != nil {
+					log.Error(err)
+				}
+			}()
 		case *schedulerv2.AnnouncePersistentCachePeerRequest_DownloadPieceFailedRequest:
 			downloadPieceFailedRequest := announcePersistentCachePeerRequest.DownloadPieceFailedRequest
 
 			log.Info("receive DownloadPieceFailedRequest")
-			if err := v.handleDownloadPersistentCachePieceFailedRequest(ctx, req.GetPeerId(), downloadPieceFailedRequest); err != nil {
-				log.Error(err)
-			}
+			go func() {
+				if err := v.handleDownloadPersistentCachePieceFailedRequest(context.Background(), req.GetPeerId(), downloadPieceFailedRequest); err != nil {
+					log.Error(err)
+				}
+			}()
 		default:
 			msg := fmt.Sprintf("receive unknow request: %#v", announcePersistentCachePeerRequest)
 			log.Error(msg)