Changeset 465 in code


Ignore:
Timestamp:
Mar 16, 2021, 8:19:12 AM (4 years ago)
Author:
contact
Message:

Correctly set WebSocket read/write deadline

The methods didn't have pointer receivers. Thus the deadline fields
were only updated for the local variable.

Closes: https://todo.sr.ht/~emersion/soju/106

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/conn.go

    r415 r465  
    4242
    4343func newWebsocketIRCConn(c *websocket.Conn, remoteAddr string) ircConn {
    44         return websocketIRCConn{conn: c, remoteAddr: remoteAddr}
    45 }
    46 
    47 func (wic websocketIRCConn) ReadMessage() (*irc.Message, error) {
     44        return &websocketIRCConn{conn: c, remoteAddr: remoteAddr}
     45}
     46
     47func (wic *websocketIRCConn) ReadMessage() (*irc.Message, error) {
    4848        ctx := context.Background()
    4949        if !wic.readDeadline.IsZero() {
     
    6464}
    6565
    66 func (wic websocketIRCConn) WriteMessage(msg *irc.Message) error {
     66func (wic *websocketIRCConn) WriteMessage(msg *irc.Message) error {
    6767        b := []byte(strings.ToValidUTF8(msg.String(), string(unicode.ReplacementChar)))
    6868        ctx := context.Background()
     
    7575}
    7676
    77 func (wic websocketIRCConn) Close() error {
     77func (wic *websocketIRCConn) Close() error {
    7878        return wic.conn.Close(websocket.StatusNormalClosure, "")
    7979}
    8080
    81 func (wic websocketIRCConn) SetReadDeadline(t time.Time) error {
     81func (wic *websocketIRCConn) SetReadDeadline(t time.Time) error {
    8282        wic.readDeadline = t
    8383        return nil
    8484}
    8585
    86 func (wic websocketIRCConn) SetWriteDeadline(t time.Time) error {
     86func (wic *websocketIRCConn) SetWriteDeadline(t time.Time) error {
    8787        wic.writeDeadline = t
    8888        return nil
    8989}
    9090
    91 func (wic websocketIRCConn) RemoteAddr() net.Addr {
     91func (wic *websocketIRCConn) RemoteAddr() net.Addr {
    9292        return websocketAddr(wic.remoteAddr)
    9393}
    9494
    95 func (wic websocketIRCConn) LocalAddr() net.Addr {
     95func (wic *websocketIRCConn) LocalAddr() net.Addr {
    9696        // Behind a reverse HTTP proxy, we don't have access to the real listening
    9797        // address
Note: See TracChangeset for help on using the changeset viewer.