GetLivestreamStatisticsの呼び出し頻度調整

初期状態で重すぎて全員呼ぶと何もできないので、とりあえず1/10
isucon · Nov 23, 2023 · c1fb85f · c1fb85f
1 parent 60b6e3a
commit c1fb85f
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 8 deletions.
diff --git a/bench/scenario/viewer.go b/bench/scenario/viewer.go
@@ -79,10 +79,12 @@ func BasicViewerScenario(
 		return err
 	}
 
-	lgr.Info("get livestream stats")
-	if _, err := client.GetLivestreamStatistics(ctx, livestream.ID, livestream.Owner.Name); err != nil && !errors.Is(err, bencherror.ErrTimeout) {
-		lgr.Warnf("view: failed to get livestream stats: %s\n", err.Error())
-		return err
+	if n%10 == 1 { // NOTE: 本来のクライアントは全員statsを呼ぶが、重すぎるので調整
+		lgr.Info("get livestream stats")
+		if _, err := client.GetLivestreamStatistics(ctx, livestream.ID, livestream.Owner.Name); err != nil && !errors.Is(err, bencherror.ErrTimeout) {
+			lgr.Warnf("view: failed to get livestream stats: %s\n", err.Error())
+			return err
+		}
 	}
 
 	contestantLogger.Info("視聴を開始しました", zap.String("username", username), zap.Int("duration_hours", livestream.Hours()))

diff --git a/bench/scenario/visit_page.go b/bench/scenario/visit_page.go
@@ -48,10 +48,13 @@ func VisitLivestream(ctx context.Context, contestantLogger *zap.Logger, client *
 		return err
 	}
 
-	_, err := client.GetLivestreamStatistics(ctx, livestream.ID, livestream.Owner.Name)
-	if err != nil {
-		return err
-	}
+	/*
+		// NOTE: viwersのほうで呼ぶのでこっちは一旦やめます
+		_, err := client.GetLivestreamStatistics(ctx, livestream.ID, livestream.Owner.Name)
+		if err != nil {
+			return err
+		}
+	*/
 
 	livecomments, err := client.GetLivecomments(ctx, livestream.ID, livestream.Owner.Name, isupipe.WithLimitQueryParam(10))
 	if err != nil {