Release message only after it has been sent to all connections.

12 years ago · 2822ceb7c8
1 changed files with 1 additions and 1 deletions
--- a/src/app/spreed-speakfreely-server/roomworker.go
+++ b/src/app/spreed-speakfreely-server/roomworker.go
@ -193,8 +193,8 @@ func (r *RoomWorker) broadcastHandler(m *MessageRequest) {
 			}
 			//fmt.Printf("%s\n", m.Message)
 			ec.send(m.Message)
 			m.Message.Decref()
 		}
 		m.Message.Decref()
 	}
 	m.Message.Incref()