Changeset 181 in code for trunk/upstream.go
- Timestamp:
- Mar 28, 2020, 12:03:00 AM (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/upstream.go
r180 r181 188 188 } 189 189 190 func (uc *upstreamConn) getPendingL ist() *pendingLIST {190 func (uc *upstreamConn) getPendingLIST() *pendingLIST { 191 191 for _, pl := range uc.user.pendingLISTs { 192 192 if _, ok := pl.pendingCommands[uc.network.ID]; !ok { … … 198 198 } 199 199 200 func (uc *upstreamConn) endPendingL ists(all bool) (found bool) {200 func (uc *upstreamConn) endPendingLISTs(all bool) (found bool) { 201 201 found = false 202 202 for i := 0; i < len(uc.user.pendingLISTs); i++ { … … 221 221 delete(uc.pendingLISTDownstreamSet, pl.downstreamID) 222 222 uc.user.forEachUpstream(func(uc *upstreamConn) { 223 uc.trySendL ist(pl.downstreamID)223 uc.trySendLIST(pl.downstreamID) 224 224 }) 225 225 return … … 229 229 } 230 230 231 func (uc *upstreamConn) trySendL ist(downstreamID uint64) {231 func (uc *upstreamConn) trySendLIST(downstreamID uint64) { 232 232 // must be called with a lock in uc.user.pendingLISTsLock 233 233 … … 959 959 } 960 960 961 pl := uc.getPendingL ist()961 pl := uc.getPendingLIST() 962 962 if pl == nil { 963 963 return fmt.Errorf("unexpected RPL_LIST: no matching pending LIST") … … 972 972 }) 973 973 case irc.RPL_LISTEND: 974 ok := uc.endPendingL ists(false)974 ok := uc.endPendingLISTs(false) 975 975 if !ok { 976 976 return fmt.Errorf("unexpected RPL_LISTEND: no matching pending LIST") … … 1246 1246 1247 1247 if command == "LIST" { 1248 ok := uc.endPendingL ists(false)1248 ok := uc.endPendingLISTs(false) 1249 1249 if !ok { 1250 1250 return fmt.Errorf("unexpected response for LIST: %q: no matching pending LIST", msg.Command)
Note:
See TracChangeset
for help on using the changeset viewer.