Changeset 102 in code for trunk/downstream.go
- Timestamp:
- Mar 16, 2020, 10:26:54 AM (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/downstream.go
r100 r102 58 58 srv *Server 59 59 logger Logger 60 messageschan *irc.Message60 outgoing chan *irc.Message 61 61 consumptions chan consumption 62 62 closed chan struct{} … … 78 78 srv: srv, 79 79 logger: &prefixLogger{srv.Logger, fmt.Sprintf("downstream %q: ", netConn.RemoteAddr())}, 80 messages: make(chan *irc.Message, 64),80 outgoing: make(chan *irc.Message, 64), 81 81 consumptions: make(chan consumption), 82 82 closed: make(chan struct{}), … … 228 228 var closed bool 229 229 select { 230 case msg := <-dc. messages:230 case msg := <-dc.outgoing: 231 231 if dc.srv.Debug { 232 232 dc.logger.Printf("sent: %v", msg) … … 291 291 292 292 func (dc *downstreamConn) SendMessage(msg *irc.Message) { 293 dc. messages<- msg293 dc.outgoing <- msg 294 294 } 295 295
Note:
See TracChangeset
for help on using the changeset viewer.