commit 63c659f048866546925bfd99b0aa6f31db895562
author Madan Jampani <madan@onlab.us> Thu Jun 11 00:52:58 2015 -0700
committer Gerrit Code Review <gerrit@onlab.us> Thu Jun 11 21:45:00 2015 +0000
tree 8415878f9229da1da1d07717412dadf043e2837d
parent bb825d73b9b022aaec4a4e3847534a0d9ea4b4f4

Support for a distributed queue primitive.

Change-Id: I13abb93ec1703105ff0137e137738483a5b6a143

core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseState.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseState.java b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseState.java
index 73eacdd..0af7f42 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseState.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseState.java
@@ -21,6 +21,7 @@
 import java.util.Map.Entry;
 import java.util.Set;
 
+import org.onosproject.cluster.NodeId;
 import org.onosproject.store.service.Transaction;
 import org.onosproject.store.service.Versioned;
 
@@ -113,6 +114,18 @@
   Long counterGetAndAdd(String counterName, long delta);
 
   @Query
+  Long queueSize(String queueName);
+
+  @Query
+  byte[] queuePeek(String queueName);
+
+  @Command
+  byte[] queuePop(String queueName, NodeId requestor);
+
+  @Command
+  Set<NodeId> queuePush(String queueName, byte[] entry);
+
+  @Query
   Long counterGet(String counterName);
 
   @Command