Changeset 102 in code


Ignore:
Timestamp:
Mar 16, 2020, 10:26:54 AM (5 years ago)
Author:
contact
Message:

Rename messages channels to outgoing

Location:
trunk
Files:
2 edited

Legend:

Unmodified
Added
Removed

  • trunk/downstream.go

    r100 r102  
    5858        srv          *Server
    5959        logger       Logger
    60         messages     chan *irc.Message
     60        outgoing     chan *irc.Message
    6161        consumptions chan consumption
    6262        closed       chan struct{}
    … …  
    7878                srv:          srv,
    7979                logger:       &prefixLogger{srv.Logger, fmt.Sprintf("downstream %q: ", netConn.RemoteAddr())},
    80                 messages:     make(chan *irc.Message, 64),
     80                outgoing:     make(chan *irc.Message, 64),
    8181                consumptions: make(chan consumption),
    8282                closed:       make(chan struct{}),
    … …  
    228228                var closed bool
    229229                select {
    230                 case msg := <-dc.messages:
     230                case msg := <-dc.outgoing:
    231231                        if dc.srv.Debug {
    232232                                dc.logger.Printf("sent: %v", msg)
    … …  
    291291
    292292func (dc *downstreamConn) SendMessage(msg *irc.Message) {
    293         dc.messages <- msg
     293        dc.outgoing <- msg
    294294}
    295295

  • trunk/upstream.go

    r98 r102  
    3434        srv      *Server
    3535        user     *user
    36         messages chan<- *irc.Message
     36        outgoing chan<- *irc.Message
    3737        ring     *Ring
    3838
    … …  
    7272        setKeepAlive(netConn)
    7373
    74         msgs := make(chan *irc.Message, 64)
     74        outgoing := make(chan *irc.Message, 64)
    7575        uc := &upstreamConn{
    7676                network:  network,
    … …  
    8080                srv:      network.user.srv,
    8181                user:     network.user,
    82                 messages: msgs,
     82                outgoing: outgoing,
    8383                ring:     NewRing(network.user.srv.RingCap),
    8484                channels: make(map[string]*upstreamChannel),
    … …  
    8888
    8989        go func() {
    90                 for msg := range msgs {
     90                for msg := range outgoing {
    9191                        if uc.srv.Debug {
    9292                                uc.logger.Printf("sent: %v", msg)
    … …  
    110110                return fmt.Errorf("upstream connection already closed")
    111111        }
    112         close(uc.messages)
     112        close(uc.outgoing)
    113113        uc.closed = true
    114114        return nil
    … …  
    682682
    683683func (uc *upstreamConn) SendMessage(msg *irc.Message) {
    684         uc.messages <- msg
    685 }
     684        uc.outgoing <- msg
     685}
Note: See TracChangeset for help on using the changeset viewer.