From d4bfc5de452578cee4b678c725a9924ff5cb76c7 Mon Sep 17 00:00:00 2001 From: michaelvlach Date: Fri, 15 Sep 2023 07:18:55 +0200 Subject: [PATCH] 0 means 0 --- agdb_benchmarks/src/readers.rs | 12 ++++++++++-- agdb_benchmarks/src/writers.rs | 12 ++++++++++-- 2 files changed, 20 insertions(+), 4 deletions(-) diff --git a/agdb_benchmarks/src/readers.rs b/agdb_benchmarks/src/readers.rs index 8daadf1c1..90e6794c9 100644 --- a/agdb_benchmarks/src/readers.rs +++ b/agdb_benchmarks/src/readers.rs @@ -154,7 +154,11 @@ pub(crate) fn start_post_readers( for i in 0..config.post_readers.count { let db = db.clone(); let limit = config.post_readers.posts; - let read_delay = Duration::from_millis(config.post_readers.delay_ms % (i + 1)); + let read_delay = Duration::from_millis(if config.post_readers.delay_ms == 0 { + 0 + } else { + config.post_readers.delay_ms % (i + 1) + }); let reads = config.post_readers.reads_per_reader; let handle = tokio::spawn(async move { @@ -188,7 +192,11 @@ pub(crate) fn start_comment_readers( for i in 0..config.comment_readers.count { let db = db.clone(); - let read_delay = Duration::from_millis(config.comment_readers.delay_ms % (i + 1)); + let read_delay = Duration::from_millis(if config.comment_readers.delay_ms == 0 { + 0 + } else { + config.comment_readers.delay_ms % (i + 1) + }); let reads = config.comment_readers.reads_per_reader; let limit = config.comment_readers.comments; diff --git a/agdb_benchmarks/src/writers.rs b/agdb_benchmarks/src/writers.rs index 2c356b025..76d4284eb 100644 --- a/agdb_benchmarks/src/writers.rs +++ b/agdb_benchmarks/src/writers.rs @@ -198,7 +198,11 @@ pub(crate) fn start_post_writers( .map(|e| { let id = e.id; let db = db.clone(); - let write_delay = Duration::from_millis(config.posters.delay_ms % id.0 as u64); + let write_delay = Duration::from_millis(if config.posters.delay_ms == 0 { + 0 + } else { + config.posters.delay_ms % id.0 as u64 + }); let posts = config.posters.posts; let title = config.posters.title.to_string(); let body = config.posters.body.to_string(); @@ -241,7 +245,11 @@ pub(crate) fn start_comment_writers( .map(|e| { let id = e.id; let db = db.clone(); - let write_delay = Duration::from_millis(config.commenters.delay_ms % id.0 as u64); + let write_delay = Duration::from_millis(if config.commenters.delay_ms == 0 { + 0 + } else { + config.commenters.delay_ms % id.0 as u64 + }); let comments = config.commenters.comments; let body = config.commenters.body.to_string();