mirror of
https://github.com/storytold/xsens-packet-send.git
synced 2026-10-09 00:09:59 +00:00
attempting to send
This commit is contained in:
+2
-1
@@ -11,4 +11,5 @@ src = "src/main.rs"
|
|||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
pcap-parser = "0.14.0"
|
pcap-parser = "0.14.0"
|
||||||
tokio = { version = "1", features = ["full"] }
|
tokio = { version = "1", features = ["full"] }
|
||||||
|
anyhow = "1.0.58"
|
||||||
+14
-6
@@ -2,26 +2,30 @@
|
|||||||
use pcap_parser::*;
|
use pcap_parser::*;
|
||||||
use pcap_parser::traits::PcapReaderIterator;
|
use pcap_parser::traits::PcapReaderIterator;
|
||||||
use std::fs::File;
|
use std::fs::File;
|
||||||
|
use tokio::net::UdpSocket;
|
||||||
|
|
||||||
|
use anyhow::Result as AnyhowResult;
|
||||||
|
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
pub fn main() {
|
pub async fn main() -> AnyhowResult<()> {
|
||||||
old_format();
|
old_format().await?;
|
||||||
|
|
||||||
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn old_format() {
|
pub async fn old_format() -> AnyhowResult<()> {
|
||||||
|
|
||||||
let path = "anim.pcap";
|
let path = "anim.pcap";
|
||||||
let file = File::open(path).unwrap();
|
let file = File::open(path).unwrap();
|
||||||
let mut num_blocks = 0;
|
let mut num_blocks = 0;
|
||||||
let mut reader = LegacyPcapReader::new(65536, file).expect("LegacyPcapReader");
|
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 {
|
loop {
|
||||||
match reader.next() {
|
match reader.next() {
|
||||||
Ok((offset, block)) => {
|
Ok((offset, block)) => {
|
||||||
@@ -36,6 +40,8 @@ pub fn old_format() {
|
|||||||
PcapBlockOwned::Legacy(block) => {
|
PcapBlockOwned::Legacy(block) => {
|
||||||
// use linktype to parse b.data()
|
// use linktype to parse b.data()
|
||||||
//println!("Block: {:?}", block)
|
//println!("Block: {:?}", block)
|
||||||
|
|
||||||
|
let len = sock.send(&block.data).await?;
|
||||||
},
|
},
|
||||||
PcapBlockOwned::NG(_) => unreachable!(),
|
PcapBlockOwned::NG(_) => unreachable!(),
|
||||||
}
|
}
|
||||||
@@ -50,7 +56,9 @@ pub fn old_format() {
|
|||||||
}
|
}
|
||||||
println!("num_blocks: {}", num_blocks);
|
println!("num_blocks: {}", num_blocks);
|
||||||
|
|
||||||
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn new_format() {
|
pub fn new_format() {
|
||||||
println!("Test");
|
println!("Test");
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user