Changeset 27281 for lang/c

Timestamp:

12/23/08 14:21:39 (4 years ago)

Author:

frsyuki

Message:

lang/c/memstored: binary protocol: support noop and flush command

Location:

lang/c/memstored/trunk/src

Files:

• binproto.cc (modified) (2 diffs)
• binproto.h (modified) (2 diffs)

lang/c/memstored/trunk/src/binproto.cc

@@ -46 +46 @@
                 NULL,        // decrement
                 NULL,        // quit
-                NULL,//cmd_flush,   // flush
+                cmd_flush,   // flush
                 cmd_get,     // getq
-                NULL,//cmd_noop,    // noop
+                cmd_noop,    // noop
                 NULL,        // version
                 cmd_get,     // getk
@@ -185 +185 @@
 }
 
+void MemprotoBinary::flush(auto_bufref_t ref,
+                memproto_header* h,
+                uint32_t expiration)
+{
+        if(expiration != 0) {
+                send_response_nodata(h, MEMPROTO_RES_INVALID_ARGUMENTS, 0);
+                return;
+        }
+        send_response_nodata(h, MEMPROTO_RES_NO_ERROR, 0);
+}
+
+void MemprotoBinary::noop(auto_bufref_t ref,
+                memproto_header* h)
+{
+        send_response_nodata(h, MEMPROTO_RES_NO_ERROR, 0);
+}
 
 

lang/c/memstored/trunk/src/binproto.h

@@ -62 +62 @@
         { SUBMIT(del, h, key, keylen, expiration); }
 
+        static void cmd_flush(void* self, memproto_header* h,
+                        uint32_t expiration)
+        { SUBMIT(flush, h, expiration); }
+
+        static void cmd_noop(void* self, memproto_header* h)
+        { SUBMIT(noop, h); }
+
 
         void get(auto_bufref_t ref,
@@ -82 +89 @@
                         const char* key, uint16_t keylen,
                         uint32_t expiration);
+
+        void flush(auto_bufref_t ref,
+                        memproto_header* h,
+                        uint32_t expiration);
+
+        void noop(auto_bufref_t ref,
+                        memproto_header* h);
 
 private: