matthiasbeyer/imag
1
0
Fork 0
Code Releases Activity

Fix Store::get()

Browse source
This commit is contained in:
Matthias Beyer 2016-05-27 12:23:26 +02:00
parent 2e80c29f47
commit 19aec6327f
1 changed files with 5 additions and 31 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
libimagstore/src/store.rs
View file

@ -353,38 +353,12 @@ impl Store {
/// Get an entry from the store if it exists. /// Get an entry from the store if it exists.
/// ///
/// This executes the {pre,post}_retrieve_aspects hooks. /// This executes the {pre,post}_retrieve_aspects hooks.
pub fn get<'a, S: IntoStoreId>(&'a self, id: S) -> Result<Option<FileLockEntry<'a>>> pub fn get<'a, S: IntoStoreId + Clone>(&'a self, id: S) -> Result<Option<FileLockEntry<'a>>> {
{ if !self.storify_id(id.clone().into_storeid()).exists() {
let id = self.storify_id(id.into_storeid()); debug!("Does not exist: {:?}", id.clone().into_storeid());
if let Err(e) = self.execute_hooks_for_id(self.pre_retrieve_aspects.clone(), &id) { return Ok(None);
return Err(e);
}
let mut entries = match self.entries.write() {
// Loosing the error here
Err(_) => return Err(SE::new(SEK::LockPoisoned, None)),
Ok(e) => e,
};
let mut se = match entries.get_mut(&id) {
Some(e) => e,
None => return Ok(None),
};
let entry = match se.get_entry() {
Ok(e) => e,
Err(e) => return Err(e),
};
se.status = StoreEntryStatus::Borrowed;
let mut fle = FileLockEntry::new(self, entry, id);
if let Err(e) = self.execute_hooks_for_mut_file(self.post_retrieve_aspects.clone(), &mut fle) {
Err(SE::new(SEK::HookExecutionError, Some(Box::new(e))))
} else {
Ok(Some(fle))
} }
self.retrieve(id).map(Some)
} }
/// Same as `Store::get()` but also tries older versions of the entry, returning an iterator /// Same as `Store::get()` but also tries older versions of the entry, returning an iterator