- Timestamp:
- Mar 30, 2021, 10:44:56 AM (4 years ago)
- Location:
- trunk
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/upstream.go
r486 r487 1753 1753 } 1754 1754 1755 for clientName, _ := range uc.user.client s {1755 for clientName, _ := range uc.user.clientNames { 1756 1756 uc.network.delivered.StoreID(entity, clientName, lastID) 1757 1757 } -
trunk/user.go
r485 r487 309 309 downstreamConns []*downstreamConn 310 310 msgStore messageStore 311 client s map[string]struct{} // indexed by client name311 clientNames map[string]struct{} 312 312 313 313 // LIST commands in progress … … 330 330 331 331 return &user{ 332 User: *record,333 srv: srv,334 events: make(chan event, 64),335 done: make(chan struct{}),336 msgStore: msgStore,337 client s:make(map[string]struct{}),332 User: *record, 333 srv: srv, 334 events: make(chan event, 64), 335 done: make(chan struct{}), 336 msgStore: msgStore, 337 clientNames: make(map[string]struct{}), 338 338 } 339 339 } … … 491 491 }) 492 492 493 u.client s[dc.clientName] = struct{}{}493 u.clientNames[dc.clientName] = struct{}{} 494 494 case eventDownstreamDisconnected: 495 495 dc := e.dc
Note:
See TracChangeset
for help on using the changeset viewer.