From ea12db4433fd1aa8166ebaa13cf8a295f0386cad Mon Sep 17 00:00:00 2001 From: christianEQ Date: Fri, 11 Jun 2021 16:28:29 +0000 Subject: [PATCH] don't enforce upper limit for requests issued; tool will run indefinitely Former-commit-id: 239d22ed722357f0973c971b998b21f4f7b3b1da --- src/keydb-diagnostic-tool.cpp | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/src/keydb-diagnostic-tool.cpp b/src/keydb-diagnostic-tool.cpp index c41995284..3dced8523 100644 --- a/src/keydb-diagnostic-tool.cpp +++ b/src/keydb-diagnostic-tool.cpp @@ -399,14 +399,6 @@ static void writeHandler(aeEventLoop *el, int fd, void *privdata, int mask) { /* Initialize request when nothing was written. */ if (c->written == 0) { - /* Enforce upper bound to number of requests. */ - int requests_issued = 0; - atomicGetIncr(config.requests_issued, requests_issued, 1); - if (requests_issued >= config.requests) { - freeClient(c); - return; - } - /* Really initialize: randomize keys and set start time. */ if (config.randomkeys) randomizeClientKey(c); atomicGet(config.slots_last_update, c->slots_last_update); @@ -913,7 +905,7 @@ int main(int argc, const char **argv) { double cpu_usage; while (threads_used < config.max_threads) { - printf("Creating clients for thread %d...\n", threads_used); + printf("Creating %d clients for thread %d...\n", config.numclients, threads_used); for (int i = 0; i < config.numclients; i++) { sprintf(command, "SET %d %s\r\n", threads_used * config.numclients + i, set_value); createClient(command, strlen(command), NULL,threads_used);