Synchronize multiple open commands coming together.

Author: cmaglie

serialport.go

@@ -20,6 +20,7 @@ import (
 	"encoding/base64"
 	"io"
 	"strconv"
+	"sync"
 	"sync/atomic"
 	"time"
 	"unicode/utf8"
@@ -76,6 +77,7 @@ type SpPortMessageRaw struct {
 }
 
 func (p *serport) reader(buftype string) {
+	defer serialPorts.List()
 
 	timeCheckOpen := time.Now()
 	var bufferedCh bytes.Buffer
@@ -273,7 +275,11 @@ func (p *serport) writerRaw() {
 	h.broadcastSys <- []byte(msgstr)
 }
 
+var spHandlerLock sync.Mutex
+
 func spHandlerOpen(portname string, baud int, buftype string) {
+	spHandlerLock.Lock()
+	defer spHandlerLock.Unlock()
 
 	log.Print("Inside spHandler")
 
@@ -342,10 +348,8 @@ func spHandlerOpen(portname string, baud int, buftype string) {
 	go p.writerNoBuf()
 	// this is thread to send to serial port but with base64 decoding
 	go p.writerRaw()
-
-	p.reader(buftype)
-
-	serialPorts.List()
+	// this is the thread that reads from the serial port
+	go p.reader(buftype)
 }
 
 func (p *serport) Close() {