[OWL-2005] Remove logging for debugging late-time alarm data

modules/alarm/cron/reader.go

@@ -71,7 +71,6 @@ func popEvent(queues []string) (*model.Event, error) {
 
 	log.Debug(event.String())
 	//insert event into database
-	go warningIfEventTooLate(5, &event)
 	err = eventmodel.InsertEvent(&event, "owl")
 	if err != nil {
 		log.Error(err.Error())
@@ -153,12 +152,3 @@ func popExternalEvent(queues []string) error {
 
 	return nil
 }
-
-func warningIfEventTooLate(minutes int, event *model.Event) {
-	now := time.Now()
-	eventTime := time.Unix(event.EventTime, 0)
-
-	if now.Sub(eventTime) >= (time.Duration(minutes) * time.Minute) {
-		log.Warnf("[DELAY DATA] Event [%v] is delay more than %d minutes. Now: %s. EventTime: %s", event, minutes, now, eventTime)
-	}
-}

modules/judge/store/judge.go

@@ -5,7 +5,6 @@ import (
 	"fmt"
 	"github.com/Cepave/open-falcon-backend/common/model"
 	"github.com/Cepave/open-falcon-backend/modules/judge/g"
-	"time"
 )
 
 func Judge(L *SafeLinkedList, firstItem *model.JudgeItem, now int64) {
@@ -81,7 +80,6 @@ func sendEvent(event *model.Event) {
 	rc := g.RedisConnPool.Get()
 	defer rc.Close()
 
-	go warningIfEventTooLate(5, event)
 	rc.Do("LPUSH", redisKey, string(bs))
 }
 
@@ -243,12 +241,3 @@ func sendEventIfNeed(historyData []*model.HistoryData, isTriggered bool, now int
 		}
 	}
 }
-
-func warningIfEventTooLate(minutes int, event *model.Event) {
-	now := time.Now()
-	eventTime := time.Unix(event.EventTime, 0)
-
-	if now.Sub(eventTime) >= (time.Duration(minutes) * time.Minute) {
-		log.Warnf("[DELAY DATA] Event [%v] is delay more than %d minutes. Now: %s. EventTime: %s", event, minutes, now, eventTime)
-	}
-}

modules/transfer/sender/send_tasks.go

@@ -101,7 +101,6 @@ func forward2JudgeTask(Q *list.SafeListLimited, node string, concurrent int) {
 			var err error
 			sendOk := false
 			for i := 0; i < 3; i++ { //最多重试3次
-				go warningIfEventTooLate(5, judgeItems)
 				err = JudgeConnPools.Call(addr, "Judge.Send", judgeItems, resp)
 				if err == nil {
 					sendOk = true
@@ -353,15 +352,3 @@ func forward2StagingTask() {
 		}(stagingItems, count)
 	}
 }
-
-func warningIfEventTooLate(minutes int, metrics []*cmodel.JudgeItem) {
-	now := time.Now()
-
-	for _, metric := range metrics {
-		metricTime := time.Unix(metric.Timestamp, 0)
-
-		if now.Sub(metricTime) >= (time.Duration(minutes) * time.Minute) {
-			log.Warnf("[DELAY DATA] Metric [%v] is delay more than %d minutes. Now: %s. EventTime: %s", metric, minutes, now, metricTime)
-		}
-	}
-}