hcq/sysbench
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Move tx_rate check from thread_run() to sb_event_stop().

Browse Source 
This is required for tx_rate to also work with Lua scripts.
This commit is contained in:
Alexey Kopytov
2017-01-22 11:17:44 +03:00
parent b179d21849
commit 4e7d6d87ca
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
sysbench/sysbench.c
View File

@ -521,6 +521,13 @@ void sb_event_stop(int thread_id)
sb_histogram_update(&sb_latency_histogram, NS2MS(value));
db_thread_stat_inc(thread_id, DB_STAT_TRX);
if (sb_globals.tx_rate > 0)
{
pthread_mutex_lock(&event_queue_mutex);
sb_globals.concurrency--;
pthread_mutex_unlock(&event_queue_mutex);
}
}
@ -543,13 +550,6 @@ static int thread_run(sb_test_t *test, int thread_id)
rc = test->ops.execute_event(&event, thread_id);
sb_event_stop(thread_id);
if (sb_globals.tx_rate > 0)
{
pthread_mutex_lock(&event_queue_mutex);
sb_globals.concurrency--;
pthread_mutex_unlock(&event_queue_mutex);
}
}
return rc;