little connections fix

Author: ivahaev

conn.go

@@ -90,6 +90,8 @@ func (c *Conn) heartbeating() {
 	ticker := time.NewTicker(heartBeatFrequency)
 	for c.Connected() {
 		msg, _ := createMessage(msgIntTypes[msgHeartbeat], hbSequence)
+		hbSequence++
+		logger("HB message: ", string(msg))
 		c.send(msg)
 		<-ticker.C
 	}
@@ -107,13 +109,15 @@ func (c *Conn) send(msg []byte) {
 func (c *Conn) sender() {
 	var err error
 	for msg := range c.sendChan {
+		logger("Sending message ", string(msg))
 		if c.stringMode {
 			err = websocket.Message.Send(c.connection, string(msg))
 		} else {
 			err = websocket.Message.Send(c.connection, msg)
 		}
 		if err != nil {
 			logger("Error when send message", err.Error())
+			c.breakChan <- struct{}{}
 		}
 	}
 }

wamp.go

@@ -379,6 +379,7 @@ func (w *Wango) receive(c *Conn) {
 		for {
 			err := websocket.Message.Receive(c.connection, &data)
 			if err != nil {
+				logger("Message receiving error: ", err)
 				if err != io.EOF {
 					// Error receiving message
 				}
@@ -392,6 +393,7 @@ MessageLoop:
 	for {
 		select {
 		case <-c.breakChan:
+			logger("breakChan signal received, will close connection.")
 			break MessageLoop
 		case data := <-dataChan:
 			msgType, msg, err := parseMessage(data)
@@ -745,7 +747,7 @@ func (w *Wango) deleteConnection(c *Conn) {
 	delete(w.connections, c.id)
 	w.connectionsLocker.Unlock()
 
-	c.subRequests.closeRequests()
+	go c.subRequests.closeRequests()
 
 	w.subscribersLocker.Lock()
 	for _, subscribers := range w.subscribers {