nonoo/kappanhang
1
0
Fork 0
mirror of https://github.com/nonoo/kappanhang.git synced 2025-12-06 08:02:00 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix not getting replies for too fast serial commands

Browse source
This commit is contained in:
Nonoo 2020-10-25 14:27:53 +01:00
parent 1fa9b0e4a4
commit f2697e76ae
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
serialstream.go
View file

@ -38,6 +38,7 @@ func (s *serialStream) send(d []byte) error {
if err := s.common.send(p); err != nil { if err := s.common.send(p); err != nil {
return err return err
} }
s.common.pkt0.sendSeq++
s.sendSeq++ s.sendSeq++
return nil return nil
} }
@ -60,6 +61,7 @@ func (s *serialStream) sendOpenClose(close bool) error {
if err := s.common.send(p); err != nil { if err := s.common.send(p); err != nil {
return err return err
} }
s.common.pkt0.sendSeq++
s.sendSeq++ s.sendSeq++
return nil return nil
} }
@ -67,7 +69,6 @@ func (s *serialStream) sendOpenClose(close bool) error {
func (s *serialStream) handleRead(r []byte) { func (s *serialStream) handleRead(r []byte) {
if len(r) >= 22 { if len(r) >= 22 {
if r[16] == 0xc1 && r[0]-0x15 == r[17] { if r[16] == 0xc1 && r[0]-0x15 == r[17] {
log.Print("rcv ", r[21:])
s.serialPort.write <- r[21:] s.serialPort.write <- r[21:]
} }
} }
@ -108,7 +109,6 @@ func (s *serialStream) gotDataFromSerialPort(r []byte) {
for _, b := range r { for _, b := range r {
s.readFromSerialPort.buf.WriteByte(b) s.readFromSerialPort.buf.WriteByte(b)
if b == 0xfc || b == 0xfd || s.readFromSerialPort.buf.Len() == maxSerialFrameLength { if b == 0xfc || b == 0xfd || s.readFromSerialPort.buf.Len() == maxSerialFrameLength {
log.Print("snd ", s.readFromSerialPort.buf.Bytes())
if err := s.send(s.readFromSerialPort.buf.Bytes()); err != nil { if err := s.send(s.readFromSerialPort.buf.Bytes()); err != nil {
reportError(err) reportError(err)
} }