diff --git a/common/crypto/chunk.go b/common/crypto/chunk.go index 9cd48181..beec6497 100644 --- a/common/crypto/chunk.go +++ b/common/crypto/chunk.go @@ -1,11 +1,13 @@ package crypto import ( + "context" "encoding/binary" "io" "github.com/xtls/xray-core/common" "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. @@ -117,6 +119,7 @@ func (r *ChunkStreamReader) ReadMultiBuffer() (buf.MultiBuffer, error) { } r.leftOverSize = size + errors.LogInfo(context.Background(), "StreamReader read ", size) mb, err := r.reader.ReadAtMost(size) if !mb.IsEmpty() { r.leftOverSize -= mb.Len() diff --git a/common/mux/reader.go b/common/mux/reader.go index b9714cdf..c3084e50 100644 --- a/common/mux/reader.go +++ b/common/mux/reader.go @@ -1,6 +1,7 @@ package mux import ( + "context" "io" "github.com/xtls/xray-core/common/buf" @@ -33,6 +34,7 @@ func (r *PacketReader) ReadMultiBuffer() (buf.MultiBuffer, error) { } size, err := serial.ReadUint16(r.reader) + errors.LogInfo(context.Background(), "PacketReader read ", size, r.dest) if err != nil { return nil, err } diff --git a/common/mux/writer.go b/common/mux/writer.go index a6dc551d..e9c113cb 100644 --- a/common/mux/writer.go +++ b/common/mux/writer.go @@ -1,8 +1,11 @@ package mux import ( + "context" + "github.com/xtls/xray-core/common" "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/protocol" "github.com/xtls/xray-core/common/serial" @@ -106,6 +109,7 @@ func (w *Writer) WriteMultiBuffer(mb buf.MultiBuffer) error { mb = mb2 chunk = buf.MultiBuffer{b} } + errors.LogInfo(context.Background(), "MuxWriter write ", chunk.Len(), w.dest) if err := w.writeData(chunk); err != nil { return err }