Skip to content

Commit 6e1827d

Browse files
authored
Fix cni logs (#548)
* Added else if to catch empty messages * Stopped sending empty messages to AI telemetry for CNI * Removing cni prefix from log messages * Reverting go.sum change back to what it was before * Adding check for empty messages before sending metric * Moving empty message check before cnimetric initialization
1 parent ef14c8d commit 6e1827d

File tree

2 files changed

+19
-13
lines changed

2 files changed

+19
-13
lines changed

cni/network/plugin/main.go

Lines changed: 15 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -242,13 +242,16 @@ func main() {
242242
}
243243

244244
executionTimeMs := time.Since(startTime).Milliseconds()
245-
cnimetric.Metric = aitelemetry.Metric{
246-
Name: telemetry.CNIExecutimeMetricStr,
247-
Value: float64(executionTimeMs),
248-
CustomDimensions: make(map[string]string),
245+
246+
if cniReport.ErrorMessage != "" || cniReport.EventMessage != "" {
247+
cnimetric.Metric = aitelemetry.Metric{
248+
Name: telemetry.CNIExecutimeMetricStr,
249+
Value: float64(executionTimeMs),
250+
CustomDimensions: make(map[string]string),
251+
}
252+
network.SetCustomDimensions(&cnimetric, nil, err)
253+
telemetry.SendCNIMetric(&cnimetric, tb)
249254
}
250-
network.SetCustomDimensions(&cnimetric, nil, err)
251-
telemetry.SendCNIMetric(&cnimetric, tb)
252255

253256
if err != nil {
254257
reportPluginError(reportManager, tb, err)
@@ -259,10 +262,11 @@ func main() {
259262
reflect.ValueOf(reportManager.Report).Elem().FieldByName("CniSucceeded").SetBool(true)
260263
reflect.ValueOf(reportManager.Report).Elem().FieldByName("OperationDuration").SetInt(executionTimeMs)
261264

262-
if err = reportManager.SendReport(tb); err != nil {
263-
log.Errorf("SendReport failed due to %v", err)
264-
} else {
265-
log.Printf("Sending report succeeded")
265+
if cniReport.ErrorMessage != "" || cniReport.EventMessage != "" {
266+
if err = reportManager.SendReport(tb); err != nil {
267+
log.Errorf("SendReport failed due to %v", err)
268+
} else {
269+
log.Printf("Sending report succeeded")
270+
}
266271
}
267-
268272
}

telemetry/aiwrapper.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,12 +47,14 @@ func SendAITelemetry(cnireport CNIReport) {
4747
var msg string
4848
if cnireport.ErrorMessage != "" {
4949
msg = cnireport.ErrorMessage
50-
} else {
50+
} else if cnireport.EventMessage != "" {
5151
msg = cnireport.EventMessage
52+
} else {
53+
return
5254
}
5355

5456
report := aitelemetry.Report{
55-
Message: "CNI:" + msg,
57+
Message: msg,
5658
Context: cnireport.ContainerName,
5759
CustomDimensions: make(map[string]string),
5860
}

0 commit comments

Comments
 (0)