github
/
v2ray-core
mirror of https://github.com/v2ray/v2ray-core
1
0
Fork 0
Code Issues Releases Wiki Activity

fix test break

pull/109/head
v2ray 2016-03-13 11:34:09 +01:00
parent ff69ac7a0e
commit 77ecd1649b
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
proxy/vmess/inbound/inbound.go
View File

@ -149,13 +149,13 @@ func (this *VMessInboundHandler) HandleConnection(connection *hub.TCPConn) {
defer readFinish.Unlock() defer readFinish.Unlock()
bodyReader := session.DecodeRequestBody(reader) bodyReader := session.DecodeRequestBody(reader)
var requestReader v2io.ReleasableReader var requestReader v2io.ReleasableReader
defer requestReader.Release()
if request.Option.IsChunkStream() { if request.Option.IsChunkStream() {
requestReader = vmessio.NewAuthChunkReader(bodyReader) requestReader = vmessio.NewAuthChunkReader(bodyReader)
} else { } else {
requestReader = v2io.NewAdaptiveReader(bodyReader) requestReader = v2io.NewAdaptiveReader(bodyReader)
} }
v2io.ReaderToChan(input, requestReader) v2io.ReaderToChan(input, requestReader)
requestReader.Release()
}() }()
writer := v2io.NewBufferedWriter(connection) writer := v2io.NewBufferedWriter(connection)