Commit d3fb3408 authored by Simon Pastor's avatar Simon Pastor
Browse files

logs update

parent 503b47dc
Loading
Loading
Loading
Loading
+1 −1
Original line number Diff line number Diff line
@@ -31,7 +31,7 @@ import (
)

func init() {
	log.MeepJSONLogInit("meep-ctrl-engine")
	log.MeepTextLogInit("meep-ctrl-engine")
}

func main() {
+3 −2
Original line number Diff line number Diff line
@@ -29,6 +29,8 @@ import (
	"net/http"
	"strings"

	log "github.com/InterDigitalInc/AdvantEDGE/go-packages/meep-logger"

	"github.com/gorilla/mux"
)

@@ -44,8 +46,7 @@ type Routes []Route
func NewRouter() *mux.Router {
	router := mux.NewRouter().StrictSlash(true)
	for _, route := range routes {
		var handler http.Handler = route.HandlerFunc
		//		handler = Logger(handler, route.Name)
		var handler http.Handler = log.HTTP(route.HandlerFunc, route.Name)

		router.
			Methods(route.Method).
+2 −3
Original line number Diff line number Diff line
@@ -76,11 +76,10 @@ func eventHandler(channel string, payload string) {

	// MEEP Ctrl Engine active scenario update Channel
	case mod.ActiveScenarioEvents:
		log.Debug("Event received on channel: ", mod.ActiveScenarioEvents)
		log.Debug("Event received on channel: ", mod.ActiveScenarioEvents, " payload: ", payload)
		processActiveScenarioUpdate()

	default:
		log.Warn("Unsupported channel")
		log.Warn("Unsupported channel", " payload: ", payload)
	}
}

+2 −2
Original line number Diff line number Diff line
@@ -115,10 +115,10 @@ func eventHandler(channel string, payload string) {

	// MEEP Ctrl Engine active scenario update event
	case mod.ActiveScenarioEvents:
		log.Debug("Event received on channel: ", mod.ActiveScenarioEvents, " payload: ", payload)
		processActiveScenarioUpdate(payload)

	default:
		log.Warn("Unsupported channel event: ", channel)
		log.Warn("Unsupported channel event: ", channel, " payload: ", payload)
	}
}

+3 −3
Original line number Diff line number Diff line
@@ -196,11 +196,10 @@ func eventHandler(channel string, payload string) {

	// MEEP Ctrl Engine active scenario update Channel
	case mod.ActiveScenarioEvents:
		log.Debug("Event received on channel: ", mod.ActiveScenarioEvents)
		log.Debug("Event received on channel: ", mod.ActiveScenarioEvents, " payload: ", payload)
		processActiveScenarioUpdate()

	default:
		log.Warn("Unsupported channel")
		log.Warn("Unsupported channel", " payload: ", payload)
	}
}

@@ -640,6 +639,7 @@ func applyMgSvcMapping() {
	}

	// Publish Edge LB rules update
	log.Debug("TX-MSG [", channelMgManagerLb, "] ", "")
	_ = mgm.lbRulesStore.rc.Publish(channelMgManagerLb, "")
}

Loading