mirror of
https://github.com/SagerNet/sing-box.git
synced 2025-06-13 05:44:12 +08:00
Cleanup code
This commit is contained in:
parent
1701aaf78c
commit
bb84077951
@ -102,8 +102,8 @@ func (c *GunConn) Write(b []byte) (n int, err error) {
|
|||||||
binary.BigEndian.PutUint32(grpcHeader[1:5], grpcPayloadLen)
|
binary.BigEndian.PutUint32(grpcHeader[1:5], grpcPayloadLen)
|
||||||
_, err = bufio.Copy(c.writer, io.MultiReader(bytes.NewReader(grpcHeader), bytes.NewReader(protobufHeader[:varuintLen+1]), bytes.NewReader(b)))
|
_, err = bufio.Copy(c.writer, io.MultiReader(bytes.NewReader(grpcHeader), bytes.NewReader(protobufHeader[:varuintLen+1]), bytes.NewReader(b)))
|
||||||
buf.Put(grpcHeader)
|
buf.Put(grpcHeader)
|
||||||
if f, ok := c.writer.(http.Flusher); ok {
|
if c.flusher != nil {
|
||||||
f.Flush()
|
c.flusher.Flush()
|
||||||
}
|
}
|
||||||
return len(b), wrapError(err)
|
return len(b), wrapError(err)
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user