gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Let server own the bank, not TPU/RPU

Browse Source
This commit is contained in:
Greg Fitzgerald
2018-05-15 11:21:40 -06:00
parent 3f38c0a245
commit 5855e18a4e
3 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/rpu.rs
View File

@ -25,7 +25,7 @@ pub struct Rpu {
impl Rpu { impl Rpu {
pub fn new<W: Write + Send + 'static>( pub fn new<W: Write + Send + 'static>(
bank: Bank, bank: Arc<Bank>,
start_hash: Hash, start_hash: Hash,
tick_duration: Option<Duration>, tick_duration: Option<Duration>,
me: ReplicatedData, me: ReplicatedData,
@ -36,8 +36,6 @@ impl Rpu {
exit: Arc<AtomicBool>, exit: Arc<AtomicBool>,
writer: W, writer: W,
) -> Self { ) -> Self {
let bank = Arc::new(bank);
let packet_recycler = packet::PacketRecycler::default(); let packet_recycler = packet::PacketRecycler::default();
let (packet_sender, packet_receiver) = channel(); let (packet_sender, packet_receiver) = channel();
let t_receiver = streamer::receiver( let t_receiver = streamer::receiver(

3
src/server.rs
View File

@ -29,8 +29,9 @@ impl Server {
exit: Arc<AtomicBool>, exit: Arc<AtomicBool>,
writer: W, writer: W,
) -> Self { ) -> Self {
let bank = Arc::new(bank);
let rpu = Rpu::new( let rpu = Rpu::new(
bank, bank.clone(),
start_hash, start_hash,
tick_duration, tick_duration,
me, me,

4
src/tpu.rs
View File

@ -24,7 +24,7 @@ pub struct Tpu {
impl Tpu { impl Tpu {
pub fn new<W: Write + Send + 'static>( pub fn new<W: Write + Send + 'static>(
bank: Bank, bank: Arc<Bank>,
start_hash: Hash, start_hash: Hash,
tick_duration: Option<Duration>, tick_duration: Option<Duration>,
me: ReplicatedData, me: ReplicatedData,
@ -34,8 +34,6 @@ impl Tpu {
exit: Arc<AtomicBool>, exit: Arc<AtomicBool>,
writer: W, writer: W,
) -> Self { ) -> Self {
let bank = Arc::new(bank);
let packet_recycler = packet::PacketRecycler::default(); let packet_recycler = packet::PacketRecycler::default();
let (packet_sender, packet_receiver) = channel(); let (packet_sender, packet_receiver) = channel();
let t_receiver = streamer::receiver( let t_receiver = streamer::receiver(