| /redis-3.2.3/src/ |
| H A D | object.c | 54 return createObject(OBJ_STRING,sdsnewlen(ptr,len)); in createRawStringObject()
64 o->type = OBJ_STRING; in createEmbeddedStringObject()
103 o = createObject(OBJ_STRING, NULL); in createStringObjectFromLongLong()
166 serverAssert(o->type == OBJ_STRING); in dupStringObject()
174 d = createObject(OBJ_STRING, NULL); in dupStringObject()
305 case OBJ_STRING: freeStringObject(o); break; in decrRefCount()
351 serverAssertWithInfo(NULL,o,o->type == OBJ_STRING); in isObjectRepresentableAsLongLong()
370 serverAssertWithInfo(NULL,o,o->type == OBJ_STRING); in tryObjectEncoding()
472 serverAssertWithInfo(NULL,a,a->type == OBJ_STRING && b->type == OBJ_STRING); in compareStringObjectsWithFlags()
529 serverAssertWithInfo(NULL,o,o->type == OBJ_STRING); in stringObjectLen()
[all …]
|
| H A D | t_string.c | 163 if (o->type != OBJ_STRING) { in getGenericCommand()
209 o = createObject(OBJ_STRING,sdsnewlen(NULL, offset+sdslen(value))); in setrangeCommand()
215 if (checkType(c,o,OBJ_STRING)) in setrangeCommand()
255 checkType(c,o,OBJ_STRING)) return; in getrangeCommand()
294 if (o->type != OBJ_STRING) { in mgetCommand()
346 if (o != NULL && checkType(c,o,OBJ_STRING)) return; in incrDecrCommand()
406 if (o != NULL && checkType(c,o,OBJ_STRING)) return; in incrbyfloatCommand()
448 if (checkType(c,o,OBJ_STRING)) in appendCommand()
471 checkType(c,o,OBJ_STRING)) return; in strlenCommand()
|
| H A D | slowlog.c | 60 se->argv[j] = createObject(OBJ_STRING, in slowlogCreateEntry()
65 if (argv[j]->type == OBJ_STRING && in slowlogCreateEntry()
74 se->argv[j] = createObject(OBJ_STRING,s); in slowlogCreateEntry()
|
| H A D | server.c | 1377 shared.nokeyerr = createObject(OBJ_STRING,sdsnew( in createSharedObjects()
1379 shared.syntaxerr = createObject(OBJ_STRING,sdsnew( in createSharedObjects()
1387 shared.loadingerr = createObject(OBJ_STRING,sdsnew( in createSharedObjects()
1393 shared.bgsaveerr = createObject(OBJ_STRING,sdsnew( in createSharedObjects()
1395 shared.roslaveerr = createObject(OBJ_STRING,sdsnew( in createSharedObjects()
1397 shared.noautherr = createObject(OBJ_STRING,sdsnew( in createSharedObjects()
1399 shared.oomerr = createObject(OBJ_STRING,sdsnew( in createSharedObjects()
1405 shared.busykeyerr = createObject(OBJ_STRING,sdsnew( in createSharedObjects()
1416 shared.select[j] = createObject(OBJ_STRING, in createSharedObjects()
1436 shared.mbulkhdr[j] = createObject(OBJ_STRING, in createSharedObjects()
[all …]
|
| H A D | notify.c | 113 chanobj = createObject(OBJ_STRING, chan); in notifyKeyspaceEvent()
125 chanobj = createObject(OBJ_STRING, chan); in notifyKeyspaceEvent()
|
| H A D | bitops.c | 476 o = createObject(OBJ_STRING,sdsnewlen(NULL, byte+1)); in lookupStringForBitCommand()
479 if (checkType(c,o,OBJ_STRING)) return NULL; in lookupStringForBitCommand()
500 serverAssert(o->type == OBJ_STRING); in getObjectReadOnlyString()
568 checkType(c,o,OBJ_STRING)) return; in getbitCommand()
631 if (checkType(c,o,OBJ_STRING)) { in bitopCommand()
745 o = createObject(OBJ_STRING,res); in bitopCommand()
766 checkType(c,o,OBJ_STRING)) return; in bitcountCommand()
830 if (checkType(c,o,OBJ_STRING)) return; in bitposCommand()
985 if (o != NULL && checkType(c,o,OBJ_STRING)) return; in bitfieldCommand()
|
| H A D | networking.c | 47 serverAssertWithInfo(NULL,o,o->type == OBJ_STRING); in getStringObjectSdsUsedMemory()
271 listAddNodeTail(c->reply,createObject(OBJ_STRING,s)); in _addReplySdsToList()
286 listAddNodeTail(c->reply,createObject(OBJ_STRING,s)); in _addReplySdsToList()
437 listAddNodeTail(c->reply,createObject(OBJ_STRING,NULL)); in addDeferredMultiBulkLength()
1099 c->argv[c->argc] = createObject(OBJ_STRING,argv[j]); in processInlineBuffer()
1233 c->argv[c->argc++] = createObject(OBJ_STRING,c->querybuf); in processMultibulkBuffer()
|
| H A D | rdb.c | 234 return createObject(OBJ_STRING,sdsfromlonglong(val)); in rdbLoadIntegerObject()
331 return createObject(OBJ_STRING,val); in rdbLoadLzfStringObject()
527 case OBJ_STRING: in rdbSaveObjectType()
574 if (o->type == OBJ_STRING) { in rdbSaveObject()
1157 o = createObject(OBJ_STRING,encoded); /* Obj type fixed below. */ in rdbLoadObject()
|
| H A D | debug.c | 153 if (o->type == OBJ_STRING) { in computeDatasetDigest()
420 if (val->type != OBJ_STRING || !sdsEncodedObject(val)) { in debugCommand()
580 if (c->argv[j]->type == OBJ_STRING && sdsEncodedObject(c->argv[j])) { in _serverAssertPrintClientInfo()
596 if (o->type == OBJ_STRING && sdsEncodedObject(o)) { in serverLogObjectDebugInfo()
|
| H A D | geo.c | 418 robj *score = createObject(OBJ_STRING, sdsfromlonglong(bits)); in geoaddCommand()
623 robj *ele = createObject(OBJ_STRING,gp->member); in georadiusGeneric()
|
| H A D | hyperloglog.c | 1114 o = createObject(OBJ_STRING,s); in createHLLObject()
1128 if (checkType(c,o,OBJ_STRING)) in isHLLObjectOrReply()
|
| H A D | aof.c | 683 argv[j] = createObject(OBJ_STRING,argsds); in loadAppendOnlyFile()
1070 if (o->type == OBJ_STRING) { in rewriteAppendOnlyFile()
|
| H A D | db.c | 266 serverAssert(o->type == OBJ_STRING); in dbUnshareStringValue()
692 case OBJ_STRING: type = "string"; break; in typeCommand()
|
| H A D | sort.c | 119 if (o->type != OBJ_STRING) goto noobj; in lookupKeyByPattern()
|
| H A D | server.h | 192 #define OBJ_STRING 0 macro
483 _var.type = OBJ_STRING; \
|
| H A D | replication.c | 197 selectcmd = createObject(OBJ_STRING, in replicationFeedSlaves()
297 cmdobj = createObject(OBJ_STRING,cmdrepr); in replicationFeedMonitors()
|
| H A D | config.c | 1227 robj *flagsobj = createObject(OBJ_STRING,
|
| H A D | cluster.c | 3908 o = createObject(OBJ_STRING,ci); in clusterCommand()
4465 dumpobj = createObject(OBJ_STRING,payload.io.buffer.ptr); in dumpCommand()
|