- Timestamp:
- Mar 26, 2021, 10:21:14 AM (4 years ago)
- Location:
- trunk
- Files:
-
- 4 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/downstream.go
r479 r480 998 998 // Fast-forward history to last message 999 999 for target, entry := range net.delivered.innerMap { 1000 delivered := entry.value.( map[string]string)1000 delivered := entry.value.(deliveredClientMap) 1001 1001 ch := net.channels.Value(target) 1002 1002 if ch != nil && ch.Detached { -
trunk/irc.go
r478 r480 601 601 } 602 602 603 type mapStringStringCasemapMap struct{ casemapMap }604 605 func (cm * mapStringStringCasemapMap) Value(name string) map[string]string{603 type deliveredCasemapMap struct{ casemapMap } 604 605 func (cm *deliveredCasemapMap) Value(name string) deliveredClientMap { 606 606 entry, ok := cm.innerMap[cm.casemap(name)] 607 607 if !ok { 608 608 return nil 609 609 } 610 return entry.value.( map[string]string)611 } 610 return entry.value.(deliveredClientMap) 611 } -
trunk/upstream.go
r478 r480 1755 1755 } 1756 1756 1757 delivered = make( map[string]string)1757 delivered = make(deliveredClientMap) 1758 1758 uc.network.delivered.SetValue(entity, delivered) 1759 1759 -
trunk/user.go
r478 r480 56 56 type eventStop struct{} 57 57 58 type deliveredClientMap map[string]string // client name -> msg ID 59 58 60 type network struct { 59 61 Network … … 63 65 conn *upstreamConn 64 66 channels channelCasemapMap 65 delivered mapStringStringCasemapMap // entity -> client name -> msg ID66 offlineClients map[string]struct{} 67 delivered deliveredCasemapMap 68 offlineClients map[string]struct{} // indexed by client name 67 69 lastError error 68 70 casemap casemapping … … 81 83 stopped: make(chan struct{}), 82 84 channels: m, 83 delivered: mapStringStringCasemapMap{newCasemapMap(0)},85 delivered: deliveredCasemapMap{newCasemapMap(0)}, 84 86 offlineClients: make(map[string]struct{}), 85 87 casemap: casemapRFC1459,
Note:
See TracChangeset
for help on using the changeset viewer.