Home
last modified time | relevance | path

Searched refs:createStringObject (Results 1 – 25 of 25) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dsort.c92 fieldobj = createStringObject(f+2,fieldlen); in lookupKeyByPattern()
101 keyobj = createStringObject(NULL,prefixlen+sublen+postfixlen); in lookupKeyByPattern()
421 vector[j].obj = createStringObject(sdsele,sdslen(sdsele)); in sortCommand()
438 vector[j].obj = createStringObject(sdsele,sdslen(sdsele)); in sortCommand()
551 if (!val) val = createStringObject("",0); in sortCommand()
H A Ddb.c248 keyobj = createStringObject(key,sdslen(key)); in dbRandomKey()
551 keyobj = createStringObject(key,sdslen(key)); in keysCommand()
573 key = createStringObject(sdskey, sdslen(sdskey)); in scanCallback()
576 key = createStringObject(keysds,sdslen(keysds)); in scanCallback()
580 key = createStringObject(sdskey,sdslen(sdskey)); in scanCallback()
581 val = createStringObject(sdsval,sdslen(sdsval)); in scanCallback()
584 key = createStringObject(sdskey,sdslen(sdskey)); in scanCallback()
729 (vstr != NULL) ? createStringObject((char*)vstr,vlen) : in scanGenericCommand()
1518 keys[j++] = createStringObject((char*)iter.key+2,iter.key_len-2); in getKeysInSlot()
1538 robj *key = createStringObject((char*)iter.key+2,iter.key_len-2); in delKeysInSlot()
H A Dt_set.c456 propargv[0] = createStringObject("SREM",4); in spopWithCountCommand()
484 objele = createStringObject(sdsele,sdslen(sdsele)); in spopWithCountCommand()
528 objele = createStringObject(sdsele,sdslen(sdsele)); in spopWithCountCommand()
580 ele = createStringObject(sdsele,sdslen(sdsele)); in spopCommand()
587 aux = createStringObject("SREM",4); in spopCommand()
693 retval = dictAdd(d,createStringObject(ele,sdslen(ele)),NULL); in srandmemberWithCountCommand()
723 objele = createStringObject(ele,sdslen(ele)); in srandmemberWithCountCommand()
H A Dnotify.c112 eventobj = createStringObject(event,strlen(event)); in notifyKeyspaceEvent()
H A Dserver.c1384 argv[0] = createStringObject("REPLCONF",8); in beforeSleep()
1385 argv[1] = createStringObject("GETACK",6); in beforeSleep()
1491 shared.messagebulk = createStringObject("$7\r\nmessage\r\n",13); in createSharedObjects()
1497 shared.del = createStringObject("DEL",3); in createSharedObjects()
1498 shared.unlink = createStringObject("UNLINK",6); in createSharedObjects()
1499 shared.rpop = createStringObject("RPOP",4); in createSharedObjects()
1500 shared.lpop = createStringObject("LPOP",4); in createSharedObjects()
1501 shared.lpush = createStringObject("LPUSH",5); in createSharedObjects()
1502 shared.rpoplpush = createStringObject("RPOPLPUSH",9); in createSharedObjects()
1503 shared.zpopmin = createStringObject("ZPOPMIN",7); in createSharedObjects()
[all …]
H A Dt_stream.c803 argv[0] = createStringObject("XCLAIM",6); in streamPropagateXCLAIM()
806 argv[3] = createStringObject(nack->consumer->name,sdslen(nack->consumer->name)); in streamPropagateXCLAIM()
809 argv[6] = createStringObject("TIME",4); in streamPropagateXCLAIM()
811 argv[8] = createStringObject("RETRYCOUNT",10); in streamPropagateXCLAIM()
813 argv[10] = createStringObject("FORCE",5); in streamPropagateXCLAIM()
814 argv[11] = createStringObject("JUSTID",6); in streamPropagateXCLAIM()
815 argv[12] = createStringObject("LASTID",6); in streamPropagateXCLAIM()
839 argv[0] = createStringObject("XGROUP",6); in streamPropagateGroupID()
840 argv[1] = createStringObject("SETID",5); in streamPropagateGroupID()
1157 robj *equal_obj = createStringObject("=",1); in streamRewriteApproxMaxlen()
H A Dt_list.c54 return createStringObject((char*)data,sz); in listPopSaver()
130 value = createStringObject((char *)entry->entry.value, in listTypeGet()
327 value = createStringObject((char*)entry.value,entry.sz); in lindexCommand()
H A Ddebug.c285 keyobj = createStringObject(key,sdslen(key)); in computeDatasetDigest()
488 key = createStringObject(buf,strlen(buf)); in debugCommand()
498 val = createStringObject(buf,strlen(buf)); in debugCommand()
501 val = createStringObject(NULL,valsize); in debugCommand()
H A Dexpire.c58 robj *keyobj = createStringObject(key,sdslen(key)); in activeExpireCycleTryExpire()
H A Dscripting.c423 argv[j] = createStringObject(obj_s, obj_len); in luaRedisGenericCommand()
1420 propargv[0] = createStringObject("EXEC",4); in evalGenericCommand()
1453 resetRefCount(createStringObject("SCRIPT",6)), in evalGenericCommand()
1454 resetRefCount(createStringObject("LOAD",4)), in evalGenericCommand()
1458 resetRefCount(createStringObject("EVAL",4))); in evalGenericCommand()
H A Dmulti.c109 robj *multistring = createStringObject("MULTI",5); in execCommandPropagateMulti()
H A Dt_hash.c137 if (vstr) return createStringObject((char*)vstr,vlen); in hashTypeGetValueObject()
636 aux = createStringObject("HSET",4); in hincrbyfloatCommand()
H A Dobject.c119 robj *createStringObject(const char *ptr, size_t len) { in createStringObject() function
182 return createStringObject(buf,len); in createStringObjectFromLongDouble()
518 dec = createStringObject(buf,strlen(buf)); in getDecodedObject()
H A Devict.c555 robj *keyobj = createStringObject(bestkey,sdslen(bestkey)); in freeMemoryIfNeeded()
H A Dblocked.c363 argv[0] = createStringObject(cmd->name,strlen(cmd->name)); in handleClientsBlockedOnKeys()
H A Dt_string.c427 aux = createStringObject("SET",3); in incrbyfloatCommand()
H A Dmodule.c527 propargv[0] = createStringObject("EXEC",4); in moduleHandlePropagationAfterCommandCallback()
872 RedisModuleString *o = createStringObject(ptr,len); in RM_CreateString()
2104 str = createStringObject(ln->ele,sdslen(ln->ele)); in RM_ZsetRangeCurrentElement()
2681 argv[0] = createStringObject(cmdname,strlen(cmdname)); in moduleCreateArgvFromUserFormat()
2689 argv[argc++] = createStringObject(cstr,strlen(cstr)); in moduleCreateArgvFromUserFormat()
2697 argv[argc++] = createStringObject(buf,len); in moduleCreateArgvFromUserFormat()
H A Daof.c571 argv[0] = createStringObject("PEXPIREAT",9); in catAppendOnlyExpireAtCommand()
601 tmpargv[0] = createStringObject("SET",3); in feedAppendOnlyFile()
H A Drdb.c515 robj *o = encode ? createStringObject(SDS_NOINIT,len) : in rdbGenericLoadStringObject()
1379 return createStringObject("module-dummy-value",18); in rdbLoadCheckModuleValue()
H A Dcluster.c2033 channel = createStringObject( in clusterProcessPacket()
2035 message = createStringObject( in clusterProcessPacket()
5316 newargv[0] = createStringObject("DEL",3); in migrateCommand()
H A Dreplication.c2607 ping_argv[0] = createStringObject("PING",4); in replicationCron()
H A Dsentinel.c643 channel = createStringObject(type,strlen(type)); in sentinelEvent()
644 payload = createStringObject(msg,strlen(msg)); in sentinelEvent()
H A Dnetworking.c1405 createStringObject(c->querybuf+c->qb_pos,c->bulklen); in processMultibulkBuffer()
H A Dserver.h1540 robj *createStringObject(const char *ptr, size_t len);
/f-stack/app/redis-5.0.5/deps/hiredis/
H A Dhiredis.c47 static void *createStringObject(const redisReadTask *task, char *str, size_t len);
55 createStringObject,
102 static void *createStringObject(const redisReadTask *task, char *str, size_t len) { in createStringObject() function