summaryrefslogtreecommitdiff
path: root/src/blocked.c
Commit message (Expand)AuthorAgeFilesLines
* Speedup: unblock clients on keys in O(1).o1-bpopantirez2020-04-081-18/+30
* timeout.c created: move client timeouts code there.antirez2020-03-271-39/+0
* Precise timeouts: cleaup the table on unblock.antirez2020-03-271-0/+1
* Precise timeouts: use only radix tree for timeouts.antirez2020-03-271-1/+1
* Precise timeouts: fix bugs in initial implementation.antirez2020-03-271-1/+1
* Precise timeouts: working initial implementation.antirez2020-03-271-0/+1
* Stream: Handle streamID-related edge casesGuy Benoish2019-12-261-1/+1
* Rename var to fixed_time_expire now that is more general.antirez2019-11-191-3/+2
* Fix patch provided in #6554.antirez2019-11-191-1/+8
* expires & blocking: handle ready keys as call()zhaozhao.zz2019-11-081-0/+5
* Modules: block on keys: fix stale comment.module-block-on-keysantirez2019-10-311-2/+3
* Modules: block on keys: fix bugs in processing order.antirez2019-10-311-0/+16
* Modules: block on keys: use a better interface.antirez2019-10-311-1/+2
* Modules: block on keys: implement the internals.antirez2019-10-301-0/+30
* handleClientsBlockedOnKeys() refactoring.antirez2019-09-061-195/+208
* Fix handleClientsBlockedOnKeys() names in comments.antirez2019-09-051-1/+1
* Merge pull request #2774 from rouzier/blocking-list-commands-support-millisec...Salvatore Sanfilippo2019-03-121-4/+11
|\
| * If the unit of a timeout is seconds treat it a floatJames Rouzier2016-02-231-4/+11
* | RESP3: t_stream.c updated.antirez2019-01-091-2/+6
* | RESP3: restore the concept of null array for RESP2 compat.antirez2019-01-091-1/+1
* | RESP3: blocked.c updated.antirez2019-01-091-3/+3
* | Slave removal: blocked.c logs fixed.antirez2018-09-111-1/+1
* | Unblocked clients API refactoring. See #4418.antirez2018-09-031-6/+26
* | Make pending buffer processing safe for CLIENT_MASTER client.antirez2018-09-031-1/+1
* | block: format codezhaozhao.zz2018-08-141-2/+2
* | Streams: using streamCompareID() instead of direct compare in block.c.dejun.xdj2018-07-141-4/+1
* | Merge branch 'unstable' of github.com:/antirez/redis into unstableantirez2018-07-101-1/+4
|\ \
| * | Bugfix: PEL is incorrect when consumer is blocked using xreadgroup with NOACK...dejun.xdj2018-07-091-1/+3
* | | Streams: fix typo "consumer".antirez2018-07-101-1/+1
* | | Streams: send an error to consumers blocked on non-existing group.antirez2018-07-101-1/+5
* | | Streams: fix unblocking logic into a consumer group.antirez2018-07-101-14/+24
|/ /
* | Fix client unblocking for XREADGROUP, issue #4978.antirez2018-06-111-6/+6
* | ZPOP: unblock multiple clients in right wayzhaozhao.zz2018-05-311-1/+3
* | ZPOP: fix replication of blocking ZPOP.antirez2018-05-151-4/+12
* | ZPOP: change sync ZPOP to have a count argument instead of N keys.antirez2018-05-111-1/+1
* | ZPOP: renaming to have explicit MIN/MAX score idea.antirez2018-05-111-9/+20
* | Implements [B]Z[REV]POP and the respective unit testsItamar Haber2018-04-301-14/+56
* | Merge pull request #4781 from guybe7/block_list_notifySalvatore Sanfilippo2018-03-221-0/+1
|\ \
| * | Make blocking list commands send keyspace notificationsGuy Benoish2018-03-221-0/+1
* | | CG: Replication WIP 1: XREADGROUP and XCLAIM propagated as XCLAIM.antirez2018-03-191-1/+6
* | | CG: XPENDING should not create consumers and obey to count.antirez2018-03-151-1/+2
* | | CG: Now XREADGROUP + blocking operations work.antirez2018-03-151-4/+26
* | | CG: creation of NACK entries in PELs.antirez2018-03-151-2/+1
* | | CG: consumer lookup + initial streamReplyWithRange() work to supprot CG.antirez2018-03-151-1/+3
* | | CG: add & populate group+consumer in the blocking state.antirez2018-03-151-0/+2
|/ /
* | Streams: state machine for reverse iteration WIP 1.antirez2017-12-011-1/+1
* | Streams: fixed memory leaks when blocking again for same stream.antirez2017-12-011-1/+4
* | Streams: fix handleClientsBlockedOnKeys() access to invalid ID.antirez2017-12-011-1/+4
* | Streams: fix XREAD ready-key signaling.antirez2017-12-011-2/+4
* | Streams: XREAD related code to serve blocked clients.antirez2017-12-011-1/+49