Home
last modified time | relevance | path

Searched refs:timestamp (Results 1 – 25 of 41) sorted by relevance

12

/rocksdb-6.9/utilities/cassandra/
Dtest_utils.cc19 int64_t timestamp) { in CreateTestColumn() argument
22 new Tombstone(mask, index, ToSeconds(timestamp), timestamp)); in CreateTestColumn()
25 mask, index, timestamp, sizeof(kExpiringData), kExpiringData, kTtl)); in CreateTestColumn()
28 new Column(mask, index, timestamp, sizeof(kData), kData)); in CreateTestColumn()
34 int64_t timestamp) { in CreateTestColumnSpec() argument
35 return std::make_tuple(mask, index, timestamp); in CreateTestColumnSpec()
51 RowValue CreateRowTombstone(int64_t timestamp) { in CreateRowTombstone() argument
52 return RowValue(ToSeconds(timestamp), timestamp); in CreateRowTombstone()
Dformat.cc58 int64_t timestamp, in Column() argument
61 ) : ColumnBase(mask, index), timestamp_(timestamp), in Column()
86 int64_t timestamp = in Deserialize() local
88 offset += sizeof(timestamp); in Deserialize()
93 mask, index, timestamp, value_size, src + offset); in Deserialize()
99 int64_t timestamp, in ExpiringColumn() argument
103 ) : Column(mask, index, timestamp, value_size, value), in ExpiringColumn()
147 int64_t timestamp = in Deserialize() local
149 offset += sizeof(timestamp); in Deserialize()
157 mask, index, timestamp, value_size, value, ttl); in Deserialize()
Dcassandra_format_test.cc22 int64_t timestamp = 1494022807044; in TEST() local
23 Column c = Column(mask, index, timestamp, sizeof(data), data); in TEST()
26 EXPECT_EQ(c.Timestamp(), timestamp); in TEST()
40 EXPECT_EQ(Deserialize<int64_t>(dest.c_str(), offset), timestamp); in TEST()
50 EXPECT_EQ(c1->Timestamp(), timestamp); in TEST()
73 int64_t timestamp = 1494022807044; in TEST() local
75 ExpiringColumn c = ExpiringColumn(mask, index, timestamp, in TEST()
79 EXPECT_EQ(c.Timestamp(), timestamp); in TEST()
93 EXPECT_EQ(Deserialize<int64_t>(dest.c_str(), offset), timestamp); in TEST()
106 EXPECT_EQ(c1->Timestamp(), timestamp); in TEST()
Dtest_utils.h24 int64_t timestamp);
28 int64_t timestamp);
33 RowValue CreateRowTombstone(int64_t timestamp);
Dformat.h95 Column(int8_t mask, int8_t index, int64_t timestamp,
129 ExpiringColumn(int8_t mask, int8_t index, int64_t timestamp,
/rocksdb-6.9/monitoring/
Dpersistent_stats_history.cc60 char timestamp[kNowSecondsStringLength + 1]; in EncodePersistentStatsKey() local
62 snprintf(timestamp, sizeof(timestamp), "%010d", in EncodePersistentStatsKey()
64 timestamp[kNowSecondsStringLength] = '\0'; in EncodePersistentStatsKey()
65 return snprintf(buf, size, "%s#%s", timestamp, key.c_str()); in EncodePersistentStatsKey()
129 char timestamp[kNowSecondsStringLength + 1]; in AdvanceIteratorByTime() local
130 snprintf(timestamp, sizeof(timestamp), "%010d", in AdvanceIteratorByTime()
132 timestamp[kNowSecondsStringLength] = '\0'; in AdvanceIteratorByTime()
134 iter->Seek(timestamp); in AdvanceIteratorByTime()
Dpersistent_stats_history.h36 int EncodePersistentStatsKey(uint64_t timestamp, const std::string& key,
/rocksdb-6.9/db/
Ddb_with_timestamp_basic_test.cc315 write_opts.timestamp = &ts; in TEST_F()
323 read_opts.timestamp = &ts; in TEST_F()
352 write_opts.timestamp = &ts; in TEST_F()
370 read_opts.timestamp = &ts; in TEST_F()
396 write_opts.timestamp = &ts; in TEST_F()
402 write_opts.timestamp = &ts; in TEST_F()
411 read_opts.timestamp = &ts; in TEST_F()
476 wopts.timestamp = &write_ts; in TEST_P()
586 std::string timestamp; in TEST_P() local
590 ropts.timestamp = &read_ts; in TEST_P()
[all …]
Dmemtable_list.h61 bool Get(const LookupKey& key, std::string* value, std::string* timestamp,
67 bool Get(const LookupKey& key, std::string* value, std::string* timestamp,
73 return Get(key, value, timestamp, s, merge_context,
93 std::string* timestamp, Status* s,
99 std::string* timestamp, Status* s,
105 return GetFromHistory(key, value, timestamp, s, merge_context,
154 std::string* value, std::string* timestamp, Status* s,
Dmemtable.h221 bool Get(const LookupKey& key, std::string* value, std::string* timestamp,
227 bool Get(const LookupKey& key, std::string* value, std::string* timestamp,
233 return Get(key, value, timestamp, s, merge_context,
546 std::string* value, std::string* timestamp, Status* s,
Dmemtable.cc603 std::string* timestamp; member
720 if (ts_sz > 0 && s->timestamp != nullptr) { in SaveValue()
722 s->timestamp->assign(ts.data(), ts.size()); in SaveValue()
779 std::string* timestamp, Status* s, in Get() argument
828 is_blob_index, value, timestamp, s, merge_context, seq, in Get()
844 std::string* timestamp, Status* s, in GetFromTable() argument
853 saver.timestamp = timestamp; in GetFromTable()
922 callback, is_blob, iter->value->GetSelf(), iter->timestamp, in MultiGet()
Dmemtable_list.cc107 std::string* timestamp, Status* s, in Get() argument
112 return GetFromList(&memlist_, key, value, timestamp, s, merge_context, in Get()
143 const LookupKey& key, std::string* value, std::string* timestamp, Status* s, in GetFromHistory() argument
146 return GetFromList(&memlist_history_, key, value, timestamp, s, merge_context, in GetFromHistory()
153 std::string* timestamp, Status* s, MergeContext* merge_context, in GetFromList() argument
161 bool done = memtable->Get(key, value, timestamp, s, merge_context, in GetFromList()
Darena_wrapped_db_iter.h65 Slice timestamp() const override { return db_iter_->timestamp(); } in timestamp() function
/rocksdb-6.9/tools/advisor/test/
Dtest_db_stats_fetcher.py29 timestamp = int(token.split()[0])
31 self.stats_dict[NO_ENTITY][stat_name][timestamp] = value
111 timestamp = int(time.time())
117 perf_ts[key][timestamp+(ix*10)] = start_val + (2 * ix * ix)
119 timestamps = [timestamp+(ix*10) for ix in range(1, 5, 1)]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DBackupInfo.java22 BackupInfo(final int backupId, final long timestamp, final long size, final int numberFiles, in BackupInfo() argument
25 timestamp_ = timestamp; in BackupInfo()
43 public long timestamp() { in timestamp() method in BackupInfo
/rocksdb-6.9/tools/advisor/advisor/
Ddb_log_parser.py77 timestamp = timegm(time.strptime(hr_time, "%Y/%m/%d-%H:%M:%S.%f%Z"))
78 return timestamp
Ddb_bench_runner.py103 timestamp = int(time.time())
107 timestamp: int(perf_context[stat])
/rocksdb-6.9/include/rocksdb/
Doptions.h1342 const Slice* timestamp; member
1414 const Slice* timestamp; member
1423 timestamp(nullptr) {} in WriteOptions()
Ddb.h422 std::string* value, std::string* timestamp) { in Get() argument
426 auto s = Get(options, column_family, key, &pinnable_val, timestamp); in Get()
440 std::string* value, std::string* timestamp) { in Get() argument
441 return Get(options, DefaultColumnFamily(), key, value, timestamp); in Get()
660 std::string* value, std::string* timestamp,
662 return KeyMayExist(options, DefaultColumnFamily(), key, value, timestamp,
Diterator.h116 virtual Slice timestamp() const { in timestamp() function
/rocksdb-6.9/table/
Dmultiget_context.h32 std::string* timestamp; member
45 timestamp(ts), in KeyContext()
Dget_context.cc44 PinnableSlice* pinnable_val, std::string* timestamp, bool* value_found, in GetContext() argument
56 timestamp_(timestamp), in GetContext()
/rocksdb-6.9/include/rocksdb/utilities/
Dbackupable_db.h180 int64_t timestamp; member
191 timestamp(_timestamp), in BackupInfo()
/rocksdb-6.9/db/db_impl/
Ddb_impl.cc1517 PinnableSlice* value, std::string* timestamp) { in Get() argument
1521 get_impl_options.timestamp = timestamp; in Get()
1601 LookupKey lkey(key, snapshot, read_options.timestamp); in GetImpl()
1610 std::string* timestamp = ts_sz > 0 ? get_impl_options.timestamp : nullptr; in GetImpl() local
1623 timestamp, &s, &merge_context, in GetImpl()
1655 read_options, lkey, get_impl_options.value, timestamp, &s, in GetImpl()
1765 std::string* timestamp = timestamps ? &(*timestamps)[i] : nullptr; in MultiGet() local
1767 LookupKey lkey(keys[i], consistent_seqnum, read_options.timestamp); in MultiGet()
1784 lkey, value, timestamp, &s, &merge_context, in MultiGet()
2497 std::string* value, std::string* timestamp, in KeyMayExist() argument
[all …]
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_trace_analyzer.cc876 const uint64_t timestamp = naccess.first / time_unit; in WriteAccessTimeline() local
878 label_access_timeline[label][timestamp] += num; in WriteAccessTimeline()
879 start_time = std::min(start_time, timestamp); in WriteAccessTimeline()
880 end_time = std::max(end_time, timestamp); in WriteAccessTimeline()
1027 const uint64_t timestamp = it->first; in UpdateReuseIntervalStats() local
1029 const uint64_t reuse_interval = timestamp - prev_timestamp; in UpdateReuseIntervalStats()
1034 prev_timestamp = timestamp; in UpdateReuseIntervalStats()
1200 const uint64_t timestamp = timeline.first; in WriteBlockReuseTimeline() local
1202 timestamp - trace_start_timestamp_in_seconds_; in WriteBlockReuseTimeline()

12