github/dndx-phantun
1
0
Fork 0
mirror of https://github.com/dndx/phantun.git synced 2025-04-20 18:59:29 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

First try new port in fake-tcp stack connect

Browse Source
This commit is contained in:
Saber Haj Rabiee 2022-11-10 16:20:44 -08:00
parent 65e200b1f2
commit 40af62d14a
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
fake-tcp/src/lib.rs
View File

@ -51,7 +51,7 @@ use pnet::packet::{tcp, Packet};
use std::collections::HashMap; use std::collections::HashMap;
use std::fmt; use std::fmt;
use std::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr}; use std::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr};
use std::sync::atomic::{AtomicU32, AtomicUsize, Ordering}; use std::sync::atomic::{AtomicU16, AtomicU32, AtomicUsize, Ordering};
use std::sync::Arc; use std::sync::Arc;
use tokio::sync::broadcast; use tokio::sync::broadcast;
use tokio::sync::mpsc; use tokio::sync::mpsc;
@ -89,6 +89,7 @@ struct Shared {
} }
pub struct Stack { pub struct Stack {
last_used_port: AtomicU16,
shared: Arc<Shared>, shared: Arc<Shared>,
local_ip: Ipv4Addr, local_ip: Ipv4Addr,
local_ip6: Option<Ipv6Addr>, local_ip6: Option<Ipv6Addr>,
@ -383,6 +384,7 @@ impl Stack {
} }
Stack { Stack {
last_used_port: AtomicU16::new(0),
shared, shared,
local_ip, local_ip,
local_ip6, local_ip6,
@ -403,7 +405,12 @@ impl Stack {
/// Connects to the remote end. `None` returned means /// Connects to the remote end. `None` returned means
/// the connection attempt failed. /// the connection attempt failed.
pub async fn connect(&self, addr: SocketAddr) -> Option<Socket> { pub async fn connect(&self, addr: SocketAddr) -> Option<Socket> {
for local_port in 1024..u16::MAX { for _ in 1024..u16::MAX {
let mut local_port = self.last_used_port.fetch_add(1, Ordering::SeqCst) % u16::MAX;
if local_port < u16::MAX - 1024 {
local_port += 1024;
}
let local_addr = SocketAddr::new( let local_addr = SocketAddr::new(
if addr.is_ipv4() { if addr.is_ipv4() {
IpAddr::V4(self.local_ip) IpAddr::V4(self.local_ip)