Set a size on the output buffer to help prevent output buffer flooding

This commit is contained in:
John Goerzen 2019-10-30 23:27:19 -05:00
parent 16a04c592d
commit 6822f37abe
3 changed files with 8 additions and 2 deletions

View File

@ -358,6 +358,12 @@ be able to ping and talk back and forth between them. Standard
commands will work at this stage. You may wish to adjust the packet commands will work at this stage. You may wish to adjust the packet
size in /etc/axports up from 70. size in /etc/axports up from 70.
To bring down the link, Ctrl-C the socat sessions and run `killall kissattach`.
For more information, see:
- [The Linux AX.25 HOWTO](http://www.tldp.org/HOWTO/AX25-HOWTO/)
# INSTALLATION # INSTALLATION
**lorapipe** is a Rust program and can be built by running **`cargo **lorapipe** is a Rust program and can be built by running **`cargo

View File

@ -101,7 +101,7 @@ impl LoraStik {
/// parameters after a read. /// parameters after a read.
pub fn new(ser: LoraSer, readqual: bool, txwait: u64, eotwait: u64) -> (LoraStik, crossbeam_channel::Receiver<ReceivedFrames>) { pub fn new(ser: LoraSer, readqual: bool, txwait: u64, eotwait: u64) -> (LoraStik, crossbeam_channel::Receiver<ReceivedFrames>) {
let (readerlinestx, readerlinesrx) = crossbeam_channel::unbounded(); let (readerlinestx, readerlinesrx) = crossbeam_channel::unbounded();
let (txblockstx, txblocksrx) = crossbeam_channel::unbounded(); let (txblockstx, txblocksrx) = crossbeam_channel::bounded(3);
let (readeroutput, readeroutputreader) = crossbeam_channel::unbounded(); let (readeroutput, readeroutputreader) = crossbeam_channel::unbounded();
let ser2 = ser.clone(); let ser2 = ser.clone();

View File

@ -25,7 +25,7 @@ pub fn stdintolora(ls: &mut LoraStik, maxframesize: usize) -> io::Result<()> {
let stdin = io::stdin(); let stdin = io::stdin();
let mut br = io::BufReader::new(stdin); let mut br = io::BufReader::new(stdin);
let mut buf = vec![0u8; 8192]; let mut buf = vec![0u8; 4096];
loop { loop {
let res = br.read(&mut buf)?; let res = br.read(&mut buf)?;