Changeset 483 in code
- Timestamp:
- Mar 29, 2021, 2:58:56 PM (4 years ago)
- Location:
- trunk
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/upstream.go
r482 r483 1756 1756 uc.network.delivered.SetValue(entity, delivered) 1757 1757 1758 for clientName, _ := range uc. network.clients {1758 for clientName, _ := range uc.user.clients { 1759 1759 delivered[clientName] = lastID 1760 1760 } -
trunk/user.go
r482 r483 66 66 channels channelCasemapMap 67 67 delivered deliveredCasemapMap 68 clients map[string]struct{} // indexed by client name69 68 lastError error 70 69 casemap casemapping … … 84 83 channels: m, 85 84 delivered: deliveredCasemapMap{newCasemapMap(0)}, 86 clients: make(map[string]struct{}),87 85 casemap: casemapRFC1459, 88 86 } … … 276 274 downstreamConns []*downstreamConn 277 275 msgStore messageStore 276 clients map[string]struct{} // indexed by client name 278 277 279 278 // LIST commands in progress … … 301 300 done: make(chan struct{}), 302 301 msgStore: msgStore, 302 clients: make(map[string]struct{}), 303 303 } 304 304 } … … 447 447 448 448 dc.forEachNetwork(func(network *network) { 449 network.clients[dc.clientName] = struct{}{}450 449 if network.lastError != nil { 451 450 sendServiceNOTICE(dc, fmt.Sprintf("disconnected from %s: %v", network.GetName(), network.lastError)) … … 456 455 uc.updateAway() 457 456 }) 457 458 u.clients[dc.clientName] = struct{}{} 458 459 case eventDownstreamDisconnected: 459 460 dc := e.dc
Note:
See TracChangeset
for help on using the changeset viewer.