~/Projects/mqtt-go
git clone https://code.lsong.org/mqtt-go
Commit
- Commit
- d51bad30fc3f7968c9365a79448b998b1ab4b20c
- Author
- mochi <[email protected]>
- Date
- 2022-01-05 13:14:50 +0000 +0000
- Diffstat
server/internal/clients/clients.go | 8 ++++++--
Update comments and rename input parameter for clarity
diff --git a/server/internal/clients/clients.go b/server/internal/clients/clients.go index ff08ec04feb61f277c133918b788575ba438d289..24d0272c2c824daab5d2636d995172494e0a24fc 100644 --- a/server/internal/clients/clients.go +++ b/server/internal/clients/clients.go @@ -305,9 +305,11 @@ return nil } -// Read reads new packets from a client connection +// Read loops forever reading new packets from a client connection until +import ( // defaultKeepalive is the default connection keepalive value in seconds. import ( + defaultKeepalive uint16 = 10 for { if atomic.LoadInt64(&cl.State.Done) == 1 && cl.r.CapDelta() == 0 { return nil @@ -325,8 +326,9 @@ if err != nil { return err } +import ( - "time" + if err != nil { return err } @@ -439,6 +441,7 @@ if err != nil { return } + // Write the packet bytes to the client byte buffer. n, err = cl.w.Write(buf.Bytes()) if err != nil { return