From 24abf3a958266aafe52f2e0f8d5c704e869d204c Mon Sep 17 00:00:00 2001 From: Jack Ding Date: Wed, 11 Sep 2024 18:04:41 -0400 Subject: [PATCH] fix double / in ResourceAddress Signed-off-by: Jack Ding --- plugins/ptp_operator/metrics/manager.go | 21 +++++++++++---------- 1 file changed, 11 insertions(+), 10 deletions(-) diff --git a/plugins/ptp_operator/metrics/manager.go b/plugins/ptp_operator/metrics/manager.go index c2c7cfd8..129c2a4d 100644 --- a/plugins/ptp_operator/metrics/manager.go +++ b/plugins/ptp_operator/metrics/manager.go @@ -2,6 +2,7 @@ package metrics import ( "fmt" + "path" "strings" "sync" @@ -177,7 +178,7 @@ func (p *PTPEventManager) PublishClockClassEvent(clockClass float64, source stri return } data := p.GetPTPEventsData(ptp.LOCKED, int64(clockClass), source, eventType) - resourceAddress := fmt.Sprintf(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)) + resourceAddress := path.Join(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)) p.publish(*data, resourceAddress, eventType) } @@ -197,7 +198,7 @@ func (p *PTPEventManager) publishGNSSEvent(state int64, offset float64, syncStat ValueType: ceevent.DECIMAL, Value: state, }) - resourceAddress := fmt.Sprintf(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)) + resourceAddress := path.Join(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)) p.publish(*data, resourceAddress, eventType) } @@ -217,7 +218,7 @@ func (p *PTPEventManager) publishSyncEEvent(syncState ptp.SyncState, source stri Version: ceevent.APISchemaVersion, Values: []ceevent.DataValue{}, } - resource := fmt.Sprintf(p.resourcePrefix, p.nodeName, fmt.Sprintf("/%s/%s", source, "Ql")) + resource := path.Join(p.resourcePrefix, p.nodeName, fmt.Sprintf("/%s/%s", source, "Ql")) if syncState == "" { // clock quality event data.Values = append(data.Values, ceevent.DataValue{ Resource: resource, @@ -225,7 +226,7 @@ func (p *PTPEventManager) publishSyncEEvent(syncState ptp.SyncState, source stri ValueType: ceevent.DECIMAL, Value: float64(ql), }) - resource = fmt.Sprintf(p.resourcePrefix, p.nodeName, fmt.Sprintf("/%s/%s", source, "extQl")) + resource = path.Join(p.resourcePrefix, p.nodeName, fmt.Sprintf("/%s/%s", source, "extQl")) if !extendedTvlEnabled { // have the default value for clarity data.Values = append(data.Values, ceevent.DataValue{ Resource: resource, @@ -243,13 +244,13 @@ func (p *PTPEventManager) publishSyncEEvent(syncState ptp.SyncState, source stri } } else { data.Values = append(data.Values, ceevent.DataValue{ - Resource: fmt.Sprintf(p.resourcePrefix, p.nodeName, fmt.Sprintf("/%s", source)), + Resource: path.Join(p.resourcePrefix, p.nodeName, source), DataType: ceevent.METRIC, ValueType: ceevent.DECIMAL, Value: syncState, }) } - resourceAddress := fmt.Sprintf(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)) + resourceAddress := path.Join(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)) p.publish(*data, resourceAddress, eventType) } @@ -260,7 +261,7 @@ func (p *PTPEventManager) GetPTPEventsData(state ptp.SyncState, ptpOffset int64, return nil } // /cluster/xyz/ptp/CLOCK_REALTIME this is not address the event is published to - eventSource := fmt.Sprintf(p.resourcePrefix, p.nodeName, fmt.Sprintf("/%s", source)) + eventSource := path.Join(p.resourcePrefix, p.nodeName, source) data := ceevent.Data{ Version: ceevent.APISchemaVersion, Values: []ceevent.DataValue{}, @@ -289,7 +290,7 @@ func (p *PTPEventManager) GetPTPCloudEvents(data ceevent.Data, eventType ptp.Eve if pubs, ok := p.publisherTypes[eventType]; ok { cneEvent, cneErr := common.CreateEvent( pubs.PubID, string(eventType), - fmt.Sprintf(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)), + path.Join(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)), data) if cneErr != nil { return nil, fmt.Errorf("failed to create ptp event, %s", cneErr) @@ -317,7 +318,7 @@ func (p *PTPEventManager) PublishEvent(state ptp.SyncState, ptpOffset int64, sou // /cluster/xyz/ptp/CLOCK_REALTIME this is not address the event is published to data := p.GetPTPEventsData(state, ptpOffset, source, eventType) - resourceAddress := fmt.Sprintf(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)) + resourceAddress := path.Join(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)) p.publish(*data, resourceAddress, eventType) // publish the event again as overall sync state // SyncStateChange is the overall sync state including PtpStateChange and OsClockSyncStateChange @@ -325,7 +326,7 @@ func (p *PTPEventManager) PublishEvent(state ptp.SyncState, ptpOffset int64, sou if state != p.lastOverallSyncState { eventType = ptp.SyncStateChange data = p.GetPTPEventsData(state, ptpOffset, source, eventType) - resourceAddress = fmt.Sprintf(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)) + resourceAddress = path.Join(p.resourcePrefix, p.nodeName, string(p.publisherTypes[eventType].Resource)) p.publish(*data, resourceAddress, eventType) p.lastOverallSyncState = state }