/freebsd/sys/kern/ |
H A D | subr_epoch.c | 32 #include <sys/epoch.h> 70 struct epoch *er_parent; 80 struct epoch { struct 96 SYSCTL_NODE(_kern, OID_AUTO, epoch, CTLFLAG_RW | CTLFLAG_MPSAFE, 0, argument 97 "epoch information"); 99 "epoch stats"); 105 &block_count, "# of times a thread was in an epoch when epoch_wait was called"); 113 &turnstile_count, "# of times a thread was blocked on a lock in an epoch during an epoch_wait"); 132 static struct epoch epoch_array[MAX_EPOCHS]; 150 epoch_currecord(epoch_t epoch) in epoch_currecord() argument [all …]
|
/freebsd/share/man/man9/ |
H A D | epoch.9 | 31 .Nm epoch , 45 .Nd kernel epoch based reclamation 52 struct epoch; /* Opaque */ 54 .Vt typedef "struct epoch *epoch_t" ; 70 .Fn epoch_free "epoch_t epoch" 72 .Fn epoch_enter "epoch_t epoch" 74 .Fn epoch_exit "epoch_t epoch" 76 .Fn epoch_wait "epoch_t epoch" 78 .Fn epoch_enter_preempt "epoch_t epoch" "epoch_tracker_t et" 80 .Fn epoch_exit_preempt "epoch_t epoch" "epoch_tracker_t et" [all …]
|
/freebsd/sys/contrib/ck/src/ |
H A D | ck_epoch.c | 44 * acquired some snapshot (e) of the global epoch value (e_g) and set an active 66 * causes epoch counter tick) actually deletes the same items that reader 68 * This is possible if the writer thread re-observes the epoch after the 89 * Now, if the epoch counter is ticked to e_g+1, then no new hazardous 91 * this is that at e_g+1, all epoch read-side critical sections started at 92 * e_g-1 must have been completed. If any epoch read-side critical sections at 121 * Blocking semantics for epoch reclamation have additional restrictions. 166 * epoch. If so, then make sure to update our shared snapshot in CK_STACK_CONTAINER() 174 ((int)(current->epoch - other->epoch) < 0)) { in CK_STACK_CONTAINER() 176 * The other epoch value is actually the newest, in CK_STACK_CONTAINER() [all …]
|
/freebsd/sys/sys/ |
H A D | epoch.h | 45 struct epoch; 46 typedef struct epoch *epoch_t; 60 struct epoch *et_epoch; 71 void epoch_free(epoch_t epoch); 72 void epoch_wait(epoch_t epoch); 73 void epoch_wait_preempt(epoch_t epoch); 74 void epoch_drain_callbacks(epoch_t epoch); 75 void epoch_call(epoch_t epoch, epoch_callback_t cb, epoch_context_t ctx); 76 int in_epoch(epoch_t epoch); 77 int in_epoch_verbose(epoch_t epoch, int dump_onfail); [all …]
|
/freebsd/sys/contrib/ck/include/ |
H A D | ck_epoch.h | 48 * epoch sections. 81 unsigned int epoch; member 89 unsigned int epoch; member 103 unsigned int epoch; member 123 * Marks the beginning of an epoch-protected section. 128 struct ck_epoch *epoch = record->global; in ck_epoch_begin() local 131 * Only observe new epoch if thread is not recursing into a read in ck_epoch_begin() 139 * is committed into the caller's epoch and active fields. in ck_epoch_begin() 152 * active flag due to monotonic nature of the global epoch. in ck_epoch_begin() 155 * of global epoch. in ck_epoch_begin() [all …]
|
/freebsd/contrib/llvm-project/compiler-rt/lib/tsan/rtl/ |
H A D | tsan_defs.h | 62 enum class Epoch : u16 {}; enum 64 constexpr Epoch kEpochZero = static_cast<Epoch>(0); 65 constexpr Epoch kEpochOver = static_cast<Epoch>(1 << kEpochBits); 66 constexpr Epoch kEpochLast = static_cast<Epoch>((1 << kEpochBits) - 1); 68 inline Epoch EpochInc(Epoch epoch) { in EpochInc() argument 69 return static_cast<Epoch>(static_cast<u16>(epoch) + 1); in EpochInc() 72 inline bool EpochOverflow(Epoch epoch) { return epoch == kEpochOver; } in EpochOverflow() argument
|
H A D | tsan_shadow.h | 32 Epoch epoch() const { return static_cast<Epoch>(part_.epoch_); } in epoch() function 34 void SetEpoch(Epoch epoch) { part_.epoch_ = static_cast<u16>(epoch); } in SetEpoch() argument 74 DCHECK_EQ(epoch(), epoch0); in Shadow() 81 Epoch epoch() const { return static_cast<Epoch>(part_.epoch_); } in epoch() function 140 static RawShadow FreedInfo(Sid sid, Epoch epoch) { in FreedInfo() argument 143 s.part_.epoch_ = static_cast<u16>(epoch); in FreedInfo()
|
H A D | tsan_vector_clock.h | 24 Epoch Get(Sid sid) const; 25 void Set(Sid sid, Epoch v); 37 VECTOR_ALIGNED Epoch clk_[kThreadSlotCount]; 40 ALWAYS_INLINE Epoch VectorClock::Get(Sid sid) const { in Get() 44 ALWAYS_INLINE void VectorClock::Set(Sid sid, Epoch v) { in Set()
|
H A D | tsan_rtl.cpp | 136 static void DoResetImpl(uptr epoch) { in DoResetImpl() argument 139 CHECK_EQ(ctx->global_epoch, epoch); in DoResetImpl() 233 void DoReset(ThreadState* thr, uptr epoch) SANITIZER_NO_THREAD_SAFETY_ANALYSIS { in DoReset() argument 236 if (UNLIKELY(epoch == 0)) in DoReset() 237 epoch = ctx->global_epoch; in DoReset() 238 if (UNLIKELY(epoch != ctx->global_epoch)) { in DoReset() 239 // Epoch can't change once we've locked the first slot. in DoReset() 245 DPrintf("#%d: DoReset epoch=%lu\n", thr ? thr->tid : -1, epoch); in DoReset() 246 DoResetImpl(epoch); in DoReset() 257 uptr epoch; in FindSlotAndLock() local [all …]
|
H A D | tsan_rtl_report.cpp | 352 // or up to the provided epoch/sid (whichever is earlier) 356 Epoch epoch, Func f) { in TraceReplay() argument 359 Epoch ev_epoch = kEpochOver; in TraceReplay() 376 ev_epoch = static_cast<Epoch>(ev->epoch); in TraceReplay() 377 if (ev_sid == sid && ev_epoch > epoch) in TraceReplay() 429 // by epoch/addr/size/typ and restores and returns tid, stack, mutex set 432 bool RestoreStack(EventType type, Sid sid, Epoch epoch, uptr addr, uptr size, in RestoreStack() argument 435 // This function restores stack trace and mutex set for the thread/epoch. in RestoreStack() 437 // trace part, and then replaying the trace till the given epoch. in RestoreStack() 439 static_cast<int>(sid), static_cast<int>(epoch), addr, size, in RestoreStack() [all …]
|
H A D | tsan_rtl.h | 136 Epoch epoch; member 147 Epoch epoch() const { in epoch() function 148 return static_cast<Epoch>(atomic_load(&raw_epoch, memory_order_relaxed)); in epoch() 151 void SetEpoch(Epoch v) { in SetEpoch() 330 // If this happens, previous access sid+epoch will be the same for all of 331 // these false races b/c if the thread will try to increment epoch, it will 333 // values. So, last_spurious_race is used to remember the last sid+epoch 335 // races with the same sid+epoch very early and quickly. 340 // would be to hold an array of such sid+epoch, but we consider such scenario 343 // 1. When a legit access with the same sid+epoch participates in a race [all …]
|
/freebsd/sys/contrib/openzfs/scripts/ |
H A D | kmodtool | 81 Requires: ${kmodname}-kmod-common >= %{?epoch:%{epoch}:}%{version} 82 Provides: ${kmodname}-kmod = %{?epoch:%{epoch}:}%{version}-%{release} 107 Provides: ${kmodname}-kmod = %{?epoch:%{epoch}:}%{version}-%{release} 108 Provides: kmod-${kmodname}-xen = %{?epoch:%{epoch}:}%{version}-%{release} 109 Provides: kmod-${kmodname}-smp = %{?epoch:%{epoch}:}%{version}-%{release} 110 Provides: kmod-${kmodname}-PAE = %{?epoch:%{epoch}:}%{version}-%{release} 111 Requires: akmod-${kmodname} = %{?epoch:%{epoch}:}%{version}-%{release} 153 Provides: ${kmodname}-kmod = %{?epoch:%{epoch}:}%{version}-%{release} 154 Requires: ${kmodname}-kmod-common >= %{?epoch:%{epoch}:}%{version} 230 Provides: ${kmodname}-devel-kmod = %{?epoch:%{epoch}:}%{version}-%{release} [all …]
|
/freebsd/contrib/jemalloc/include/jemalloc/internal/ |
H A D | arena_structs_b.h | 35 * not actually advance to a new epoch until sometime after it starts 37 * to completely skip epochs. In all cases, during epoch advancement we 38 * merge all relevant activity into the most recently recorded epoch. 40 nstime_t epoch; member 44 * Deadline for current epoch. This is the sum of interval and per 45 * epoch jitter which is a uniform random variable in [0..interval). 52 * Number of unpurged pages at beginning of current epoch. During epoch 61 * element is the most recent epoch. Corresponding epoch times are 62 * relative to epoch.
|
/freebsd/usr.sbin/pw/tests/ |
H A D | pw_useradd_test.sh | 75 # Test add user with account expiration as an epoch date 92 EPOCH=`date -j -f "%d-%m-%Y %H:%M:%S" "${DATE} 00:00:00" "+%s"` 94 atf_check -s exit:0 -o match:"^test:\*:.*::0:${EPOCH}:User &:.*" \ 104 EPOCH=`date -j -f "%d-%b-%Y %H:%M:%S" "${DATE} 00:00:00" "+%s"` 106 atf_check -s exit:0 -o match:"^test:\*:.*::0:${EPOCH}:User &:.*" \ 115 EPOCH=`date -j -v+13m "+%s"` 116 BUF=`expr $EPOCH + 5` 119 [ ! -z $TIME -a $TIME -ge $EPOCH -a $TIME -lt $BUF ] || \ 120 atf_fail "Expiration time($TIME) was not within $EPOCH - $BUF seconds." 123 # Test add user with password expiration as an epoch date [all …]
|
/freebsd/sys/tests/epoch/ |
H A D | epoch_test.c | 31 #include <sys/epoch.h> 55 MTX_SYSINIT(state_mtx, &state_mtx, "epoch state mutex", MTX_DEF); 57 MTX_SYSINIT(mutexA, &mutexA, "epoch mutexA", MTX_DEF); 59 MTX_SYSINIT(mutexB, &mutexB, "epoch mutexB", MTX_DEF); 117 msleep(&state_mtx, &state_mtx, 0, "epoch start wait", 0); in testloop() 186 "Epoch Test Framework"); 190 "Execute an epoch test"); 208 pause("epoch unload", 3*hz); in epoch_test_module_event_handler()
|
/freebsd/contrib/llvm-project/llvm/include/llvm/ADT/ |
H A D | EpochTracker.h | 1 //===- llvm/ADT/EpochTracker.h - ADT epoch tracking --------------*- C++ -*-==// 38 uint64_t Epoch = 0; variable 45 void incrementEpoch() { ++Epoch; } in incrementEpoch() 67 : EpochAddress(&Parent->Epoch), EpochAtCreation(Parent->Epoch) {} in HandleBase() 74 /// Returns a pointer to the epoch word stored in the data structure
|
/freebsd/contrib/ntp/ntpd/ |
H A D | refclock_wwv.c | 84 #define WWV_SEC 8000 /* second epoch (sample rate) (Hz) */ 85 #define WWV_MIN (WWV_SEC * 60) /* minute epoch */ 133 #define MSYNC 0x0001 /* minute epoch sync */ 134 #define SSYNC 0x0002 /* second epoch sync */ 481 double epoch; /* accumulated epoch differences */ member 486 long mepoch; /* minute synch epoch */ 536 int yepoch; /* sync epoch */ 537 int repoch; /* buffered sync epoch */ 896 * quadrature phase. The routine also determines the minute synch epoch, 972 int epoch; /* comb filter index */ wwv_rf() local 1304 long epoch; wwv_qrz() local [all...] |
/freebsd/contrib/ntp/scripts/monitoring/ |
H A D | timelocal.pl | 27 @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];
|
/freebsd/usr.bin/calendar/ |
H A D | pom.c | 57 #define EPOCH 85 macro 58 #define EPSILONg 279.611371 /* solar ecliptic long at EPOCH */ 59 #define RHOg 282.680403 /* solar ecliptic long of perigee at EPOCH */ 61 #define lzero 18.251907 /* lunar mean long at EPOCH */ 62 #define Pzero 192.917585 /* lunar mean long of perigee at EPOCH */ 63 #define Nzero 55.204723 /* lunar mean long of node at EPOCH */ 125 for (cnt = EPOCH; cnt < GMT.tm_year; ++cnt) in fpom() 135 for (cnt = EPOCH; cnt < GMT.tm_year; ++cnt) in fpom()
|
/freebsd/usr.bin/pom/ |
H A D | pom.c | 58 #define EPOCH 85 macro 59 #define EPSILONg 279.611371 /* solar ecliptic long at EPOCH */ 60 #define RHOg 282.680403 /* solar ecliptic long of perigee at EPOCH */ 62 #define lzero 18.251907 /* lunar mean long at EPOCH */ 63 #define Pzero 192.917585 /* lunar mean long of perigee at EPOCH */ 64 #define Nzero 55.204723 /* lunar mean long of node at EPOCH */ 138 for (cnt = EPOCH; cnt < GMT.tm_year; ++cnt) in main()
|
/freebsd/contrib/llvm-project/compiler-rt/lib/fuzzer/ |
H A D | FuzzerIOPosix.cpp | 55 void ListFilesInDirRecursive(const std::string &Dir, long *Epoch, in ListFilesInDirRecursive() argument 58 if (Epoch) in ListFilesInDirRecursive() 59 if (E && *Epoch >= E) return; in ListFilesInDirRecursive() 74 ListFilesInDirRecursive(Path, Epoch, V, false); in ListFilesInDirRecursive() 77 if (Epoch && TopDir) in ListFilesInDirRecursive() 78 *Epoch = E; in ListFilesInDirRecursive()
|
/freebsd/contrib/unbound/sldns/ |
H A D | parseutil.h | 50 * Convert TM to seconds since epoch (midnight, January 1st, 1970). 53 * \return the seconds since epoch 58 * The function interprets time as the number of seconds since epoch 64 * \param[in] time number of seconds since epoch (midnight, January 1st, 1970) 66 * \param[in] now number of seconds since epoch (midnight, January 1st, 1970)
|
/freebsd/crypto/openssl/ssl/record/ |
H A D | rec_layer_d1.c | 222 * retrieve a buffered record that belongs to the new epoch, i.e., not 240 /* Check if epoch is current. */ in dtls1_process_buffered_records() 241 if (s->rlayer.d->unprocessed_rcds.epoch != s->rlayer.d->r_epoch) in dtls1_process_buffered_records() 251 * be a record from the new epoch in it - so don't overwrite it in dtls1_process_buffered_records() 265 * current record is from a different epoch. But that cannot in dtls1_process_buffered_records() 266 * be the case because we already checked the epoch above in dtls1_process_buffered_records() 305 * sync epoch numbers once all the unprocessed records have been in dtls1_process_buffered_records() 308 s->rlayer.d->processed_rcds.epoch = s->rlayer.d->r_epoch; in dtls1_process_buffered_records() 309 s->rlayer.d->unprocessed_rcds.epoch = s->rlayer.d->r_epoch + 1; in dtls1_process_buffered_records() 868 /* field where we are to write out packet epoch, seq num and len */ in do_dtls1_write() [all …]
|
/freebsd/crypto/openssl/test/helpers/ |
H A D | ssltestlib.c | 129 int rem, i, content, reclen, msglen, fragoff, fraglen, epoch; in dump_data() 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; 360 unsigned int seq, offset, len, epoch; in mempacket_test_read() 386 epoch = (rec[EPOCH_HI] << 8) | rec[EPOCH_LO]; in mempacket_test_read() 387 if (epoch != ctx->epoch) { in mempacket_test_read() 120 int rem, i, content, reclen, msglen, fragoff, fraglen, epoch; dump_data() local 267 unsigned int epoch; global() member 351 unsigned int seq, offset, len, epoch; mempacket_test_read() local 424 unsigned int epoch; mempacket_swap_epoch() local [all...] |
/freebsd/sbin/routed/ |
H A D | main.c | 57 struct timeval epoch; /* when started */ variable 68 EPOCH+SUPPLY_INTERVAL, 0 113 epoch = clk; in main() 114 epoch.tv_sec -= EPOCH; in main() 115 now.tv_sec = EPOCH; in main() 116 now_stale = EPOCH - STALE_TIME; in main() 117 now_expire = EPOCH - EXPIRE_TIME; in main() 118 now_garbage = EPOCH - GARBAGE_TIME; in main() 316 intvl_random(&next_bcast, EPOCH+MIN_WAITTIME, EPOCH+SUPPLY_INTERVAL); in main() 318 age_timer.tv_sec = EPOCH+MIN_WAITTIME; in main() [all …]
|