HomeSort by: relevance | last modified time | path
    Searched refs:URCU_TLS (Results 1 - 25 of 31) sorted by relevancy

1 2

  /src/external/lgpl2/userspace-rcu/dist/tests/benchmark/
test_urcu_hash_rw.c 56 URCU_TLS(rand_lookup) = urcu_get_thread_id() ^ time(NULL);
67 (void *)(((unsigned long) rand_r(&URCU_TLS(rand_lookup)) % lookup_pool_size) + lookup_pool_offset),
75 URCU_TLS(lookup_fail)++;
77 URCU_TLS(lookup_ok)++;
83 URCU_TLS(nr_reads)++;
86 if (caa_unlikely((URCU_TLS(nr_reads) & ((1 << 10) - 1)) == 0))
92 *count = URCU_TLS(nr_reads);
97 URCU_TLS(lookup_fail),
98 URCU_TLS(lookup_ok));
113 URCU_TLS(rand_lookup) = urcu_get_thread_id() ^ time(NULL)
    [all...]
test_urcu_hash_unique.c 54 URCU_TLS(rand_lookup) = urcu_get_thread_id() ^ time(NULL);
85 URCU_TLS(nr_reads)++;
88 if (caa_unlikely((URCU_TLS(nr_reads) & ((1 << 10) - 1)) == 0))
94 *count = URCU_TLS(nr_reads);
98 urcu_get_thread_id(), URCU_TLS(lookup_fail),
99 URCU_TLS(lookup_ok));
116 URCU_TLS(rand_lookup) = urcu_get_thread_id() ^ time(NULL);
129 || (addremove == AR_RANDOM && rand_r(&URCU_TLS(rand_lookup)) & 1)) {
132 (void *)(((unsigned long) rand_r(&URCU_TLS(rand_lookup)) % write_pool_size) + write_pool_offset),
135 loc_add_unique = rand_r(&URCU_TLS(rand_lookup)) & 1
    [all...]
test_urcu_wfs.c 154 URCU_TLS(nr_successful_enqueues)++;
156 URCU_TLS(nr_empty_dest_enqueues)++;
161 URCU_TLS(nr_enqueues)++;
167 count[0] = URCU_TLS(nr_enqueues);
168 count[1] = URCU_TLS(nr_successful_enqueues);
169 count[2] = URCU_TLS(nr_empty_dest_enqueues);
174 URCU_TLS(nr_enqueues),
175 URCU_TLS(nr_successful_enqueues),
176 URCU_TLS(nr_empty_dest_enqueues));
194 URCU_TLS(nr_pop_last)++
    [all...]
test_urcu_wfcq.c 152 URCU_TLS(nr_successful_enqueues)++;
154 URCU_TLS(nr_empty_dest_enqueues)++;
159 URCU_TLS(nr_enqueues)++;
165 count[0] = URCU_TLS(nr_enqueues);
166 count[1] = URCU_TLS(nr_successful_enqueues);
167 count[2] = URCU_TLS(nr_empty_dest_enqueues);
172 URCU_TLS(nr_enqueues),
173 URCU_TLS(nr_successful_enqueues),
174 URCU_TLS(nr_empty_dest_enqueues));
192 URCU_TLS(nr_dequeue_last)++
    [all...]
test_urcu_lfq.c 143 URCU_TLS(nr_successful_enqueues)++;
148 URCU_TLS(nr_enqueues)++;
155 count[0] = URCU_TLS(nr_enqueues);
156 count[1] = URCU_TLS(nr_successful_enqueues);
160 URCU_TLS(nr_enqueues),
161 URCU_TLS(nr_successful_enqueues));
200 URCU_TLS(nr_successful_dequeues)++;
203 URCU_TLS(nr_dequeues)++;
214 URCU_TLS(nr_dequeues),
215 URCU_TLS(nr_successful_dequeues))
    [all...]
test_urcu_lfs_rcu.c 146 URCU_TLS(nr_successful_enqueues)++;
151 URCU_TLS(nr_enqueues)++;
158 count[0] = URCU_TLS(nr_enqueues);
159 count[1] = URCU_TLS(nr_successful_enqueues);
163 URCU_TLS(nr_enqueues),
164 URCU_TLS(nr_successful_enqueues));
202 URCU_TLS(nr_successful_dequeues)++;
204 URCU_TLS(nr_dequeues)++;
216 URCU_TLS(nr_dequeues),
217 URCU_TLS(nr_successful_dequeues))
    [all...]
test_urcu_wfq.c 138 URCU_TLS(nr_successful_enqueues)++;
143 URCU_TLS(nr_enqueues)++;
148 count[0] = URCU_TLS(nr_enqueues);
149 count[1] = URCU_TLS(nr_successful_enqueues);
153 URCU_TLS(nr_enqueues),
154 URCU_TLS(nr_successful_enqueues));
176 URCU_TLS(nr_successful_dequeues)++;
179 URCU_TLS(nr_dequeues)++;
189 URCU_TLS(nr_dequeues),
190 URCU_TLS(nr_successful_dequeues))
    [all...]
test_urcu_lfs.c 154 URCU_TLS(nr_successful_enqueues)++;
159 URCU_TLS(nr_enqueues)++;
166 count[0] = URCU_TLS(nr_enqueues);
167 count[1] = URCU_TLS(nr_successful_enqueues);
171 URCU_TLS(nr_enqueues),
172 URCU_TLS(nr_successful_enqueues));
205 URCU_TLS(nr_successful_dequeues)++;
207 URCU_TLS(nr_dequeues)++;
227 URCU_TLS(nr_successful_dequeues)++;
228 URCU_TLS(nr_dequeues)++
    [all...]
test_urcu_qsbr.c 131 URCU_TLS(nr_reads)++;
133 if (caa_unlikely((URCU_TLS(nr_reads) & ((1 << 10) - 1)) == 0))
145 *count = URCU_TLS(nr_reads);
176 URCU_TLS(nr_writes)++;
185 *count = URCU_TLS(nr_writes);
test_mutex.c 132 URCU_TLS(nr_reads)++;
137 tot_nr_reads[tidx] = URCU_TLS(nr_reads);
163 URCU_TLS(nr_writes)++;
172 tot_nr_writes[wtidx] = URCU_TLS(nr_writes);
test_perthreadlock.c 160 URCU_TLS(nr_reads)++;
165 tot_nr_reads[tidx] = URCU_TLS(nr_reads);
196 URCU_TLS(nr_writes)++;
205 tot_nr_writes[wtidx] = URCU_TLS(nr_writes);
test_rwlock.c 143 URCU_TLS(nr_reads)++;
148 *count = URCU_TLS(nr_reads);
188 URCU_TLS(nr_writes)++;
194 *count = URCU_TLS(nr_writes);
test_urcu.c 128 URCU_TLS(nr_reads)++;
139 *count = URCU_TLS(nr_reads);
170 URCU_TLS(nr_writes)++;
179 *count = URCU_TLS(nr_writes);
test_urcu_assign.c 186 URCU_TLS(nr_reads)++;
193 *count = URCU_TLS(nr_reads);
226 URCU_TLS(nr_writes)++;
235 *count = URCU_TLS(nr_writes);
test_urcu_bp.c 128 URCU_TLS(nr_reads)++;
135 *count = URCU_TLS(nr_reads);
165 URCU_TLS(nr_writes)++;
174 *count = URCU_TLS(nr_writes);
  /src/external/lgpl2/userspace-rcu/dist/include/urcu/static/
urcu-mb.h 60 _CMM_STORE_SHARED(URCU_TLS(urcu_mb_reader).ctr, _CMM_LOAD_SHARED(urcu_mb_gp.ctr));
63 _CMM_STORE_SHARED(URCU_TLS(urcu_mb_reader).ctr, tmp + URCU_GP_COUNT);
80 urcu_assert_debug(URCU_TLS(urcu_mb_reader).registered);
82 tmp = URCU_TLS(urcu_mb_reader).ctr;
97 unsigned long *ctr = &URCU_TLS(urcu_mb_reader).ctr;
116 urcu_assert_debug(URCU_TLS(urcu_mb_reader).registered);
117 tmp = URCU_TLS(urcu_mb_reader).ctr;
132 return URCU_TLS(urcu_mb_reader).ctr & URCU_GP_CTR_NEST_MASK;
urcu-qsbr.h 70 if (caa_unlikely(_CMM_LOAD_SHARED(URCU_TLS(urcu_qsbr_reader).waiting))) {
71 _CMM_STORE_SHARED(URCU_TLS(urcu_qsbr_reader).waiting, 0);
110 urcu_assert_debug(URCU_TLS(urcu_qsbr_reader).ctr);
122 urcu_assert_debug(URCU_TLS(urcu_qsbr_reader).ctr);
134 return URCU_TLS(urcu_qsbr_reader).ctr;
141 * URCU_TLS(urcu_qsbr_reader).ctr, and ensures that mutexes held within an
144 * store to URCU_TLS(urcu_qsbr_reader).ctr.
148 uatomic_store(&URCU_TLS(urcu_qsbr_reader).ctr, gp_ctr, CMM_SEQ_CST);
150 /* write URCU_TLS(urcu_qsbr_reader).ctr before read futex */
171 urcu_assert_debug(URCU_TLS(urcu_qsbr_reader).registered)
    [all...]
urcu-memb.h 83 unsigned long *ctr = &URCU_TLS(urcu_memb_reader).ctr;
113 urcu_assert_debug(URCU_TLS(urcu_memb_reader).registered);
115 tmp = URCU_TLS(urcu_memb_reader).ctr;
130 unsigned long *ctr = &URCU_TLS(urcu_memb_reader).ctr;
152 urcu_assert_debug(URCU_TLS(urcu_memb_reader).registered);
153 tmp = URCU_TLS(urcu_memb_reader).ctr;
168 return URCU_TLS(urcu_memb_reader).ctr & URCU_GP_CTR_NEST_MASK;
urcu-bp.h 138 _CMM_STORE_SHARED(URCU_TLS(urcu_bp_reader)->ctr, _CMM_LOAD_SHARED(urcu_bp_gp.ctr));
141 _CMM_STORE_SHARED(URCU_TLS(urcu_bp_reader)->ctr, tmp + URCU_BP_GP_COUNT);
158 if (caa_unlikely(!URCU_TLS(urcu_bp_reader)))
161 tmp = URCU_TLS(urcu_bp_reader)->ctr;
174 unsigned long *ctr = &URCU_TLS(urcu_bp_reader)->ctr;
176 tmp = URCU_TLS(urcu_bp_reader)->ctr;
194 if (caa_unlikely(!URCU_TLS(urcu_bp_reader)))
196 return URCU_TLS(urcu_bp_reader)->ctr & URCU_BP_GP_CTR_NEST_MASK;
  /src/external/lgpl2/userspace-rcu/dist/tests/common/
debug-yield.h 34 if (rand_r(&URCU_TLS(rcu_rand_yield)) & 0x1)
35 usleep(rand_r(&URCU_TLS(rcu_rand_yield)) % MAX_SLEEP);
41 if (rand_r(&URCU_TLS(rcu_rand_yield)) & 0x1)
42 usleep(rand_r(&URCU_TLS(rcu_rand_yield)) % MAX_SLEEP);
57 URCU_TLS(rcu_rand_yield) = time(NULL) ^ (unsigned long) pthread_self();
  /src/external/lgpl2/userspace-rcu/dist/src/
urcu-defer-impl.h 248 head = URCU_TLS(defer_queue).head;
249 num_items = head - URCU_TLS(defer_queue).tail;
253 rcu_defer_barrier_queue(&URCU_TLS(defer_queue), head);
314 head = URCU_TLS(defer_queue).head;
315 tail = CMM_LOAD_SHARED(URCU_TLS(defer_queue).tail);
324 urcu_posix_assert(head - CMM_LOAD_SHARED(URCU_TLS(defer_queue).tail) == 0);
343 if (caa_unlikely(URCU_TLS(defer_queue).last_fct_in != fct
346 URCU_TLS(defer_queue).last_fct_in = fct;
348 _CMM_STORE_SHARED(URCU_TLS(defer_queue).q[head++ & DEFER_QUEUE_MASK],
350 _CMM_STORE_SHARED(URCU_TLS(defer_queue).q[head++ & DEFER_QUEUE_MASK]
    [all...]
urcu.c 141 if (CMM_LOAD_SHARED(URCU_TLS(rcu_reader).need_mb)) {
143 _CMM_STORE_SHARED(URCU_TLS(rcu_reader).need_mb, 0);
241 * Wait for each thread URCU_TLS(rcu_reader).ctr to either
303 * URCU_TLS(rcu_reader).ctr update to memory if we wait
398 * URCU_TLS(rcu_reader).ctr before store to rcu_gp.ctr.
481 URCU_TLS(rcu_reader).tid = pthread_self();
482 urcu_posix_assert(URCU_TLS(rcu_reader).need_mb == 0);
483 urcu_posix_assert(!(URCU_TLS(rcu_reader).ctr & URCU_GP_CTR_NEST_MASK));
486 urcu_posix_assert(!URCU_TLS(rcu_reader).registered);
487 URCU_TLS(rcu_reader).registered = 1
    [all...]
urcu-qsbr.c 153 * Wait for each thread URCU_TLS(urcu_qsbr_reader).ctr to either
289 * compiler-order of load URCU_TLS(urcu_qsbr_reader).ctr before store
310 * before load URCU_TLS(urcu_qsbr_reader).ctr.
405 * before load URCU_TLS(urcu_qsbr_reader).ctr.
480 URCU_TLS(urcu_qsbr_reader).tid = pthread_self();
481 urcu_posix_assert(URCU_TLS(urcu_qsbr_reader).ctr == 0);
484 urcu_posix_assert(!URCU_TLS(urcu_qsbr_reader).registered);
485 URCU_TLS(urcu_qsbr_reader).registered = 1;
486 cds_list_add(&URCU_TLS(urcu_qsbr_reader).node, &registry);
498 urcu_posix_assert(URCU_TLS(urcu_qsbr_reader).registered)
    [all...]
  /src/external/lgpl2/userspace-rcu/dist/tests/unit/
test_build.c 97 URCU_TLS(my_tls_int) = 1;
98 URCU_TLS(my_tls_struct).int1 = 1;
99 URCU_TLS(my_tls_struct).char1 = 'a';
100 URCU_TLS(my_tls_struct).void1 = NULL;
  /src/external/lgpl2/userspace-rcu/dist/include/urcu/
tls-compat.h 51 * NOTE: URCU_TLS() is NOT async-signal-safe, you can't use it
55 * platform, you can make URCU_TLS() async-signal-safe via:
56 * ensuring the first call to URCU_TLS() of a given TLS variable of
59 * Example: In any thread, the first call of URCU_TLS(rcu_reader)
61 * URCU_TLS(rcu_reader) in any thread is async-signal-safe.
63 * Moreover, URCU_TLS variables should not be touched from signal
76 # define URCU_TLS(name) (name)
86 struct urcu_tls { struct
104 static struct urcu_tls __tls_ ## name = { \
143 # define URCU_TLS(name) URCU_TLS_1(name
    [all...]

Completed in 29 milliseconds

1 2