test

vmware · Sep 28, 2021 · c1e9be9 · c1e9be9
1 parent f2e5883
commit c1e9be9
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/pkg/intermediate/aggregate.go b/pkg/intermediate/aggregate.go
@@ -472,6 +472,14 @@ func (a *AggregationProcess) aggregateRecords(incomingRecord, existingRecord ent
 			existingIeWithValue, index, _ := existingRecord.GetInfoElementWithValue(element)
 			switch ieWithValue.Element.Name {
 			case "flowEndSeconds":
+				srcPodName, _, _ := incomingRecord.GetInfoElementWithValue("sourcePodName")
+				dstPodName, _, _ := incomingRecord.GetInfoElementWithValue("destinationPodName")
+				if srcPodName.Value.(string) == "perftest-a" || dstPodName.Value.(string) == "perftest-c" {
+					klog.Info("FLOWENDSECONDS: ", ieWithValue.Value)
+					klog.Info("FILLSRCSTATS: ", fillSrcStats)
+					klog.Info("FILLDSTSTATS: ", fillDstStats)
+					klog.Info("\n\n")
+				}
 				// Update flow end timestamp if it is latest.
 				if isLatest {
 					existingIeWithValue.Value = ieWithValue.Value