Home
last modified time | relevance | path

Searched refs:now (Results 1 – 25 of 72) sorted by relevance

123

/rocksdb-6.9/utilities/cassandra/
Dcassandra_functional_test.cc143 int64_t now = time(nullptr); in TEST_F() local
178 int64_t now= time(nullptr); in TEST_F() local
190 CreateTestColumnSpec(kColumn, 2, ToMicroSeconds(now)) in TEST_F()
211 int64_t now = time(nullptr); in TEST_F() local
223 CreateTestColumnSpec(kColumn, 2, ToMicroSeconds(now)) in TEST_F()
242 int64_t now = time(nullptr); in TEST_F() local
264 int64_t now = time(nullptr); in TEST_F() local
268 CreateTestColumnSpec(kColumn, 1, ToMicroSeconds(now)) in TEST_F()
272 CreateTestColumnSpec(kColumn, 0, ToMicroSeconds(now)) in TEST_F()
278 CreateTestColumnSpec(kColumn, 1, ToMicroSeconds(now)), in TEST_F()
[all …]
Dcassandra_format_test.cc126 int32_t now = (int32_t)time(nullptr); in TEST() local
130 now - gc_grace_seconds - time_delta_seconds, in TEST()
134 now - gc_grace_seconds + time_delta_seconds, in TEST()
318 int64_t now = time(nullptr); in TEST() local
321 CreateTestColumnSpec(kColumn, 0, ToMicroSeconds(now)), in TEST()
324 CreateTestColumnSpec(kTombstone, 3, ToMicroSeconds(now)) in TEST()
331 VerifyRowValueColumns(purged.columns_, 0, kColumn, 0, ToMicroSeconds(now)); in TEST()
333 VerifyRowValueColumns(purged.columns_, 2, kTombstone, 3, ToMicroSeconds(now)); in TEST()
340 int64_t now = time(nullptr); in TEST() local
343 CreateTestColumnSpec(kColumn, 0, ToMicroSeconds(now)), in TEST()
[all …]
/rocksdb-6.9/util/
Dtimer_queue_test.cc33 double now() { in now() function
34 static auto start = Clock::now(); in now()
35 return std::chrono::duration<double, std::milli>(Clock::now() - start) in now()
44 double tnow = Timing::now(); in main()
47 printf("T 1: %d, Elapsed %4.2fms\n", aborted, Timing::now() - tnow); in main()
51 printf("T 2: %d, Elapsed %4.2fms\n", aborted, Timing::now() - tnow); in main()
56 printf("T 3: %d, Elapsed %4.2fms\n", aborted, Timing::now() - tnow); in main()
61 printf("T 4: %d, Elapsed %4.2fms\n", aborted, Timing::now() - tnow); in main()
Dstop_watch.h101 auto now = env_->NowNanos(); variable
102 auto elapsed = now - start_;
104 start_ = now;
Drepeatable_thread_test.cc36 uint64_t now = env->NowMicros(); in TEST_F() local
37 assert(count == 1 || prev_time + 1 * kSecond <= now); in TEST_F()
38 prev_time = now; in TEST_F()
Dtimer_queue.h76 Clock::time_point tp = Clock::now(); in add()
187 while (m_items.size() && m_items.top().end <= Clock::now()) { in checkWork()
201 item.end = Clock::now() + std::chrono::milliseconds(new_period); in checkWork()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_driver.cc66 uint64_t now = db_stress_env->NowMicros(); in RunStressTest() local
68 db_stress_env->TimeToString(now / 1000000).c_str()); in RunStressTest()
101 now = db_stress_env->NowMicros(); in RunStressTest()
103 db_stress_env->TimeToString(now / 1000000).c_str()); in RunStressTest()
111 now = db_stress_env->NowMicros(); in RunStressTest()
114 db_stress_env->TimeToString((uint64_t)now / 1000000).c_str()); in RunStressTest()
117 db_stress_env->TimeToString((uint64_t)now / 1000000).c_str()); in RunStressTest()
136 now = db_stress_env->NowMicros(); in RunStressTest()
139 db_stress_env->TimeToString(now / 1000000).c_str()); in RunStressTest()
Ddb_stress_stat.h108 auto now = Env::Default()->NowMicros(); in FinishedSingleOp() local
109 auto micros = now - last_op_finish_; in FinishedSingleOp()
114 last_op_finish_ = now; in FinishedSingleOp()
/rocksdb-6.9/db/
Dforward_iterator_bench.cc214 std::chrono::steady_clock::now() + in run()
229 auto now = std::chrono::steady_clock::now(); in run() local
230 if (FLAGS_runtime >= 0 && now >= deadline) { in run()
236 workq.push(now + offset); in run()
239 while (!workq.empty() && workq.front() < now) { in run()
276 auto tstart = std::chrono::steady_clock::now(), tlast = tstart; in run()
283 auto now = std::chrono::steady_clock::now(); in run() local
286 now - tlast).count(); in run()
293 std::chrono::duration_cast<std::chrono::seconds>(now - tstart) in run()
299 tlast = now; in run()
Dwrite_thread.cc149 auto spin_begin = std::chrono::steady_clock::now(); in AwaitState()
167 auto now = std::chrono::steady_clock::now(); in AwaitState() local
168 if (now == iter_begin || in AwaitState()
169 now - iter_begin >= std::chrono::microseconds(slow_yield_usec_)) { in AwaitState()
180 iter_begin = now; in AwaitState()
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_trace_analyzer.cc465 for (uint64_t now = start_time; now <= end_time; now++) { in WriteMissRatioTimeline() local
467 header += std::to_string(now); in WriteMissRatioTimeline()
472 for (uint64_t now = start_time; now <= end_time; now++) { in WriteMissRatioTimeline() local
531 for (uint64_t now = start_time; now <= end_time; now++) { in WriteMissTimeline() local
533 header += std::to_string(now); in WriteMissTimeline()
538 for (uint64_t now = start_time; now <= end_time; now++) { in WriteMissTimeline() local
902 for (uint64_t now = start_time; now <= end_time; now++) { in WriteAccessTimeline() local
912 for (uint64_t now = start_time; now <= end_time; now++) { in WriteAccessTimeline() local
927 for (uint64_t now = start_time; now <= end_time; now++) { in WriteAccessTimeline() local
929 header += std::to_string(now); in WriteAccessTimeline()
[all …]
Dblock_cache_pysim.py565 def compare(self, e1, e2, now): argument
590 now = auxilliary_info[0]
614 e1_density = e1_entry.density(now)
615 e2_density = e2_entry.density(now)
643 now = auxilliary_info[0]
869 def avg_lifetime_in_cache(self, now): argument
883 def density(self, now): argument
1725 now = time.time()
1821 now = time.time()
1843 now = time.time()
[all …]
/rocksdb-6.9/
DHISTORY.md72 * `db_bench` now supports the `garbage_collection_cutoff` option for BlobDB.
171 * The MemTable Bloom filter, when enabled, now always uses cache locality. Options::bloom_locality …
505 * Close() method now returns a status when closing a db.
512 * Updated to and now continuously tested in Visual Studio 2017.
565 * `DBOptions::writable_file_max_buffer_size` can now be changed dynamically.
601 * DB property "rocksdb.sstables" now prints keys in hex form.
805 * ldb tool now supports operations to non-default column families.
880 * Env::FileExists now returns a Status instead of a boolean
934 * We now allow level-compaction to place files in different paths by
952 * Logger method logv with log level parameter is now virtual
[all …]
/rocksdb-6.9/file/
Drandom_access_file_reader.cc62 start_ts = std::chrono::system_clock::now(); in Read()
71 auto finish_ts = std::chrono::system_clock::now(); in Read()
116 start_ts = std::chrono::system_clock::now(); in Read()
126 auto finish_ts = std::chrono::system_clock::now(); in Read()
244 start_ts = std::chrono::system_clock::now(); in MultiRead()
277 auto finish_ts = std::chrono::system_clock::now(); in MultiRead()
Dwritable_file_writer.cc316 start_ts = std::chrono::system_clock::now(); in WriteBuffered()
328 auto finish_ts = std::chrono::system_clock::now(); in WriteBuffered()
400 start_ts = std::chrono::system_clock::now(); in WriteDirect()
406 auto finish_ts = std::chrono::system_clock::now(); in WriteDirect()
/rocksdb-6.9/third-party/folly/folly/synchronization/detail/
DSpin.h33 auto tbegin = Clock::now(); in spin_pause_until()
39 auto const tnow = Clock::now(); in spin_pause_until()
68 if (deadline != max && Clock::now() >= deadline) { in spin_yield_until()
/rocksdb-6.9/monitoring/
Dperf_step_timer.h49 uint64_t now = time_now(); in Measure() local
50 *metric_ += now - start_; in Measure()
51 start_ = now; in Measure()
/rocksdb-6.9/java/
DHISTORY-JAVA.md12 * MemEnv is now available in RocksJava via RocksMemEnv class.
13 * lz4 compression is now included in rocksjava static library when running `make rocksdbjavastatic`.
16 * Overflowing a size_t when setting rocksdb options now throws an IllegalArgumentException, which r…
25 * Snapshots carry now information about the related sequence number.
/rocksdb-6.9/env/
Dmock_env_test.cc68 int64_t now = 0; in TEST_F() local
69 auto s = env_->GetCurrentTime(&now); in TEST_F()
75 auto delta = after_sleep - now; in TEST_F()
/rocksdb-6.9/tools/
Dbenchmark_leveldb.sh144 function now() { function
162 start=$(now)
178 end=$(now)
/rocksdb-6.9/third-party/folly/folly/synchronization/
DDistributedMutex-inl.h883 auto now = ((waitMode == kCombineWaiting) && !spins)
893 auto data = strip(now) | waitMode;
1256 inline bool preempted(std::uint64_t value, std::chrono::nanoseconds now) {
1257 auto currentTime = recover(strip(now));
1312 std::chrono::nanoseconds now,
1334 (iteration <= kMaxCombineIterations || preempted(value, now))) {
1360 auto now = time();
1361 if (tryCombine(waiter, value, next, iteration, now, task)) {
1366 if ((!publishing || !preempted(value, now)) && !isSleeper(value)) {
1402 assert(preempted(value, now));
[all …]
/rocksdb-6.9/docs/_posts/
D2016-04-26-rocksdb-4-5-1-released.markdown22 …* Add a new perf context level between kEnableCount and kEnableTime. Level 2 now does not include …
27 * ldb tool now supports operations to non-default column families.
54 …* RocksDB will now persist options under the same directory as the RocksDB database on successful …
D2014-09-15-rocksdb-3-5-release.markdown26 …1. The Prefix Extractor used with V2 compaction filters is now passed user key to SliceTransform::…
35 …4. OptimizeForPointLookup() takes one parameter for block cache size. It now builds hash index, bl…
D2015-07-22-rocksdb-is-now-available-in-windows-platform.markdown2 title: RocksDB is now available in Windows Platform
7 - /blog/2033/rocksdb-is-now-available-in-windows-platform/
/rocksdb-6.9/logging/
Dauto_roll_logger.cc82 uint64_t now = env_->NowMicros(); in RollLogFile() local
86 dbname_, now, db_absolute_path_, db_log_dir_); in RollLogFile()
87 now++; in RollLogFile()

123