anonfunc/LedD.PCA9685
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fixed some errors

Browse Source
This commit is contained in:
Giovanni Harting
2017-12-12 19:36:25 +01:00
parent ffe46a0f4b
commit d3018819de
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
main.go
View File

@@ -38,14 +38,14 @@ type config struct {
} }
} }
type LedD struct { type LedDaemon struct {
name string name string
socket net.Conn socket net.Conn
data chan []byte data chan []byte
} }
var log = logging.MustGetLogger("LedD") var log = logging.MustGetLogger("LedD")
var ledDaemon = &LedD{} var ledDaemon = &LedDaemon{}
var pca9685 = device.PCA9685{} var pca9685 = device.PCA9685{}
@@ -55,7 +55,7 @@ func check(e error) {
} }
} }
func (ledd *LedD) receive() { func (ledd *LedDaemon) receive() {
for { for {
message := make([]byte, 4096) message := make([]byte, 4096)
length, err := ledd.socket.Read(message) length, err := ledd.socket.Read(message)
@@ -71,7 +71,7 @@ func (ledd *LedD) receive() {
backendMsg := &ledd.BackendWrapperMessage{} backendMsg := &ledd.BackendWrapperMessage{}
err = proto.Unmarshal(message[4:msgLen], backendMsg) err = proto.Unmarshal(message[4:msgLen], backendMsg)
if err != nil { if err != nil {
log.Warningf("[%s] Couldn't decode protobuf msg!", backend.niceName()) log.Warningf("[%s] Couldn't decode protobuf msg!", ledd.name)
continue continue
} }
@@ -84,7 +84,7 @@ func (ledd *LedD) receive() {
} }
} }
func (ledd *LedD) send() { func (ledd *LedDaemon) send() {
defer ledd.socket.Close() defer ledd.socket.Close()
for { for {
select { select {
@@ -120,7 +120,7 @@ func main() {
conn, err := net.Dial("tcp4", fmt.Sprintf("%s:%d", config.Ledd.Host, config.Ledd.Port)) conn, err := net.Dial("tcp4", fmt.Sprintf("%s:%d", config.Ledd.Host, config.Ledd.Port))
check(err) check(err)
ledDaemon = &LedD{ ledDaemon = &LedDaemon{
socket:conn, socket:conn,
data: make (chan []byte), data: make (chan []byte),
} }