From 489b3de1b1768f7aec8e5a9435044681ed24a591 Mon Sep 17 00:00:00 2001 From: Radu Ioan Fericean Date: Mon, 30 Jul 2012 14:38:13 +0300 Subject: [PATCH] not listening on internal rater and scheduler no schedulet actions --- cmd/cgr-rater/cgr-rater.go | 2 +- cmd/cgr-rater/scheduler.go | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/cmd/cgr-rater/cgr-rater.go b/cmd/cgr-rater/cgr-rater.go index 678637c62..f690afb38 100644 --- a/cmd/cgr-rater/cgr-rater.go +++ b/cmd/cgr-rater/cgr-rater.go @@ -256,7 +256,7 @@ func main() { go stopRaterSingnalHandler() } responder := ×pans.Responder{ExitChan: exitChan} - if rater_enabled && !balancer_enabled { + if rater_enabled && !balancer_enabled && rater_listen != INTERNAL { go listenToRPCRequests(responder, rater_listen, rater_rpc_encoding) } if balancer_enabled { diff --git a/cmd/cgr-rater/scheduler.go b/cmd/cgr-rater/scheduler.go index 5cda72fcd..afadca763 100644 --- a/cmd/cgr-rater/scheduler.go +++ b/cmd/cgr-rater/scheduler.go @@ -37,6 +37,9 @@ type scheduler struct { func (s scheduler) loop() { for { + if len(s.queue) == 0 { + <-restartLoop + } a0 := s.queue[0] now := time.Now() if a0.GetNextStartTime().Equal(now) || a0.GetNextStartTime().Before(now) {