Changeset 102 in code for trunk/upstream.go

Timestamp:

Mar 16, 2020, 10:26:54 AM (5 years ago)

Author:

contact

Message:

Rename messages channels to outgoing

File:

• trunk/upstream.go (modified) (6 diffs)

trunk/upstream.go

@@ -34 +34 @@
         srv      *Server
         user     *user
-        messages chan<- *irc.Message
+        outgoing chan<- *irc.Message
         ring     *Ring
 
@@ -72 +72 @@
         setKeepAlive(netConn)
 
-        msgs := make(chan *irc.Message, 64)
+        outgoing := make(chan *irc.Message, 64)
         uc := &upstreamConn{
                 network:  network,
@@ -80 +80 @@
                 srv:      network.user.srv,
                 user:     network.user,
-                messages: msgs,
+                outgoing: outgoing,
                 ring:     NewRing(network.user.srv.RingCap),
                 channels: make(map[string]*upstreamChannel),
@@ -88 +88 @@
 
         go func() {
-                for msg := range msgs {
+                for msg := range outgoing {
                         if uc.srv.Debug {
                                 uc.logger.Printf("sent: %v", msg)
@@ -110 +110 @@
                 return fmt.Errorf("upstream connection already closed")
         }
-        close(uc.messages)
+        close(uc.outgoing)
         uc.closed = true
         return nil
@@ -682 +682 @@
 
 func (uc *upstreamConn) SendMessage(msg *irc.Message) {
-        uc.messages <- msg
-}
+        uc.outgoing <- msg
+}