blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Marked Tvu functionality in Fullnode as unused for now

This commit is contained in:
Carl 2018-09-19 14:42:01 -07:00 committed by Grimes
parent 431692d9d0
commit 55126f5fb6
2 changed files with 5 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/fullnode.rs
View File

@ -81,13 +81,10 @@ pub struct Fullnode {
bank: Arc<Bank>, bank: Arc<Bank>,
crdt: Arc<RwLock<Crdt>>, crdt: Arc<RwLock<Crdt>>,
ledger_path: String, ledger_path: String,
sigverify_disabled: bool,
shared_window: window::SharedWindow, shared_window: window::SharedWindow,
replicate_socket: Vec<UdpSocket>, replicate_socket: Vec<UdpSocket>,
repair_socket: UdpSocket, repair_socket: UdpSocket,
retransmit_socket: UdpSocket, retransmit_socket: UdpSocket,
transaction_sockets: Vec<UdpSocket>,
broadcast_socket: UdpSocket,
requests_socket: UdpSocket, requests_socket: UdpSocket,
respond_socket: UdpSocket, respond_socket: UdpSocket,
} }
@ -348,7 +345,6 @@ impl Fullnode {
crdt, crdt,
shared_window, shared_window,
bank, bank,
sigverify_disabled,
rpu, rpu,
ncp, ncp,
rpc_service, rpc_service,
@ -358,8 +354,6 @@ impl Fullnode {
replicate_socket: node.sockets.replicate, replicate_socket: node.sockets.replicate,
repair_socket: node.sockets.repair, repair_socket: node.sockets.repair,
retransmit_socket: node.sockets.retransmit, retransmit_socket: node.sockets.retransmit,
transaction_sockets: node.sockets.transaction,
broadcast_socket: node.sockets.broadcast,
requests_socket: node.sockets.requests, requests_socket: node.sockets.requests,
respond_socket: node.sockets.respond, respond_socket: node.sockets.respond,
} }

8
src/write_stage.rs
View File

@ -307,7 +307,7 @@ mod tests {
my_id: Pubkey, my_id: Pubkey,
write_stage: WriteStage, write_stage: WriteStage,
entry_sender: Sender<Vec<Entry>>, entry_sender: Sender<Vec<Entry>>,
write_stage_entry_receiver: Receiver<Vec<Entry>>, _write_stage_entry_receiver: Receiver<Vec<Entry>>,
crdt: Arc<RwLock<Crdt>>, crdt: Arc<RwLock<Crdt>>,
bank: Arc<Bank>, bank: Arc<Bank>,
leader_ledger_path: String, leader_ledger_path: String,
@ -345,7 +345,7 @@ mod tests {
let (entry_sender, entry_receiver) = channel(); let (entry_sender, entry_receiver) = channel();
// Start up the write stage // Start up the write stage
let (write_stage, write_stage_entry_receiver) = WriteStage::new( let (write_stage, _write_stage_entry_receiver) = WriteStage::new(
leader_keypair, leader_keypair,
bank.clone(), bank.clone(),
crdt.clone(), crdt.clone(),
@ -358,7 +358,9 @@ mod tests {
my_id, my_id,
write_stage, write_stage,
entry_sender, entry_sender,
write_stage_entry_receiver, // Need to keep this alive, otherwise the write_stage will detect ChannelClosed
// and shut down
_write_stage_entry_receiver,
crdt, crdt,
bank, bank,
leader_ledger_path, leader_ledger_path,