diff --git a/src/ipv4.rs b/src/ipv4.rs index e53ace9..4a26e14 100644 --- a/src/ipv4.rs +++ b/src/ipv4.rs @@ -33,7 +33,7 @@ impl IPv4 { } // Reverse it so that we start from the top - // ip = ip.into_iter().rev().collect(); + ip = ip.into_iter().rev().collect(); // convert to array let ip: [u8; 4] = ip @@ -57,7 +57,7 @@ impl IPv4 { } } -#[derive(Debug)] +#[derive(Debug, Clone)] pub struct IPv4Range { pub id_start: u32, pub id_end: u32, @@ -66,7 +66,6 @@ pub struct IPv4Range { impl IPv4Range { pub fn new(from: u32, to: u32, id_ignore: Option>) -> Self { - let to = to.clamp(0, u32::max_value()); let id_ignore = id_ignore.unwrap_or(Vec::new()); if from > to { @@ -84,6 +83,8 @@ impl IPv4Range { let cidr = Ipv4Cidr::from_str(cidr_string).unwrap(); let (from, to) = (cidr.first(), cidr.last()); // TODO: fix forgotten "constants" + println!("############### {} {}", from, to); + println!("{:?}", cidr.last_as_u8_array()); Self::new(from, to, id_ignore) diff --git a/src/scanner.rs b/src/scanner.rs index 8811095..7fc9f2a 100644 --- a/src/scanner.rs +++ b/src/scanner.rs @@ -6,6 +6,7 @@ use std::thread::JoinHandle; use std::{panic, thread}; fn tcp_scan(mut target: IPv4, target_port: u16) -> bool { + debug!("Starting scan on {:?}", target); let dest = target .to_socketaddr(target_port) .unwrap_or_else(|e| panic!("{}", e)); @@ -38,14 +39,17 @@ fn create_scan_thread(ip_range: IPv4Range, target_port: u16) -> JoinHandle, ) -> JoinHandle> { + + let ignorelist = range.id_ignore; + let (f, t) = ( - (thread_id * ips_per_thread), - ((thread_id + 1) * ips_per_thread - 1), + (thread_id * ips_per_thread) + range.id_start as u64, + ((thread_id + 1) * ips_per_thread - 1) + range.id_end as u64, ); let range = IPv4Range::new(f as u32, t as u32, Some(ignorelist)); create_scan_thread(range, target_port) @@ -67,10 +71,10 @@ fn get_scan_workers( // TODO: make last thread do the "ips_left" work debug!("Creating scan workers..."); for thread_id in 0..num_threads { - let id_ignorelist = range.id_ignore.clone(); + let range_copy = range.clone(); // Create a worker - let worker = create_scan_worker(thread_id, ips_per_thread, target_port, id_ignorelist); + let worker = create_scan_worker(range_copy, thread_id, ips_per_thread, target_port); threads.push(worker); } @@ -82,12 +86,11 @@ fn get_scan_workers( // Clean up the rest warn!("Number of IPv4 addresses is not divisible by the amount of threads! Creating extra thread..."); - let id_ignorelist = range.id_ignore.clone(); let worker = create_scan_worker( + range, threads.len() as u64 + 1, ips_left, - target_port, - id_ignorelist, + target_port ); threads.push(worker); };