40 void hashTypeTryConversion(robj *o, robj **argv, int start, int end) {  in hashTypeTryConversion()  argument
46         if (sdsEncodedObject(argv[i]) &&  in hashTypeTryConversion()
47             sdslen(argv[i]->ptr) > server.hash_max_ziplist_value)  in hashTypeTryConversion()
490     if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;  in hsetCommand()
491     hashTypeTryConversion(o,c->argv,2,3);  in hsetCommand()
492     hashTypeTryObjectEncoding(o,&c->argv[2], &c->argv[3]);  in hsetCommand()
493     update = hashTypeSet(o,c->argv[2],c->argv[3]);  in hsetCommand()
495     signalModifiedKey(c->db,c->argv[1]);  in hsetCommand()
496     notifyKeyspaceEvent(NOTIFY_HASH,"hset",c->argv[1],c->db->id);  in hsetCommand()
502     if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;  in hsetnxCommand()
503     hashTypeTryConversion(o,c->argv,2,3);  in hsetnxCommand()
505     if (hashTypeExists(o, c->argv[2])) {  in hsetnxCommand()
508         hashTypeTryObjectEncoding(o,&c->argv[2], &c->argv[3]);  in hsetnxCommand()
509         hashTypeSet(o,c->argv[2],c->argv[3]);  in hsetnxCommand()
511         signalModifiedKey(c->db,c->argv[1]);  in hsetnxCommand()
512         notifyKeyspaceEvent(NOTIFY_HASH,"hset",c->argv[1],c->db->id);  in hsetnxCommand()
526     if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;  in hmsetCommand()
527     hashTypeTryConversion(o,c->argv,2,c->argc-1);  in hmsetCommand()
529         hashTypeTryObjectEncoding(o,&c->argv[i], &c->argv[i+1]);  in hmsetCommand()
530         hashTypeSet(o,c->argv[i],c->argv[i+1]);  in hmsetCommand()
533     signalModifiedKey(c->db,c->argv[1]);  in hmsetCommand()
534     notifyKeyspaceEvent(NOTIFY_HASH,"hset",c->argv[1],c->db->id);  in hmsetCommand()
542     if (getLongLongFromObjectOrReply(c,c->argv[3],&incr,NULL) != C_OK) return;  in hincrbyCommand()
543     if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;  in hincrbyCommand()
544     if ((current = hashTypeGetObject(o,c->argv[2])) != NULL) {  in hincrbyCommand()
563     hashTypeTryObjectEncoding(o,&c->argv[2],NULL);  in hincrbyCommand()
564     hashTypeSet(o,c->argv[2],new);  in hincrbyCommand()
567     signalModifiedKey(c->db,c->argv[1]);  in hincrbyCommand()
568     notifyKeyspaceEvent(NOTIFY_HASH,"hincrby",c->argv[1],c->db->id);  in hincrbyCommand()
576     if (getLongDoubleFromObjectOrReply(c,c->argv[3],&incr,NULL) != C_OK) return;  in hincrbyfloatCommand()
577     if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;  in hincrbyfloatCommand()
578     if ((current = hashTypeGetObject(o,c->argv[2])) != NULL) {  in hincrbyfloatCommand()
591     hashTypeTryObjectEncoding(o,&c->argv[2],NULL);  in hincrbyfloatCommand()
592     hashTypeSet(o,c->argv[2],new);  in hincrbyfloatCommand()
594     signalModifiedKey(c->db,c->argv[1]);  in hincrbyfloatCommand()
595     notifyKeyspaceEvent(NOTIFY_HASH,"hincrbyfloat",c->argv[1],c->db->id);  in hincrbyfloatCommand()
650     if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.nullbulk)) == NULL ||  in hgetCommand()
653     addHashFieldToReply(c, o, c->argv[2]);  in hgetCommand()
662     o = lookupKeyRead(c->db, c->argv[1]);  in hmgetCommand()
670         addHashFieldToReply(c, o, c->argv[i]);  in hmgetCommand()
678     if ((o = lookupKeyWriteOrReply(c,c->argv[1],shared.czero)) == NULL ||  in hdelCommand()
682         if (hashTypeDelete(o,c->argv[j])) {  in hdelCommand()
685                 dbDelete(c->db,c->argv[1]);  in hdelCommand()
692         signalModifiedKey(c->db,c->argv[1]);  in hdelCommand()
693         notifyKeyspaceEvent(NOTIFY_HASH,"hdel",c->argv[1],c->db->id);  in hdelCommand()
695             notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1],  in hdelCommand()
705     if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.czero)) == NULL ||  in hlenCommand()
714     if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.czero)) == NULL ||  in hstrlenCommand()
716     addReplyLongLong(c,hashTypeGetValueLength(o,c->argv[2]));  in hstrlenCommand()
749     if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.emptymultibulk)) == NULL  in genericHgetallCommand()
788     if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.czero)) == NULL ||  in hexistsCommand()
791     addReply(c, hashTypeExists(o,c->argv[2]) ? shared.cone : shared.czero);  in hexistsCommand()
798     if (parseScanCursorOrReply(c,c->argv[2],&cursor) == C_ERR) return;  in hscanCommand()
799     if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.emptyscan)) == NULL ||  in hscanCommand()