summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/rhctl/audio_switch.go12
-rw-r--r--src/rhctl/serial_port.go3
2 files changed, 8 insertions, 7 deletions
diff --git a/src/rhctl/audio_switch.go b/src/rhctl/audio_switch.go
index 5fc9fac..4464a10 100644
--- a/src/rhctl/audio_switch.go
+++ b/src/rhctl/audio_switch.go
@@ -35,11 +35,13 @@ func (sw *AudioSwitch) Run() {
stop := make(chan bool)
sw.port.Run(stop)
- select {
- case <-stop:
- return
- case data := <-sw.port.rx:
- rhl.Printf("got data from audio switch: %q", data)
+ for {
+ select {
+ case <-stop:
+ return
+ case data := <-sw.port.rx:
+ rhl.Printf("got data from audio switch: %q", data)
+ }
}
}
diff --git a/src/rhctl/serial_port.go b/src/rhctl/serial_port.go
index e809484..7a0af2c 100644
--- a/src/rhctl/serial_port.go
+++ b/src/rhctl/serial_port.go
@@ -146,11 +146,10 @@ func serialReader(c chan<- string, port *sio.Port, stop chan<- bool) {
if len(data) == 0 {
continue
}
- c <- string(data)
+ c <- data
}
if err := scanner.Err(); err != nil {
rhl.Printf("device(%s): read error: %s", port.LocalAddr(), err)
- panic(err.Error())
} else {
rhl.Printf("device(%s): closed", port.LocalAddr())
}