no log
parent
c4a21861cd
commit
b89d8e3d3f
|
|
@ -32,7 +32,6 @@ func (s *Server) WS(w http.ResponseWriter, r *http.Request) error {
|
||||||
defer sess.Close()
|
defer sess.Close()
|
||||||
|
|
||||||
sess.cb = func(m message) error {
|
sess.cb = func(m message) error {
|
||||||
log.Printf("cbing to all other sessions %+v", m)
|
|
||||||
for i := range s.sessions {
|
for i := range s.sessions {
|
||||||
if s.sessions[i].id != sess.id {
|
if s.sessions[i].id != sess.id {
|
||||||
select {
|
select {
|
||||||
|
|
|
||||||
|
|
@ -71,7 +71,6 @@ func (s *session) gather() {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Printf("gathered %+v (%s)", m, msg)
|
|
||||||
return s.cb(m)
|
return s.cb(m)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
@ -80,7 +79,6 @@ func (s *session) scatter() {
|
||||||
s.while(func() error {
|
s.while(func() error {
|
||||||
select {
|
select {
|
||||||
case m := <-s.scatterc:
|
case m := <-s.scatterc:
|
||||||
log.Printf("scattering %+v", m)
|
|
||||||
b, _ := json.Marshal(m)
|
b, _ := json.Marshal(m)
|
||||||
return s.ws.WriteMessage(1, b)
|
return s.ws.WriteMessage(1, b)
|
||||||
case <-s.ctx.Done():
|
case <-s.ctx.Done():
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue