monitor: Broadcaster only logic in SegmentEmerged

livepeer · Nov 27, 2020 · 27f2247 · 27f2247
1 parent 0ab7f6f
commit 27f2247
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/monitor/census.go b/monitor/census.go
@@ -891,7 +891,9 @@ func SetTranscodersNumberAndLoad(load, capacity, number int) {
 
 func SegmentEmerged(nonce, seqNo uint64, profilesNum int, dur float64) {
 	glog.V(logLevel).Infof("Logging SegmentEmerged... nonce=%d seqNo=%d duration=%v", nonce, seqNo, dur)
-	census.segmentEmerged(nonce, seqNo, profilesNum)
+	if census.nodeType == Broadcaster {
+		census.segmentEmerged(nonce, seqNo, profilesNum)
+	}
 	stats.Record(census.ctx, census.mSourceSegmentDuration.M(dur))
 }
 

diff --git a/monitor/census_test.go b/monitor/census_test.go
@@ -49,7 +49,7 @@ func TestLastSegmentTimeout(t *testing.T) {
 	defer func() { unitTestMode = false }()
 	NodeID = "testid"
 
-	InitCensus("tst", "testversion")
+	InitCensus("bctr", "testversion")
 	// defer func() {
 	// 	shutDown <- nil
 	// }()