k no deadlock
This commit is contained in:
@@ -8,8 +8,10 @@ import (
|
|||||||
"log"
|
"log"
|
||||||
"mayhem-party/src/device/input/button"
|
"mayhem-party/src/device/input/button"
|
||||||
"mayhem-party/src/device/input/raw"
|
"mayhem-party/src/device/input/raw"
|
||||||
|
"mayhem-party/src/device/input/wrap"
|
||||||
"net/http"
|
"net/http"
|
||||||
"os"
|
"os"
|
||||||
|
"syscall"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"gopkg.in/yaml.v2"
|
"gopkg.in/yaml.v2"
|
||||||
@@ -82,8 +84,11 @@ func (v01 *V01) listen() {
|
|||||||
v := v01.cfg.Users["broadcast"]
|
v := v01.cfg.Users["broadcast"]
|
||||||
v.Message = string(b)
|
v.Message = string(b)
|
||||||
v01.cfg.Users["broadcast"] = v
|
v01.cfg.Users["broadcast"] = v
|
||||||
if _, ok := r.URL.Query()["refresh"]; ok {
|
}
|
||||||
//wrap.Signal <- syscall.SIGUSR1
|
if _, ok := r.URL.Query()["refresh"]; ok {
|
||||||
|
select {
|
||||||
|
case wrap.ChSigUsr1 <- syscall.SIGUSR1:
|
||||||
|
default:
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}),
|
}),
|
||||||
|
|||||||
Reference in New Issue
Block a user