diff --git a/src/modules/network_element/fetch_link/ne_trace.go b/src/modules/network_element/fetch_link/ne_trace.go index a90f93bf..387633fa 100644 --- a/src/modules/network_element/fetch_link/ne_trace.go +++ b/src/modules/network_element/fetch_link/ne_trace.go @@ -14,7 +14,7 @@ import ( func NeTraceInfo(neInfo model.NeInfo, traceId string) (map[string]any, error) { // 跟踪任务信息 neUrl := fmt.Sprintf("http://%s:%d/api/rest/traceManagement/v1/subscriptions?id=%s", neInfo.IP, neInfo.Port, traceId) - resBytes, err := fetch.Get(neUrl, nil, 60_000) + resBytes, err := fetch.Get(neUrl, nil, 30_000) if err != nil { logger.Warnf("NeTraceInfo Get \"%s\"", neUrl) logger.Errorf("NeTraceInfo %s", err.Error()) @@ -40,11 +40,10 @@ func NeTraceAdd(neInfo model.NeInfo, data map[string]any) (map[string]any, error if err != nil { errStr := err.Error() logger.Warnf("NeTraceAdd POST \"%s\"", neUrl) - if strings.HasPrefix(errStr, "201") || strings.HasPrefix(errStr, "204") { - return resData, nil + if !(strings.HasPrefix(errStr, "201") || strings.HasPrefix(errStr, "400")) { + logger.Errorf("NeTraceAdd %s", errStr) + return nil, fmt.Errorf("NeService Trace Add API Error") } - logger.Errorf("NeTraceAdd %s", errStr) - return nil, fmt.Errorf("NeService Trace Add API Error") } // 200 成功无数据时