Niko/hysteria
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: consume TCP request frame type with StreamDispatcher

Browse source
This commit is contained in:
Hari 2026-02-18 10:18:42 +08:00
parent cd2f0a7bec
commit 6da70e80aa
No known key found for this signature in database
GPG key ID: E5C0CDE01361312F
1 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
core/server/server.go
View file

@ -10,6 +10,7 @@ import (
"github.com/apernet/quic-go"
"github.com/apernet/quic-go/http3"
"github.com/apernet/quic-go/quicvarint"
"github.com/apernet/hysteria/core/v2/internal/congestion"
"github.com/apernet/hysteria/core/v2/internal/protocol"
@ -210,11 +211,15 @@ func (h *h3sHandler) ProxyStreamHijacker(ft http3.FrameType, stream *quic.Stream
return false, nil
}
// Wraps the stream with QStream, which handles Close() properly
qStream := &utils.QStream{Stream: stream}
switch ft {
case protocol.FrameTypeTCPRequest:
// StreamDispatcher only peeks the frame type. Consume it so ReadTCPRequest
// starts at address length, matching pre-upgrade StreamHijacker behavior.
if _, err := quicvarint.Read(quicvarint.NewReader(stream)); err != nil {
return false, err
}
// Wraps the stream with QStream, which handles Close() properly
qStream := &utils.QStream{Stream: stream}
go h.handleTCPRequest(qStream)
return true, nil
default: