@@ -244,8 +244,8 @@ type Conn struct {
244
244
subprotocol string
245
245
246
246
// Write fields
247
- mu chan bool // used as mutex to protect write to conn
248
- writeBuf []byte // frame is constructed in this buffer.
247
+ mu chan struct {} // used as mutex to protect write to conn
248
+ writeBuf []byte // frame is constructed in this buffer.
249
249
writePool BufferPool
250
250
writeBufSize int
251
251
writeDeadline time.Time
@@ -302,8 +302,8 @@ func newConn(conn net.Conn, isServer bool, readBufferSize, writeBufferSize int,
302
302
writeBuf = make ([]byte , writeBufferSize )
303
303
}
304
304
305
- mu := make (chan bool , 1 )
306
- mu <- true
305
+ mu := make (chan struct {} , 1 )
306
+ mu <- struct {}{}
307
307
c := & Conn {
308
308
isServer : isServer ,
309
309
br : br ,
@@ -377,7 +377,7 @@ func (c *Conn) read(n int) ([]byte, error) {
377
377
378
378
func (c * Conn ) write (frameType int , deadline time.Time , buf0 , buf1 []byte ) error {
379
379
<- c .mu
380
- defer func () { c .mu <- true }()
380
+ defer func () { c .mu <- struct {}{} }()
381
381
382
382
c .writeErrMu .Lock ()
383
383
err := c .writeErr
@@ -429,7 +429,7 @@ func (c *Conn) WriteControl(messageType int, data []byte, deadline time.Time) er
429
429
maskBytes (key , 0 , buf [6 :])
430
430
}
431
431
432
- d := time . Hour * 1000
432
+ d := 1000 * time . Hour
433
433
if ! deadline .IsZero () {
434
434
d = deadline .Sub (time .Now ())
435
435
if d < 0 {
@@ -444,7 +444,7 @@ func (c *Conn) WriteControl(messageType int, data []byte, deadline time.Time) er
444
444
case <- timer .C :
445
445
return errWriteTimeout
446
446
}
447
- defer func () { c .mu <- true }()
447
+ defer func () { c .mu <- struct {}{} }()
448
448
449
449
c .writeErrMu .Lock ()
450
450
err := c .writeErr
0 commit comments