Changeset 14:8b4b6177d6a2 for jmemcached-core/src/main/java/com/thimbleware/jmemcached/CommandDecoder.java

Timestamp:

04/01/08 15:16:49 (8 months ago)

Author:

ryan@…

Branch:

default

Message:

Added: cas/gets, and noreply option on sets

Files:

• jmemcached-core/src/main/java/com/thimbleware/jmemcached/CommandDecoder.java (modified) (2 diffs)

jmemcached-core/src/main/java/com/thimbleware/jmemcached/CommandDecoder.java

@@ -178 +178 @@
         if (cmd.cmd == Commands.ADD ||
                 cmd.cmd == Commands.SET ||
-                cmd.cmd == Commands.REPLACE) {
+                cmd.cmd == Commands.REPLACE ||
+                cmd.cmd == Commands.CAS) {
 
             // if we don't have all the parts, it's malformed
-            if (parts.size() != 5) {
+            if (parts.size() < 5) {
                 return new SessionStatus(ERROR);
             }
+
 
             int size = Integer.parseInt(parts.get(4));
@@ -196 +198 @@
             cmd.element.data_length = size;
 
+            // look for cas and "noreply" elements
+            if (parts.size() > 5) {
+                int noreply = cmd.cmd == Commands.CAS ? 6 : 5;
+                if (cmd.cmd == Commands.CAS) {
+                    cmd.cas_key = Long.valueOf(parts.get(5));
+                }
+
+                if (parts.size() == noreply + 1 && parts.get(noreply).equalsIgnoreCase("noreply"))
+                    cmd.noreply = true;
+
+            }
+
             return new SessionStatus(WAITING_FOR_DATA, size, cmd);
 
         } else if (cmd.cmd == Commands.GET ||
+                cmd.cmd == Commands.GETS ||
                 cmd.cmd == Commands.INCR ||
                 cmd.cmd == Commands.DECR ||