server: Introduce constant common.SegmentUploadTimeout

livepeer · Dec 6, 2021 · 166d638 · 166d638
1 parent 381768f
commit 166d638
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/common/util.go b/common/util.go
@@ -29,6 +29,9 @@ import (
 // HTTPTimeout timeout used in HTTP connections between nodes
 var HTTPTimeout = 8 * time.Second
 
+// SegmentUploadTimeout timeout used in HTTP connections for uploading the segment
+var SegmentUploadTimeout = 2 * time.Second
+
 // Max Segment Duration
 var MaxDuration = (5 * time.Minute)
 

diff --git a/server/segment_rpc.go b/server/segment_rpc.go
@@ -447,7 +447,7 @@ func SubmitSegment(sess *BroadcastSession, seg *stream.HLSSegment, nonce uint64,
 	// timeout for the segment upload, until HTTP returns OK 200
 	uploadTimeout := time.Duration(segUploadTimeoutMultiplier * seg.Duration * float64(time.Second))
 	if uploadTimeout <= 0 {
-		uploadTimeout = httpTimeout
+		uploadTimeout = common.SegmentUploadTimeout
 	}
 
 	ctx, cancel := context.WithTimeout(context.Background(), httpTimeout)