From ff4344e50cd2b5e453f473901d01850d3f4f3485 Mon Sep 17 00:00:00 2001 From: Eli Mallon Date: Tue, 4 May 2021 23:49:15 -0700 Subject: [PATCH] loadtester: add -wait-for-target=30s --- cmd/loadtester/loadtester.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/cmd/loadtester/loadtester.go b/cmd/loadtester/loadtester.go index c715aede..a3ea48ae 100644 --- a/cmd/loadtester/loadtester.go +++ b/cmd/loadtester/loadtester.go @@ -41,6 +41,7 @@ func main() { // startDelay := fs.Duration("start-delay", 0*time.Second, "time delay before start") streamDuration := fs.Duration("stream-dur", 0, "How long to stream each stream (0 to stream whole file)") testDuration := fs.Duration("test-dur", 0, "How long to run overall test") + waitForTargetDuration := fs.Duration("wait-for-target", 30*time.Second, "How long to wait for a new stream to appear before giving up") // profiles := fs.Uint("profiles", 2, "number of transcoded profiles should be in output") sim := fs.Uint("sim", 1, "Number of simulteneous streams to stream") @@ -243,7 +244,7 @@ func main() { // exit(0, fn, fa, nil) }(fileName, *fileArg) - err = loadTester.Start(fileName, 30*time.Second, *streamDuration, *testDuration, int(*sim)) + err = loadTester.Start(fileName, *waitForTargetDuration, *streamDuration, *testDuration, int(*sim)) if err != nil { glog.Errorf("Error starting test: %v", err) exit(255, fileName, *fileArg, err)