Skip to content

Commit

Permalink
64 bit instances are no longer limited to have at max 2^32-1 elements…
Browse files Browse the repository at this point in the history
… in lists.
  • Loading branch information
antirez committed Jan 31, 2012
1 parent fc4ed42 commit 3c08fda
Show file tree
Hide file tree
Showing 5 changed files with 12 additions and 18 deletions.
4 changes: 2 additions & 2 deletions src/adlist.c
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ list *listCreate(void)
* This function can't fail. */
void listRelease(list *list)
{
unsigned int len;
unsigned long len;
listNode *current, *next;

current = list->head;
Expand Down Expand Up @@ -310,7 +310,7 @@ listNode *listSearchKey(list *list, void *key)
* and so on. Negative integers are used in order to count
* from the tail, -1 is the last element, -2 the penultimante
* and so on. If the index is out of range NULL is returned. */
listNode *listIndex(list *list, int index) {
listNode *listIndex(list *list, long index) {
listNode *n;

if (index < 0) {
Expand Down
4 changes: 2 additions & 2 deletions src/adlist.h
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ typedef struct list {
void *(*dup)(void *ptr);
void (*free)(void *ptr);
int (*match)(void *ptr, void *key);
unsigned int len;
unsigned long len;
} list;

/* Functions implemented as macros */
Expand Down Expand Up @@ -81,7 +81,7 @@ listNode *listNext(listIter *iter);
void listReleaseIterator(listIter *iter);
list *listDup(list *orig);
listNode *listSearchKey(list *list, void *key);
listNode *listIndex(list *list, int index);
listNode *listIndex(list *list, long index);
void listRewind(list *list, listIter *li);
void listRewindTail(list *list, listIter *li);

Expand Down
6 changes: 3 additions & 3 deletions src/redis.c
Original file line number Diff line number Diff line change
Expand Up @@ -1465,7 +1465,7 @@ sds genRedisInfoString(char *section) {
if (sections++) info = sdscat(info,"\r\n");
info = sdscatprintf(info,
"# Clients\r\n"
"connected_clients:%d\r\n"
"connected_clients:%lu\r\n"
"client_longest_output_list:%lu\r\n"
"client_biggest_input_buf:%lu\r\n"
"blocked_clients:%d\r\n",
Expand Down Expand Up @@ -1580,7 +1580,7 @@ sds genRedisInfoString(char *section) {
"keyspace_hits:%lld\r\n"
"keyspace_misses:%lld\r\n"
"pubsub_channels:%ld\r\n"
"pubsub_patterns:%u\r\n"
"pubsub_patterns:%lu\r\n"
"latest_fork_usec:%lld\r\n",
server.stat_numconnections,
server.stat_numcommands,
Expand Down Expand Up @@ -1633,7 +1633,7 @@ sds genRedisInfoString(char *section) {
}
}
info = sdscatprintf(info,
"connected_slaves:%d\r\n",
"connected_slaves:%lu\r\n",
listLength(server.slaves));
if (listLength(server.slaves)) {
int slaveid = 0;
Expand Down
2 changes: 1 addition & 1 deletion src/redis.h
Original file line number Diff line number Diff line change
Expand Up @@ -823,7 +823,7 @@ void listTypeTryConversion(robj *subject, robj *value);
void listTypePush(robj *subject, robj *value, int where);
robj *listTypePop(robj *subject, int where);
unsigned long listTypeLength(robj *subject);
listTypeIterator *listTypeInitIterator(robj *subject, int index, unsigned char direction);
listTypeIterator *listTypeInitIterator(robj *subject, long index, unsigned char direction);
void listTypeReleaseIterator(listTypeIterator *li);
int listTypeNext(listTypeIterator *li, listTypeEntry *entry);
robj *listTypeGet(listTypeEntry *entry);
Expand Down
14 changes: 4 additions & 10 deletions src/t_list.c
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ unsigned long listTypeLength(robj *subject) {
}

/* Initialize an iterator at the specified index. */
listTypeIterator *listTypeInitIterator(robj *subject, int index, unsigned char direction) {
listTypeIterator *listTypeInitIterator(robj *subject, long index, unsigned char direction) {
listTypeIterator *li = zmalloc(sizeof(listTypeIterator));
li->subject = subject;
li->encoding = subject->encoding;
Expand Down Expand Up @@ -484,10 +484,7 @@ void rpopCommand(redisClient *c) {

void lrangeCommand(redisClient *c) {
robj *o;
long start;
long end;
int llen;
int rangelen;
long start, end, llen, rangelen;

if ((getLongFromObjectOrReply(c, c->argv[2], &start, NULL) != REDIS_OK) ||
(getLongFromObjectOrReply(c, c->argv[3], &end, NULL) != REDIS_OK)) return;
Expand Down Expand Up @@ -546,10 +543,7 @@ void lrangeCommand(redisClient *c) {

void ltrimCommand(redisClient *c) {
robj *o;
long start;
long end;
int llen;
int j, ltrim, rtrim;
long start, end, llen, j, ltrim, rtrim;
list *list;
listNode *ln;

Expand Down Expand Up @@ -604,7 +598,7 @@ void lremCommand(redisClient *c) {
robj *subject, *obj;
obj = c->argv[3] = tryObjectEncoding(c->argv[3]);
long toremove;
int removed = 0;
long removed = 0;
listTypeEntry entry;

if ((getLongFromObjectOrReply(c, c->argv[2], &toremove, NULL) != REDIS_OK))
Expand Down

0 comments on commit 3c08fda

Please sign in to comment.