Align Tpu::new() and Tpu::switch_to_leader() arguments
This commit is contained in:
@ -282,14 +282,14 @@ impl Fullnode {
|
|||||||
.try_clone()
|
.try_clone()
|
||||||
.expect("Failed to clone broadcast socket"),
|
.expect("Failed to clone broadcast socket"),
|
||||||
cluster_info.clone(),
|
cluster_info.clone(),
|
||||||
blob_index,
|
|
||||||
config.sigverify_disabled,
|
config.sigverify_disabled,
|
||||||
max_tpu_tick_height,
|
max_tpu_tick_height,
|
||||||
|
blob_index,
|
||||||
&last_entry_id,
|
&last_entry_id,
|
||||||
id,
|
id,
|
||||||
scheduled_leader == id,
|
|
||||||
&to_validator_sender,
|
&to_validator_sender,
|
||||||
&blob_sender,
|
&blob_sender,
|
||||||
|
scheduled_leader == id,
|
||||||
);
|
);
|
||||||
|
|
||||||
inc_new_counter_info!("fullnode-new", 1);
|
inc_new_counter_info!("fullnode-new", 1);
|
||||||
|
@ -81,14 +81,14 @@ impl Tpu {
|
|||||||
transactions_sockets: Vec<UdpSocket>,
|
transactions_sockets: Vec<UdpSocket>,
|
||||||
broadcast_socket: UdpSocket,
|
broadcast_socket: UdpSocket,
|
||||||
cluster_info: Arc<RwLock<ClusterInfo>>,
|
cluster_info: Arc<RwLock<ClusterInfo>>,
|
||||||
blob_index: u64,
|
|
||||||
sigverify_disabled: bool,
|
sigverify_disabled: bool,
|
||||||
max_tick_height: u64,
|
max_tick_height: u64,
|
||||||
|
blob_index: u64,
|
||||||
last_entry_id: &Hash,
|
last_entry_id: &Hash,
|
||||||
leader_id: Pubkey,
|
leader_id: Pubkey,
|
||||||
is_leader: bool,
|
|
||||||
to_validator_sender: &TpuRotationSender,
|
to_validator_sender: &TpuRotationSender,
|
||||||
blob_sender: &BlobSender,
|
blob_sender: &BlobSender,
|
||||||
|
is_leader: bool,
|
||||||
) -> Self {
|
) -> Self {
|
||||||
let mut tpu = Self {
|
let mut tpu = Self {
|
||||||
tpu_mode: None,
|
tpu_mode: None,
|
||||||
|
Reference in New Issue
Block a user