added nil check for xferdone chan

Azure · Oct 18, 2024 · 0f823a5 · 0f823a5
1 parent 15eb334
commit 0f823a5
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/ste/jobStatusManager.go b/ste/jobStatusManager.go
@@ -85,9 +85,11 @@ func (jm *jobMgr) SendXferDoneMsg(msg xferDoneMsg) {
 			jm.Log(common.LogError, "Cannot send message on channel")
 		}
 	}()
-	select {
-	case jm.jstm.xferDone <- msg:
-	case <-jm.jstm.statusMgrDone: // Nobody is listening anymore, let's back off.
+	if jm.jstm.xferDone != nil {
+		select {
+		case jm.jstm.xferDone <- msg:
+		case <-jm.jstm.statusMgrDone: // Nobody is listening anymore, let's back off.
+		}
 	}
 }