Searched refs:delivery_count (Results 1 – 4 of 4) sorted by relevance
84 uint64_t delivery_count; /* Number of times this message was delivered.*/ member
812 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()
703 if ((n = rdbSaveLen(rdb,nack->delivery_count)) == -1) return -1; in rdbSaveStreamPEL()1713 nack->delivery_count = rdbLoadLen(rdb,NULL); in rdbLoadObject()
1154 if (rioWriteBulkLongLong(r,nack->delivery_count) == 0) return 0; in rioWriteStreamPendingEntry()