WIP: fix(ci): restore Rust and supply-chain checks on Gitea #117
No files matched your search
@@ -42,6 +42,10 @@ pub struct Controller {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl Controller {
|
impl Controller {
|
||||||
|
#[allow(
|
||||||
|
clippy::too_many_arguments,
|
||||||
|
reason = "Constructor wires the controller channels and shared stream state"
|
||||||
|
)]
|
||||||
pub fn new(
|
pub fn new(
|
||||||
reflector_rx: Receiver<Vec<SocketAddr>>,
|
reflector_rx: Receiver<Vec<SocketAddr>>,
|
||||||
icmp_binding_tx: Sender<Vec<IcmpBinding>>,
|
icmp_binding_tx: Sender<Vec<IcmpBinding>>,
|
||||||
|
|||||||
@@ -150,6 +150,10 @@ pub struct Ratecontroller<S: InterfaceStatsProvider, T: TrafficControlBackend> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl<S: InterfaceStatsProvider, T: TrafficControlBackend> Ratecontroller<S, T> {
|
impl<S: InterfaceStatsProvider, T: TrafficControlBackend> Ratecontroller<S, T> {
|
||||||
|
#[allow(
|
||||||
|
clippy::too_many_arguments,
|
||||||
|
reason = "Constructor injects independent runtime and test backends"
|
||||||
|
)]
|
||||||
fn new_with_backends(
|
fn new_with_backends(
|
||||||
settings: Settings,
|
settings: Settings,
|
||||||
control_snapshot_rx: Receiver<ControlSnapshot>,
|
control_snapshot_rx: Receiver<ControlSnapshot>,
|
||||||
|
|||||||
@@ -235,7 +235,7 @@ impl ReflectorSelector {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Sort the candidates table now by ascending RTT
|
// Sort the candidates table now by ascending RTT
|
||||||
candidates.sort_by(|a, b| a.1.cmp(&b.1));
|
candidates.sort_by_key(|candidate| candidate.1);
|
||||||
|
|
||||||
// Now we will just limit the candidates down to 2 * num_reflectors
|
// Now we will just limit the candidates down to 2 * num_reflectors
|
||||||
let num_reflectors = self.settings.reflectors.num_reflectors;
|
let num_reflectors = self.settings.reflectors.num_reflectors;
|
||||||
|
|||||||
Reference in new issue
Block a user