Home
last modified time | relevance | path

Searched refs:epoch (Results 1 – 25 of 145) sorted by relevance

123456

/netbsd-src/external/bsd/openldap/dist/servers/lloadd/
H A Depoch.c43 #define EPOCH_PREV(epoch) ( ( (epoch) + EPOCH_MASK - 1 ) % EPOCH_MASK ) argument
44 #define EPOCH_NEXT(epoch) ( ( (epoch) + 1 ) % EPOCH_MASK ) argument
61 epoch_t epoch; in epoch_init() local
64 for ( epoch = 0; epoch < EPOCH_MASK; epoch++ ) { in epoch_init()
65 assert( !epoch_threads[epoch] ); in epoch_init()
66 assert( !references[epoch] ); in epoch_init()
75 epoch_t epoch; in epoch_shutdown() local
78 for ( epoch = 0; epoch < EPOCH_MASK; epoch++ ) { in epoch_shutdown()
79 assert( !epoch_threads[epoch] ); in epoch_shutdown()
86 epoch = EPOCH_PREV(current_epoch); in epoch_shutdown()
[all …]
H A Dconnection.c78 epoch_t epoch; in handle_pdus() local
83 epoch = epoch_join(); in handle_pdus()
146 epoch_leave( epoch ); in handle_pdus()
147 epoch = epoch_join(); in handle_pdus()
165 epoch_leave( epoch ); in handle_pdus()
183 epoch_t epoch; in connection_read_cb() local
199 epoch = epoch_join(); in connection_read_cb()
201 epoch_leave( epoch ); in connection_read_cb()
208 epoch = epoch_join(); in connection_read_cb()
295 epoch_leave( epoch ); in connection_read_cb()
[all …]
H A Dbackend.c41 epoch_t epoch; in upstream_connect_cb() local
53 epoch = epoch_join(); in upstream_connect_cb()
64 epoch_leave( epoch ); in upstream_connect_cb()
75 epoch_leave( epoch ); in upstream_connect_cb()
107 epoch_t epoch; in upstream_name_cb() local
126 epoch = epoch_join(); in upstream_name_cb()
275 epoch_leave( epoch ); in upstream_name_cb()
289 epoch_leave( epoch ); in upstream_name_cb()
466 epoch_t epoch; in backend_connect() local
483 epoch = epoch_join(); in backend_connect()
[all …]
/netbsd-src/external/gpl3/gcc/dist/libsanitizer/tsan/
H A Dtsan_clock.cpp144 if (clk_[tid] < dirty.epoch) { in acquire()
145 clk_[tid] = dirty.epoch; in acquire()
157 u64 epoch = src_elem.epoch; in acquire() local
158 if (*dst_pos < epoch) { in acquire()
159 *dst_pos = epoch; in acquire()
201 if (clk_[i] < ce.epoch) { in releaseStoreAcquire()
202 clk_[i] = ce.epoch; in releaseStoreAcquire()
205 ce.epoch = tmp; in releaseStoreAcquire()
252 ce.epoch = max(ce.epoch, clk_[i]); in release()
285 dst->dirty_[0].epoch = clk_[tid_]; in ReleaseStore()
[all …]
H A Dtsan_mutexset.cpp22 void MutexSet::Add(u64 id, bool write, u64 epoch) { in Add() argument
27 descs_[i].epoch = epoch; in Add()
36 if (descs_[i].epoch < minepoch) { in Add()
37 minepoch = descs_[i].epoch; in Add()
49 descs_[size_].epoch = epoch; in Add()
98 descs_[size_].epoch = 0; in AddAddr()
H A Dtsan_shadow.h25 FastState(u64 tid, u64 epoch) { in FastState() argument
27 x_ |= epoch; in FastState()
29 DCHECK_EQ(epoch, this->epoch()); in FastState()
47 u64 epoch() const { in epoch() function
53 u64 old_epoch = epoch(); in IncrementEpoch()
55 DCHECK_EQ(old_epoch + 1, epoch()); in IncrementEpoch()
81 return epoch() & mask; in GetTracePos()
H A Dtsan_rtl_mutex.cpp120 RestoreStack(last.tid(), last.epoch(), &trace, 0); in MutexDestroy()
193 thr->mset.Add(s->GetId(), true, thr->fast_state.epoch()); in MutexPostLock()
291 thr->mset.Add(s->GetId(), false, thr->fast_state.epoch()); in MutexPostReadLock()
417 u64 epoch = tctx->epoch1; in UpdateClockCallback() local
419 epoch = tctx->thr->fast_state.epoch(); in UpdateClockCallback()
420 tctx->thr->clock.NoteGlobalAcquire(epoch); in UpdateClockCallback()
422 thr->clock.set(&thr->proc()->clock_cache, tctx->tid, epoch); in UpdateClockCallback()
473 u64 epoch = tctx->epoch1; in UpdateSleepClockCallback() local
475 epoch = tctx->thr->fast_state.epoch(); in UpdateSleepClockCallback()
476 thr->last_sleep_clock.set(&thr->proc()->clock_cache, tctx->tid, epoch); in UpdateSleepClockCallback()
[all …]
H A Dtsan_rtl_report.cpp390 void RestoreStack(Tid tid, const u64 epoch, VarSizeStackTrace *stk, in RestoreStack() argument
397 const int partidx = (epoch / kTracePartSize) % TraceParts(); in RestoreStack()
399 if (epoch < hdr->epoch0 || epoch >= hdr->epoch0 + kTracePartSize) in RestoreStack()
401 CHECK_EQ(RoundDown(epoch, kTracePartSize), hdr->epoch0); in RestoreStack()
402 const u64 epoch0 = RoundDown(epoch, TraceSize()); in RestoreStack()
403 const u64 eend = epoch % TraceSize(); in RestoreStack()
406 tid, (uptr)epoch, (uptr)ebegin, (uptr)eend, partidx); in RestoreStack()
460 Epoch epoch, Func f) { in TraceReplay() argument
479 ev_epoch = static_cast<Epoch>(ev->epoch); in TraceReplay()
480 if (ev_sid == sid && ev_epoch > epoch) in TraceReplay()
[all …]
H A Dtsan_mutexset.h29 u64 epoch; member
44 void Add(u64 id, bool write, u64 epoch);
85 void MutexSet::Add(u64 id, bool write, u64 epoch) {} in Add() argument
/netbsd-src/sys/external/bsd/compiler_rt/dist/lib/tsan/rtl/
H A Dtsan_clock.cc147 if (clk_[tid] < dirty.epoch) { in acquire()
148 clk_[tid] = dirty.epoch; in acquire()
161 u64 epoch = src_elem.epoch; in acquire() local
162 if (*dst_pos < epoch) { in acquire()
163 *dst_pos = epoch; in acquire()
200 if (dst->elem(tid_).epoch > last_acquire_) { in release()
219 ce.epoch = max(ce.epoch, clk_[i]); in release()
257 dst->dirty_[0].epoch = clk_[tid_]; in ReleaseStore()
273 dst->elem(tid_).epoch > last_acquire_) { in ReleaseStore()
286 ce.epoch = clk_[i]; in ReleaseStore()
[all …]
H A Dtsan_mutexset.cc25 void MutexSet::Add(u64 id, bool write, u64 epoch) { in Add() argument
30 descs_[i].epoch = epoch; in Add()
39 if (descs_[i].epoch < minepoch) { in Add()
40 minepoch = descs_[i].epoch; in Add()
50 descs_[size_].epoch = epoch; in Add()
H A Dtsan_rtl_mutex.cc119 RestoreStack(last.tid(), last.epoch(), &trace, 0); in MutexDestroy()
192 thr->mset.Add(s->GetId(), true, thr->fast_state.epoch()); in MutexPostLock()
287 thr->mset.Add(s->GetId(), false, thr->fast_state.epoch()); in MutexPostReadLock()
418 u64 epoch = tctx->epoch1; in UpdateClockCallback() local
420 epoch = tctx->thr->fast_state.epoch(); in UpdateClockCallback()
421 thr->clock.set(&thr->proc()->clock_cache, tctx->tid, epoch); in UpdateClockCallback()
461 u64 epoch = tctx->epoch1; in UpdateSleepClockCallback() local
463 epoch = tctx->thr->fast_state.epoch(); in UpdateSleepClockCallback()
464 thr->last_sleep_clock.set(&thr->proc()->clock_cache, tctx->tid, epoch); in UpdateSleepClockCallback()
481 thr->clock.set(thr->fast_state.epoch()); in AcquireImpl()
[all …]
H A Dtsan_mutexset.h28 u64 epoch; member
35 void Add(u64 id, bool write, u64 epoch);
60 void MutexSet::Add(u64 id, bool write, u64 epoch) {} in Add() argument
/netbsd-src/external/gpl3/gcc.old/dist/libsanitizer/tsan/
H A Dtsan_clock.cc145 if (clk_[tid] < dirty.epoch) { in acquire()
146 clk_[tid] = dirty.epoch; in acquire()
159 u64 epoch = src_elem.epoch; in acquire() local
160 if (*dst_pos < epoch) { in acquire()
161 *dst_pos = epoch; in acquire()
198 if (dst->elem(tid_).epoch > last_acquire_) { in release()
217 ce.epoch = max(ce.epoch, clk_[i]); in release()
255 dst->dirty_[0].epoch = clk_[tid_]; in ReleaseStore()
271 dst->elem(tid_).epoch > last_acquire_) { in ReleaseStore()
284 ce.epoch = clk_[i]; in ReleaseStore()
[all …]
H A Dtsan_mutexset.cc23 void MutexSet::Add(u64 id, bool write, u64 epoch) { in Add() argument
28 descs_[i].epoch = epoch; in Add()
37 if (descs_[i].epoch < minepoch) { in Add()
38 minepoch = descs_[i].epoch; in Add()
48 descs_[size_].epoch = epoch; in Add()
H A Dtsan_rtl_mutex.cc117 RestoreStack(last.tid(), last.epoch(), &trace, 0); in MutexDestroy()
190 thr->mset.Add(s->GetId(), true, thr->fast_state.epoch()); in MutexPostLock()
285 thr->mset.Add(s->GetId(), false, thr->fast_state.epoch()); in MutexPostReadLock()
416 u64 epoch = tctx->epoch1; in UpdateClockCallback() local
418 epoch = tctx->thr->fast_state.epoch(); in UpdateClockCallback()
419 thr->clock.set(&thr->proc()->clock_cache, tctx->tid, epoch); in UpdateClockCallback()
459 u64 epoch = tctx->epoch1; in UpdateSleepClockCallback() local
461 epoch = tctx->thr->fast_state.epoch(); in UpdateSleepClockCallback()
462 thr->last_sleep_clock.set(&thr->proc()->clock_cache, tctx->tid, epoch); in UpdateSleepClockCallback()
479 thr->clock.set(thr->fast_state.epoch()); in AcquireImpl()
[all …]
H A Dtsan_mutexset.h26 u64 epoch; member
33 void Add(u64 id, bool write, u64 epoch);
58 void MutexSet::Add(u64 id, bool write, u64 epoch) {} in Add() argument
/netbsd-src/sys/crypto/cprng_fast/
H A Dcprng_fast.c58 unsigned epoch;
90 cprng->epoch = entropy_epoch(); in cprng_fast_init_cpu()
111 if (__predict_false(cprng->epoch != entropy_epoch())) in cprng_fast_get()
137 unsigned epoch = entropy_epoch(); in cprng_fast_reseed()
147 cprng->epoch = epoch; in cprng_fast_reseed()
57 unsigned epoch; global() member
96 unsigned epoch; cprng_fast_get() local
126 cprng_fast_reseed(struct cprng_fast ** cprngp,unsigned epoch) cprng_fast_reseed() argument
/netbsd-src/sys/external/bsd/drm2/dist/drm/i915/
H A Di915_globals.c28 static atomic_t epoch; variable
34 int epoch; member
58 park.epoch = atomic_inc_return(&epoch); in __i915_globals_queue_rcu()
70 if (park.epoch != atomic_read(&epoch)) { in __i915_globals_park()
145 atomic_inc(&epoch); in i915_globals_unpark()
/netbsd-src/sys/external/bsd/common/linux/
H A Dlinux_srcu.c135 unsigned epoch = gen & 1; /* active epoch */ in srcu_adjust() local
138 cpu->src_count[epoch] += delta; in srcu_adjust()
240 unsigned gen, epoch; in synchronize_srcu_xc() local
247 epoch = 1 ^ (gen & 1); /* draining epoch */ in synchronize_srcu_xc()
251 local = cpu->src_count[epoch]; in synchronize_srcu_xc()
253 cpu->src_count[epoch] -= local; /* i.e., cpu->src_count[epoch] = 0 */ in synchronize_srcu_xc()
254 KASSERT(cpu->src_count[epoch] == 0); in synchronize_srcu_xc()
/netbsd-src/external/bsd/ntp/dist/scripts/monitoring/
H A Dtimelocal.pl27 @epoch = localtime(0);
28 $tzmin = $epoch[2] * 60 + $epoch[1]; # minutes east of GMT
31 $tzmin -= 24 * 60 if $epoch[5] == 70; # account for the date line
65 $year += $YearFix if $year < $epoch[5];
/netbsd-src/sys/kern/
H A Dsubr_cprng.c269 cprng_strong_reseed(struct cprng_strong *cprng, unsigned epoch, in cprng_strong_reseed() argument
295 (*ccp)->cc_epoch = epoch; in cprng_strong_reseed()
302 unsigned epoch; in cprng_strong() local
324 epoch = entropy_epoch(); in cprng_strong()
325 if (__predict_false(epoch != cc->cc_epoch)) in cprng_strong()
326 cprng_strong_reseed(cprng, epoch, &cc, &s); in cprng_strong()
331 cprng_strong_reseed(cprng, epoch, &cc, &s); in cprng_strong()
/netbsd-src/crypto/external/bsd/openssl/dist/test/helpers/
H A Dssltestlib.c129 int rem, i, content, reclen, msglen, fragoff, fraglen, epoch; in dump_data() local
149 epoch = (rec[RECORD_EPOCH_HI] << 8) | rec[RECORD_EPOCH_LO]; in dump_data()
150 printf("** Record Epoch: %d\n", epoch); in dump_data()
162 if (epoch > 0) { in dump_data()
276 unsigned int epoch; member
360 unsigned int seq, offset, len, epoch; in mempacket_test_read() local
386 epoch = (rec[EPOCH_HI] << 8) | rec[EPOCH_LO]; in mempacket_test_read()
387 if (epoch != ctx->epoch) { in mempacket_test_read()
388 ctx->epoch = epoch; in mempacket_test_read()
403 if (ctx->droprec == (int)ctx->currrec && ctx->dropepoch == epoch) { in mempacket_test_read()
[all …]
/netbsd-src/crypto/external/bsd/openssl.old/dist/test/
H A Dssltestlib.c144 int rem, i, content, reclen, msglen, fragoff, fraglen, epoch; in dump_data() local
164 epoch = (rec[RECORD_EPOCH_HI] << 8) | rec[RECORD_EPOCH_LO]; in dump_data()
165 printf("** Record Epoch: %d\n", epoch); in dump_data()
177 if (epoch > 0) { in dump_data()
291 unsigned int epoch; member
375 unsigned int seq, offset, len, epoch; in mempacket_test_read() local
401 epoch = (rec[EPOCH_HI] << 8) | rec[EPOCH_LO]; in mempacket_test_read()
402 if (epoch != ctx->epoch) { in mempacket_test_read()
403 ctx->epoch = epoch; in mempacket_test_read()
418 if (ctx->droprec == (int)ctx->currrec && ctx->dropepoch == epoch) { in mempacket_test_read()
/netbsd-src/sys/external/bsd/compiler_rt/dist/lib/tsan/tests/unit/
H A Dtsan_shadow_test.cc22 EXPECT_EQ(s.epoch(), (u64)22); in TEST()
31 EXPECT_EQ(s.epoch(), (u64)23); in TEST()
33 EXPECT_EQ(s.epoch(), (u64)24); in TEST()

123456