summaryrefslogtreecommitdiff
path: root/src/blocked.c
Commit message (Expand)AuthorAgeFilesLines
* 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
* Streams: XREAD ability to block fixed.antirez2017-12-011-2/+2
* Streams: augment client.bpop with XREAD specific fields.antirez2017-12-011-0/+4
* Streams: more internal preparation for blocking XREAD.antirez2017-12-011-9/+25
* Streams: initial work to use blocking lists logic for streams XREAD.antirez2017-12-011-0/+208
* Module: API to block clients with threading support.antirez2016-10-071-1/+6
* RDMF: More consistent define names.antirez2015-07-271-20/+20
* RDMF: REDIS_OK REDIS_ERR -> C_OK C_ERR.antirez2015-07-261-4/+4
* RDMF: redisAssert -> serverAssert.antirez2015-07-261-1/+1
* RDMF: use client instead of redisClient, like Disque.antirez2015-07-261-6/+6
* RDMF (Redis/Disque merge friendlyness) refactoring WIP 1.antirez2015-07-261-1/+1
* Substitute DISQUE to REDIS after merge from Disqueantirez2015-05-051-1/+1
* processUnblockedClients: don't process clients that blocekd againantirez2015-05-051-3/+8
* Don't put clients into unblocked list multiple timesantirez2015-05-051-2/+6
* Replication: disconnect blocked clients when switching to slave role.antirez2015-03-241-0/+24
* Cluster: redirection refactoring + handling of blocked clients.antirez2015-03-241-0/+2
* Net: processUnblockedClients() and clientsArePaused() minor changes.antirez2015-03-211-1/+0
* server.current_client fix and minor refactoring.antirez2015-02-271-2/+0
* WAIT command: synchronous replication for Redis.antirez2013-12-041-0/+4
* blocked.c API commented.antirez2013-12-031-0/+33
* BLPOP blocking code refactored to be generic & reusable.antirez2013-12-031-0/+121