Merge pull request #571 from TiceDB/patch-2

Point JSON field in_bytes to inBytes instead of inPackets
phaag · Oct 19, 2024 · 4c8b892 · 4c8b892
2 parents b96828f + b1d2a1f
commit 4c8b892
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/output/output_json.c b/src/output/output_json.c
@@ -149,7 +149,7 @@ static char *stringEXgenericFlow(char *streamPtr, void *extensionRecord) {
     streamPtr += len;
 
     AddElementU64("in_packets", genericFlow->inPackets);
-    AddElementU64("in_bytes", genericFlow->inPackets);
+    AddElementU64("in_bytes", genericFlow->inBytes);
 
     if (genericFlow->proto == IPPROTO_ICMP || genericFlow->proto == IPPROTO_ICMPV6) {  // ICMP
         AddElementU32("proto", (uint32_t)genericFlow->proto);

diff --git a/src/output/output_ndjson.c b/src/output/output_ndjson.c
@@ -137,7 +137,7 @@ static char *stringEXgenericFlow(char *streamPtr, void *extensionRecord) {
     streamPtr += len;
 
     AddElementU64("in_packets", genericFlow->inPackets);
-    AddElementU64("in_bytes", genericFlow->inPackets);
+    AddElementU64("in_bytes", genericFlow->inBytes);
 
     if (genericFlow->proto == IPPROTO_ICMP || genericFlow->proto == IPPROTO_ICMPV6) {  // ICMP
         AddElementU32("proto", (uint32_t)genericFlow->proto);
@@ -942,4 +942,4 @@ void flow_record_to_ndjson(FILE *stream, recordHandle_t *recordHandle, int tag)
 
     fputs(streamBuff, stream);
 
-}  // End of flow_record_to_ndjson
+}  // End of flow_record_to_ndjson