Mako: fix minor bugs
This commit is contained in:
parent
1700d479c9
commit
38c3adbb84
|
@ -739,7 +739,7 @@ void *worker_thread(void *thread_args) {
|
||||||
fdb_error_t err;
|
fdb_error_t err;
|
||||||
int rc;
|
int rc;
|
||||||
FDBTransaction *transaction;
|
FDBTransaction *transaction;
|
||||||
int thread_tps;
|
int thread_tps = 0;
|
||||||
int thread_iters = 0;
|
int thread_iters = 0;
|
||||||
int op;
|
int op;
|
||||||
volatile int *signal = &((thread_args_t *)thread_args)->process->shm->signal;
|
volatile int *signal = &((thread_args_t *)thread_args)->process->shm->signal;
|
||||||
|
@ -1813,8 +1813,8 @@ int main(int argc, char *argv[]) {
|
||||||
shm->readycount = 0;
|
shm->readycount = 0;
|
||||||
shm->throttle_factor = 1.0;
|
shm->throttle_factor = 1.0;
|
||||||
|
|
||||||
/* fork worker processes */
|
/* fork worker processes + 1 stats process */
|
||||||
worker_pids = (pid_t *)calloc(sizeof(pid_t), args.num_processes);
|
worker_pids = (pid_t *)calloc(sizeof(pid_t), args.num_processes + 1);
|
||||||
if (!worker_pids) {
|
if (!worker_pids) {
|
||||||
fprintf(stderr, "ERROR: cannot allocate worker_pids (%d processes)\n",
|
fprintf(stderr, "ERROR: cannot allocate worker_pids (%d processes)\n",
|
||||||
args.num_processes);
|
args.num_processes);
|
||||||
|
|
Loading…
Reference in New Issue