Home
last modified time | relevance | path

Searched refs:delivery_count (Results 1 – 4 of 4) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dstream.h84 uint64_t delivery_count; /* Number of times this message was delivered.*/ member
H A Dt_stream.c812 argv[9] = createStringObjectFromLongLong(nack->delivery_count); in streamPropagateXCLAIM()
974 nack->delivery_count = 1; in streamReplyWithRange()
1043 nack->delivery_count++; in streamReplyWithRangeFromConsumerPEL()
1595 nack->delivery_count = 1; in streamCreateNACK()
2054 addReplyLongLong(c,nack->delivery_count); in xpendingCommand()
2282 nack->delivery_count = retrycount; in xclaimCommand()
2284 nack->delivery_count++; in xclaimCommand()
H A Drdb.c703 if ((n = rdbSaveLen(rdb,nack->delivery_count)) == -1) return -1; in rdbSaveStreamPEL()
1713 nack->delivery_count = rdbLoadLen(rdb,NULL); in rdbLoadObject()
H A Daof.c1154 if (rioWriteBulkLongLong(r,nack->delivery_count) == 0) return 0; in rioWriteStreamPendingEntry()