From: Mathieu Desnoyers Date: Tue, 24 Apr 2012 14:52:57 +0000 (-0400) Subject: rculfhash tests: use array of callbacks to modularize X-Git-Tag: v0.7.0~28 X-Git-Url: https://git.lttng.org./?a=commitdiff_plain;h=f52c1ef78f707a5c5246582928e7dc8ed70efb37;p=urcu.git rculfhash tests: use array of callbacks to modularize Signed-off-by: Mathieu Desnoyers --- diff --git a/tests/test_urcu_hash.c b/tests/test_urcu_hash.c index 3578cc9..be632ee 100644 --- a/tests/test_urcu_hash.c +++ b/tests/test_urcu_hash.c @@ -23,6 +23,56 @@ #define _GNU_SOURCE #include "test_urcu_hash.h" +enum test_hash { + TEST_HASH_RW, +}; + +struct test_hash_cb { + void (*sigusr1)(int signo); + void (*sigusr2)(int signo); + void *(*thr_reader)(void *_count); + void *(*thr_writer)(void *_count); + int (*populate_hash)(void); +}; + +static +struct test_hash_cb test_hash_cb[] = { + [TEST_HASH_RW] = { + test_hash_rw_sigusr1_handler, + test_hash_rw_sigusr2_handler, + test_hash_rw_thr_reader, + test_hash_rw_thr_writer, + test_hash_rw_populate_hash, + }, +}; + +static enum test_hash test_choice = TEST_HASH_RW; + +void (*get_sigusr1_cb(void))(int) +{ + return test_hash_cb[test_choice].sigusr1; +} + +void (*get_sigusr2_cb(void))(int) +{ + return test_hash_cb[test_choice].sigusr2; +} + +void *(*get_thr_reader_cb(void))(void *) +{ + return test_hash_cb[test_choice].thr_reader; +} + +void *(*get_thr_writer_cb(void))(void *) +{ + return test_hash_cb[test_choice].thr_writer; +} + +int (*get_populate_hash_cb(void))(void) +{ + return test_hash_cb[test_choice].populate_hash; +} + unsigned int __thread rand_lookup; unsigned long __thread nr_add; unsigned long __thread nr_addexist; @@ -422,7 +472,7 @@ int main(int argc, char **argv) perror("sigemptyset"); return -1; } - act.sa_handler = test_hash_rw_sigusr1_handler; + act.sa_handler = get_sigusr1_cb(); act.sa_flags = SA_RESTART; ret = sigaction(SIGUSR1, &act, NULL); if (ret == -1) { @@ -442,7 +492,7 @@ int main(int argc, char **argv) if (err != 0) exit(1); - act.sa_handler = test_hash_rw_sigusr2_handler; + act.sa_handler = get_sigusr2_cb(); act.sa_flags = SA_RESTART; ret = sigaction(SIGUSR2, &act, NULL); if (ret == -1) { @@ -497,7 +547,7 @@ int main(int argc, char **argv) * thread from the point of view of resize. */ rcu_register_thread(); - ret = test_hash_rw_populate_hash(); + ret = (get_populate_hash_cb())(); assert(!ret); rcu_thread_offline(); @@ -506,14 +556,14 @@ int main(int argc, char **argv) for (i = 0; i < nr_readers; i++) { err = pthread_create(&tid_reader[i], - NULL, test_hash_rw_thr_reader, + NULL, get_thr_reader_cb(), &count_reader[i]); if (err != 0) exit(1); } for (i = 0; i < nr_writers; i++) { err = pthread_create(&tid_writer[i], - NULL, test_hash_rw_thr_writer, + NULL, get_thr_writer_cb(), &count_writer[i]); if (err != 0) exit(1); diff --git a/tests/test_urcu_hash.h b/tests/test_urcu_hash.h index 994c659..9abb2e0 100644 --- a/tests/test_urcu_hash.h +++ b/tests/test_urcu_hash.h @@ -199,12 +199,6 @@ typedef unsigned long cpu_set_t; void set_affinity(void); -/* rw test */ -void test_hash_rw_sigusr1_handler(int signo); -void test_hash_rw_sigusr2_handler(int signo); -void *test_hash_rw_thr_reader(void *_count); -void *test_hash_rw_thr_writer(void *_count); - /* * returns 0 if test should end. */ @@ -381,4 +375,11 @@ void cds_lfht_test_lookup(struct cds_lfht *ht, void *key, size_t key_len, void free_node_cb(struct rcu_head *head); +/* rw test */ +void test_hash_rw_sigusr1_handler(int signo); +void test_hash_rw_sigusr2_handler(int signo); +void *test_hash_rw_thr_reader(void *_count); +void *test_hash_rw_thr_writer(void *_count); +int test_hash_rw_populate_hash(void); + #endif /* _TEST_URCU_HASH_H */