X-Git-Url: http://git.liburcu.org/?p=urcu.git;a=blobdiff_plain;f=test_urcu_timing.c;h=8577b8f092e472f2e25fc5e0e4c10d070320a949;hp=ac23846d784f783c1c34d86beab2323bc8381995;hb=2a67ec322b40544b9e4fc5f138629a65b4f20352;hpb=2d6debff95ad695255d2ea9d590d1e418590b238 diff --git a/test_urcu_timing.c b/test_urcu_timing.c index ac23846..8577b8f 100644 --- a/test_urcu_timing.c +++ b/test_urcu_timing.c @@ -5,7 +5,19 @@ * * Copyright February 2009 - Mathieu Desnoyers * - * Distributed under GPLv2 + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ #include @@ -18,6 +30,10 @@ #include #include #include +#include + +/* Make this big enough to include the POWER5+ L3 cacheline size of 256B */ +#define CACHE_LINE_SIZE 4096 #if defined(_syscall0) _syscall0(pid_t, gettid) @@ -34,6 +50,7 @@ static inline pid_t gettid(void) } #endif +#define _LGPL_SOURCE #include "urcu.h" pthread_mutex_t rcu_copy_mutex = PTHREAD_MUTEX_INITIALIZER; @@ -69,12 +86,18 @@ static struct test_array *test_rcu_pointer; #define INNER_READ_LOOP 100000U #define READ_LOOP ((unsigned long long)OUTER_READ_LOOP * INNER_READ_LOOP) -#define WRITE_LOOP 2000U +#define OUTER_WRITE_LOOP 10U +#define INNER_WRITE_LOOP 200U +#define WRITE_LOOP ((unsigned long long)OUTER_WRITE_LOOP * INNER_WRITE_LOOP) + +static int num_read; +static int num_write; -#define NR_READ 10 -#define NR_WRITE 9 +#define NR_READ num_read +#define NR_WRITE num_write -static cycles_t reader_time[NR_READ] __attribute__((aligned(128))); +static cycles_t __attribute__((aligned(CACHE_LINE_SIZE))) *reader_time; +static cycles_t __attribute__((aligned(CACHE_LINE_SIZE))) *writer_time; void *thr_reader(void *arg) { @@ -86,7 +109,7 @@ void *thr_reader(void *arg) "reader", pthread_self(), (unsigned long)gettid()); sleep(2); - urcu_register_thread(); + rcu_register_thread(); time1 = get_cycles(); for (i = 0; i < OUTER_READ_LOOP; i++) { @@ -101,7 +124,7 @@ void *thr_reader(void *arg) } time2 = get_cycles(); - urcu_unregister_thread(); + rcu_unregister_thread(); reader_time[(unsigned long)arg] = time2 - time1; @@ -114,29 +137,35 @@ void *thr_reader(void *arg) void *thr_writer(void *arg) { - int i; + int i, j; struct test_array *new, *old; + cycles_t time1, time2; printf("thread_begin %s, thread id : %lx, tid %lu\n", "writer", pthread_self(), (unsigned long)gettid()); sleep(2); - for (i = 0; i < WRITE_LOOP; i++) { - new = malloc(sizeof(struct test_array)); - rcu_copy_mutex_lock(); - old = test_rcu_pointer; - if (old) { - assert(old->a == 8); - } - new->a = 8; - old = urcu_publish_content(&test_rcu_pointer, new); - rcu_copy_mutex_unlock(); - /* can be done after unlock */ - if (old) { - old->a = 0; + for (i = 0; i < OUTER_WRITE_LOOP; i++) { + for (j = 0; j < INNER_WRITE_LOOP; j++) { + time1 = get_cycles(); + new = malloc(sizeof(struct test_array)); + rcu_copy_mutex_lock(); + old = test_rcu_pointer; + if (old) { + assert(old->a == 8); + } + new->a = 8; + old = rcu_publish_content(&test_rcu_pointer, new); + rcu_copy_mutex_unlock(); + /* can be done after unlock */ + if (old) { + old->a = 0; + } + free(old); + time2 = get_cycles(); + writer_time[(unsigned long)arg] += time2 - time1; + usleep(1); } - free(old); - usleep(1); } printf("thread_end %s, thread id : %lx, tid %lu\n", @@ -144,13 +173,26 @@ void *thr_writer(void *arg) return ((void*)2); } -int main() +int main(int argc, char **argv) { int err; - pthread_t tid_reader[NR_READ], tid_writer[NR_WRITE]; + pthread_t *tid_reader, *tid_writer; void *tret; int i; - cycles_t tot_time = 0; + cycles_t tot_rtime = 0; + cycles_t tot_wtime = 0; + + if (argc < 2) { + printf("Usage : %s nr_readers nr_writers\n", argv[0]); + exit(-1); + } + num_read = atoi(argv[1]); + num_write = atoi(argv[2]); + + reader_time = malloc(sizeof(*reader_time) * num_read); + writer_time = malloc(sizeof(*writer_time) * num_write); + tid_reader = malloc(sizeof(*tid_reader) * num_read); + tid_writer = malloc(sizeof(*tid_writer) * num_write); printf("thread %-6s, thread id : %lx, tid %lu\n", "main", pthread_self(), (unsigned long)gettid()); @@ -162,7 +204,8 @@ int main() exit(1); } for (i = 0; i < NR_WRITE; i++) { - err = pthread_create(&tid_writer[i], NULL, thr_writer, NULL); + err = pthread_create(&tid_writer[i], NULL, thr_writer, + (void *)(long)i); if (err != 0) exit(1); } @@ -173,16 +216,24 @@ int main() err = pthread_join(tid_reader[i], &tret); if (err != 0) exit(1); - tot_time += reader_time[i]; + tot_rtime += reader_time[i]; } for (i = 0; i < NR_WRITE; i++) { err = pthread_join(tid_writer[i], &tret); if (err != 0) exit(1); + tot_wtime += writer_time[i]; } free(test_rcu_pointer); printf("Time per read : %g cycles\n", - (double)tot_time / ((double)NR_READ * (double)READ_LOOP)); + (double)tot_rtime / ((double)NR_READ * (double)READ_LOOP)); + printf("Time per write : %g cycles\n", + (double)tot_wtime / ((double)NR_WRITE * (double)WRITE_LOOP)); + + free(reader_time); + free(writer_time); + free(tid_reader); + free(tid_writer); return 0; }