Home
last modified time | relevance | path

Searched refs:OBJ_STREAM (Results 1 – 9 of 9) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dt_stream.c1064 if (o->type != OBJ_STREAM) { in streamTypeLookupWriteOrCreate()
1290 || checkType(c,o,OBJ_STREAM)) return; in xrangeGenericCommand()
1315 || checkType(c,o,OBJ_STREAM)) return; in xlenCommand()
1413 if (o && checkType(c,o,OBJ_STREAM)) goto cleanup; in xreadCommand()
1736 if (checkType(c,o,OBJ_STREAM)) return; in xgroupCommand()
1839 if (o == NULL || checkType(c,o,OBJ_STREAM)) return; in xsetidCommand()
1881 if (checkType(c,o,OBJ_STREAM)) return; /* Type error. */ in xackCommand()
1953 if (o && checkType(c,o,OBJ_STREAM)) return; in xpendingCommand()
2322 || checkType(c,o,OBJ_STREAM)) return; in xdelCommand()
2367 || checkType(c,o,OBJ_STREAM)) return; in xtrimCommand()
[all …]
H A Ddefrag.c611 if (ob->type != OBJ_STREAM || ob->encoding != OBJ_ENCODING_STREAM) { in scanLaterStraemListpacks()
740 serverAssert(ob->type == OBJ_STREAM && ob->encoding == OBJ_ENCODING_STREAM); in defragStream()
828 } else if (ob->type == OBJ_STREAM) { in defragKey()
911 } else if (ob->type == OBJ_STREAM) { in defragLaterItem()
H A Dobject.c269 robj *o = createObject(OBJ_STREAM,s); in createStreamObject()
362 case OBJ_STREAM: freeStreamObject(o); break; in decrRefCount()
867 } else if (o->type == OBJ_STREAM) { in objectComputeSize()
H A Dblocked.c375 else if (o != NULL && o->type == OBJ_STREAM) { in handleClientsBlockedOnKeys()
H A Ddb.c830 case OBJ_STREAM: type = "stream"; break; in typeCommand()
985 value->type == OBJ_STREAM || in scanDatabaseForReadyLists()
H A Drdb.c655 case OBJ_STREAM: in rdbSaveObjectType()
894 } else if (o->type == OBJ_STREAM) { in rdbSaveObject()
H A Daof.c1334 } else if (o->type == OBJ_STREAM) { in rewriteAppendOnlyFileRio()
H A Ddebug.c215 } else if (o->type == OBJ_STREAM) { in xorObjectDigest()
H A Dserver.h485 #define OBJ_STREAM 6 /* Stream object. */ macro