mirror of https://github.com/jgoerzen/xbnet.git
remove some warnings
This commit is contained in:
parent
8c8374e575
commit
0f93ff9dc2
|
@ -30,7 +30,6 @@ mod ping;
|
||||||
|
|
||||||
use std::path::PathBuf;
|
use std::path::PathBuf;
|
||||||
use structopt::StructOpt;
|
use structopt::StructOpt;
|
||||||
use std::convert::TryInto;
|
|
||||||
|
|
||||||
#[derive(Debug, StructOpt)]
|
#[derive(Debug, StructOpt)]
|
||||||
#[structopt(name = "xbnet", about = "Networking for XBee Radios", author = "John Goerzen <jgoerzen@complete.org>")]
|
#[structopt(name = "xbnet", about = "Networking for XBee Radios", author = "John Goerzen <jgoerzen@complete.org>")]
|
||||||
|
@ -98,7 +97,7 @@ fn main() {
|
||||||
thread::spawn(move || pipe::stdout_processor(&mut xbreframer, &mut xb.ser_reader).expect("Failure in stdout_processor"));
|
thread::spawn(move || pipe::stdout_processor(&mut xbreframer, &mut xb.ser_reader).expect("Failure in stdout_processor"));
|
||||||
pipe::stdin_processor(dest_u64, 1600, xbeesender).expect("Failure in stdin_processor");
|
pipe::stdin_processor(dest_u64, 1600, xbeesender).expect("Failure in stdin_processor");
|
||||||
// Make sure queued up data is sent
|
// Make sure queued up data is sent
|
||||||
writerthread.join();
|
let _ = writerthread.join();
|
||||||
|
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
|
@ -22,12 +22,8 @@ use crate::xbpacket::*;
|
||||||
use crate::ser::*;
|
use crate::ser::*;
|
||||||
use crate::xbrx::*;
|
use crate::xbrx::*;
|
||||||
use crossbeam_channel;
|
use crossbeam_channel;
|
||||||
use std::thread;
|
|
||||||
use std::time::Duration;
|
|
||||||
use bytes::*;
|
use bytes::*;
|
||||||
|
|
||||||
const INTERVAL: u64 = 5;
|
|
||||||
|
|
||||||
pub fn stdin_processor(dest: u64, maxframesize: usize,
|
pub fn stdin_processor(dest: u64, maxframesize: usize,
|
||||||
sender: crossbeam_channel::Sender<XBTX>) -> io::Result<()> {
|
sender: crossbeam_channel::Sender<XBTX>) -> io::Result<()> {
|
||||||
let stdin = io::stdin();
|
let stdin = io::stdin();
|
||||||
|
|
|
@ -20,7 +20,6 @@ use std::io;
|
||||||
use serialport::prelude::*;
|
use serialport::prelude::*;
|
||||||
use std::io::{BufReader, BufRead, Write};
|
use std::io::{BufReader, BufRead, Write};
|
||||||
use log::*;
|
use log::*;
|
||||||
use std::sync::{Arc, Mutex};
|
|
||||||
use std::time::Duration;
|
use std::time::Duration;
|
||||||
use std::path::PathBuf;
|
use std::path::PathBuf;
|
||||||
use bytes::*;
|
use bytes::*;
|
||||||
|
|
|
@ -24,13 +24,10 @@ use std::io;
|
||||||
use crossbeam_channel;
|
use crossbeam_channel;
|
||||||
use hex;
|
use hex;
|
||||||
use std::thread;
|
use std::thread;
|
||||||
use std::time::{Duration, Instant};
|
use std::time::{Duration};
|
||||||
use format_escape_default::format_escape_default;
|
|
||||||
use std::path::PathBuf;
|
use std::path::PathBuf;
|
||||||
use bytes::Bytes;
|
use bytes::Bytes;
|
||||||
use std::convert::TryInto;
|
|
||||||
use crate::xbpacket::*;
|
use crate::xbpacket::*;
|
||||||
use serialport::prelude::*;
|
|
||||||
|
|
||||||
pub fn mkerror(msg: &str) -> Error {
|
pub fn mkerror(msg: &str) -> Error {
|
||||||
Error::new(ErrorKind::Other, msg)
|
Error::new(ErrorKind::Other, msg)
|
||||||
|
|
|
@ -21,15 +21,8 @@
|
||||||
use crate::ser::*;
|
use crate::ser::*;
|
||||||
use crate::xbpacket::*;
|
use crate::xbpacket::*;
|
||||||
use log::*;
|
use log::*;
|
||||||
use std::fs;
|
use std::io::{Read};
|
||||||
use std::io::{BufRead, BufReader, Error, ErrorKind, Read};
|
|
||||||
use std::io;
|
|
||||||
use crossbeam_channel;
|
|
||||||
use hex;
|
use hex;
|
||||||
use std::thread;
|
|
||||||
use std::time::{Duration, Instant};
|
|
||||||
use format_escape_default::format_escape_default;
|
|
||||||
use std::path::PathBuf;
|
|
||||||
use bytes::*;
|
use bytes::*;
|
||||||
use std::collections::HashMap;
|
use std::collections::HashMap;
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue