Skip to content

Commit

Permalink
Remove unused forward_worker module (#3128)
Browse files Browse the repository at this point in the history
* Remove unused `forward_worker` module
* Remove `ForwardWork`
  • Loading branch information
KirillLykov authored Oct 14, 2024
1 parent f03bce5 commit 2348429
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 236 deletions.
2 changes: 0 additions & 2 deletions core/src/banking_stage.rs
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,6 @@ pub mod unprocessed_transaction_storage;
mod consume_worker;
mod decision_maker;
mod forward_packet_batches_by_accounts;
mod forward_worker;
mod immutable_deserialized_packet;
mod latest_unprocessed_votes;
mod leader_slot_timing_metrics;
Expand All @@ -74,7 +73,6 @@ mod packet_deserializer;
mod packet_filter;
mod packet_receiver;
mod read_write_account_set;
#[allow(dead_code)]
mod scheduler_messages;
mod transaction_scheduler;

Expand Down
219 changes: 0 additions & 219 deletions core/src/banking_stage/forward_worker.rs

This file was deleted.

16 changes: 1 addition & 15 deletions core/src/banking_stage/scheduler_messages.rs
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
use {
super::immutable_deserialized_packet::ImmutableDeserializedPacket,
solana_sdk::{clock::Slot, transaction::SanitizedTransaction},
std::{fmt::Display, sync::Arc},
std::fmt::Display,
};

/// A unique identifier for a transaction batch.
Expand Down Expand Up @@ -45,22 +44,9 @@ pub struct ConsumeWork {
pub max_age_slots: Vec<Slot>,
}

/// Message: [Scheduler -> Worker]
/// Transactions to be forwarded to the next leader(s)
pub struct ForwardWork {
pub packets: Vec<Arc<ImmutableDeserializedPacket>>,
}

/// Message: [Worker -> Scheduler]
/// Processed transactions.
pub struct FinishedConsumeWork {
pub work: ConsumeWork,
pub retryable_indexes: Vec<usize>,
}

/// Message: [Worker -> Scheduler]
/// Forwarded transactions.
pub struct FinishedForwardWork {
pub work: ForwardWork,
pub successful: bool,
}

0 comments on commit 2348429

Please sign in to comment.