Changeset 238 in code for trunk/downstream.go


Ignore:
Timestamp:
Apr 6, 2020, 7:34:45 PM (5 years ago)
Author:
contact
Message:

Add origin argument to upstreamConn.produce

File:
1 edited

Legend:

Unmodified
Added
Removed

  • trunk/downstream.go

    r236 r238  
    11881188
    11891189                        uc.appendLog(upstreamName, echoMsg)
    1190 
    1191                         uc.network.ring.Produce(echoMsg)
    1192 
    1193                         uc.forEachDownstream(func(c *downstreamConn) {
    1194                                 if c != dc || c.caps["echo-message"] {
    1195                                         c.sendFromUpstream(echoMsg, uc)
    1196                                 }
    1197                         })
     1190                        uc.produce(echoMsg, dc)
    11981191                }
    11991192        case "NOTICE":
Note: See TracChangeset for help on using the changeset viewer.