rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-08 14:02:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

[refer #190] Refectoring based on the reviews

Browse Source
This commit is contained in:
Konstantin Knizhnik
2021-05-27 10:11:01 +03:00
parent e6926d1794
commit 736d387f7b
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pageserver/src/repository/rocksdb.rs
View File

@@ -489,7 +489,7 @@ impl RocksTimeline {
}
///
/// Drop relations with all its forks or non-relational file
/// Drop relations with all its forks
///
fn delete_entries(&self, tag: BufferTag) -> Result<()> {
let mut iter = self.db.raw_iterator();
@@ -508,14 +508,8 @@ impl RocksTimeline {
iter.seek_for_prev(key.ser()?);
while iter.valid() {
let key = CacheKey::des(iter.key().unwrap())?;
// For relational data we should delete all block
if key.tag.rel.relnode != tag.rel.relnode
|| key.tag.rel.spcnode != tag.rel.spcnode
|| key.tag.rel.dbnode != tag.rel.dbnode
|| (key.tag.rel.forknum != tag.rel.forknum
&& tag.rel.forknum != pg_constants::MAIN_FORKNUM)
{
// no more entries belonging to this relation or file
if key.tag.rel != tag.rel {
// no more entries belonging to this relation
break;
}
let v = iter.value().unwrap();