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

Temp: add some logs

Browse Source
This commit is contained in:
yuhan6665 2025-04-06 17:27:24 -04:00
parent 33acf3c2b6
commit e4a5344189
3 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
common/crypto/chunk.go
View File

@ -1,11 +1,13 @@
package crypto package crypto
import ( import (
"context"
"encoding/binary" "encoding/binary"
"io" "io"
"github.com/xtls/xray-core/common" "github.com/xtls/xray-core/common"
"github.com/xtls/xray-core/common/buf" "github.com/xtls/xray-core/common/buf"
"github.com/xtls/xray-core/common/errors"
) )
// ChunkSizeDecoder is a utility class to decode size value from bytes. // ChunkSizeDecoder is a utility class to decode size value from bytes.
@ -117,6 +119,7 @@ func (r *ChunkStreamReader) ReadMultiBuffer() (buf.MultiBuffer, error) {
} }
r.leftOverSize = size r.leftOverSize = size
errors.LogInfo(context.Background(), "StreamReader read ", size)
mb, err := r.reader.ReadAtMost(size) mb, err := r.reader.ReadAtMost(size)
if !mb.IsEmpty() { if !mb.IsEmpty() {
r.leftOverSize -= mb.Len() r.leftOverSize -= mb.Len()

2
common/mux/reader.go
View File

@ -1,6 +1,7 @@
package mux package mux
import ( import (
"context"
"io" "io"
"github.com/xtls/xray-core/common/buf" "github.com/xtls/xray-core/common/buf"
@ -33,6 +34,7 @@ func (r *PacketReader) ReadMultiBuffer() (buf.MultiBuffer, error) {
} }
size, err := serial.ReadUint16(r.reader) size, err := serial.ReadUint16(r.reader)
errors.LogInfo(context.Background(), "PacketReader read ", size, r.dest)
if err != nil { if err != nil {
return nil, err return nil, err
} }

4
common/mux/writer.go
View File

@ -1,8 +1,11 @@
package mux package mux
import ( import (
"context"
"github.com/xtls/xray-core/common" "github.com/xtls/xray-core/common"
"github.com/xtls/xray-core/common/buf" "github.com/xtls/xray-core/common/buf"
"github.com/xtls/xray-core/common/errors"
"github.com/xtls/xray-core/common/net" "github.com/xtls/xray-core/common/net"
"github.com/xtls/xray-core/common/protocol" "github.com/xtls/xray-core/common/protocol"
"github.com/xtls/xray-core/common/serial" "github.com/xtls/xray-core/common/serial"
@ -106,6 +109,7 @@ func (w *Writer) WriteMultiBuffer(mb buf.MultiBuffer) error {
mb = mb2 mb = mb2
chunk = buf.MultiBuffer{b} chunk = buf.MultiBuffer{b}
} }
errors.LogInfo(context.Background(), "MuxWriter write ", chunk.Len(), w.dest)
if err := w.writeData(chunk); err != nil { if err := w.writeData(chunk); err != nil {
return err return err
} }