|
|
|
|
@ -199,7 +199,7 @@ func readFrame(br *bufio.Reader, maxSize uint32, b []byte) (t frameType, frameLe |
|
|
|
|
return 0, 0, fmt.Errorf("frame header size %d exceeds reader limit of %d", frameLen, maxSize) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
n, err := io.ReadFull(br, b[:minUint32(frameLen, uint32(len(b)))]) |
|
|
|
|
n, err := io.ReadFull(br, b[:min(frameLen, uint32(len(b)))]) |
|
|
|
|
if err != nil { |
|
|
|
|
return 0, 0, err |
|
|
|
|
} |
|
|
|
|
@ -233,10 +233,3 @@ func writeFrame(bw *bufio.Writer, t frameType, b []byte) error { |
|
|
|
|
} |
|
|
|
|
return bw.Flush() |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func minUint32(a, b uint32) uint32 { |
|
|
|
|
if a < b { |
|
|
|
|
return a |
|
|
|
|
} |
|
|
|
|
return b |
|
|
|
|
} |
|
|
|
|
|