| commit | 6cb86367396b18eebaf1e5a69c5e924b7ef5a310 | [log] [tgz] |
|---|---|---|
| author | alshabib <alshabibi.ali@gmail.com> | Thu Mar 03 18:00:58 2016 -0800 |
| committer | Gerrit Code Review <gerrit@onlab.us> | Fri Mar 04 21:34:13 2016 +0000 |
| tree | 24ffd5c26de089f31a73f0e21b34606e10f68d55 | |
| parent | 881f29f37cfad45dd6ba86597ff4b9bc7172b138 [diff] |
fix removal of rules in a distributed setting Change-Id: I44cb49990b8051f5f1542c11cbda6846049906e3
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DatabaseState.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DatabaseState.java index 58801e8..d9ab7e5 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DatabaseState.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DatabaseState.java
@@ -104,6 +104,9 @@ Long counterGet(String counterName); @Command + void counterSet(String counterName, long value); + + @Command CommitResponse prepareAndCommit(Transaction transaction); @Command
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultDatabaseState.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultDatabaseState.java index 027341e..27d953b 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultDatabaseState.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultDatabaseState.java
@@ -207,6 +207,11 @@ } @Override + public void counterSet(String counterName, long value) { + getCounter(counterName).set(value); + } + + @Override public Long queueSize(String queueName) { return Long.valueOf(getQueue(queueName).size()); }