Home
last modified time | relevance | path

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

/dports/databases/redis5/redis-5.0.14/src/
H A Dt_stream.c974 int propagate_last_id = 0; in streamReplyWithRange() local
993 propagate_last_id = 1; in streamReplyWithRange()
1058 if (propagate_last_id) in streamReplyWithRange()
2263 int propagate_last_id = 0; in xclaimCommand() local
2298 propagate_last_id = 1; in xclaimCommand()
2395 propagate_last_id = 0; /* Will be propagated by XCLAIM itself. */ in xclaimCommand()
2399 if (propagate_last_id) { in xclaimCommand()
/dports/databases/redis6/redis-6.0.16/src/
H A Dt_stream.c974 int propagate_last_id = 0; in streamReplyWithRange() local
997 if (noack) propagate_last_id = 1; in streamReplyWithRange()
1068 if (spi && propagate_last_id) in streamReplyWithRange()
2269 int propagate_last_id = 0; in xclaimCommand() local
2304 propagate_last_id = 1; in xclaimCommand()
2401 propagate_last_id = 0; /* Will be propagated by XCLAIM itself. */ in xclaimCommand()
2405 if (propagate_last_id) { in xclaimCommand()
/dports/databases/redis-devel/redis-0e5b813/src/
H A Dt_stream.c1511 int propagate_last_id = 0; in streamReplyWithRange() local
1534 if (noack) propagate_last_id = 1; in streamReplyWithRange()
1605 if (spi && propagate_last_id) in streamReplyWithRange()
2925 int propagate_last_id = 0; in xclaimCommand() local
2960 propagate_last_id = 1; in xclaimCommand()
3062 propagate_last_id = 0; /* Will be propagated by XCLAIM itself. */ in xclaimCommand()
3066 if (propagate_last_id) { in xclaimCommand()
/dports/databases/redis5/redis-5.0.14/
H A D00-RELEASENOTES1628 Streams: use propagate_last_id itself as streamPropagateGroupID trigger.
1632 Streams: better naming: lastid_updated -> propagate_last_id.