- Timestamp:
- Mar 27, 2020, 9:24:12 PM (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/server.go
r167 r172 56 56 db *DB 57 57 58 lock sync.Mutex 59 users map[string]*user 60 downstreamConns []*downstreamConn 58 lock sync.Mutex 59 users map[string]*user 61 60 } 62 61 … … 113 112 nextDownstreamID++ 114 113 go func() { 115 s.lock.Lock()116 s.downstreamConns = append(s.downstreamConns, dc)117 s.lock.Unlock()118 119 114 if err := dc.runUntilRegistered(); err != nil { 120 115 dc.logger.Print(err) … … 127 122 } 128 123 dc.Close() 129 130 s.lock.Lock()131 for i := range s.downstreamConns {132 if s.downstreamConns[i] == dc {133 s.downstreamConns = append(s.downstreamConns[:i], s.downstreamConns[i+1:]...)134 break135 }136 }137 s.lock.Unlock()138 124 }() 139 125 }
Note:
See TracChangeset
for help on using the changeset viewer.