Skip to content

Commit c9d8cc3

Browse files
committed
Revert unrelated event forwarding refactor
1 parent 34fde89 commit c9d8cc3

1 file changed

Lines changed: 7 additions & 7 deletions

File tree

comp/networkpath/npcollector/impl/npcollector.go

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -460,13 +460,13 @@ func (s *npCollectorImpl) runTracerouteForPath(ptest *pathteststore.PathtestCont
460460
payloadBytes, err := json.Marshal(path)
461461
if err != nil {
462462
s.logger.Errorf("json marshall error: %s", err)
463-
return
464-
}
465-
s.logger.Debugf("network path event: %s", string(payloadBytes))
466-
m := message.NewMessage(payloadBytes, nil, "", 0)
467-
err = s.epForwarder.SendEventPlatformEventBlocking(m, eventplatform.EventTypeNetworkPath)
468-
if err != nil {
469-
s.logger.Errorf("failed to send event to epForwarder: %s", err)
463+
} else {
464+
s.logger.Debugf("network path event: %s", string(payloadBytes))
465+
m := message.NewMessage(payloadBytes, nil, "", 0)
466+
err = s.epForwarder.SendEventPlatformEventBlocking(m, eventplatform.EventTypeNetworkPath)
467+
if err != nil {
468+
s.logger.Errorf("failed to send event to epForwarder: %s", err)
469+
}
470470
}
471471
}
472472

0 commit comments

Comments
 (0)