Home
last modified time | relevance | path

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

12345678910>>...15

/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/rust/crates/crossbeam-epoch/src/
Dinternal.rs52 use crate::epoch::{AtomicEpoch, Epoch};
104 fn seal(self, epoch: Epoch) -> SealedBag { in seal()
105 SealedBag { epoch, _bag: self } in seal()
141 epoch: Epoch, field
153 global_epoch.wrapping_sub(self.epoch) >= 2 in is_expired()
166 pub(crate) epoch: CachePadded<AtomicEpoch>, field
179 epoch: CachePadded::new(AtomicEpoch::new(Epoch::starting())), in new()
189 let epoch = self.epoch.load(Ordering::Relaxed); in push_bag() localVariable
190 self.queue.push(bag.seal(epoch), guard); in push_bag()
231 let global_epoch = self.epoch.load(Ordering::Relaxed); in try_advance()
[all …]
Depoch.rs85 pub(crate) fn new(epoch: Epoch) -> Self { in new()
86 let data = AtomicUsize::new(epoch.data); in new()
100 pub(crate) fn store(&self, epoch: Epoch, ord: Ordering) { in store()
101 self.data.store(epoch.data, ord); in store()
/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/cronet/base/allocator/partition_allocator/starscan/
Dstate_bitmap.h98 PA_ALWAYS_INLINE bool Quarantine(uintptr_t address, Epoch epoch);
103 Epoch epoch);
127 inline void IterateQuarantined(size_t epoch, Callback) const;
131 inline void IterateUnmarkedQuarantined(size_t epoch, Callback) const;
137 inline void IterateUnmarkedQuarantinedAndFree(size_t epoch, Callback);
153 const size_t epoch; member
158 const size_t epoch; member
163 const size_t epoch; member
168 PA_ALWAYS_INLINE explicit SimpleCallbackForwarder(size_t epoch) {} in SimpleCallbackForwarder()
179 PA_ALWAYS_INLINE explicit QuarantineCallbackForwarder(size_t epoch) in QuarantineCallbackForwarder()
[all …]
/external/rust/crates/quiche/src/recovery/
Dmod.rs312 pub fn should_elicit_ack(&self, epoch: packet::Epoch) -> bool { in should_elicit_ack()
313 self.loss_probes[epoch] > 0 || in should_elicit_ack()
319 &mut self, mut pkt: Sent, epoch: packet::Epoch, in on_packet_sent()
333 self.largest_sent_pkt[epoch] = in on_packet_sent()
334 cmp::max(self.largest_sent_pkt[epoch], pkt_num); in on_packet_sent()
338 self.time_of_last_sent_ack_eliciting_pkt[epoch] = Some(now); in on_packet_sent()
341 self.in_flight_count[epoch] += 1; in on_packet_sent()
356 epoch == packet::Epoch::Application && in on_packet_sent()
371 self.schedule_next_packet(epoch, now, sent_bytes); in on_packet_sent()
379 self.sent[epoch].push_back(pkt); in on_packet_sent()
[all …]
/external/perfetto/src/trace_processor/metrics/sql/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/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/tensorflow/tensorflow/python/keras/
Dcallbacks.py407 def on_epoch_begin(self, epoch, logs=None): argument
419 callback.on_epoch_begin(epoch, logs)
421 def on_epoch_end(self, epoch, logs=None): argument
434 callback.on_epoch_end(epoch, logs)
678 def on_epoch_begin(self, epoch, logs=None): argument
691 def on_epoch_end(self, epoch, logs=None): argument
921 def on_epoch_begin(self, epoch, logs=None): argument
942 def on_epoch_end(self, epoch, logs=None): argument
1045 def on_epoch_begin(self, epoch, logs=None): argument
1049 print('Epoch %d/%d' % (epoch + 1, self.epochs))
[all …]
/external/rust/crates/crossbeam-epoch/
DMETADATA2 # Usage: tools/external_updater/updater.sh update rust/crates/crossbeam-epoch
5 name: "crossbeam-epoch"
10 value: "https://crates.io/crates/crossbeam-epoch"
14 value: "https://static.crates.io/crates/crossbeam-epoch/crossbeam-epoch-0.9.14.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/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()
Dpin.rs5 use crossbeam_epoch as epoch;
11 b.iter(epoch::pin); in single_pin()
24 epoch::pin(); in multi_pin()
/external/rust/crates/crossbeam-deque/
DCHANGELOG.md38 - Bump `crossbeam-epoch` to `0.8`.
61 - Bump `crossbeam-epoch` to `0.7`.
96 - Update `crossbeam-epoch` to `0.5.0`.
100 - Update `crossbeam-epoch` to `0.4.2`.
109 - Update `crossbeam-epoch` to `0.3.0`.
115 - Update `crossbeam-epoch` to `0.4.0`.
120 - Update `crossbeam-epoch` to `0.3.0`.
125 - Update `crossbeam-epoch` to `0.2.0`.
/external/python/setuptools/setuptools/_vendor/packaging/
Dversion.py132 def epoch(self) -> int: member in LegacyVersion
202 epoch = -1
220 return epoch, tuple(parts)
270 epoch=int(match.group("epoch")) if match.group("epoch") else 0,
282 self._version.epoch,
297 if self.epoch != 0:
322 def epoch(self) -> int: member in Version
323 _epoch: int = self._version.epoch
360 if self.epoch != 0:
445 epoch: int,
[all …]
/external/python/setuptools/pkg_resources/_vendor/packaging/
Dversion.py132 def epoch(self) -> int: member in LegacyVersion
202 epoch = -1
220 return epoch, tuple(parts)
270 epoch=int(match.group("epoch")) if match.group("epoch") else 0,
282 self._version.epoch,
297 if self.epoch != 0:
322 def epoch(self) -> int: member in Version
323 _epoch: int = self._version.epoch
360 if self.epoch != 0:
445 epoch: int,
[all …]
/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()
/external/tensorflow/tensorflow/python/keras/distribute/
Dworker_training_state.py85 def back_up(self, epoch): argument
91 backend.set_value(self._ckpt_saved_epoch, epoch)
138 epoch = backend.eval(self._ckpt_saved_epoch)
139 if mode == mode_keys.ModeKeys.TRAIN and epoch >= 0:
142 return epoch + 1
/external/pigweed/pw_chrono/
Dchrono.proto37 // UTC at that date (i.e., its epoch, 1958-01-01 00:00:00 TAI, is
50 // 2. A representation of the clock's epoch.
69 // of ticks, an epoch is required to make a clock represent a time point.
71 // defines what a tick count of `0` represents. Some epoch types (e.g. UTC, GPS,
82 // A point in time relative to a clock's epoch.
84 // The duration that has elapsed (number of clock ticks) since the epoch,
85 // where the tick period and epoch are specified by the clock parameters.
95 // from epoch, etc).
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DKeepAliveEnforcer.java34 private final long epoch; field in KeepAliveEnforcer
51 this.epoch = ticker.nanoTime(); in KeepAliveEnforcer()
52 lastValidPingTime = epoch; in KeepAliveEnforcer()
79 lastValidPingTime = epoch; in resetCounters()

12345678910>>...15