Stefan/evcc-io
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix data race
Some checks failed
Release / call-build-workflow (push) Has been cancelled
Details
Release / Publish Docker :release (push) Has been cancelled
Details
Release / Publish Github & APT release (push) Has been cancelled
Details

Browse source
This commit is contained in:
andig 2022-03-15 21:44:22 +00:00
parent f79b8a164d
commit 7a3c30729b
1 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

9
util/modbus/modbus.go
View file

@ -5,6 +5,7 @@ import (
"fmt"
"strconv"
"strings"
"sync"
"time"
"github.com/evcc-io/evcc/util"
@ -146,9 +147,15 @@ func (mb *Connection) ReadFIFOQueue(address uint16) (results []byte, err error)
return mb.handle(mb.conn.ModbusClient().ReadFIFOQueue(address))
}
var connections = make(map[string]meters.Connection)
var (
connections = make(map[string]meters.Connection)
mu sync.Mutex
)
func registeredConnection(key string, newConn meters.Connection) meters.Connection {
mu.Lock()
defer mu.Unlock()
if conn, ok := connections[key]; ok {
return conn
}