refactor(main): Make reflector pool configurable
This commit is contained in:
1 file changed
+2
-2
+2
-2
@@ -61,7 +61,7 @@ fn main() -> anyhow::Result<()> {
|
|||||||
IpAddr::from_str("94.140.14.14")?,
|
IpAddr::from_str("94.140.14.14")?,
|
||||||
];
|
];
|
||||||
|
|
||||||
match reflector_pool_size > 5 {
|
match reflector_pool_size > config.num_reflectors as usize {
|
||||||
true => {
|
true => {
|
||||||
let mut peers = reflector_peers_lock.write().unwrap();
|
let mut peers = reflector_peers_lock.write().unwrap();
|
||||||
peers.append(default_reflectors.to_vec().as_mut());
|
peers.append(default_reflectors.to_vec().as_mut());
|
||||||
@@ -145,7 +145,7 @@ fn main() -> anyhow::Result<()> {
|
|||||||
|
|
||||||
let mut threads = vec![receiver_handle, sender_handle, baseliner_handle];
|
let mut threads = vec![receiver_handle, sender_handle, baseliner_handle];
|
||||||
|
|
||||||
if reflector_pool_size > 5 {
|
if reflector_pool_size > config.num_reflectors as usize {
|
||||||
let reflector_selector = ReflectorSelector {
|
let reflector_selector = ReflectorSelector {
|
||||||
config: config.clone(),
|
config: config.clone(),
|
||||||
owd_recent: owd_recent.clone(),
|
owd_recent: owd_recent.clone(),
|
||||||
|
|||||||
Reference in new issue
Block a user