gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

don't enforce upper limit for requests issued; tool will run indefinitely

Browse Source 
Former-commit-id: 239d22ed722357f0973c971b998b21f4f7b3b1da
This commit is contained in:
christianEQ 2021-06-11 16:28:29 +00:00
parent 0c41217fba
commit ea12db4433
1 changed files with 1 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/keydb-diagnostic-tool.cpp
View File

@ -399,14 +399,6 @@ static void writeHandler(aeEventLoop *el, int fd, void *privdata, int mask) {
/* Initialize request when nothing was written. */ /* Initialize request when nothing was written. */
if (c->written == 0) { 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. */ /* Really initialize: randomize keys and set start time. */
if (config.randomkeys) randomizeClientKey(c); if (config.randomkeys) randomizeClientKey(c);
atomicGet(config.slots_last_update, c->slots_last_update); atomicGet(config.slots_last_update, c->slots_last_update);
@ -913,7 +905,7 @@ int main(int argc, const char **argv) {
double cpu_usage; double cpu_usage;
while (threads_used < config.max_threads) { 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++) { for (int i = 0; i < config.numclients; i++) {
sprintf(command, "SET %d %s\r\n", threads_used * config.numclients + i, set_value); sprintf(command, "SET %d %s\r\n", threads_used * config.numclients + i, set_value);
createClient(command, strlen(command), NULL,threads_used); createClient(command, strlen(command), NULL,threads_used);