- Timestamp:
- Apr 1, 2020, 10:21:31 AM (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/user.go
r198 r199 78 78 } 79 79 80 net.lock.Lock()81 net.conn = uc82 net.lock.Unlock()83 84 80 net.user.events <- eventUpstreamConnected{uc} 85 81 if err := uc.readMessages(net.user.events); err != nil { … … 88 84 uc.Close() 89 85 net.user.events <- eventUpstreamDisconnected{uc} 90 91 net.lock.Lock()92 net.conn = nil93 net.lock.Unlock()94 86 } 95 87 } … … 177 169 case eventUpstreamConnected: 178 170 uc := e.uc 171 172 uc.network.lock.Lock() 173 uc.network.conn = uc 174 uc.network.lock.Unlock() 175 179 176 uc.updateAway() 180 177 case eventUpstreamDisconnected: 181 178 uc := e.uc 179 180 uc.network.lock.Lock() 181 uc.network.conn = nil 182 uc.network.lock.Unlock() 183 182 184 for _, log := range uc.logs { 183 185 log.file.Close() 184 186 } 187 185 188 uc.endPendingLISTs(true) 186 189 case eventUpstreamMessage:
Note:
See TracChangeset
for help on using the changeset viewer.