rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-21 15:30:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

release dashmap reference

Browse Source 
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
This commit is contained in:
Ruihang Xia
2026-05-16 12:49:23 +08:00
parent 226a02e6de
commit 8029580d64
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/mito2/src/cache.rs
View File

@@ -1245,7 +1245,10 @@ impl PageRangeCache {
.inc();
let group_key = key.group_key();
if let Some(group) = eviction_index.get(&group_key).map(|group| group.clone()) {
if let Some(group) = eviction_index
.get(&group_key)
.map(|group| Arc::clone(group.value()))
{
let mut ranges = group.write().unwrap();
ranges.remove(&(key.start, key.end));
if ranges.is_empty() {
@@ -1274,7 +1277,10 @@ impl PageRangeCache {
row_group_idx,
};
let group = self.index.get(&group_key);
let group = self
.index
.get(&group_key)
.map(|group| Arc::clone(group.value()));
for range in ranges {
if range.start >= range.end {
cached_parts.push(Vec::new());
@@ -1282,7 +1288,7 @@ impl PageRangeCache {
}
let mut parts = Vec::new();
if let Some(group) = group.as_ref() {
if let Some(group) = &group {
let index = group.read().unwrap();
// A simple first-stage interval lookup: inspect fragments whose start is before
// the requested end and keep those that overlap the requested range.