Merge branch 'hotfix/array-flush-commands'

nicolasff · nicolasff · commit da0cd3f65522 · 2013-05-02T19:59:53.000+01:00
diff --git a/redis_array.c b/redis_array.c
@@ -55,6 +55,8 @@ zend_function_entry redis_array_functions[] = {
      PHP_ME(RedisArray, select, NULL, ZEND_ACC_PUBLIC)
      PHP_ME(RedisArray, info, NULL, ZEND_ACC_PUBLIC)
      PHP_ME(RedisArray, ping, NULL, ZEND_ACC_PUBLIC)
+     PHP_ME(RedisArray, flushdb, NULL, ZEND_ACC_PUBLIC)
+     PHP_ME(RedisArray, flushall, NULL, ZEND_ACC_PUBLIC)
      PHP_ME(RedisArray, mget, NULL, ZEND_ACC_PUBLIC)
      PHP_ME(RedisArray, mset, NULL, ZEND_ACC_PUBLIC)
      PHP_ME(RedisArray, del, NULL, ZEND_ACC_PUBLIC)
@@ -577,6 +579,16 @@ PHP_METHOD(RedisArray, ping)
 	multihost_distribute(INTERNAL_FUNCTION_PARAM_PASSTHRU, "PING");
 }
 
+PHP_METHOD(RedisArray, flushdb)
+{
+	multihost_distribute(INTERNAL_FUNCTION_PARAM_PASSTHRU, "FLUSHDB");
+}
+
+PHP_METHOD(RedisArray, flushall)
+{
+	multihost_distribute(INTERNAL_FUNCTION_PARAM_PASSTHRU, "FLUSHALL");
+}
+
 PHP_METHOD(RedisArray, keys)
 {
 	zval *object, *z_args[1], *z_tmp, z_fun;
diff --git a/redis_array.h b/redis_array.h
@@ -18,6 +18,8 @@ PHP_METHOD(RedisArray, _rehash);
 PHP_METHOD(RedisArray, select);
 PHP_METHOD(RedisArray, info);
 PHP_METHOD(RedisArray, ping);
+PHP_METHOD(RedisArray, flushdb);
+PHP_METHOD(RedisArray, flushall);
 PHP_METHOD(RedisArray, mget);
 PHP_METHOD(RedisArray, mset);
 PHP_METHOD(RedisArray, del);
