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 virtual serial port

Browse source
This commit is contained in:
Nonoo 2020-10-27 17:27:39 +01:00
parent 303012fa56
commit afa48dc7a0
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
serial-linux.go
View file

@ -48,8 +48,8 @@ func (s *serialPortStruct) writeLoop() {
func (s *serialPortStruct) readLoop() { func (s *serialPortStruct) readLoop() {
s.read = make(chan []byte) s.read = make(chan []byte)
b := make([]byte, maxSerialFrameLength)
for { for {
b := make([]byte, maxSerialFrameLength)
n, err := s.pty.Master.Read(b) n, err := s.pty.Master.Read(b)
if err != nil { if err != nil {
if _, ok := err.(*os.PathError); !ok { if _, ok := err.(*os.PathError); !ok {

6
serialstream.go
View file

@ -175,6 +175,9 @@ func (s *serialStream) loop() {
if enableSerialDevice { if enableSerialDevice {
for { for {
select { select {
case r := <-s.serialPort.read:
s.gotDataForRadio(r)
case r := <-s.common.readChan: case r := <-s.common.readChan:
if err := s.handleRead(r); err != nil { if err := s.handleRead(r); err != nil {
reportError(err) reportError(err)
@ -194,9 +197,6 @@ func (s *serialStream) loop() {
} else { } else {
for { for {
select { select {
case r := <-s.serialPort.read:
s.gotDataForRadio(r)
case r := <-s.common.readChan: case r := <-s.common.readChan:
if err := s.handleRead(r); err != nil { if err := s.handleRead(r); err != nil {
reportError(err) reportError(err)