diff --git a/route/RoutingTable.go b/route/RoutingTable.go index 6238e93..639ec36 100644 --- a/route/RoutingTable.go +++ b/route/RoutingTable.go @@ -123,10 +123,12 @@ func (t *RoutingTable) FindRoutingTableEntry(destRouter *component.Identifier) * func (t *RoutingTable) ScheduleRoutingTableCalculation() error { if !t.m_isRouteCalculationScheduled { common2.LogInfo("Scheduling routing table calculation in ", t.m_routingCalcInterval) - err := t.scheduler.ScheduleTaskAfterDuration(t.m_routingCalcInterval, t.Calculate) + job, err := t.scheduler.ScheduleTaskAfterDuration(t.m_routingCalcInterval, 1).Do(t.Calculate) if err != nil { return err } + job.LimitRunsTo(1) + t.scheduler.StartAsync() t.m_isRouteCalculationScheduled = true } return nil