From b2ffd5160ccae60ff499b2f55b1bf81e3eb15a69 Mon Sep 17 00:00:00 2001 From: Brandon Thomas Date: Wed, 29 Jun 2022 03:38:10 -0400 Subject: [PATCH] attempting to send --- Cargo.toml | 3 ++- src/main.rs | 20 ++++++++++++++------ 2 files changed, 16 insertions(+), 7 deletions(-) diff --git a/Cargo.toml b/Cargo.toml index c297541..3f872ea 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -11,4 +11,5 @@ src = "src/main.rs" [dependencies] pcap-parser = "0.14.0" -tokio = { version = "1", features = ["full"] } \ No newline at end of file +tokio = { version = "1", features = ["full"] } +anyhow = "1.0.58" \ No newline at end of file diff --git a/src/main.rs b/src/main.rs index f7cb5c0..426e54a 100644 --- a/src/main.rs +++ b/src/main.rs @@ -2,26 +2,30 @@ use pcap_parser::*; use pcap_parser::traits::PcapReaderIterator; use std::fs::File; +use tokio::net::UdpSocket; +use anyhow::Result as AnyhowResult; #[tokio::main] -pub fn main() { - old_format(); +pub async fn main() -> AnyhowResult<()> { + old_format().await?; + Ok(()) } -pub fn old_format() { +pub async fn old_format() -> AnyhowResult<()> { let path = "anim.pcap"; let file = File::open(path).unwrap(); let mut num_blocks = 0; let mut reader = LegacyPcapReader::new(65536, file).expect("LegacyPcapReader"); + let sock = UdpSocket::bind("0.0.0.0:8022").await?; + + let remote_addr = "192.168.50.31:9763"; + sock.connect(remote_addr).await?; - - - loop { match reader.next() { Ok((offset, block)) => { @@ -36,6 +40,8 @@ pub fn old_format() { PcapBlockOwned::Legacy(block) => { // use linktype to parse b.data() //println!("Block: {:?}", block) + + let len = sock.send(&block.data).await?; }, PcapBlockOwned::NG(_) => unreachable!(), } @@ -50,7 +56,9 @@ pub fn old_format() { } println!("num_blocks: {}", num_blocks); + Ok(()) } + pub fn new_format() { println!("Test");