| /rocksdb-6.9/tools/ |
| D | db_crashtest.py | 7 import time
291 exit_time = time.time() + cmd_params['duration']
297 while time.time() < exit_time:
299 killtime = time.time() + cmd_params['interval']
310 while time.time() < killtime:
316 time.sleep(1)
339 time.sleep(1) # time to stabilize before the next run
351 cur_time = time.time()
363 while time.time() < exit_time:
467 if time.time() > half_time:
[all …]
|
| D | write_stress_runner.py | 8 import time
54 killtime = time.time() + runtime
55 while not kill or time.time() < killtime:
56 time.sleep(1)
67 time.sleep(3)
70 random.seed(time.time())
|
| /rocksdb-6.9/test_util/ |
| D | mock_time_env.h | 16 virtual Status GetCurrentTime(int64_t* time) override { in GetCurrentTime() argument
17 assert(time != nullptr); in GetCurrentTime()
20 *time = static_cast<int64_t>(current_time_); in GetCurrentTime()
36 void set_current_time(uint64_t time) { in set_current_time() argument
37 assert(time >= current_time_); in set_current_time()
38 current_time_ = time; in set_current_time()
|
| /rocksdb-6.9/tools/advisor/advisor/ |
| D | db_log_parser.py | 11 import time
41 self.time = token_list[0]
58 return self.time
76 hr_time = self.time + 'GMT'
77 timestamp = timegm(time.strptime(hr_time, "%Y/%m/%d-%H:%M:%S.%f%Z"))
82 'time: ' + self.time + '; context: ' + self.context +
|
| D | db_bench_runner.py | 13 import time
103 timestamp = int(time.time())
204 experiment_start_time = int(time.time())
207 experiment_end_time = int(time.time())
|
| D | rules.ini | 125 window_sec=300 # the smaller this window, the more sensitivity to changes in the time series, so t…
192 [Rule "decompress-time-long"]
193 conditions=decompress-time-long
196 [Condition "decompress-time-long"]
|
| D | db_stats_fetcher.py | 12 import time
195 diff = int(time.time() - int(start_time))
|
| /rocksdb-6.9/buckifier/ |
| D | util.py | 16 import time
77 start = time.time()
85 end = time.time()
|
| /rocksdb-6.9/build_tools/ |
| D | precommit_checker.py | 14 import time
149 start_time = time.time()
152 elapsed_min = (time.time() - start_time) / 60
|
| /rocksdb-6.9/utilities/cassandra/ |
| D | cassandra_functional_test.cc | 143 int64_t now = time(nullptr); in TEST_F()
178 int64_t now= time(nullptr); in TEST_F()
211 int64_t now = time(nullptr); in TEST_F()
242 int64_t now = time(nullptr); in TEST_F()
264 int64_t now = time(nullptr); in TEST_F()
294 int64_t now = time(nullptr); in TEST_F()
|
| /rocksdb-6.9/logging/ |
| D | auto_roll_logger_test.cc | 79 void RollLogFileByTimeTest(Env*, AutoRollLogger* logger, size_t time,
161 size_t time, in RollLogFileByTimeTest() argument
189 env->SleepForMicroseconds(static_cast<int>(time * 1000000)); in RollLogFileByTimeTest()
213 size_t time = 2; in TEST_F() local
220 AutoRollLogger logger(&nse, kTestDir, "", log_size, time, keep_log_file_num); in TEST_F()
223 RollLogFileByTimeTest(&nse, &logger, time, in TEST_F()
272 size_t time = 2, log_max_size = 1024 * 5; in TEST_F() local
278 AutoRollLogger logger(&nse, kTestDir, "", log_max_size, time, in TEST_F()
286 RollLogFileByTimeTest(&nse, &logger, time, in TEST_F()
|
| /rocksdb-6.9/third-party/folly/folly/detail/ |
| D | Futex-inl.h | 19 std::chrono::time_point<Clock, Duration> const& time) { in time_point_conv() argument
24 if (time == TimePoint::max()) { in time_point_conv()
28 auto const delta = time.time_since_epoch(); in time_point_conv()
32 auto const delta = time - Clock::now(); in time_point_conv()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | statistics.h | 495 virtual void reportTimeToHistogram(uint32_t histogramType, uint64_t time) { in reportTimeToHistogram() argument
499 recordInHistogram(histogramType, time); in reportTimeToHistogram()
508 virtual void recordInHistogram(uint32_t histogramType, uint64_t time) { in recordInHistogram() argument
513 measureTime(histogramType, time); in recordInHistogram()
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/detail/ |
| D | ProxyLockable-inl.h | 106 const std::chrono::time_point<Clock, Duration>& time) { in ProxyLockableUniqueLock() argument
108 if (auto state = mtx.try_lock_until(time)) { in ProxyLockableUniqueLock()
161 const std::chrono::time_point<Clock, Duration>& time) { in try_lock_until() argument
165 if (auto state = mutex_->try_lock_until(time)) { in try_lock_until()
|
| D | ProxyLockable.h | 82 const std::chrono::time_point<Clock, Duration>& time);
103 bool try_lock_until(const std::chrono::time_point<Clock, Duration>& time);
|
| /rocksdb-6.9/utilities/ |
| D | env_librados.md | 55 1. Write (1<<20) keys in random order. The time of writing under default env is around 10s while th…
57 …rite (1<<20) keys in sequential order. The time of writing under default env drops to arround 1s. …
59 3. Read (1<<16) keys from (1<<20) keys in random order. The time of reading under both Envs are rou…
|
| D | env_librados_test.cc | 393 ROCKSDB_NAMESPACE::Random64 r1(time(nullptr)); in TEST_F()
429 ROCKSDB_NAMESPACE::Random64 r2(time(nullptr)); in TEST_F()
471 ROCKSDB_NAMESPACE::Random64 r1(time(nullptr)); in TEST_F()
510 ROCKSDB_NAMESPACE::Random64 r2(time(nullptr)); in TEST_F()
555 ROCKSDB_NAMESPACE::Random64 r1(time(nullptr)); in TEST_F()
594 ROCKSDB_NAMESPACE::Random64 r2(time(nullptr)); in TEST_F()
640 ROCKSDB_NAMESPACE::Random64 r1(time(nullptr)); in TEST_F()
691 ROCKSDB_NAMESPACE::Random64 r2(time(nullptr)); in TEST_F()
938 ROCKSDB_NAMESPACE::Random64 r1(time(nullptr)); in TEST_F()
981 ROCKSDB_NAMESPACE::Random64 r2(time(nullptr)); in TEST_F()
|
| /rocksdb-6.9/tools/advisor/test/ |
| D | test_db_stats_fetcher.py | 10 import time
111 timestamp = int(time.time())
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_trace_analyzer.cc | 320 for (auto const& time : time_stats) { in adjust_time_unit() local
322 time.second; in adjust_time_unit()
421 uint64_t time = num_miss.first; in WriteMissRatioTimeline() local
422 start_time = std::min(start_time, time); in WriteMissRatioTimeline()
423 end_time = std::max(end_time, time); in WriteMissRatioTimeline()
425 auto it = trace_num_accesses.find(time); in WriteMissRatioTimeline()
444 uint64_t time = num_miss.first; in WriteMissRatioTimeline() local
448 auto it = num_accesses.find(time); in WriteMissRatioTimeline()
498 uint64_t time = num_miss.first; in WriteMissTimeline() local
500 end_time = std::max(end_time, time); in WriteMissTimeline()
[all …]
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2017-12-18-17-auto-tuned-rate-limiter.markdown | 10 …ose DB instances have different workloads, or have workloads that vary over time, or commonly both.
12 To address this, in RocksDB 5.9 we released a dynamic rate limiter that adjusts itself over time ac…
26 The following graph summarizes the above two time series graphs in CDF form. In particular, notice …
|
| D | 2014-07-29-rocksdb-3-3-release.markdown | 24 …d that any write completes earlier than the specified time-out will not be aborted due to the time…
|
| D | 2014-04-21-indexing-sst-files-for-better-lookup-performance.markdown | 12 On level 0, files are sorted based on the time they are flushed. Their key range (as defined by Fil…
26 …time on level 1 files that point to a range of files on level 2. For example, file 1 on level 1 po…
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/ |
| D | DistributedMutex-inl.h | 714 inline std::chrono::nanoseconds time() {
740 auto time = t.count();
741 return static_cast<std::uint64_t>(time) << 8;
870 auto current = time();
884 ? decltype(time())::max()
885 : (spins < kMaxSpins) ? previous : decltype(time())::zero();
904 auto previous = time();
1360 auto now = time();
|
| /rocksdb-6.9/monitoring/ |
| D | statistics.h | 60 void measureTime(uint32_t histogramType, uint64_t time) override { in measureTime() argument
61 recordInHistogram(histogramType, time); in measureTime()
|
| /rocksdb-6.9/ |
| D | USERS.md | 48 Check out their blog post: http://blog.cloudera.com/blog/2015/08/inside-santanders-near-real-time-d…
61 …age layer for their core key-value storage, high-performance counters and time-windowed HyperLogLo…
64 …marketing.rakuten.com/) uses RocksDB as the disk cache layer for the real-time bidding service in …
104 …y%E2%80%93attribute%E2%80%93value_model) index storage to enable point-in-time bitemporal Datalog …
|