WEBDIENSTE/NLnetLabs-krill
1
0
Fork 0
mirror of https://github.com/NLnetLabs/krill.git synced 2026-09-28 12:24:52 +02:00
Code Issues Packages Projects Releases Wiki Activity

Don't apply a limit when getting latest aggregate.

Browse Source
This commit is contained in:
Tim Bruijnzeels
2022-02-23 14:17:18 +01:00
parent b047f5cfa3
commit 2d5a87e216
1 changed files with 2 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/commons/eventsourcing/store.rs
+2 -9
View File
@@ -640,15 +640,8 @@ where
fn get_latest_no_lock(&self, handle: &Handle) -> StoreResult<Arc<A>> {
trace!("Trying to load aggregate id: {}", handle);
let info_key = Self::key_for_info(handle);
let limit = self
.kv
.get::<StoredValueInfo>(&info_key)
.map_err(|_| AggregateStoreError::InfoCorrupt(handle.clone()))?
.map(|info| info.last_event);
match self.cache_get(handle) {
None => match self.get_aggregate(handle, limit)? {
None => match self.get_aggregate(handle, None)? {
None => {
error!("Could not load aggregate with id: {} from disk", handle);
Err(AggregateStoreError::UnknownAggregate(handle.clone()))
@@ -663,7 +656,7 @@ where
Some(mut arc) => {
if self.has_updates(handle, &arc)? {
let agg = Arc::make_mut(&mut arc);
self.update_aggregate(handle, agg, limit)?;
self.update_aggregate(handle, agg, None)?;
}
trace!("Loaded aggregate id: {} from memory", handle);
Ok(arc)