Ecosystem/gupaxx
1
0
Fork 0
mirror of https://github.com/Cyrix126/gupaxx.git synced 2025-03-24 16:18:55 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: remove deprecated test for detecting share

Browse source
This commit is contained in:
Cyrix126 2024-03-25 22:47:52 +01:00
parent 46284c61b5
commit f87a9e5b99
1 changed files with 2 additions and 81 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

83
src/helper/xvb.rs
View file

@ -962,17 +962,15 @@ mod test {
// }; // };
use std::{ use std::{
path::PathBuf,
sync::{Arc, Mutex}, sync::{Arc, Mutex},
thread, thread,
time::Duration,
}; };
use crate::{ use crate::{
disk::state::{P2pool, Xvb}, disk::state::{P2pool, Xvb},
helper::{p2pool::PubP2poolApi, xmrig::PubXmrigApi, xvb::XvbRound, Process, ProcessState}, helper::{p2pool::PubP2poolApi, xmrig::PubXmrigApi, xvb::XvbRound},
macros::lock, macros::lock,
TIME_PPLNS_WINDOW_MINI, XVB_TIME_ALGO, XVB_TIME_ALGO,
}; };
use super::{PubXvbApi, XvbPrivStats, XvbPubStats}; use super::{PubXvbApi, XvbPrivStats, XvbPubStats};
@ -1211,83 +1209,6 @@ mod test {
Some(XvbRound::DonorMega) Some(XvbRound::DonorMega)
); );
} }
#[test]
fn detect_new_share() {
let gui_api_p2pool = Arc::new(Mutex::new(PubP2poolApi::new()));
let mut state_p2pool = P2pool::default();
state_p2pool.mini = true;
// verify that when no new share is found, share is false
let mut last_share = None;
let mut nb_old_share = 0;
lock!(gui_api_p2pool).shares_found = Some(0);
let (share, new_time) = lock!(gui_api_p2pool).is_share_present_in_ppplns_window(
&mut nb_old_share,
last_share,
state_p2pool.mini,
);
if let Some(n) = new_time {
last_share = Some(n);
}
dbg!(&last_share);
dbg!(&nb_old_share);
assert!(!share);
// verify that if a new share is found, it is detected.
lock!(gui_api_p2pool).shares_found = Some(1);
let (share, new_time) = lock!(gui_api_p2pool).is_share_present_in_ppplns_window(
&mut nb_old_share,
last_share,
state_p2pool.mini,
);
if let Some(n) = new_time {
last_share = Some(n);
}
dbg!(&last_share);
dbg!(&nb_old_share);
assert!(share);
// verify that if a new share is found after another one, it is detected.
last_share = Some(last_share.unwrap() + Duration::from_secs(1));
lock!(gui_api_p2pool).shares_found = Some(2);
let (share, new_time) = lock!(gui_api_p2pool).is_share_present_in_ppplns_window(
&mut nb_old_share,
last_share,
state_p2pool.mini,
);
if let Some(n) = new_time {
last_share = Some(n);
}
dbg!(&last_share);
dbg!(&nb_old_share);
assert!(share);
// verify that the last share is still valid because not enough time has passed.
last_share = Some(last_share.unwrap() + Duration::from_secs(1));
let (share, new_time) = lock!(gui_api_p2pool).is_share_present_in_ppplns_window(
&mut nb_old_share,
last_share,
state_p2pool.mini,
);
if let Some(n) = new_time {
last_share = Some(n);
}
dbg!(&last_share);
dbg!(&nb_old_share);
assert!(share);
// verify that share is no more valid after window time if no new share was found.
last_share = Some(last_share.unwrap() + TIME_PPLNS_WINDOW_MINI);
let (share, new_time) = lock!(gui_api_p2pool).is_share_present_in_ppplns_window(
&mut nb_old_share,
last_share,
state_p2pool.mini,
);
dbg!(&new_time);
if let Some(n) = new_time {
last_share = Some(n);
}
dbg!(&last_share);
dbg!(&nb_old_share);
assert!(!share);
}
// #[tokio::main] // #[tokio::main]
// async fn algo(share: bool, xvb_time_algo: u32) -> XvbPubStats { // async fn algo(share: bool, xvb_time_algo: u32) -> XvbPubStats {
// XvbPubStats::request_api(&client).await.unwrap() // XvbPubStats::request_api(&client).await.unwrap()