- Timestamp:
- Mar 26, 2020, 9:28:13 PM (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/upstream.go
r159 r161 55 55 tagsSupported bool 56 56 labelsSupported bool 57 nextLabelI duint6457 nextLabelID uint64 58 58 59 59 saslClient sasl.Client … … 131 131 } 132 132 133 func (uc *upstreamConn) forEachDownstreamByI d(id uint64, f func(*downstreamConn)) {133 func (uc *upstreamConn) forEachDownstreamByID(id uint64, f func(*downstreamConn)) { 134 134 uc.forEachDownstream(func(dc *downstreamConn) { 135 135 if id != 0 && id != dc.id { … … 182 182 } 183 183 184 var downstreamI duint64 = 0184 var downstreamID uint64 = 0 185 185 if label != "" { 186 186 var labelOffset uint64 187 n, err := fmt.Sscanf(label, "sd-%d-%d", &downstreamI d, &labelOffset)187 n, err := fmt.Sscanf(label, "sd-%d-%d", &downstreamID, &labelOffset) 188 188 if err == nil && n < 2 { 189 189 err = errors.New("not enough arguments") … … 789 789 if !ok { 790 790 // NAMES on a channel we have not joined, forward to downstream 791 uc.forEachDownstreamByI d(downstreamId, func(dc *downstreamConn) {791 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 792 792 channel := dc.marshalChannel(uc, name) 793 793 members := strings.Split(members, " ") … … 826 826 if !ok { 827 827 // NAMES on a channel we have not joined, forward to downstream 828 uc.forEachDownstreamByI d(downstreamId, func(dc *downstreamConn) {828 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 829 829 channel := dc.marshalChannel(uc, name) 830 830 … … 865 865 trailing = strconv.Itoa(hops) + " " + realname 866 866 867 uc.forEachDownstreamByI d(downstreamId, func(dc *downstreamConn) {867 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 868 868 channel := channel 869 869 if channel != "*" { … … 883 883 } 884 884 885 uc.forEachDownstreamByI d(downstreamId, func(dc *downstreamConn) {885 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 886 886 name := name 887 887 if name != "*" { … … 901 901 } 902 902 903 uc.forEachDownstreamByI d(downstreamId, func(dc *downstreamConn) {903 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 904 904 nick := dc.marshalNick(uc, nick) 905 905 dc.SendMessage(&irc.Message{ … … 915 915 } 916 916 917 uc.forEachDownstreamByI d(downstreamId, func(dc *downstreamConn) {917 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 918 918 nick := dc.marshalNick(uc, nick) 919 919 dc.SendMessage(&irc.Message{ … … 929 929 } 930 930 931 uc.forEachDownstreamByI d(downstreamId, func(dc *downstreamConn) {931 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 932 932 nick := dc.marshalNick(uc, nick) 933 933 dc.SendMessage(&irc.Message{ … … 943 943 } 944 944 945 uc.forEachDownstreamByI d(downstreamId, func(dc *downstreamConn) {945 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 946 946 nick := dc.marshalNick(uc, nick) 947 947 params := []string{dc.nick, nick} … … 960 960 channels := strings.Split(channelList, " ") 961 961 962 uc.forEachDownstreamByI d(downstreamId, func(dc *downstreamConn) {962 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 963 963 nick := dc.marshalNick(uc, nick) 964 964 channelList := make([]string, len(channels)) … … 981 981 } 982 982 983 uc.forEachDownstreamByI d(downstreamId, func(dc *downstreamConn) {983 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 984 984 nick := dc.marshalNick(uc, nick) 985 985 dc.SendMessage(&irc.Message{ … … 1159 1159 msg.Tags = make(map[string]irc.TagValue) 1160 1160 } 1161 msg.Tags["label"] = irc.TagValue(fmt.Sprintf("sd-%d-%d", dc.id, uc.nextLabelI d))1162 uc.nextLabelI d++1161 msg.Tags["label"] = irc.TagValue(fmt.Sprintf("sd-%d-%d", dc.id, uc.nextLabelID)) 1162 uc.nextLabelID++ 1163 1163 } 1164 1164 uc.SendMessage(msg)
Note:
See TracChangeset
for help on using the changeset viewer.