d

captrace/captrace.go

@@ -298,7 +298,7 @@ func gtpuHandler(rvMsg []byte, rvLen int) {
 				tr.DstAddr = fmt.Sprintf("%s:%d", extHdr.DstIP, extHdr.DstPort)
 				tr.MsgType = int(extHdr.MsgType)
 				tr.MsgDirect = int(extHdr.MsgDirect)
-
+				tr.Length = int(rvLen - off)
 				tr.RawMsg = make([]byte, int(rvLen-off))
 				copy(tr.RawMsg, []byte(msg[off:]))
 

database/upgrade/zupgrade.sql

@@ -92,4 +92,8 @@ ADD COLUMN IF NOT EXISTS `path` varchar(128) NULL AFTER `status`,
 ADD COLUMN IF NOT EXISTS `file_name` varchar(64) NULL AFTER `path`,
 ADD COLUMN IF NOT EXISTS `comment` varchar(255) NULL AFTER `file_name`;
 
-DELETE FROM ne_license WHERE file_name IS NULL
+DELETE FROM ne_license WHERE file_name IS NULL;
+
+ALTER TABLE `omc_db`.`trace_data` 
+ADD COLUMN IF NOT EXISTS `length` int NULL AFTER `msg_direct`;
+

lib/dborm/dborm.go

@@ -1751,6 +1751,7 @@ type TraceData struct {
 	IfType    int    `json:"ifType" xorm:"if_type"`
 	MsgType   int    `json:"msgType" xorm:"msg_type"`
 	MsgDirect int    `json:"msgDirect" xorm:"msg_direct"`
+	Length    int    `json:"length" xorm:"length"`
 	Timestamp int64  `json:"timestamp" xorm:"timestamp"`
 	RawMsg    []byte `json:"rawMsg" xorm:"raw_msg"`
 	DecMsg    string `json:"decMsg" xorm:"dec_msg"`