Merge pull request #2768 from filecoin-project/fix/add-explanation

Fix/add explanation
2020-08-01 16:59:20 -07:00
parent 9c51b48754 f2d1fbdfa5
commit 43491cb7ed
1 changed files with 4 additions and 0 deletions
@@ -243,6 +243,10 @@ func (mp *MessagePool) Close() error {
 }

 func (mp *MessagePool) Prune() {
+	//so, its a single slot buffered channel. The first send fills the channel,
+	//the second send goes through when the pruning starts,
+	//and the third send goes through (and noops) after the pruning finishes
+	//and goes through the loop again
 	mp.pruneTrigger <- struct{}{}
 	mp.pruneTrigger <- struct{}{}
 	mp.pruneTrigger <- struct{}{}