Home
last modified time | relevance | path

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

12345678910>>...12

/external/compiler-rt/lib/tsan/rtl/
Dtsan_clock.cc125 u64 epoch = src->elem(tid).epoch; in acquire() local
126 if (clk_[tid].epoch < epoch) { in acquire()
127 clk_[tid].epoch = epoch; in acquire()
134 last_acquire_ = clk_[tid_].epoch; in acquire()
144 u64 epoch = src->elem(i).epoch; in acquire() local
145 if (clk_[i].epoch < epoch) { in acquire()
146 clk_[i].epoch = epoch; in acquire()
157 last_acquire_ = clk_[tid_].epoch; in acquire()
180 if (dst->elem(tid_).epoch > last_acquire_) { in release()
197 ce.epoch = max(ce.epoch, clk_[i].epoch); in release()
[all …]
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()
Dtsan_clock.h22 u64 epoch : kClkBits; member
54 return elem(tid).epoch; in get()
89 return clk_[tid].epoch; in get()
95 DCHECK_GE(v, clk_[tid_].epoch); in set()
96 clk_[tid_].epoch = v; in set()
100 clk_[tid_].epoch++; in tick()
/external/skqp/src/compute/skc/
Dweakref.c48 skc_ulong epoch : 64 - SKC_WEAKREF_INDEX_BITS; member
60 skc_weakref_epoch_init(skc_epoch_t * const epoch) in skc_weakref_epoch_init() argument
62 *epoch = SKC_WEAKREF_EPOCH_INIT; in skc_weakref_epoch_init()
66 skc_weakref_epoch_inc(skc_epoch_t * const epoch) in skc_weakref_epoch_inc() argument
68 *epoch += SKC_WEAKREF_EPOCH_ONE; in skc_weakref_epoch_inc()
73 skc_epoch_t * const epoch, in skc_weakref_init() argument
76 *weakref = *epoch | (index & SKC_WEAKREF_INDEX_MASK); in skc_weakref_init()
81 skc_epoch_t const * const epoch) in skc_weakref_is_invalid() argument
83 return ((*weakref ^ *epoch) & SKC_WEAKREF_EPOCH_MASK) != 0UL; in skc_weakref_is_invalid()
Dweakref.h29 skc_weakref_epoch_init(skc_epoch_t * const epoch);
32 skc_weakref_epoch_inc(skc_epoch_t * const epoch);
36 skc_epoch_t * const epoch,
41 skc_epoch_t const * const epoch);
/external/rust/crates/quiche/src/recovery/
Dmod.rs197 &mut self, mut pkt: Sent, epoch: packet::Epoch, in on_packet_sent()
207 self.largest_sent_pkt[epoch] = in on_packet_sent()
208 cmp::max(self.largest_sent_pkt[epoch], pkt_num); in on_packet_sent()
210 self.sent[epoch].push_back(pkt); in on_packet_sent()
214 self.time_of_last_sent_ack_eliciting_pkt[epoch] = Some(now); in on_packet_sent()
217 self.in_flight_count[epoch] += 1; in on_packet_sent()
229 epoch == packet::EPOCH_APPLICATION && in on_packet_sent()
244 epoch: packet::Epoch, handshake_status: HandshakeStatus, now: Instant, in on_ack_received()
252 if largest_acked > self.largest_sent_pkt[epoch] { in on_ack_received()
260 if self.largest_acked_pkt[epoch] == std::u64::MAX { in on_ack_received()
[all …]
/external/jemalloc_new/test/unit/
Dstats.c30 uint64_t epoch; in TEST_BEGIN() local
39 assert_d_eq(mallctl("epoch", NULL, NULL, (void *)&epoch, sizeof(epoch)), in TEST_BEGIN()
70 uint64_t epoch; in TEST_BEGIN() local
90 assert_d_eq(mallctl("epoch", NULL, NULL, (void *)&epoch, sizeof(epoch)), in TEST_BEGIN()
146 uint64_t epoch, nmalloc, ndalloc, nrequests; in TEST_BEGIN() local
157 assert_d_eq(mallctl("epoch", NULL, NULL, (void *)&epoch, sizeof(epoch)), in TEST_BEGIN()
191 uint64_t epoch, nmalloc, ndalloc; in TEST_BEGIN() local
197 assert_d_eq(mallctl("epoch", NULL, NULL, (void *)&epoch, sizeof(epoch)), in TEST_BEGIN()
231 uint64_t epoch, nmalloc, ndalloc, nrequests, nfills, nflushes; in TEST_BEGIN() local
254 assert_d_eq(mallctl("epoch", NULL, NULL, (void *)&epoch, sizeof(epoch)), in TEST_BEGIN()
[all …]
Dretained.c10 static atomic_u_t epoch; variable
38 uint64_t epoch = 1; in do_refresh() local
39 assert_d_eq(mallctl("epoch", NULL, NULL, (void *)&epoch, in do_refresh()
40 sizeof(epoch)), 0, "Unexpected mallctl() failure"); in do_refresh()
75 while ((cur_epoch = atomic_load_u(&epoch, ATOMIC_ACQUIRE)) != in thd_start()
107 atomic_store_u(&epoch, 0, ATOMIC_RELAXED); in TEST_BEGIN()
117 atomic_store_u(&epoch, e, ATOMIC_RELEASE); in TEST_BEGIN()
Dmallctl.c6 uint64_t epoch; in TEST_BEGIN() local
16 assert_d_eq(mallctl("epoch", NULL, NULL, (void *)&epoch, in TEST_BEGIN()
17 sizeof(epoch)-1), EINVAL, in TEST_BEGIN()
19 assert_d_eq(mallctl("epoch", NULL, NULL, (void *)&epoch, in TEST_BEGIN()
20 sizeof(epoch)+1), EINVAL, in TEST_BEGIN()
23 sz = sizeof(epoch)-1; in TEST_BEGIN()
24 assert_d_eq(mallctl("epoch", (void *)&epoch, &sz, NULL, 0), EINVAL, in TEST_BEGIN()
26 sz = sizeof(epoch)+1; in TEST_BEGIN()
27 assert_d_eq(mallctl("epoch", (void *)&epoch, &sz, NULL, 0), EINVAL, in TEST_BEGIN()
43 uint64_t epoch; in TEST_BEGIN() local
[all …]
/external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/
DEventCount.h68 w->epoch = state_.fetch_add(kWaiterInc, std::memory_order_relaxed); in Prewait()
76 uint64_t epoch = in CommitWait() local
77 (w->epoch & kEpochMask) + in CommitWait()
78 (((w->epoch & kWaiterMask) >> kWaiterShift) << kEpochShift); in CommitWait()
81 if (int64_t((state & kEpochMask) - epoch) < 0) { in CommitWait()
89 if (int64_t((state & kEpochMask) - epoch) > 0) return; in CommitWait()
107 uint64_t epoch = in CancelWait() local
108 (w->epoch & kEpochMask) + in CancelWait()
109 (((w->epoch & kWaiterMask) >> kWaiterShift) << kEpochShift); in CancelWait()
112 if (int64_t((state & kEpochMask) - epoch) < 0) { in CancelWait()
[all …]
/external/perfetto/src/trace_processor/metrics/experimental/
Dblink_gc_metric.sql78 thread.upid || ':' || EXTRACT_ARG(arg_set_id, 'debug.epoch') AS epoch,
111 epoch, field
437 GROUP BY epoch
452 GROUP BY epoch
467 GROUP BY epoch
482 GROUP BY epoch
497 GROUP BY epoch
512 GROUP BY epoch
527 GROUP BY epoch
542 GROUP BY epoch
[all …]
/external/rust/crates/crossbeam-epoch/src/
Dinternal.rs52 use crate::epoch::{AtomicEpoch, Epoch};
103 fn seal(self, epoch: Epoch) -> SealedBag { in seal()
104 SealedBag { epoch, bag: self } in seal()
218 epoch: Epoch, field
230 global_epoch.wrapping_sub(self.epoch) >= 2 in is_expired()
243 pub(crate) epoch: CachePadded<AtomicEpoch>, field
256 epoch: CachePadded::new(AtomicEpoch::new(Epoch::starting())), in new()
266 let epoch = self.epoch.load(Ordering::Relaxed); in push_bag() localVariable
267 self.queue.push(bag.seal(epoch), guard); in push_bag()
308 let global_epoch = self.epoch.load(Ordering::Relaxed); in try_advance()
[all …]
/external/llvm-project/compiler-rt/lib/tsan/rtl/
Dtsan_clock.cpp155 if (clk_[tid] < dirty.epoch) { in acquire()
156 clk_[tid] = dirty.epoch; in acquire()
169 u64 epoch = src_elem.epoch; in acquire() local
170 if (*dst_pos < epoch) { in acquire()
171 *dst_pos = epoch; in acquire()
214 if (clk_[i] < ce.epoch) { in releaseStoreAcquire()
215 clk_[i] = ce.epoch; in releaseStoreAcquire()
218 ce.epoch = tmp; in releaseStoreAcquire()
270 ce.epoch = max(ce.epoch, clk_[i]); in release()
306 dst->dirty_[0].epoch = clk_[tid_]; in ReleaseStore()
[all …]
Dtsan_mutexset.cpp24 void MutexSet::Add(u64 id, bool write, u64 epoch) { in Add() argument
29 descs_[i].epoch = epoch; in Add()
38 if (descs_[i].epoch < minepoch) { in Add()
39 minepoch = descs_[i].epoch; in Add()
49 descs_[size_].epoch = epoch; in Add()
/external/llvm/unittests/Support/
DTimeValueTest.cpp26 sys::TimeValue epoch; in TEST() local
30 epoch.fromWin32Time(ft1970); in TEST()
33 EXPECT_EQ(0u, epoch.toEpochTime()); in TEST()
34 EXPECT_EQ(ns, static_cast<uint32_t>(epoch.nanoseconds())); in TEST()
37 EXPECT_EQ(ft1970, epoch.toWin32Time()); in TEST()
/external/rust/crates/crossbeam-deque/
DCHANGELOG.md14 - Bump `crossbeam-epoch` to `0.8`.
33 - Bump `crossbeam-epoch` to `0.7`.
68 - Update `crossbeam-epoch` to `0.5.0`.
72 - Update `crossbeam-epoch` to `0.4.2`.
81 - Update `crossbeam-epoch` to `0.3.0`.
87 - Update `crossbeam-epoch` to `0.4.0`.
92 - Update `crossbeam-epoch` to `0.3.0`.
97 - Update `crossbeam-epoch` to `0.2.0`.
/external/tensorflow/tensorflow/python/keras/
Dcallbacks.py396 def on_epoch_begin(self, epoch, logs=None): argument
410 callback.on_epoch_begin(epoch, logs)
414 callback.on_epoch_begin(epoch, numpy_logs)
416 def on_epoch_end(self, epoch, logs=None): argument
431 callback.on_epoch_end(epoch, logs)
435 callback.on_epoch_end(epoch, numpy_logs)
650 def on_epoch_begin(self, epoch, logs=None): argument
663 def on_epoch_end(self, epoch, logs=None): argument
893 def on_epoch_begin(self, epoch, logs=None): argument
914 def on_epoch_end(self, epoch, logs=None): argument
[all …]
/external/rust/crates/crossbeam-epoch/benches/
Ddefer.rs5 use crossbeam_epoch::{self as epoch, Owned};
12 let guard = &epoch::pin(); in single_alloc_defer_free()
23 let guard = &epoch::pin(); in single_defer()
38 let guard = &epoch::pin(); in multi_alloc_defer_free()
61 let guard = &epoch::pin(); in multi_defer()
Dflush.rs7 use crossbeam_epoch as epoch;
21 epoch::pin(); in single_flush()
28 b.iter(|| epoch::pin().flush()); in single_flush()
44 let guard = &epoch::pin(); in multi_flush()
/external/rust/crates/crossbeam-epoch/
DMETADATA1 name: "crossbeam-epoch"
6 value: "https://crates.io/crates/crossbeam-epoch"
10 value: "https://static.crates.io/crates/crossbeam-epoch/crossbeam-epoch-0.9.3.crate"
DREADME.md6 https://github.com/crossbeam-rs/crossbeam/tree/master/crossbeam-epoch#license)
7 [![Cargo](https://img.shields.io/crates/v/crossbeam-epoch.svg)](
8 https://crates.io/crates/crossbeam-epoch)
9 [![Documentation](https://docs.rs/crossbeam-epoch/badge.svg)](
10 https://docs.rs/crossbeam-epoch)
15 This crate provides epoch-based garbage collection for building concurrent data structures.
31 crossbeam-epoch = "0.9"
/external/python/setuptools/pkg_resources/_vendor/packaging/
Dversion.py136 epoch = -1
155 return epoch, parts
206 epoch=int(match.group("epoch")) if match.group("epoch") else 0,
225 self._version.epoch,
240 if self._version.epoch != 0:
241 parts.append("{0}!".format(self._version.epoch))
275 if self._version.epoch != 0:
276 parts.append("{0}!".format(self._version.epoch))
343 def _cmpkey(epoch, release, pre, post, dev, local): argument
393 return epoch, release, pre, post, dev, local
/external/python/setuptools/setuptools/_vendor/packaging/
Dversion.py136 epoch = -1
155 return epoch, parts
206 epoch=int(match.group("epoch")) if match.group("epoch") else 0,
225 self._version.epoch,
240 if self._version.epoch != 0:
241 parts.append("{0}!".format(self._version.epoch))
275 if self._version.epoch != 0:
276 parts.append("{0}!".format(self._version.epoch))
343 def _cmpkey(epoch, release, pre, post, dev, local): argument
393 return epoch, release, pre, post, dev, local
/external/tensorflow/tensorflow/python/keras/distribute/
Dworker_training_state.py88 def back_up(self, epoch): argument
94 K.set_value(self._ckpt_saved_epoch, epoch)
138 epoch = K.eval(self._ckpt_saved_epoch)
139 if mode == mode_keys.ModeKeys.TRAIN and epoch >= 0:
142 return epoch + 1
/external/rust/crates/crossbeam-epoch/tests/
Dloom.rs3 use crossbeam_epoch as epoch;
6 use epoch::*;
7 use epoch::{Atomic, Owned};
79 let guard = epoch::pin(); in treiber_stack()
99 let guard = epoch::pin(); in treiber_stack()
125 let guard = epoch::pin(); in treiber_stack()

12345678910>>...12