mirror of
https://github.com/fluencelabs/redis
synced 2025-04-02 15:51:05 +00:00
Merge branch 'unstable'
This commit is contained in:
commit
e4f6b8c327
@ -141,7 +141,7 @@ int pubsubUnsubscribePattern(redisClient *c, robj *pattern, int notify) {
|
|||||||
/* Unsubscribe from all the channels. Return the number of channels the
|
/* Unsubscribe from all the channels. Return the number of channels the
|
||||||
* client was subscribed from. */
|
* client was subscribed from. */
|
||||||
int pubsubUnsubscribeAllChannels(redisClient *c, int notify) {
|
int pubsubUnsubscribeAllChannels(redisClient *c, int notify) {
|
||||||
dictIterator *di = dictGetIterator(c->pubsub_channels);
|
dictIterator *di = dictGetSafeIterator(c->pubsub_channels);
|
||||||
dictEntry *de;
|
dictEntry *de;
|
||||||
int count = 0;
|
int count = 0;
|
||||||
|
|
||||||
|
@ -1521,7 +1521,7 @@ void zunionInterGenericCommand(redisClient *c, robj *dstkey, int op) {
|
|||||||
|
|
||||||
score = src[0].weight * zval.score;
|
score = src[0].weight * zval.score;
|
||||||
for (j = 1; j < setnum; j++) {
|
for (j = 1; j < setnum; j++) {
|
||||||
/* It is not safe to access the hash we zset we are
|
/* It is not safe to access the zset we are
|
||||||
* iterating, so explicitly check for equal object. */
|
* iterating, so explicitly check for equal object. */
|
||||||
if (src[j].subject == src[0].subject) {
|
if (src[j].subject == src[0].subject) {
|
||||||
value = zval.score*src[j].weight;
|
value = zval.score*src[j].weight;
|
||||||
@ -1566,7 +1566,7 @@ void zunionInterGenericCommand(redisClient *c, robj *dstkey, int op) {
|
|||||||
/* Because the inputs are sorted by size, it's only possible
|
/* Because the inputs are sorted by size, it's only possible
|
||||||
* for sets at larger indices to hold this element. */
|
* for sets at larger indices to hold this element. */
|
||||||
for (j = (i+1); j < setnum; j++) {
|
for (j = (i+1); j < setnum; j++) {
|
||||||
/* It is not safe to access the hash we zset we are
|
/* It is not safe to access the zset we are
|
||||||
* iterating, so explicitly check for equal object. */
|
* iterating, so explicitly check for equal object. */
|
||||||
if(src[j].subject == src[i].subject) {
|
if(src[j].subject == src[i].subject) {
|
||||||
value = zval.score*src[j].weight;
|
value = zval.score*src[j].weight;
|
||||||
|
@ -1,9 +1,11 @@
|
|||||||
|
#include "fmacros.h"
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <ctype.h>
|
#include <ctype.h>
|
||||||
#include <limits.h>
|
#include <limits.h>
|
||||||
#include <math.h>
|
#include <math.h>
|
||||||
|
|
||||||
#include "util.h"
|
#include "util.h"
|
||||||
|
|
||||||
/* Glob-style pattern matching. */
|
/* Glob-style pattern matching. */
|
||||||
|
@ -28,7 +28,7 @@ start_server {tags {"repl"}} {
|
|||||||
createComplexDataset r 50000 useexpire
|
createComplexDataset r 50000 useexpire
|
||||||
after 4000 ;# Make sure everything expired before taking the digest
|
after 4000 ;# Make sure everything expired before taking the digest
|
||||||
r keys * ;# Force DEL syntesizing to slave
|
r keys * ;# Force DEL syntesizing to slave
|
||||||
after 1000 ;# Wait another second. Now everything should be file.
|
after 1000 ;# Wait another second. Now everything should be fine.
|
||||||
if {[r debug digest] ne [r -1 debug digest]} {
|
if {[r debug digest] ne [r -1 debug digest]} {
|
||||||
set csv1 [csvdump r]
|
set csv1 [csvdump r]
|
||||||
set csv2 [csvdump {r -1}]
|
set csv2 [csvdump {r -1}]
|
||||||
|
@ -110,6 +110,7 @@ proc cleanup {} {
|
|||||||
}
|
}
|
||||||
|
|
||||||
proc execute_everything {} {
|
proc execute_everything {} {
|
||||||
|
execute_tests "unit/printver"
|
||||||
execute_tests "unit/auth"
|
execute_tests "unit/auth"
|
||||||
execute_tests "unit/protocol"
|
execute_tests "unit/protocol"
|
||||||
execute_tests "unit/basic"
|
execute_tests "unit/basic"
|
||||||
|
6
tests/unit/printver.tcl
Normal file
6
tests/unit/printver.tcl
Normal file
@ -0,0 +1,6 @@
|
|||||||
|
start_server {} {
|
||||||
|
set i [r info]
|
||||||
|
regexp {redis_version:(.*?)\r\n} $i - version
|
||||||
|
regexp {redis_git_sha1:(.*?)\r\n} $i - sha1
|
||||||
|
puts "Testing Redis version $version ($sha1)"
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user