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

v0.3.14-pre.002-fix.001

Browse Source
This commit is contained in:
SinuS von SifriduS
2026-09-11 20:00:56 +02:00
parent b2068e9ef2
commit 5932250314
4 changed files with 210 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1,5 +1,5 @@
// file: crates/ksp-worker-raw-transaction-ingest-lib/src/continuity.rs
// version: 1
// version: 2
/// Maximum number of simultaneously retained non-repaired run-local gaps.
pub(crate) const MAX_RAW_TRANSACTION_INGEST_OPEN_REPAIR_GAPS: usize = 64;
@@ -206,8 +206,9 @@ impl RawTransactionIngestGapLedger {
if !RawTransactionIngestGapReason::ALL.contains(&gap.reason) || !RawTransactionIngestGapState::ALL.contains(&gap.state) {
return std::result::Result::Err(crate::runtime_error("continuity.gap_catalog_invalid"));
}
if gap.range.start_slot() > gap.range.end_slot() {
return std::result::Result::Err(crate::runtime_error("continuity.gap_range_reversed"));
let range_validation = RawTransactionIngestGapRange::new(gap.range.start_slot(), gap.range.end_slot());
if let std::result::Result::Err(error) = range_validation {
return std::result::Result::Err(error);
}
}
if open_gap_count > crate::MAX_RAW_TRANSACTION_INGEST_OPEN_REPAIR_GAPS {

3
crates/ksp-worker-raw-transaction-ingest-lib/src/runtime_resources.rs
View File

@@ -1,5 +1,5 @@
// file: crates/ksp-worker-raw-transaction-ingest-lib/src/runtime_resources.rs
// version: 27
// version: 28
use sha2::Digest; // rust-rules: trait-import
@@ -2794,7 +2794,6 @@ fn standard_logs_live_source_key(
fn yellowstone_coverage_scope_fingerprint(request: &ksp_onchain_transport_lib::YellowstoneSubscribeRequest) -> ksp_core_lib::Result<[u8; 32]> {
let mut normalized = request.clone();
normalized.set_commitment(std::option::Option::None);
normalized.set_from_slot(std::option::Option::None);
normalized.set_ping(std::option::Option::None);
let identity = match normalized.identity() {
std::result::Result::Ok(value) => value,