Sasedev/khadhroony-solana-project
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v0.3.13-pre.008-fix.001

Browse Source
This commit is contained in:
SinuS von SifriduS
2026-09-10 17:55:46 +02:00
parent 1f2720463b
commit 9bb2f7bcae
3 changed files with 91 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
crates/ksp-worker-raw-transaction-ingest-lib/src/persistence.rs
View File

@@ -1,5 +1,5 @@
// file: crates/ksp-worker-raw-transaction-ingest-lib/src/persistence.rs
// version: 2
// version: 3
/// Canonical entity disposition produced by one Worker Store persistence attempt.
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
@@ -182,7 +182,7 @@ where
let entry = convergence.entry(key);
let entry = match entry {
std::option::Option::Some(value) => value,
std::option::Option::None => return persist_raw_transaction_ingest_acquisition(port, acquisition).await,
std::option::Option::None => return crate::persist_raw_transaction_ingest_acquisition(port, acquisition).await,
};
let mut known_hash = entry.lock().await;
if let std::option::Option::Some(known_hash_value) = *known_hash {
@@ -196,7 +196,7 @@ where
std::result::Result::Err(error) => map_store_error(error),
};
}
let outcome = persist_raw_transaction_ingest_acquisition(port, acquisition).await;
let outcome = crate::persist_raw_transaction_ingest_acquisition(port, acquisition).await;
let outcome = match outcome {
std::result::Result::Ok(value) => value,
std::result::Result::Err(error) => return std::result::Result::Err(error),
@@ -259,6 +259,7 @@ fn map_additional_observation_outcome(
ksp_store_lib::RawObservationWriteOutcome::NotRecorded => {
std::result::Result::Err(crate::runtime_error("persistence.additional_observation_not_recorded"))
},
_ => std::result::Result::Err(crate::runtime_error("persistence.additional_observation_outcome_invalid")),
};
}