Changeset 130 in code for trunk/downstream.go


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

Fix deadlocks in single-upstream mode

File:
1 edited

Legend:

Unmodified
Added
Removed

  • trunk/downstream.go

    r129 r130  
    109109        }()
    110110
     111        dc.logger.Printf("new connection")
    111112        return dc
    112113}
    … …  
    159160
    160161func (dc *downstreamConn) marshalChannel(uc *upstreamConn, name string) string {
    161         if dc.upstream() != nil {
     162        if dc.network != nil {
    162163                return name
    163164        }
    … …  
    196197                return dc.nick
    197198        }
    198         if dc.upstream() != nil {
     199        if dc.network != nil {
    199200                return nick
    200201        }
    … …  
    206207                return dc.prefix()
    207208        }
    208         if dc.upstream() != nil {
     209        if dc.network != nil {
    209210                return prefix
    210211        }
    … …  
    226227
    227228func (dc *downstreamConn) readMessages(ch chan<- downstreamIncomingMessage) error {
    228         dc.logger.Printf("new connection")
    229 
    230229        for {
    231230                msg, err := dc.irc.ReadMessage()
    … …  
    665664        dc.registered = true
    666665        dc.username = dc.user.Username
     666        dc.logger.Printf("registration complete for user %q", dc.username)
    667667
    668668        dc.user.lock.Lock()
Note: See TracChangeset for help on using the changeset viewer.