Changeset 205 in code for trunk/upstream.go


Ignore:
Timestamp:
Apr 1, 2020, 2:27:53 PM (5 years ago)
Author:
contact
Message:

Set write deadlines

References: ​https://todo.sr.ht/~emersion/soju/26

File:
1 edited

Legend:

Unmodified
Added
Removed

  • trunk/upstream.go

    r198 r205  
    112112
    113113        go func() {
     114                // TODO: any SendMessage call after the connection is closed will
     115                // either block or drop
    114116                for {
    115117                        var closed bool
    … …  
    119121                                        uc.logger.Printf("sent: %v", msg)
    120122                                }
     123                                uc.net.SetWriteDeadline(time.Now().Add(writeTimeout))
    121124                                if err := uc.irc.WriteMessage(msg); err != nil {
    122125                                        uc.logger.Printf("failed to write message: %v", err)
     126                                        closed = true
    123127                                }
    124128                        case <-uc.closed:
Note: See TracChangeset for help on using the changeset viewer.