[redis.git] / src / t_hash.c

#include "redis.h"

#include <math.h>

/*-----------------------------------------------------------------------------
 * Hash type API
 *----------------------------------------------------------------------------*/

/* Check the length of a number of objects to see if we need to convert a
 * zipmap to a real hash. Note that we only check string encoded objects
 * as their string length can be queried in constant time. */
void hashTypeTryConversion(robj *subject, robj **argv, int start, int end) {
    int i;
    if (subject->encoding != REDIS_ENCODING_ZIPMAP) return;

    for (i = start; i <= end; i++) {
        if (argv[i]->encoding == REDIS_ENCODING_RAW &&
            sdslen(argv[i]->ptr) > server.hash_max_zipmap_value)
        {
            convertToRealHash(subject);
            return;
        }
    }
}

/* Encode given objects in-place when the hash uses a dict. */
void hashTypeTryObjectEncoding(robj *subject, robj **o1, robj **o2) {
    if (subject->encoding == REDIS_ENCODING_HT) {
        if (o1) *o1 = tryObjectEncoding(*o1);
        if (o2) *o2 = tryObjectEncoding(*o2);
    }
}

/* Get the value from a hash identified by key. Returns either a string
 * object or NULL if the value cannot be found. The refcount of the object
 * is always increased by 1 when the value was found. */
robj *hashTypeGet(robj *o, robj *key) {
    robj *value = NULL;
    if (o->encoding == REDIS_ENCODING_ZIPMAP) {
        unsigned char *v;
        unsigned int vlen;
        key = getDecodedObject(key);
        if (zipmapGet(o->ptr,key->ptr,sdslen(key->ptr),&v,&vlen)) {
            value = createStringObject((char*)v,vlen);
        }
        decrRefCount(key);
    } else {
        dictEntry *de = dictFind(o->ptr,key);
        if (de != NULL) {
            value = dictGetEntryVal(de);
            incrRefCount(value);
        }
    }
    return value;
}

/* Test if the key exists in the given hash. Returns 1 if the key
 * exists and 0 when it doesn't. */
int hashTypeExists(robj *o, robj *key) {
    if (o->encoding == REDIS_ENCODING_ZIPMAP) {
        key = getDecodedObject(key);
        if (zipmapExists(o->ptr,key->ptr,sdslen(key->ptr))) {
            decrRefCount(key);
            return 1;
        }
        decrRefCount(key);
    } else {
        if (dictFind(o->ptr,key) != NULL) {
            return 1;
        }
    }
    return 0;
}

/* Add an element, discard the old if the key already exists.
 * Return 0 on insert and 1 on update. */
int hashTypeSet(robj *o, robj *key, robj *value) {
    int update = 0;
    if (o->encoding == REDIS_ENCODING_ZIPMAP) {
        key = getDecodedObject(key);
        value = getDecodedObject(value);
        o->ptr = zipmapSet(o->ptr,
            key->ptr,sdslen(key->ptr),
            value->ptr,sdslen(value->ptr), &update);
        decrRefCount(key);
        decrRefCount(value);

        /* Check if the zipmap needs to be upgraded to a real hash table */
        if (zipmapLen(o->ptr) > server.hash_max_zipmap_entries)
            convertToRealHash(o);
    } else {
        if (dictReplace(o->ptr,key,value)) {
            /* Insert */
            incrRefCount(key);
        } else {
            /* Update */
            update = 1;
        }
        incrRefCount(value);
    }
    return update;
}

/* Delete an element from a hash.
 * Return 1 on deleted and 0 on not found. */
int hashTypeDelete(robj *o, robj *key) {
    int deleted = 0;
    if (o->encoding == REDIS_ENCODING_ZIPMAP) {
        key = getDecodedObject(key);
        o->ptr = zipmapDel(o->ptr,key->ptr,sdslen(key->ptr), &deleted);
        decrRefCount(key);
    } else {
        deleted = dictDelete((dict*)o->ptr,key) == DICT_OK;
        /* Always check if the dictionary needs a resize after a delete. */
        if (deleted && htNeedsResize(o->ptr)) dictResize(o->ptr);
    }
    return deleted;
}

/* Return the number of elements in a hash. */
unsigned long hashTypeLength(robj *o) {
    return (o->encoding == REDIS_ENCODING_ZIPMAP) ?
        zipmapLen((unsigned char*)o->ptr) : dictSize((dict*)o->ptr);
}

hashTypeIterator *hashTypeInitIterator(robj *subject) {
    hashTypeIterator *hi = zmalloc(sizeof(hashTypeIterator));
    hi->encoding = subject->encoding;
    if (hi->encoding == REDIS_ENCODING_ZIPMAP) {
        hi->zi = zipmapRewind(subject->ptr);
    } else if (hi->encoding == REDIS_ENCODING_HT) {
        hi->di = dictGetIterator(subject->ptr);
    } else {
        redisAssert(NULL);
    }
    return hi;
}

void hashTypeReleaseIterator(hashTypeIterator *hi) {
    if (hi->encoding == REDIS_ENCODING_HT) {
        dictReleaseIterator(hi->di);
    }
    zfree(hi);
}

/* Move to the next entry in the hash. Return REDIS_OK when the next entry
 * could be found and REDIS_ERR when the iterator reaches the end. */
int hashTypeNext(hashTypeIterator *hi) {
    if (hi->encoding == REDIS_ENCODING_ZIPMAP) {
        if ((hi->zi = zipmapNext(hi->zi, &hi->zk, &hi->zklen,
            &hi->zv, &hi->zvlen)) == NULL) return REDIS_ERR;
    } else {
        if ((hi->de = dictNext(hi->di)) == NULL) return REDIS_ERR;
    }
    return REDIS_OK;
}

/* Get key or value object at current iteration position.
 * This increases the refcount of the field object by 1. */
robj *hashTypeCurrent(hashTypeIterator *hi, int what) {
    robj *o;
    if (hi->encoding == REDIS_ENCODING_ZIPMAP) {
        if (what & REDIS_HASH_KEY) {
            o = createStringObject((char*)hi->zk,hi->zklen);
        } else {
            o = createStringObject((char*)hi->zv,hi->zvlen);
        }
    } else {
        if (what & REDIS_HASH_KEY) {
            o = dictGetEntryKey(hi->de);
        } else {
            o = dictGetEntryVal(hi->de);
        }
        incrRefCount(o);
    }
    return o;
}

robj *hashTypeLookupWriteOrCreate(redisClient *c, robj *key) {
    robj *o = lookupKeyWrite(c->db,key);
    if (o == NULL) {
        o = createHashObject();
        dbAdd(c->db,key,o);
    } else {
        if (o->type != REDIS_HASH) {
            addReply(c,shared.wrongtypeerr);
            return NULL;
        }
    }
    return o;
}

void convertToRealHash(robj *o) {
    unsigned char *key, *val, *p, *zm = o->ptr;
    unsigned int klen, vlen;
    dict *dict = dictCreate(&hashDictType,NULL);

    redisAssert(o->type == REDIS_HASH && o->encoding != REDIS_ENCODING_HT);
    p = zipmapRewind(zm);
    while((p = zipmapNext(p,&key,&klen,&val,&vlen)) != NULL) {
        robj *keyobj, *valobj;

        keyobj = createStringObject((char*)key,klen);
        valobj = createStringObject((char*)val,vlen);
        keyobj = tryObjectEncoding(keyobj);
        valobj = tryObjectEncoding(valobj);
        dictAdd(dict,keyobj,valobj);
    }
    o->encoding = REDIS_ENCODING_HT;
    o->ptr = dict;
    zfree(zm);
}

/*-----------------------------------------------------------------------------
 * Hash type commands
 *----------------------------------------------------------------------------*/

void hsetCommand(redisClient *c) {
    int update;
    robj *o;

    if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;
    hashTypeTryConversion(o,c->argv,2,3);
    hashTypeTryObjectEncoding(o,&c->argv[2], &c->argv[3]);
    update = hashTypeSet(o,c->argv[2],c->argv[3]);
    addReply(c, update ? shared.czero : shared.cone);
    touchWatchedKey(c->db,c->argv[1]);
    server.dirty++;
}

void hsetnxCommand(redisClient *c) {
    robj *o;
    if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;
    hashTypeTryConversion(o,c->argv,2,3);

    if (hashTypeExists(o, c->argv[2])) {
        addReply(c, shared.czero);
    } else {
        hashTypeTryObjectEncoding(o,&c->argv[2], &c->argv[3]);
        hashTypeSet(o,c->argv[2],c->argv[3]);
        addReply(c, shared.cone);
        touchWatchedKey(c->db,c->argv[1]);
        server.dirty++;
    }
}

void hmsetCommand(redisClient *c) {
    int i;
    robj *o;

    if ((c->argc % 2) == 1) {
        addReplyError(c,"wrong number of arguments for HMSET");
        return;
    }

    if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;
    hashTypeTryConversion(o,c->argv,2,c->argc-1);
    for (i = 2; i < c->argc; i += 2) {
        hashTypeTryObjectEncoding(o,&c->argv[i], &c->argv[i+1]);
        hashTypeSet(o,c->argv[i],c->argv[i+1]);
    }
    addReply(c, shared.ok);
    touchWatchedKey(c->db,c->argv[1]);
    server.dirty++;
}

void hincrbyCommand(redisClient *c) {
    long long value, incr;
    robj *o, *current, *new;

    if (getLongLongFromObjectOrReply(c,c->argv[3],&incr,NULL) != REDIS_OK) return;
    if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;
    if ((current = hashTypeGet(o,c->argv[2])) != NULL) {
        if (getLongLongFromObjectOrReply(c,current,&value,
            "hash value is not an integer") != REDIS_OK) {
            decrRefCount(current);
            return;
        }
        decrRefCount(current);
    } else {
        value = 0;
    }

    value += incr;
    new = createStringObjectFromLongLong(value);
    hashTypeTryObjectEncoding(o,&c->argv[2],NULL);
    hashTypeSet(o,c->argv[2],new);
    decrRefCount(new);
    addReplyLongLong(c,value);
    touchWatchedKey(c->db,c->argv[1]);
    server.dirty++;
}

void hgetCommand(redisClient *c) {
    robj *o, *value;
    if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.nullbulk)) == NULL ||
        checkType(c,o,REDIS_HASH)) return;

    if ((value = hashTypeGet(o,c->argv[2])) != NULL) {
        addReplyBulk(c,value);
        decrRefCount(value);
    } else {
        addReply(c,shared.nullbulk);
    }
}

void hmgetCommand(redisClient *c) {
    int i;
    robj *o, *value;
    o = lookupKeyRead(c->db,c->argv[1]);
    if (o != NULL && o->type != REDIS_HASH) {
        addReply(c,shared.wrongtypeerr);
        return;
    }

    /* Note the check for o != NULL happens inside the loop. This is
     * done because objects that cannot be found are considered to be
     * an empty hash. The reply should then be a series of NULLs. */
    addReplyMultiBulkLen(c,c->argc-2);
    for (i = 2; i < c->argc; i++) {
        if (o != NULL && (value = hashTypeGet(o,c->argv[i])) != NULL) {
            addReplyBulk(c,value);
            decrRefCount(value);
        } else {
            addReply(c,shared.nullbulk);
        }
    }
}

void hdelCommand(redisClient *c) {
    robj *o;
    if ((o = lookupKeyWriteOrReply(c,c->argv[1],shared.czero)) == NULL ||
        checkType(c,o,REDIS_HASH)) return;

    if (hashTypeDelete(o,c->argv[2])) {
        if (hashTypeLength(o) == 0) dbDelete(c->db,c->argv[1]);
        addReply(c,shared.cone);
        touchWatchedKey(c->db,c->argv[1]);
        server.dirty++;
    } else {
        addReply(c,shared.czero);
    }
}

void hlenCommand(redisClient *c) {
    robj *o;
    if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.czero)) == NULL ||
        checkType(c,o,REDIS_HASH)) return;

    addReplyLongLong(c,hashTypeLength(o));
}

void genericHgetallCommand(redisClient *c, int flags) {
    robj *o, *obj;
    unsigned long count = 0;
    hashTypeIterator *hi;
    void *replylen = NULL;

    if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.emptymultibulk)) == NULL
        || checkType(c,o,REDIS_HASH)) return;

    replylen = addDeferredMultiBulkLength(c);
    hi = hashTypeInitIterator(o);
    while (hashTypeNext(hi) != REDIS_ERR) {
        if (flags & REDIS_HASH_KEY) {
            obj = hashTypeCurrent(hi,REDIS_HASH_KEY);
            addReplyBulk(c,obj);
            decrRefCount(obj);
            count++;
        }
        if (flags & REDIS_HASH_VALUE) {
            obj = hashTypeCurrent(hi,REDIS_HASH_VALUE);
            addReplyBulk(c,obj);
            decrRefCount(obj);
            count++;
        }
    }
    hashTypeReleaseIterator(hi);
    setDeferredMultiBulkLength(c,replylen,count);
}

void hkeysCommand(redisClient *c) {
    genericHgetallCommand(c,REDIS_HASH_KEY);
}

void hvalsCommand(redisClient *c) {
    genericHgetallCommand(c,REDIS_HASH_VALUE);
}

void hgetallCommand(redisClient *c) {
    genericHgetallCommand(c,REDIS_HASH_KEY|REDIS_HASH_VALUE);
}

void hexistsCommand(redisClient *c) {
    robj *o;
    if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.czero)) == NULL ||
        checkType(c,o,REDIS_HASH)) return;

    addReply(c, hashTypeExists(o,c->argv[2]) ? shared.cone : shared.czero);
}
Commit	Line	Data
e2641e09	1	#include "redis.h"
	2
	3	#include <math.h>
	4
	5	/*-----------------------------------------------------------------------------
	6	* Hash type API
	7	----------------------------------------------------------------------------/
	8
	9	/* Check the length of a number of objects to see if we need to convert a
	10	* zipmap to a real hash. Note that we only check string encoded objects
	11	* as their string length can be queried in constant time. */
	12	void hashTypeTryConversion(robj subject, robj *argv, int start, int end) {
	13	int i;
	14	if (subject->encoding != REDIS_ENCODING_ZIPMAP) return;
	15
	16	for (i = start; i <= end; i++) {
	17	if (argv[i]->encoding == REDIS_ENCODING_RAW &&
	18	sdslen(argv[i]->ptr) > server.hash_max_zipmap_value)
	19	{
	20	convertToRealHash(subject);
	21	return;
	22	}
	23	}
	24	}
	25
	26	/* Encode given objects in-place when the hash uses a dict. */
	27	void hashTypeTryObjectEncoding(robj subject, robj o1, robj *o2) {
	28	if (subject->encoding == REDIS_ENCODING_HT) {
	29	if (o1) o1 = tryObjectEncoding(o1);
	30	if (o2) o2 = tryObjectEncoding(o2);
	31	}
	32	}
	33
	34	/* Get the value from a hash identified by key. Returns either a string
	35	* object or NULL if the value cannot be found. The refcount of the object
	36	* is always increased by 1 when the value was found. */
	37	robj hashTypeGet(robj o, robj *key) {
	38	robj *value = NULL;
	39	if (o->encoding == REDIS_ENCODING_ZIPMAP) {
	40	unsigned char *v;
	41	unsigned int vlen;
	42	key = getDecodedObject(key);
	43	if (zipmapGet(o->ptr,key->ptr,sdslen(key->ptr),&v,&vlen)) {
	44	value = createStringObject((char*)v,vlen);
	45	}
	46	decrRefCount(key);
	47	} else {
	48	dictEntry *de = dictFind(o->ptr,key);
	49	if (de != NULL) {
	50	value = dictGetEntryVal(de);
	51	incrRefCount(value);
	52	}
	53	}
	54	return value;
	55	}
	56
	57	/* Test if the key exists in the given hash. Returns 1 if the key
	58	* exists and 0 when it doesn't. */
	59	int hashTypeExists(robj o, robj key) {
	60	if (o->encoding == REDIS_ENCODING_ZIPMAP) {
	61	key = getDecodedObject(key);
	62	if (zipmapExists(o->ptr,key->ptr,sdslen(key->ptr))) {
	63	decrRefCount(key);
	64	return 1;
65	}
66	decrRefCount(key);
67	} else {
68	if (dictFind(o->ptr,key) != NULL) {
69	return 1;
70	}
71	}
72	return 0;
73	}
74
75	/* Add an element, discard the old if the key already exists.
76	* Return 0 on insert and 1 on update. */
77	int hashTypeSet(robj o, robj key, robj *value) {
78	int update = 0;
79	if (o->encoding == REDIS_ENCODING_ZIPMAP) {
80	key = getDecodedObject(key);
81	value = getDecodedObject(value);
82	o->ptr = zipmapSet(o->ptr,
83	key->ptr,sdslen(key->ptr),
84	value->ptr,sdslen(value->ptr), &update);
85	decrRefCount(key);
86	decrRefCount(value);
87
88	/* Check if the zipmap needs to be upgraded to a real hash table */
89	if (zipmapLen(o->ptr) > server.hash_max_zipmap_entries)
90	convertToRealHash(o);
91	} else {
92	if (dictReplace(o->ptr,key,value)) {
93	/* Insert */
94	incrRefCount(key);
95	} else {
96	/* Update */
97	update = 1;
98	}
99	incrRefCount(value);
100	}
101	return update;
102	}
103
104	/* Delete an element from a hash.
105	* Return 1 on deleted and 0 on not found. */
106	int hashTypeDelete(robj o, robj key) {
107	int deleted = 0;
108	if (o->encoding == REDIS_ENCODING_ZIPMAP) {
109	key = getDecodedObject(key);
110	o->ptr = zipmapDel(o->ptr,key->ptr,sdslen(key->ptr), &deleted);
111	decrRefCount(key);
112	} else {
113	deleted = dictDelete((dict*)o->ptr,key) == DICT_OK;
114	/* Always check if the dictionary needs a resize after a delete. */
115	if (deleted && htNeedsResize(o->ptr)) dictResize(o->ptr);
116	}
117	return deleted;
118	}
119
120	/* Return the number of elements in a hash. */
121	unsigned long hashTypeLength(robj *o) {
122	return (o->encoding == REDIS_ENCODING_ZIPMAP) ?
123	zipmapLen((unsigned char)o->ptr) : dictSize((dict)o->ptr);
124	}
125
126	hashTypeIterator hashTypeInitIterator(robj subject) {
127	hashTypeIterator *hi = zmalloc(sizeof(hashTypeIterator));
128	hi->encoding = subject->encoding;
129	if (hi->encoding == REDIS_ENCODING_ZIPMAP) {
130	hi->zi = zipmapRewind(subject->ptr);
131	} else if (hi->encoding == REDIS_ENCODING_HT) {
132	hi->di = dictGetIterator(subject->ptr);
133	} else {
134	redisAssert(NULL);
135	}
136	return hi;
137	}
138
139	void hashTypeReleaseIterator(hashTypeIterator *hi) {
140	if (hi->encoding == REDIS_ENCODING_HT) {
141	dictReleaseIterator(hi->di);
142	}
143	zfree(hi);
144	}
145
146	/* Move to the next entry in the hash. Return REDIS_OK when the next entry
147	* could be found and REDIS_ERR when the iterator reaches the end. */
148	int hashTypeNext(hashTypeIterator *hi) {
149	if (hi->encoding == REDIS_ENCODING_ZIPMAP) {
150	if ((hi->zi = zipmapNext(hi->zi, &hi->zk, &hi->zklen,
151	&hi->zv, &hi->zvlen)) == NULL) return REDIS_ERR;
152	} else {
153	if ((hi->de = dictNext(hi->di)) == NULL) return REDIS_ERR;
154	}
155	return REDIS_OK;
156	}
157
158	/* Get key or value object at current iteration position.
159	* This increases the refcount of the field object by 1. */
160	robj hashTypeCurrent(hashTypeIterator hi, int what) {
161	robj *o;
162	if (hi->encoding == REDIS_ENCODING_ZIPMAP) {
163	if (what & REDIS_HASH_KEY) {
164	o = createStringObject((char*)hi->zk,hi->zklen);
165	} else {
166	o = createStringObject((char*)hi->zv,hi->zvlen);
167	}
168	} else {
169	if (what & REDIS_HASH_KEY) {
170	o = dictGetEntryKey(hi->de);
171	} else {
172	o = dictGetEntryVal(hi->de);
173	}
174	incrRefCount(o);
175	}
176	return o;
177	}
178
179	robj hashTypeLookupWriteOrCreate(redisClient c, robj *key) {
180	robj *o = lookupKeyWrite(c->db,key);
181	if (o == NULL) {
182	o = createHashObject();
183	dbAdd(c->db,key,o);
184	} else {
185	if (o->type != REDIS_HASH) {
186	addReply(c,shared.wrongtypeerr);
187	return NULL;
188	}
189	}
190	return o;
191	}
192
193	void convertToRealHash(robj *o) {
194	unsigned char key, val, p, zm = o->ptr;
195	unsigned int klen, vlen;
196	dict *dict = dictCreate(&hashDictType,NULL);
197
198	redisAssert(o->type == REDIS_HASH && o->encoding != REDIS_ENCODING_HT);
199	p = zipmapRewind(zm);
200	while((p = zipmapNext(p,&key,&klen,&val,&vlen)) != NULL) {
201	robj keyobj, valobj;
202
203	keyobj = createStringObject((char*)key,klen);
204	valobj = createStringObject((char*)val,vlen);
205	keyobj = tryObjectEncoding(keyobj);
206	valobj = tryObjectEncoding(valobj);
207	dictAdd(dict,keyobj,valobj);
208	}
209	o->encoding = REDIS_ENCODING_HT;
210	o->ptr = dict;
211	zfree(zm);
212	}
213
214	/*-----------------------------------------------------------------------------
215	* Hash type commands
216	----------------------------------------------------------------------------/
217
218	void hsetCommand(redisClient *c) {
219	int update;
220	robj *o;
221
222	if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;
223	hashTypeTryConversion(o,c->argv,2,3);
224	hashTypeTryObjectEncoding(o,&c->argv[2], &c->argv[3]);
225	update = hashTypeSet(o,c->argv[2],c->argv[3]);
226	addReply(c, update ? shared.czero : shared.cone);
5b4bff9c	227	touchWatchedKey(c->db,c->argv[1]);
e2641e09	228	server.dirty++;
	229	}
	230
	231	void hsetnxCommand(redisClient *c) {
	232	robj *o;
	233	if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;
	234	hashTypeTryConversion(o,c->argv,2,3);
	235
	236	if (hashTypeExists(o, c->argv[2])) {
	237	addReply(c, shared.czero);
	238	} else {
	239	hashTypeTryObjectEncoding(o,&c->argv[2], &c->argv[3]);
	240	hashTypeSet(o,c->argv[2],c->argv[3]);
	241	addReply(c, shared.cone);
5b4bff9c	242	touchWatchedKey(c->db,c->argv[1]);
e2641e09	243	server.dirty++;
	244	}
	245	}
	246
	247	void hmsetCommand(redisClient *c) {
	248	int i;
	249	robj *o;
	250
	251	if ((c->argc % 2) == 1) {
3ab20376	252	addReplyError(c,"wrong number of arguments for HMSET");
e2641e09	253	return;
	254	}
	255
	256	if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;
	257	hashTypeTryConversion(o,c->argv,2,c->argc-1);
	258	for (i = 2; i < c->argc; i += 2) {
	259	hashTypeTryObjectEncoding(o,&c->argv[i], &c->argv[i+1]);
	260	hashTypeSet(o,c->argv[i],c->argv[i+1]);
	261	}
	262	addReply(c, shared.ok);
5b4bff9c	263	touchWatchedKey(c->db,c->argv[1]);
e2641e09	264	server.dirty++;
	265	}
	266
	267	void hincrbyCommand(redisClient *c) {
	268	long long value, incr;
	269	robj o, current, *new;
	270
	271	if (getLongLongFromObjectOrReply(c,c->argv[3],&incr,NULL) != REDIS_OK) return;
	272	if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;
	273	if ((current = hashTypeGet(o,c->argv[2])) != NULL) {
	274	if (getLongLongFromObjectOrReply(c,current,&value,
	275	"hash value is not an integer") != REDIS_OK) {
	276	decrRefCount(current);
	277	return;
	278	}
	279	decrRefCount(current);
	280	} else {
	281	value = 0;
	282	}
	283
	284	value += incr;
	285	new = createStringObjectFromLongLong(value);
	286	hashTypeTryObjectEncoding(o,&c->argv[2],NULL);
	287	hashTypeSet(o,c->argv[2],new);
	288	decrRefCount(new);
	289	addReplyLongLong(c,value);
5b4bff9c	290	touchWatchedKey(c->db,c->argv[1]);
e2641e09	291	server.dirty++;
	292	}
	293
	294	void hgetCommand(redisClient *c) {
	295	robj o, value;
	296	if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.nullbulk)) == NULL \|\|
	297	checkType(c,o,REDIS_HASH)) return;
	298
	299	if ((value = hashTypeGet(o,c->argv[2])) != NULL) {
	300	addReplyBulk(c,value);
	301	decrRefCount(value);
	302	} else {
	303	addReply(c,shared.nullbulk);
	304	}
	305	}
	306
	307	void hmgetCommand(redisClient *c) {
	308	int i;
	309	robj o, value;
	310	o = lookupKeyRead(c->db,c->argv[1]);
	311	if (o != NULL && o->type != REDIS_HASH) {
	312	addReply(c,shared.wrongtypeerr);
e584d82f	313	return;
e2641e09	314	}
	315
	316	/* Note the check for o != NULL happens inside the loop. This is
	317	* done because objects that cannot be found are considered to be
	318	* an empty hash. The reply should then be a series of NULLs. */
0537e7bf	319	addReplyMultiBulkLen(c,c->argc-2);
e2641e09	320	for (i = 2; i < c->argc; i++) {
	321	if (o != NULL && (value = hashTypeGet(o,c->argv[i])) != NULL) {
	322	addReplyBulk(c,value);
	323	decrRefCount(value);
	324	} else {
	325	addReply(c,shared.nullbulk);
	326	}
	327	}
	328	}
	329
	330	void hdelCommand(redisClient *c) {
	331	robj *o;
	332	if ((o = lookupKeyWriteOrReply(c,c->argv[1],shared.czero)) == NULL \|\|
	333	checkType(c,o,REDIS_HASH)) return;
	334
	335	if (hashTypeDelete(o,c->argv[2])) {
	336	if (hashTypeLength(o) == 0) dbDelete(c->db,c->argv[1]);
	337	addReply(c,shared.cone);
5b4bff9c	338	touchWatchedKey(c->db,c->argv[1]);
e2641e09	339	server.dirty++;
	340	} else {
	341	addReply(c,shared.czero);
	342	}
	343	}
	344
	345	void hlenCommand(redisClient *c) {
	346	robj *o;
	347	if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.czero)) == NULL \|\|
	348	checkType(c,o,REDIS_HASH)) return;
	349
b70d3555	350	addReplyLongLong(c,hashTypeLength(o));
e2641e09	351	}
	352
	353	void genericHgetallCommand(redisClient *c, int flags) {
b301c1fc	354	robj o, obj;
e2641e09	355	unsigned long count = 0;
e2641e09	356	hashTypeIterator *hi;
b301c1fc	357	void *replylen = NULL;
e2641e09	358
	359	if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.emptymultibulk)) == NULL
	360	\|\| checkType(c,o,REDIS_HASH)) return;
	361
b301c1fc	362	replylen = addDeferredMultiBulkLength(c);
e2641e09	363	hi = hashTypeInitIterator(o);
	364	while (hashTypeNext(hi) != REDIS_ERR) {
	365	if (flags & REDIS_HASH_KEY) {
	366	obj = hashTypeCurrent(hi,REDIS_HASH_KEY);
	367	addReplyBulk(c,obj);
	368	decrRefCount(obj);
	369	count++;
	370	}
	371	if (flags & REDIS_HASH_VALUE) {
	372	obj = hashTypeCurrent(hi,REDIS_HASH_VALUE);
	373	addReplyBulk(c,obj);
	374	decrRefCount(obj);
	375	count++;
	376	}
	377	}
	378	hashTypeReleaseIterator(hi);
b301c1fc	379	setDeferredMultiBulkLength(c,replylen,count);
e2641e09	380	}
	381
	382	void hkeysCommand(redisClient *c) {
	383	genericHgetallCommand(c,REDIS_HASH_KEY);
	384	}
	385
	386	void hvalsCommand(redisClient *c) {
	387	genericHgetallCommand(c,REDIS_HASH_VALUE);
	388	}
	389
	390	void hgetallCommand(redisClient *c) {
	391	genericHgetallCommand(c,REDIS_HASH_KEY\|REDIS_HASH_VALUE);
	392	}
	393
	394	void hexistsCommand(redisClient *c) {
	395	robj *o;
	396	if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.czero)) == NULL \|\|
	397	checkType(c,o,REDIS_HASH)) return;
	398
	399	addReply(c, hashTypeExists(o,c->argv[2]) ? shared.cone : shared.czero);
	400	}