go-packages/iris
1
0
Fork 0
mirror of https://github.com/kataras/iris.git synced 2025-03-21 11:06:26 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Some fixes to the previous edit

Browse Source 
Former-commit-id: da5219084b60d820ced713feff837e3964fa1fb0
This commit is contained in:
Gerasimos (Makis) Maropoulos 2017-10-22 00:41:04 +03:00 committed by GitHub
parent 9061d3d695
commit 1cd9b70791
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
websocket/server.go
View File

@ -106,7 +106,7 @@ type (
config Config config Config
connections connections connections connections
rooms map[string][]string // by default a connection is joined to a room which has the connection id as its name rooms map[string][]string // by default a connection is joined to a room which has the connection id as its name
mu sync.RWMutex // for rooms mu sync.RWMutex // for rooms
onConnectionListeners []ConnectionFunc onConnectionListeners []ConnectionFunc
//connectionPool sync.Pool // sadly we can't make this because the websocket connection is live until is closed. //connectionPool sync.Pool // sadly we can't make this because the websocket connection is live until is closed.
handler context.Handler handler context.Handler
@ -308,7 +308,7 @@ func (s *Server) leave(roomName string, connID string) (left bool) {
// GetTotalConnections returns the number of total connections // GetTotalConnections returns the number of total connections
func (s *Server) GetTotalConnections() int { func (s *Server) GetTotalConnections() int {
s.mu.RLock() s.mu.RLock()
l:= len(s.connections) l := len(s.connections)
s.mu.RUnlock() s.mu.RUnlock()
return l return l
} }
@ -316,8 +316,10 @@ func (s *Server) GetTotalConnections() int {
// GetConnections returns all connections // GetConnections returns all connections
func (s *Server) GetConnections() []Connection { func (s *Server) GetConnections() []Connection {
s.mu.RLock() s.mu.RLock()
conns:= make([]Connection, len(s.connections)) conns := make([]Connection, len(s.connections), len(s.connections))
copy(conns, s.connections) for i, c := range s.connections {
conns[i] = c.value
}
s.mu.RUnlock() s.mu.RUnlock()
return conns return conns
} }