feat: add cdn task peers monitor log (#764)

Signed-off-by: santong <[email protected]>
dragonflyoss · Oct 28, 2021 · 51b36b5 · 51b36b5
1 parent aaf769e
commit 51b36b5
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git a/scheduler/core/scheduler/basic/basic_scheduler.go b/scheduler/core/scheduler/basic/basic_scheduler.go
@@ -140,7 +140,7 @@ func (s *Scheduler) ScheduleParent(peer *supervisor.Peer, blankParents sets.Stri
 
 func (s *Scheduler) selectCandidateChildren(peer *supervisor.Peer, limit int, blankChildren sets.String) (candidateChildren []*supervisor.Peer) {
 	peer.Log().Debug("start schedule children flow")
-	defer peer.Log().Debugf("finish schedule parent flow, select num %d candidate children, "+
+	defer peer.Log().Debugf("finish schedule children flow, select num %d candidate children, "+
 		"current task tree node count %d, back source peers: %v", len(candidateChildren), peer.Task.GetPeers().Size(), peer.Task.GetBackToSourcePeers())
 	candidateChildren = peer.Task.Pick(limit, func(candidateNode *supervisor.Peer) bool {
 		if candidateNode == nil {

diff --git a/scheduler/supervisor/cdn.go b/scheduler/supervisor/cdn.go
@@ -215,6 +215,7 @@ func (c *cdn) initCDNPeer(ctx context.Context, task *Task, ps *cdnsystem.PieceSe
 
 	peer.SetStatus(PeerStatusRunning)
 	c.peerManager.Add(peer)
+	peer.Task.Log().Debugf("cdn peer %s has been added", peer.ID)
 	return peer, nil
 }
 

diff --git a/scheduler/supervisor/task.go b/scheduler/supervisor/task.go
@@ -262,6 +262,7 @@ func (task *Task) UpdateSuccess(pieceCount int32, contentLength int64) {
 
 func (task *Task) AddPeer(peer *Peer) {
 	task.peers.UpdateOrAdd(peer)
+	task.logger.Debugf("peer %s has been added, current total peer count is %d", peer.ID, task.peers.Size())
 }
 
 func (task *Task) UpdatePeer(peer *Peer) {
@@ -270,6 +271,7 @@ func (task *Task) UpdatePeer(peer *Peer) {
 
 func (task *Task) DeletePeer(peer *Peer) {
 	task.peers.Delete(peer)
+	task.logger.Debugf("peer %s has been deleted, current total peer count is %d", peer.ID, task.peers.Size())
 }
 
 func (task *Task) GetPeers() *sortedlist.SortedList {