commit | c3824e8f186b3aaae1d79a5c13e9aa0e86da1eeb | [log] [tgz] |
---|---|---|
author | sunish vk <sunish.vk@cognizant.com> | Wed May 11 19:38:24 2016 +0530 |
committer | Gerrit Code Review <gerrit@onlab.us> | Wed May 11 17:13:26 2016 +0000 |
tree | 17b644e33d1bfe236216b950903359e8e05d860a | |
parent | 1703fea6b3870dd44f0ab9cc39517e1d1bf6d1c6 [diff] [blame] |
ONOS-4505: Bug Fixes Change-Id: I190b4e6b950381eef8d6fba1e3ac345ea6854e40
diff --git a/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/lsdb/DefaultIsisLsdbAge.java b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/lsdb/DefaultIsisLsdbAge.java index 5a48798..9ceb97c 100644 --- a/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/lsdb/DefaultIsisLsdbAge.java +++ b/protocols/isis/ctl/src/main/java/org/onosproject/isis/controller/impl/lsdb/DefaultIsisLsdbAge.java
@@ -44,6 +44,7 @@ private int ageCounterRollOver = 0; private IsisLspQueueConsumer queueConsumer = null; private BlockingQueue<LspWrapper> lsaQueue = new ArrayBlockingQueue<>(1024); + private boolean timerStarted = false; /** * Creates an instance of LSDB age. @@ -128,9 +129,12 @@ * Starts the aging timer and queue consumer. */ public void startDbAging() { - startDbAgeTimer(); - queueConsumer = new IsisLspQueueConsumer(lsaQueue); - new Thread(queueConsumer).start(); + if (!timerStarted) { + startDbAgeTimer(); + queueConsumer = new IsisLspQueueConsumer(lsaQueue); + new Thread(queueConsumer).start(); + timerStarted = true; + } } /**