int nrooms = sizeof(random_rooms) / sizeof(char *);
char *test_user = "Load Test User";
char test_pass[16];
+time_t time_started;
+volatile int ops_completed;
// These are our randomized load test operations: an even mix of changing rooms, posting messages, and deleting messages.
serv_gets(serv_sock, buf);
} while ( (buf[0] != '2') && (total_msgs > 0));
}
-
}
#define ROW_OFFSET 8
while(1) {
perform_random_thing(serv_sock);
printf("\033[%d;%dH\033[32m%8ld\033[0m", row, col, ++ops);
+ ++ops_completed; // this is declared "volatile" so we don't need to lock it
+ if (thread_id == 0) {
+ printf("\033[2;55H\033[44m\033[33m\033[1m%d ops/sec \033[0m", (ops_completed / (time(NULL) - time_started)));
+ }
fflush(stdout);
}
}
threadId[i] = i;
}
+ time_started = time(NULL);
+ ops_completed = 0;
+
for (i=1; i<nthreads; ++i) {
pthread_t thread;