Skip to content

Commit

Permalink
remove unnesary changes
Browse files Browse the repository at this point in the history
  • Loading branch information
davemarco committed Jan 30, 2025
1 parent faecdf9 commit 5d7aa3b
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 17 deletions.
3 changes: 1 addition & 2 deletions components/core/src/clp/streaming_archive/writer/Archive.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -563,6 +563,7 @@ void Archive::persist_file_metadata(vector<File*> const& files) {

m_metadata_db.update_files(files);

// Mark files' metadata as clean
for (auto file : files) {
file->mark_metadata_as_clean();
}
Expand All @@ -580,7 +581,6 @@ void Archive::close_segment_and_persist_file_metadata(

segment.close();

// Want to keep this
m_local_metadata->increment_static_compressed_size(segment.get_compressed_size());

#if FLUSH_TO_DISK_ENABLED
Expand All @@ -600,7 +600,6 @@ void Archive::close_segment_and_persist_file_metadata(
}

persist_file_metadata(files);
m_files.emplace_back(files);
update_metadata();

for (auto file : files) {
Expand Down
15 changes: 0 additions & 15 deletions components/core/src/clp/streaming_archive/writer/Archive.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -279,18 +279,6 @@ class Archive {
*/
void update_metadata();

std::unique_ptr<MetadataDB::FileIterator> get_file_iterator() {
return m_metadata_db.get_file_iterator(
cEpochTimeMin,
cEpochTimeMax,
"",
"",
false,
cInvalidSegmentId,
false
);
}

// Variables
boost::uuids::uuid m_id;
std::string m_id_as_string;
Expand Down Expand Up @@ -328,9 +316,6 @@ class Archive {
std::vector<File*> m_files_with_timestamps_in_segment;
std::vector<File*> m_files_without_timestamps_in_segment;

// Holds all files in the archive.
std::vector<File*> m_files;

size_t m_target_segment_uncompressed_size;
Segment m_segment_for_files_with_timestamps;
ArrayBackedPosIntSet<logtype_dictionary_id_t>
Expand Down

0 comments on commit 5d7aa3b

Please sign in to comment.