Home
last modified time | relevance | path

Searched refs:streamID (Results 1 – 10 of 10) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dstream.h11 typedef struct streamID { struct
14 } streamID; typedef
19 streamID last_id; /* Zero if there are yet no items. */
31 streamID master_id; /* ID of the master entry at listpack head. */
52 streamID last_id; /* Last delivered (not acknowledged) ID for this
101 size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end, size_t count, int…
102 void streamIteratorStart(streamIterator *si, stream *s, streamID *start, streamID *end, int rev);
103 int streamIteratorGetID(streamIterator *si, streamID *id, int64_t *numfields);
108 streamCG *streamCreateCG(stream *s, char *name, size_t namelen, streamID *id);
110 void streamDecodeID(void *buf, streamID *id);
[all …]
H A Dt_stream.c74 void streamNextID(streamID *last_id, streamID *new_id) { in streamNextID()
153 int streamCompareID(streamID *a, streamID *b) { in streamCompareID()
196 streamID id; in streamAppendItem()
766 streamID myid; in streamDeleteItem()
903 streamID id; in streamReplyWithRange()
1168 streamID id; in xaddCommand()
1767 streamID id; in xgroupCommand()
1798 streamID id; in xgroupCommand()
1842 streamID id; in xsetidCommand()
1893 streamID id; in xackCommand()
[all …]
H A Dblocked.c391 streamID *gt = dictFetchValue(receiver->bpop.keys, in handleClientsBlockedOnKeys()
421 streamID start = *gt; in handleClientsBlockedOnKeys()
497 …ys(client *c, int btype, robj **keys, int numkeys, mstime_t timeout, robj *target, streamID *ids) { in blockForKeys()
512 key_data = zmalloc(sizeof(streamID)); in blockForKeys()
513 memcpy(key_data,ids+j,sizeof(streamID)); in blockForKeys()
H A Drdb.c695 if ((n = rdbWriteRaw(rdb,ri.key,sizeof(streamID))) == -1) return -1; in rdbSaveStreamPEL()
1652 if (sdslen(nodekey) != sizeof(streamID)) { in rdbLoadObject()
1671 (unsigned char*)nodekey,sizeof(streamID),lp,NULL); in rdbLoadObject()
1688 streamID cg_id; in rdbLoadObject()
1709 unsigned char rawid[sizeof(streamID)]; in rdbLoadObject()
1737 unsigned char rawid[sizeof(streamID)]; in rdbLoadObject()
H A Daof.c1126 int rioWriteBulkStreamID(rio *r,streamID *id) { in rioWriteBulkStreamID()
1142 streamID id; in rioWriteStreamPendingEntry()
1166 streamID id; in rewriteStreamObject()
H A Ddefrag.c608 static unsigned char last[sizeof(streamID)]; in scanLaterStraemListpacks()
H A Dobject.c768 size = rax->numele * sizeof(streamID); in streamRadixTreeMemoryUsage()
H A Ddebug.c218 streamID id; in xorObjectDigest()
H A Dserver.h1914 …eys(client *c, int btype, robj **keys, int numkeys, mstime_t timeout, robj *target, streamID *ids);
/f-stack/app/redis-5.0.5/
H A D00-RELEASENOTES1083 Streams: panic if streamID invalid after check, should not be possible.