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.
26 #include "../config.h"
31 #include <sys/types.h>
40 #include <urcu/tls-compat.h>
46 #define DEFAULT_RAND_POOL 1000000
48 /* Make this big enough to include the POWER5+ L3 cacheline size of 256B */
49 #define CACHE_LINE_SIZE 4096
51 /* hardcoded number of CPUs */
55 #define poison_free(ptr) \
57 memset(ptr, 0x42, sizeof(*(ptr))); \
61 #define poison_free(ptr) free(ptr)
66 #if defined(_syscall0)
67 _syscall0(pid_t
, gettid
)
68 #elif defined(__NR_gettid)
69 static inline pid_t
gettid(void)
71 return syscall(__NR_gettid
);
74 #warning "use pid as tid"
75 static inline pid_t
gettid(void)
81 #ifndef DYNAMIC_LINK_TEST
84 #define debug_yield_read()
86 #include <urcu-qsbr.h>
87 #include <urcu/rcuja.h>
88 #include <urcu-call-rcu.h>
91 unsigned long update_ops
;
93 unsigned long add_exist
;
97 extern DECLARE_URCU_TLS(unsigned int, rand_lookup
);
98 extern DECLARE_URCU_TLS(unsigned long, nr_add
);
99 extern DECLARE_URCU_TLS(unsigned long, nr_addexist
);
100 extern DECLARE_URCU_TLS(unsigned long, nr_del
);
101 extern DECLARE_URCU_TLS(unsigned long, nr_delnoent
);
102 extern DECLARE_URCU_TLS(unsigned long, lookup_fail
);
103 extern DECLARE_URCU_TLS(unsigned long, lookup_ok
);
105 extern struct cds_ja
*test_ja
;
107 struct ja_test_node
{
108 struct cds_ja_node node
;
109 uint64_t key
; /* for testing */
110 struct rcu_head head
; /* delayed reclaim */
113 static inline struct ja_test_node
*
114 to_test_node(struct cds_ja_node
*node
)
116 return caa_container_of(node
, struct ja_test_node
, node
);
120 void ja_test_node_init(struct ja_test_node
*node
, uint64_t key
)
122 cds_ja_node_init(&node
->node
);
126 extern volatile int test_go
, test_stop
;
128 extern unsigned long wdelay
;
130 extern unsigned long duration
;
132 /* read-side C.S. duration, in loops */
133 extern unsigned long rduration
;
135 extern unsigned long init_populate
;
138 extern unsigned long init_pool_offset
, lookup_pool_offset
, write_pool_offset
;
139 extern unsigned long init_pool_size
,
142 extern int validate_lookup
;
144 extern int count_pipe
[2];
146 static inline void loop_sleep(unsigned long l
)
152 extern int verbose_mode
;
154 #define printf_verbose(fmt, args...) \
157 printf(fmt, ## args); \
160 extern unsigned int cpu_affinities
[NR_CPUS
];
161 extern unsigned int next_aff
;
162 extern int use_affinity
;
164 extern pthread_mutex_t affinity_mutex
;
166 #ifndef HAVE_CPU_SET_T
167 typedef unsigned long cpu_set_t
;
168 # define CPU_ZERO(cpuset) do { *(cpuset) = 0; } while(0)
169 # define CPU_SET(cpu, cpuset) do { *(cpuset) |= (1UL << (cpu)); } while(0)
172 void set_affinity(void);
175 * returns 0 if test should end.
177 static inline int test_duration_write(void)
182 static inline int test_duration_read(void)
187 extern DECLARE_URCU_TLS(unsigned long long, nr_writes
);
188 extern DECLARE_URCU_TLS(unsigned long long, nr_reads
);
190 extern unsigned int nr_readers
;
191 extern unsigned int nr_writers
;
193 void rcu_copy_mutex_lock(void);
194 void rcu_copy_mutex_unlock(void);
196 #endif /* _TEST_URCU_JA_H */