1 #ifndef _TEST_URCU_JA_H
2 #define _TEST_URCU_JA_H
7 * Userspace RCU library - test program
9 * Copyright 2009-2012 - Mathieu Desnoyers <mathieu.desnoyers@polymtl.ca>
11 * This program is free software; you can redistribute it and/or modify
12 * it under the terms of the GNU General Public License as published by
13 * the Free Software Foundation; either version 2 of the License, or
14 * (at your option) any later version.
16 * This program is distributed in the hope that it will be useful,
17 * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 * GNU General Public License for more details.
21 * You should have received a copy of the GNU General Public License along
22 * with this program; if not, write to the Free Software Foundation, Inc.,
23 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
30 #include <sys/types.h>
39 #include <urcu/tls-compat.h>
40 #include "thread-id.h"
42 #define DEFAULT_RAND_POOL 1000000
44 /* Make this big enough to include the POWER5+ L3 cacheline size of 256B */
45 #define CACHE_LINE_SIZE 4096
47 /* hardcoded number of CPUs */
51 #define poison_free(ptr) \
53 memset(ptr, 0x42, sizeof(*(ptr))); \
57 #define poison_free(ptr) free(ptr)
60 #ifndef DYNAMIC_LINK_TEST
63 #define debug_yield_read()
65 #include <urcu-qsbr.h>
66 #include <urcu/rcuja.h>
67 #include <urcu-call-rcu.h>
70 unsigned long update_ops
;
72 unsigned long add_exist
;
76 extern DECLARE_URCU_TLS(unsigned int, rand_lookup
);
77 extern DECLARE_URCU_TLS(unsigned long, nr_add
);
78 extern DECLARE_URCU_TLS(unsigned long, nr_addexist
);
79 extern DECLARE_URCU_TLS(unsigned long, nr_del
);
80 extern DECLARE_URCU_TLS(unsigned long, nr_delnoent
);
81 extern DECLARE_URCU_TLS(unsigned long, lookup_fail
);
82 extern DECLARE_URCU_TLS(unsigned long, lookup_ok
);
84 extern struct cds_ja
*test_ja
;
87 struct cds_ja_node node
;
88 uint64_t key
; /* for testing */
89 struct rcu_head head
; /* delayed reclaim */
92 static inline struct ja_test_node
*
93 to_test_node(struct cds_ja_node
*node
)
95 return caa_container_of(node
, struct ja_test_node
, node
);
99 void ja_test_node_init(struct ja_test_node
*node
, uint64_t key
)
101 cds_ja_node_init(&node
->node
);
105 extern volatile int test_go
, test_stop
;
107 extern unsigned long wdelay
;
109 extern unsigned long duration
;
111 /* read-side C.S. duration, in loops */
112 extern unsigned long rduration
;
114 extern unsigned long init_populate
;
117 extern unsigned long init_pool_offset
, lookup_pool_offset
, write_pool_offset
;
118 extern unsigned long init_pool_size
,
121 extern int validate_lookup
;
123 extern int count_pipe
[2];
125 static inline void loop_sleep(unsigned long l
)
131 extern int verbose_mode
;
133 #define printf_verbose(fmt, args...) \
136 printf(fmt, ## args); \
139 extern unsigned int cpu_affinities
[NR_CPUS
];
140 extern unsigned int next_aff
;
141 extern int use_affinity
;
143 extern pthread_mutex_t affinity_mutex
;
145 #ifndef HAVE_CPU_SET_T
146 typedef unsigned long cpu_set_t
;
147 # define CPU_ZERO(cpuset) do { *(cpuset) = 0; } while(0)
148 # define CPU_SET(cpu, cpuset) do { *(cpuset) |= (1UL << (cpu)); } while(0)
151 void set_affinity(void);
154 * returns 0 if test should end.
156 static inline int test_duration_write(void)
161 static inline int test_duration_read(void)
166 extern DECLARE_URCU_TLS(unsigned long long, nr_writes
);
167 extern DECLARE_URCU_TLS(unsigned long long, nr_reads
);
169 extern unsigned int nr_readers
;
170 extern unsigned int nr_writers
;
172 void rcu_copy_mutex_lock(void);
173 void rcu_copy_mutex_unlock(void);
175 #endif /* _TEST_URCU_JA_H */