mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-24 18:40:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

convert the code that writes the partition key to file to threads

Browse Source 
Signed-off-by: Glauber Costa <glommer@cloudius-systems.com>
This commit is contained in:
Glauber Costa
2015-06-04 14:14:01 -04:00
parent a1f4eb9601
commit 9ee588bc49
1 changed files with 22 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
sstables/sstables.cc
View File

@@ -1346,6 +1346,28 @@ void sstable::do_write_components(const memtable& mt) {
// Write index file entry from partition key into index file.
write_index_entry_t(*index, p_key, w->offset());
// Write partition key into data file.
write(*w, p_key).get();
auto tombstone = partition_entry.second.partition_tombstone();
deletion_time d;
if (tombstone) {
d.local_deletion_time = tombstone.deletion_time.time_since_epoch().count();
d.marked_for_delete_at = tombstone.timestamp;
_c_stats.tombstone_histogram.update(d.local_deletion_time);
_c_stats.update_max_local_deletion_time(d.local_deletion_time);
_c_stats.update_min_timestamp(d.marked_for_delete_at);
_c_stats.update_max_timestamp(d.marked_for_delete_at);
} else {
// Default values for live, undeleted rows.
d.local_deletion_time = std::numeric_limits<int32_t>::max();
d.marked_for_delete_at = std::numeric_limits<int64_t>::min();
}
write(*w, d).get();
}
w->close().get();