Skip to content
GitLab
Menu
Projects
Groups
Snippets
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
Menu
Open sidebar
ruanhaishen
redis
Commits
8a1219d9
Commit
8a1219d9
authored
Aug 14, 2018
by
zhaozhao.zz
Browse files
block: rewrite BRPOPLPUSH as RPOPLPUSH to propagate
parent
39c70e72
Changes
3
Hide whitespace changes
Inline
Side-by-side
src/server.c
View file @
8a1219d9
...
...
@@ -1491,6 +1491,7 @@ void createSharedObjects(void) {
shared
.
rpop
=
createStringObject
(
"RPOP"
,
4
);
shared
.
lpop
=
createStringObject
(
"LPOP"
,
4
);
shared
.
lpush
=
createStringObject
(
"LPUSH"
,
5
);
shared
.
rpoplpush
=
createStringObject
(
"RPOPLPUSH"
,
9
);
shared
.
zpopmin
=
createStringObject
(
"ZPOPMIN"
,
7
);
shared
.
zpopmax
=
createStringObject
(
"ZPOPMAX"
,
7
);
for
(
j
=
0
;
j
<
OBJ_SHARED_INTEGERS
;
j
++
)
{
...
...
src/server.h
View file @
8a1219d9
...
...
@@ -781,7 +781,7 @@ struct sharedObjectsStruct {
*
masterdownerr
,
*
roslaveerr
,
*
execaborterr
,
*
noautherr
,
*
noreplicaserr
,
*
busykeyerr
,
*
oomerr
,
*
plus
,
*
messagebulk
,
*
pmessagebulk
,
*
subscribebulk
,
*
unsubscribebulk
,
*
psubscribebulk
,
*
punsubscribebulk
,
*
del
,
*
unlink
,
*
rpop
,
*
lpop
,
*
lpush
,
*
zpopmin
,
*
zpopmax
,
*
emptyscan
,
*
rpop
,
*
lpop
,
*
lpush
,
*
rpoplpush
,
*
zpopmin
,
*
zpopmax
,
*
emptyscan
,
*
select
[
PROTO_SHARED_SELECT_CMDS
],
*
integers
[
OBJ_SHARED_INTEGERS
],
*
mbulkhdr
[
OBJ_SHARED_BULKHDR_LEN
],
/* "*<value>\r\n" */
...
...
src/t_list.c
View file @
8a1219d9
...
...
@@ -596,6 +596,9 @@ void rpoplpushCommand(client *c) {
signalModifiedKey
(
c
->
db
,
touchedkey
);
decrRefCount
(
touchedkey
);
server
.
dirty
++
;
if
(
c
->
lastcmd
->
proc
==
brpoplpushCommand
)
{
rewriteClientCommandVector
(
c
,
3
,
shared
.
rpoplpush
,
c
->
argv
[
1
],
c
->
argv
[
2
]);
}
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment