X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=tests%2Fbenchmark%2Ftest_rwlock.c;h=4628080e3ba30846ad65a11fcbbec6c0329dfca4;hb=6a29bfc1b6d5d57c4dbd8811a5229cf993e5fa65;hp=f95e4e172bc40f3e233cc5d67c01ca6cdccd0f6f;hpb=89a6a9ce587a0b6e5570ab07fb4c680fe24a77ad;p=urcu.git diff --git a/tests/benchmark/test_rwlock.c b/tests/benchmark/test_rwlock.c index f95e4e1..4628080 100644 --- a/tests/benchmark/test_rwlock.c +++ b/tests/benchmark/test_rwlock.c @@ -202,8 +202,9 @@ void *thr_reader(void *_count) } *count = URCU_TLS(nr_reads); - printf_verbose("thread_end %s, tid %lu\n", - "reader", urcu_get_thread_id()); + + printf_verbose("thread_end %s, tid %lu, count %llu\n", + "reader", urcu_get_thread_id(), *count); return ((void*)1); } @@ -248,10 +249,10 @@ void *thr_writer(void *_count) if (caa_unlikely(wdelay)) loop_sleep(wdelay); } - - printf_verbose("thread_end %s, tid %lu\n", - "writer", urcu_get_thread_id()); *count = URCU_TLS(nr_writes); + + printf_verbose("thread_end %s, tid %lu, count %llu\n", + "writer", urcu_get_thread_id(), *count); return ((void*)2); } @@ -276,6 +277,7 @@ int main(int argc, char **argv) unsigned long long *count_reader, *count_writer; unsigned long long tot_reads = 0, tot_writes = 0; int i, a; + unsigned int i_thr; if (argc < 4) { show_usage(argc, argv); @@ -345,6 +347,7 @@ int main(int argc, char **argv) printf_verbose("running test for %lu seconds, %u readers, %u writers.\n", duration, nr_readers, nr_writers); printf_verbose("Writer delay : %lu loops.\n", wdelay); + printf_verbose("Writer duration : %lu loops.\n", wduration); printf_verbose("Reader duration : %lu loops.\n", rduration); printf_verbose("thread %-6s, tid %lu\n", "main", urcu_get_thread_id()); @@ -362,15 +365,15 @@ int main(int argc, char **argv) next_aff = 0; - for (i = 0; i < nr_readers; i++) { - err = pthread_create(&tid_reader[i], NULL, thr_reader, - &count_reader[i]); + for (i_thr = 0; i_thr < nr_readers; i_thr++) { + err = pthread_create(&tid_reader[i_thr], NULL, thr_reader, + &count_reader[i_thr]); if (err != 0) exit(1); } - for (i = 0; i < nr_writers; i++) { - err = pthread_create(&tid_writer[i], NULL, thr_writer, - &count_writer[i]); + for (i_thr = 0; i_thr < nr_writers; i_thr++) { + err = pthread_create(&tid_writer[i_thr], NULL, thr_writer, + &count_writer[i_thr]); if (err != 0) exit(1); } @@ -383,17 +386,17 @@ int main(int argc, char **argv) test_stop = 1; - for (i = 0; i < nr_readers; i++) { - err = pthread_join(tid_reader[i], &tret); + for (i_thr = 0; i_thr < nr_readers; i_thr++) { + err = pthread_join(tid_reader[i_thr], &tret); if (err != 0) exit(1); - tot_reads += count_reader[i]; + tot_reads += count_reader[i_thr]; } - for (i = 0; i < nr_writers; i++) { - err = pthread_join(tid_writer[i], &tret); + for (i_thr = 0; i_thr < nr_writers; i_thr++) { + err = pthread_join(tid_writer[i_thr], &tret); if (err != 0) exit(1); - tot_writes += count_writer[i]; + tot_writes += count_writer[i_thr]; } printf_verbose("total number of reads : %llu, writes %llu\n", tot_reads,