- Timestamp:
- Mar 27, 2020, 11:54:42 PM (5 years ago)
- Location:
- trunk
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/downstream.go
r179 r180 307 307 } 308 308 309 // Close closes the connection. It is safe to call from any goroutine. 309 310 func (dc *downstreamConn) Close() error { 310 311 if dc.isClosed() { 311 312 return fmt.Errorf("downstream connection already closed") 312 313 } 313 314 314 close(dc.closed) 315 315 return nil 316 316 } 317 317 318 // SendMessage queues a new outgoing message. It is safe to call from any 319 // goroutine. 318 320 func (dc *downstreamConn) SendMessage(msg *irc.Message) { 319 321 dc.outgoing <- msg -
trunk/upstream.go
r179 r180 146 146 } 147 147 148 // Close closes the connection. It is safe to call from any goroutine. 148 149 func (uc *upstreamConn) Close() error { 149 150 if uc.isClosed() { … … 1392 1393 } 1393 1394 1395 // SendMessage queues a new outgoing message. It is safe to call from any 1396 // goroutine. 1394 1397 func (uc *upstreamConn) SendMessage(msg *irc.Message) { 1395 1398 uc.outgoing <- msg
Note:
See TracChangeset
for help on using the changeset viewer.