feat(adaptive):add new attribute for compressInfo.

wqshr12345 · Oct 24, 2023 · 53ff30d · 53ff30d
1 parent 6ec335d
commit 53ff30d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/adaptive/adaptive.go b/adaptive/adaptive.go
@@ -3,6 +3,7 @@ package adaptive
 type CompressInfo struct {
 	PkgId          int
 	CompressType   int
+	DataLen        int //original data
 	CompressTime   int64
 	TranportTime   int64
 	DecompressTime int64

diff --git a/adaptive/reader.go b/adaptive/reader.go
@@ -107,6 +107,7 @@ func (r *Reader) fill() error {
 	endTs := time.Now().UnixNano()
 	compressInfo := CompressInfo{
 		PkgId:          r.pkgID,
+		DataLen:        len(r.oBuf),
 		CompressType:   int(compressType),
 		CompressTime:   midTs - startTs,
 		TranportTime:   mid2Ts - midTs,