mirrors/onos
1
0
Fork 0
mirror of https://github.com/opennetworkinglab/onos.git synced 2025-11-04 18:21:45 +01:00
Code Issues Projects Releases Wiki Activity

Foo: Do not dump DatabaseException backtrace

Browse Source 
Change-Id: I43e538cfcedc0c9f6f51fd6d7ccb2509f6723f0f
This commit is contained in:
Yuta HIGUCHI 2014-11-26 13:38:44 -08:00 committed by Yuta Higuchi
parent 673771e96a
commit 1a22cc05ea
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/foo/src/main/java/org/onlab/onos/foo/FooComponent.java
View File

@ -44,6 +44,7 @@ import org.onlab.onos.net.intent.IntentEvent;
import org.onlab.onos.net.intent.IntentListener; import org.onlab.onos.net.intent.IntentListener;
import org.onlab.onos.net.intent.IntentService; import org.onlab.onos.net.intent.IntentService;
import org.onlab.onos.store.service.DatabaseAdminService; import org.onlab.onos.store.service.DatabaseAdminService;
import org.onlab.onos.store.service.DatabaseException;
import org.onlab.onos.store.service.DatabaseService; import org.onlab.onos.store.service.DatabaseService;
import org.onlab.onos.store.service.Lock; import org.onlab.onos.store.service.Lock;
import org.onlab.onos.store.service.LockService; import org.onlab.onos.store.service.LockService;
@ -209,7 +210,7 @@ public class FooComponent {
} }
} }
} }
int retry = 5; int retry = 1;
do { do {
if (vv == null) { if (vv == null) {
@ -223,13 +224,15 @@ public class FooComponent {
log.info("Write success. New value: {}", next); log.info("Write success. New value: {}", next);
break; break;
} else { } else {
log.info("Write failed trying to write {}", next); log.info("Write failed retrying.....{}", retry);
vv = dbService.get(someTable, someKey); vv = dbService.get(someTable, someKey);
if (vv == null) { if (vv == null) {
log.error("Shouldn't reach here"); log.error("Shouldn't reach here");
} }
} }
} while (retry-- > 0); } while (retry++ < 5);
} catch (DatabaseException e) {
log.debug("DB Exception thrown {}", e.getMessage());
} catch (Exception e) { } catch (Exception e) {
log.error("Exception thrown", e); log.error("Exception thrown", e);
} }