|
@@ -121,10 +121,10 @@ func (s *FlowSession) ClientRemove(c *websocket.Conn) {
|
|
|
}
|
|
|
}
|
|
|
s.Chat.ClientRemove(c)
|
|
|
- if len(s.clients) == 0 && s.flow == nil {
|
|
|
+ /*if len(s.clients) == 0 && s.flow == nil {
|
|
|
log.Println("No more clients, remove session")
|
|
|
delete(s.mgr.sessions, s.ID) // Clear memory session
|
|
|
- }
|
|
|
+ }*/
|
|
|
}
|
|
|
|
|
|
// ChatJoin the chat room on this session
|
|
@@ -243,14 +243,14 @@ func (s *FlowSession) NodeRun(c *websocket.Conn, data []byte) error {
|
|
|
if s.flow.Err() != nil {
|
|
|
log.Println("error processing node", s.flow.Err())
|
|
|
}
|
|
|
- func() {
|
|
|
+ /*func() {
|
|
|
s.Lock()
|
|
|
defer s.Unlock()
|
|
|
if len(s.clients) == 0 {
|
|
|
log.Println("No more clients, remove session")
|
|
|
delete(s.mgr.sessions, s.ID) // Clear memory session
|
|
|
}
|
|
|
- }()
|
|
|
+ }()*/
|
|
|
|
|
|
}()
|
|
|
return nil
|