support mget for Redis

protocol.cpp

@@ -289,8 +289,37 @@ int redis_protocol::write_command_set(const char *key, int key_len, const char *
 
 int redis_protocol::write_command_multi_get(const keylist *keylist)
 {
-    fprintf(stderr, "error: multi get not implemented for redis yet!\n");
-    assert(0);
+    assert(keylist != NULL);
+    assert(keylist->get_keys_count() > 0);
+
+    int n = 0;
+    int size = 0;
+
+    size = evbuffer_add_printf(m_write_buf,
+        "*%u\r\n"
+        "$4\r\n"
+        "MGET\r\n", keylist->get_keys_count() + 1);
+
+    for (unsigned int i = 0; i < keylist->get_keys_count(); i++) {
+        const char *key;
+        unsigned int key_len;
+
+        key = keylist->get_key(i, &key_len);
+        assert(key != NULL);
+
+        size += evbuffer_add_printf(m_write_buf,
+            "$%u\r\n",
+            key_len);
+
+        n = evbuffer_add(m_write_buf, key, key_len);
+        assert(n != -1);
+        n = evbuffer_add(m_write_buf, "\r\n", 2);
+        assert(n != -1);
+
+        size += key_len + 2;
+    }
+
+    return size;
 }
 
 int redis_protocol::write_command_get(const char *key, int key_len, unsigned int offset)