Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
H A Dstream.h83 mstime_t delivery_time; /* Last time this message was delivered. */ member
H A Dt_stream.c810 argv[7] = createStringObjectFromLongLong(nack->delivery_time); in streamPropagateXCLAIM()
973 nack->delivery_time = mstime(); in streamReplyWithRange()
1042 nack->delivery_time = mstime(); in streamReplyWithRangeFromConsumerPEL()
1594 nack->delivery_time = mstime(); in streamCreateNACK()
2049 mstime_t elapsed = now - nack->delivery_time; in xpendingCommand()
2268 mstime_t this_idle = now - nack->delivery_time; in xclaimCommand()
2278 nack->delivery_time = deliverytime; in xclaimCommand()
H A Drdb.c700 if ((n = rdbSaveMillisecondTime(rdb,nack->delivery_time)) == -1) in rdbSaveStreamPEL()
1712 nack->delivery_time = rdbLoadMillisecondTime(rdb,RDB_VERSION); in rdbLoadObject()
H A Daof.c1152 if (rioWriteBulkLongLong(r,nack->delivery_time) == 0) return 0; in rioWriteStreamPendingEntry()