Home
last modified time | relevance | path

Searched refs:ts (Results 1 – 25 of 44) sorted by relevance

12

/rocksdb-6.9/db/
Ddbformat.cc80 const Slice& ts) { in AppendInternalKeyWithDifferentTimestamp() argument
81 assert(key.user_key.size() >= ts.size()); in AppendInternalKeyWithDifferentTimestamp()
82 result->append(key.user_key.data(), key.user_key.size() - ts.size()); in AppendInternalKeyWithDifferentTimestamp()
83 result->append(ts.data(), ts.size()); in AppendInternalKeyWithDifferentTimestamp()
172 const Slice* ts) { in LookupKey() argument
174 size_t ts_sz = (nullptr == ts) ? 0 : ts->size(); in LookupKey()
188 if (nullptr != ts) { in LookupKey()
189 memcpy(dst, ts->data(), ts_sz); in LookupKey()
Ddb_with_timestamp_basic_test.cc130 std::string ts; in Timestamp() local
131 PutFixed64(&ts, low); in Timestamp()
132 PutFixed64(&ts, high); in Timestamp()
133 return ts; in Timestamp()
314 Slice ts = ts_str; in TEST_F() local
322 Slice ts = ts_str; in TEST_F() local
351 Slice ts = ts_str; in TEST_F() local
369 Slice ts = ts_str; in TEST_F() local
395 Slice ts = ts_str; in TEST_F() local
401 Slice ts = ts_str; in TEST_F() local
[all …]
Ddb_iter.cc248 Slice ts; in FindNextUserEntryInternal() local
250 ts = ExtractTimestampFromUserKey(ikey_.user_key, timestamp_size_); in FindNextUserEntryInternal()
252 if (IsVisible(ikey_.sequence, ts)) { in FindNextUserEntryInternal()
737 Slice ts; in FindValueForCurrentKey() local
742 if (!IsVisible(ikey.sequence, ts) || in FindValueForCurrentKey()
899 Slice ts; in FindValueForCurrentKeyUsingSeek() local
913 if (IsVisible(ikey.sequence, ts)) { in FindValueForCurrentKeyUsingSeek()
1054 Slice ts; in FindUserKeyBeforeSavedKey() local
1059 if (!IsVisible(ikey.sequence, ts)) { in FindUserKeyBeforeSavedKey()
1104 bool DBIter::IsVisible(SequenceNumber sequence, const Slice& ts) { in IsVisible() argument
[all …]
Ddbformat.h140 std::string* result, const ParsedInternalKey& key, const Slice& ts);
451 const Slice* ts = nullptr) {
454 size_t ts_sz = (ts != nullptr ? ts->size() : 0);
460 if (ts) {
461 memcpy(buf_ + psize + usize, ts->data(), ts_sz);
473 const Slice* ts = nullptr) {
474 SetInternalKey(Slice(), user_key, s, value_type, ts);
Dlookup_key.h25 const Slice* ts = nullptr);
Dwrite_batch.cc143 explicit TimestampAssigner(const Slice& ts) in TimestampAssigner() argument
144 : timestamp_(ts), timestamps_(kEmptyTimestampList) {} in TimestampAssigner()
221 const Slice& ts = timestamps_.empty() ? timestamp_ : timestamps_[idx_]; in AssignTimestamp() local
222 size_t ts_sz = ts.size(); in AssignTimestamp()
224 memcpy(ptr, ts.data(), ts_sz); in AssignTimestamp()
1178 Status WriteBatch::AssignTimestamp(const Slice& ts) { in AssignTimestamp() argument
1179 TimestampAssigner ts_assigner(ts); in AssignTimestamp()
/rocksdb-6.9/env/
Denv_posix.cc267 struct timespec ts; in NowNanos() local
268 clock_gettime(CLOCK_MONOTONIC, &ts); in NowNanos()
269 return static_cast<uint64_t>(ts.tv_sec) * 1000000000 + ts.tv_nsec; in NowNanos()
274 mach_timespec_t ts; in NowNanos()
276 clock_get_time(cclock, &ts); in NowNanos()
278 return static_cast<uint64_t>(ts.tv_sec) * 1000000000 + ts.tv_nsec; in NowNanos()
288 struct timespec ts; in NowCPUNanos() local
289 clock_gettime(CLOCK_THREAD_CPUTIME_ID, &ts); in NowCPUNanos()
290 return static_cast<uint64_t>(ts.tv_sec) * 1000000000 + ts.tv_nsec; in NowCPUNanos()
/rocksdb-6.9/trace_replay/
Dtrace_replay.cc37 PutFixed64(encoded_trace, trace.ts); in EncodeTrace()
47 if (!GetFixed64(&enc_slice, &trace->ts)) { in DecodeTrace()
76 trace.ts = env_->NowMicros(); in Write()
88 trace.ts = env_->NowMicros(); in Get()
100 trace.ts = env_->NowMicros(); in IteratorSeek()
112 trace.ts = env_->NowMicros(); in IteratorSeekForPrev()
150 trace.ts = env_->NowMicros(); in WriteHeader()
158 trace.ts = env_->NowMicros(); in WriteFooter()
221 std::chrono::microseconds((trace.ts - header.ts) / fast_forward_)); in Replay()
329 (ra->trace_entry.ts - header.ts) / fast_forward_)); in MultiThreadReplay()
Dtrace_replay.h58 uint64_t ts; // timestamp member
63 ts = 0; in reset()
Dblock_cache_tracer.cc119 trace.ts = record.access_timestamp; in WriteBlockAccess()
148 trace.ts = env_->NowMicros(); in WriteHeader()
174 header->start_time = trace.ts; in ReadHeader()
216 record->access_timestamp = trace.ts; in ReadAccess()
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_pysim.py1704 cf_name = ts[5]
1768 ts = line.split(",")
1769 timestamp = int(ts[0])
1770 cf_name = ts[5]
1784 block_id = int(ts[1])
1792 cf_id=int(ts[4]),
1793 cf_name=ts[5],
1794 level=int(ts[6]),
1795 fd=int(ts[7]),
1796 caller=int(ts[8]),
[all …]
/rocksdb-6.9/tools/
Dtrace_analyzer_tool.cc431 GetFixed64(&enc_slice, &trace->ts); in ReadTraceRecord()
449 trace_create_time_ = header.ts; in StartProcessing()
451 time_series_start_ = header.ts; in StartProcessing()
463 end_time_ = trace.ts; in StartProcessing()
466 c_time_ = trace.ts; in StartProcessing()
1190 unit.latest_ts = ts; in KeyStatsInsertion()
1208 begin_time_ = ts; in KeyStatsInsertion()
1211 if (ts < begin_time_) { in KeyStatsInsertion()
1323 trace_u.ts = (ts - time_series_start_) / 1000000; in KeyStatsInsertion()
1367 unit.latest_ts = ts; in StatsUnitCorrelationUpdate()
[all …]
Dtrace_analyzer_tool.h39 uint64_t ts; member
185 const uint64_t& ts, const uint32_t& get_ret);
195 const uint64_t& ts, TraceType& trace_type);
233 const uint64_t ts);
235 const uint64_t& ts, const std::string& key);
248 const uint64_t ts);
/rocksdb-6.9/third-party/folly/folly/detail/
DFutex.cpp100 struct timespec ts; in nativeFutexWaitImpl() local
105 ts = timeSpecFromTimePoint(*absSystemTime); in nativeFutexWaitImpl()
106 timeout = &ts; in nativeFutexWaitImpl()
108 ts = timeSpecFromTimePoint(*absSteadyTime); in nativeFutexWaitImpl()
109 timeout = &ts; in nativeFutexWaitImpl()
/rocksdb-6.9/third-party/folly/folly/
DConstexprMath.h14 constexpr T constexpr_max(T a, T b, Ts... ts) { in constexpr_max() argument
15 return b < a ? constexpr_max(a, ts...) : constexpr_max(b, ts...); in constexpr_max()
/rocksdb-6.9/port/
Dport_posix.cc114 struct timespec ts; in TimedWait() local
115 ts.tv_sec = static_cast<time_t>(abs_time_us / 1000000); in TimedWait()
116 ts.tv_nsec = static_cast<suseconds_t>((abs_time_us % 1000000) * 1000); in TimedWait()
121 int err = pthread_cond_timedwait(&cv_, &mu_->mu_, &ts); in TimedWait()
/rocksdb-6.9/CMakeFiles/rocksdb.dir/
Dbuild.make74 CMakeFiles/rocksdb.dir/cache/clock_cache.cc.o: CMakeFiles/rocksdb.dir/compiler_depend.ts
88 CMakeFiles/rocksdb.dir/cache/lru_cache.cc.o: CMakeFiles/rocksdb.dir/compiler_depend.ts
172 CMakeFiles/rocksdb.dir/db/builder.cc.o: CMakeFiles/rocksdb.dir/compiler_depend.ts
186 CMakeFiles/rocksdb.dir/db/c.cc.o: CMakeFiles/rocksdb.dir/compiler_depend.ts
494 CMakeFiles/rocksdb.dir/db/db_iter.cc.o: CMakeFiles/rocksdb.dir/compiler_depend.ts
508 CMakeFiles/rocksdb.dir/db/dbformat.cc.o: CMakeFiles/rocksdb.dir/compiler_depend.ts
592 CMakeFiles/rocksdb.dir/db/flush_job.cc.o: CMakeFiles/rocksdb.dir/compiler_depend.ts
718 CMakeFiles/rocksdb.dir/db/memtable.cc.o: CMakeFiles/rocksdb.dir/compiler_depend.ts
802 CMakeFiles/rocksdb.dir/db/repair.cc.o: CMakeFiles/rocksdb.dir/compiler_depend.ts
1012 CMakeFiles/rocksdb.dir/env/env.cc.o: CMakeFiles/rocksdb.dir/compiler_depend.ts
[all …]
/rocksdb-6.9/CMakeFiles/rocksdb-shared.dir/
Dbuild.make74 …keFiles/rocksdb-shared.dir/cache/clock_cache.cc.o: CMakeFiles/rocksdb-shared.dir/compiler_depend.ts
88 CMakeFiles/rocksdb-shared.dir/cache/lru_cache.cc.o: CMakeFiles/rocksdb-shared.dir/compiler_depend.ts
172 CMakeFiles/rocksdb-shared.dir/db/builder.cc.o: CMakeFiles/rocksdb-shared.dir/compiler_depend.ts
186 CMakeFiles/rocksdb-shared.dir/db/c.cc.o: CMakeFiles/rocksdb-shared.dir/compiler_depend.ts
494 CMakeFiles/rocksdb-shared.dir/db/db_iter.cc.o: CMakeFiles/rocksdb-shared.dir/compiler_depend.ts
508 CMakeFiles/rocksdb-shared.dir/db/dbformat.cc.o: CMakeFiles/rocksdb-shared.dir/compiler_depend.ts
592 CMakeFiles/rocksdb-shared.dir/db/flush_job.cc.o: CMakeFiles/rocksdb-shared.dir/compiler_depend.ts
718 CMakeFiles/rocksdb-shared.dir/db/memtable.cc.o: CMakeFiles/rocksdb-shared.dir/compiler_depend.ts
802 CMakeFiles/rocksdb-shared.dir/db/repair.cc.o: CMakeFiles/rocksdb-shared.dir/compiler_depend.ts
1012 CMakeFiles/rocksdb-shared.dir/env/env.cc.o: CMakeFiles/rocksdb-shared.dir/compiler_depend.ts
[all …]
/rocksdb-6.9/tools/advisor/advisor/
Ddb_stats_fetcher.py149 for ix, ts in enumerate(timeseries[:-1]):
150 epoch_ts[NO_ENTITY][stat][ts] = (
151 epoch_ts[NO_ENTITY][stat][ts] -
154 if epoch_ts[NO_ENTITY][stat][ts] < 0:
/rocksdb-6.9/db_stress_tool/CMakeFiles/db_stress.dir/
Dbuild.make74 …CMakeFiles/db_stress.dir/db_stress.cc.o: db_stress_tool/CMakeFiles/db_stress.dir/compiler_depend.ts
88 …Files/db_stress.dir/db_stress_tool.cc.o: db_stress_tool/CMakeFiles/db_stress.dir/compiler_depend.ts
102 …s/db_stress.dir/batched_ops_stress.cc.o: db_stress_tool/CMakeFiles/db_stress.dir/compiler_depend.ts
116 …b_stress.dir/cf_consistency_stress.cc.o: db_stress_tool/CMakeFiles/db_stress.dir/compiler_depend.ts
130 …les/db_stress.dir/db_stress_common.cc.o: db_stress_tool/CMakeFiles/db_stress.dir/compiler_depend.ts
144 …les/db_stress.dir/db_stress_driver.cc.o: db_stress_tool/CMakeFiles/db_stress.dir/compiler_depend.ts
158 …/db_stress.dir/db_stress_test_base.cc.o: db_stress_tool/CMakeFiles/db_stress.dir/compiler_depend.ts
172 …_stress.dir/db_stress_shared_state.cc.o: db_stress_tool/CMakeFiles/db_stress.dir/compiler_depend.ts
186 …les/db_stress.dir/db_stress_gflags.cc.o: db_stress_tool/CMakeFiles/db_stress.dir/compiler_depend.ts
200 …b_stress.dir/no_batched_ops_stress.cc.o: db_stress_tool/CMakeFiles/db_stress.dir/compiler_depend.ts
/rocksdb-6.9/table/
Dget_context.cc276 Slice ts = ExtractTimestampFromUserKey(parsed_key.user_key, ts_sz); in SaveValue() local
277 timestamp_->assign(ts.data(), ts.size()); in SaveValue()
Dmultiget_context.h36 PinnableSlice* val, std::string* ts, Status* stat) in KeyContext()
45 timestamp(ts), in KeyContext()
/rocksdb-6.9/CMakeFiles/db_bench.dir/
Dbuild.make74 CMakeFiles/db_bench.dir/tools/db_bench.cc.o: CMakeFiles/db_bench.dir/compiler_depend.ts
88 CMakeFiles/db_bench.dir/tools/db_bench_tool.cc.o: CMakeFiles/db_bench.dir/compiler_depend.ts
/rocksdb-6.9/file/
Dfilename.cc198 std::string OldInfoLogFileName(const std::string& dbname, uint64_t ts, in OldInfoLogFileName() argument
201 snprintf(buf, sizeof(buf), "%llu", static_cast<unsigned long long>(ts)); in OldInfoLogFileName()
Dfilename.h132 extern std::string OldInfoLogFileName(const std::string& dbname, uint64_t ts,

12