Changeset 131 in code for trunk/downstream.go


Ignore:
Timestamp:
Mar 20, 2020, 9:48:17 PM (5 years ago)
Author:
contact
Message:

Move upstreamConn.history to network

File:
1 edited

Legend:

Unmodified
Added
Removed

  • trunk/downstream.go

    r130 r131  
    709709                var seqPtr *uint64
    710710                if firstDownstream {
    711                         uc.lock.Lock()
    712                         seq, ok := uc.history[historyName]
    713                         uc.lock.Unlock()
     711                        uc.network.lock.Lock()
     712                        seq, ok := uc.network.history[historyName]
     713                        uc.network.lock.Unlock()
    714714                        if ok {
    715715                                seqPtr = &seq
    … …  
    739739
    740740                        if lastDownstream {
    741                                 uc.lock.Lock()
    742                                 uc.history[historyName] = seq
    743                                 uc.lock.Unlock()
     741                                uc.network.lock.Lock()
     742                                uc.network.history[historyName] = seq
     743                                uc.network.lock.Unlock()
    744744                        }
    745745                }()
Note: See TracChangeset for help on using the changeset viewer.