lab/etri-smartfarm-poc-controller-serial
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

commit 2021-12-16]17:42:53

Browse Source
This commit is contained in:
Godopu 2021-12-16 17:42:57 +09:00
parent 0f1e5e610e
commit 652d936d83
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
listener.go
View File

@ -12,6 +12,7 @@ type SyncHandler struct {
devices map[string]*_device devices map[string]*_device
mutex *sync.Mutex mutex *sync.Mutex
chanForSync map[string]chan map[string]interface{} chanForSync map[string]chan map[string]interface{}
states map[string]map[string]interface{}
} }
func compareMap(src map[string]interface{}, dst map[string]interface{}) bool { func compareMap(src map[string]interface{}, dst map[string]interface{}) bool {
@ -69,6 +70,7 @@ func (sh *SyncHandler) Handle(e Event) {
origin[key] = value origin[key] = value
} }
sh.states[device.UUID] = origin
// props := []string{"fan", "light", "servo"} // props := []string{"fan", "light", "servo"}
err := encoder.Encode(origin) err := encoder.Encode(origin)
@ -90,7 +92,7 @@ func (sh *SyncHandler) Handle(e Event) {
sh.mutex.Unlock() sh.mutex.Unlock()
for state := range chanForSync { for state := range chanForSync {
if compareMap(origin, state) { if compareMap(sh.states[device.UUID], state) {
sh.mutex.Lock() sh.mutex.Lock()
close(sh.chanForSync[device.IfaceName]) close(sh.chanForSync[device.IfaceName])
delete(sh.chanForSync, device.IfaceName) delete(sh.chanForSync, device.IfaceName)
@ -98,8 +100,8 @@ func (sh *SyncHandler) Handle(e Event) {
return return
} }
log.Println("wrong: ", state) log.Println("wrong: ", state)
log.Println("resend: ", origin) log.Println("resend: ", sh.states[device.UUID])
err := encoder.Encode(origin) err := encoder.Encode(sh.states[device.UUID])
if err != nil { if err != nil {
return return
} }