Save JSON playlist to object storage in own goroutine

Fixes #1609
livepeer · Aug 27, 2020 · 28e2047 · 28e2047
1 parent 642fa61
commit 28e2047
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/core/playlistmanager.go b/core/playlistmanager.go
@@ -217,10 +217,12 @@ func (mgr *BasicPlaylistManager) FlushRecord() {
 			glog.Error("Error encoding playlist: ", err)
 			return
 		}
-		now := time.Now()
-		mgr.recordSession.SaveData(mgr.jsonList.name, b, nil)
-		glog.V(common.VERBOSE).Infof("Saving json playlist name=%s size=%d bytes took=%s", mgr.jsonList.name,
-			len(b), time.Since(now))
+		go func(name string, data []byte) {
+			now := time.Now()
+			mgr.recordSession.SaveData(mgr.jsonList.name, b, nil)
+			glog.V(common.VERBOSE).Infof("Saving json playlist name=%s size=%d bytes took=%s", mgr.jsonList.name,
+				len(b), time.Since(now))
+		}(mgr.jsonList.name, b)
 		if mgr.jsonList.DurationMs > 60*60*1000 { // 1 hour
 			mgr.jsonList = NewJSONPlaylist()
 		}