mirrors/Xray-core
1
0
Fork 0
mirror of https://github.com/XTLS/Xray-core.git synced 2025-04-15 01:54:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add some logs for troubleshooting

Browse Source
This commit is contained in:
yuhan6665 2025-03-09 22:59:30 -04:00
parent 129b2be9c1
commit 7c78408df9
2 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
transport/internet/quic/conn.go
View File

@ -41,6 +41,7 @@ func NewConnInitReader(ctx context.Context, quicConn quic.Connection, done *done
go func() { go func() {
for { for {
received, e := c.quicConn.ReceiveDatagram(c.ctx) received, e := c.quicConn.ReceiveDatagram(c.ctx)
errors.LogInfo(c.ctx, "Read ReceiveDatagram ", len(received))
c.readChannel <- readResult{buffer: received, err: e} c.readChannel <- readResult{buffer: received, err: e}
} }
}() }()
@ -51,6 +52,7 @@ func NewConnInitReader(ctx context.Context, quicConn quic.Connection, done *done
func (c *interConn) acceptStreams() { func (c *interConn) acceptStreams() {
for { for {
stream, err := c.quicConn.AcceptStream(context.Background()) stream, err := c.quicConn.AcceptStream(context.Background())
errors.LogInfo(c.ctx, "Read AcceptStream ", err)
if err != nil { if err != nil {
errors.LogInfoInner(context.Background(), err, "failed to accept stream") errors.LogInfoInner(context.Background(), err, "failed to accept stream")
select { select {
@ -70,6 +72,7 @@ func (c *interConn) acceptStreams() {
for { for {
received := make([]byte, buf.Size) received := make([]byte, buf.Size)
i, e := stream.Read(received) i, e := stream.Read(received)
errors.LogInfo(c.ctx, "Read stream ", i)
c.readChannel <- readResult{buffer: received[:i], err: e} c.readChannel <- readResult{buffer: received[:i], err: e}
} }
}() }()
@ -83,6 +86,7 @@ func (c *interConn) Read(b []byte) (int, error) {
return 0, received.err return 0, received.err
} }
nBytes := copy(b, received.buffer[:]) nBytes := copy(b, received.buffer[:])
errors.LogInfo(c.ctx, "Read copy ", nBytes)
return nBytes, nil return nBytes, nil
} }
@ -95,9 +99,11 @@ func (c *interConn) WriteMultiBuffer(mb buf.MultiBuffer) error {
func (c *interConn) Write(b []byte) (int, error) { func (c *interConn) Write(b []byte) (int, error) {
var err = c.quicConn.SendDatagram(b) var err = c.quicConn.SendDatagram(b)
errors.LogInfo(c.ctx, "Write SendDatagram ", len(b), err)
if _, ok := err.(*quic.DatagramTooLargeError); ok { if _, ok := err.(*quic.DatagramTooLargeError); ok {
if len(c.streams) < MaxIncomingStreams { if len(c.streams) < MaxIncomingStreams {
stream, err := c.quicConn.OpenStream() stream, err := c.quicConn.OpenStream()
errors.LogInfo(c.ctx, "Write OpenStream ", err)
if err == nil { if err == nil {
c.streams = append(c.streams, stream) c.streams = append(c.streams, stream)
} else { } else {
@ -108,6 +114,7 @@ func (c *interConn) Write(b []byte) (int, error) {
if currentStream > len(c.streams) - 1 { if currentStream > len(c.streams) - 1 {
currentStream = 0; currentStream = 0;
} }
errors.LogInfo(c.ctx, "Write stream ", len(b), currentStream, len(c.streams))
return c.streams[currentStream].Write(b) return c.streams[currentStream].Write(b)
} }
if err != nil { if err != nil {

2
transport/internet/quic/quic_test.go
View File

@ -89,6 +89,8 @@ func testQuicConnection(t *testing.T, dataLen int32) {
t.Error(r) t.Error(r)
} }
time.Sleep(1000 * time.Millisecond)
common.Must2(conn.Write(b1)) common.Must2(conn.Write(b1))
b2.Clear() b2.Clear()