Hartmut/PixSpace
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

remove all other attempts to extract data from VRPN-RS

Browse source
This commit is contained in:
Hartmut Seichter 2022-12-20 23:28:17 +01:00
parent d39fd7b0f6
commit cf7d3a9846
1 changed files with 0 additions and 87 deletions
Download patch file Download diff file Expand all files Collapse all files

87
src/tracker.rs
View file

@ -88,96 +88,9 @@ impl FromWorld for Tracker {
Err(_) => {}
}
// match result {
// Ok(i) => i,
// _ => false
// }
// match result {
// Message<PoseReport> => println!("")
// }
// eprintln!(
// "{:?} {:?}",
// typed_message.body.sensor, typed_message.body.pos
// );
}
});
Self {}
}
}
// pub fn setup_threaded_tracker_simple(mut commands: Commands) {
// commands.spawn(Tracker::new());
// }
// impl TypedBodylessHandler for Tracker {
// type Item = PoseReport;
// fn handle_typed_bodyless(&mut self, header: &vrpn::MessageHeader) -> Result<HandlerCode> {
// Ok(HandlerCode::ContinueProcessing)
// }
// }
// impl TypedHandler for Tracker {
// type Item = PoseReport;
// fn handle_typed(&mut self, msg: &Message<PoseReport>) -> Result<HandlerCode> {
// println!("{:?}\n {:?}", msg.header, msg.body);
// Ok(HandlerCode::ContinueProcessing)
// }
// }
#[derive(Debug)]
struct TrackerHandler;
impl TypedHandler for TrackerHandler {
type Item = PoseReport;
fn handle_typed(&mut self, msg: &Message<PoseReport>) -> Result<HandlerCode> {
println!("{:?}\n {:?}", msg.header, msg.body);
Ok(HandlerCode::ContinueProcessing)
}
}
pub fn setup_threaded_tracker(mut commands: Commands) {
// let (tx, rx) = bounded::<u32>(10);
std::thread::spawn(move || {
let addr: SocketAddr = "127.0.0.1:3883".parse().unwrap();
let mut stream = TcpStream::connect(addr).unwrap();
stream.set_nodelay(true).unwrap();
// We first write our cookie, then read and check the server's cookie, before the loop.
write_cookie(&mut stream, CookieData::from(MAGIC_DATA)).unwrap();
let cookie_buf = read_cookie(&mut stream).unwrap();
let mut cookie_buf = Bytes::from(&cookie_buf[..]);
CookieData::unbuffer_ref(&mut cookie_buf)
.and_then(|msg| check_ver_nonfile_compatible(msg.version))
.unwrap();
let mut endpoint = EndpointSyncTcp::new(stream);
let mut dispatcher = TypeDispatcher::new();
let _ = dispatcher
.add_typed_handler(Box::new(TrackerHandler {}), None)
.unwrap();
// setup a channel
// let (tx, rx) = mpsc::channel();
loop {
// vrpn implementation is rather verbose - we need to see what specific errors
// should be handled properly!
endpoint
.poll_endpoint(&mut dispatcher)
.unwrap_or_else(|err| {
info!("error from tracker thread {:?}", err);
})
// dispatcher.han
}
});
}