Commit 491682a6 authored by dejun.xdj's avatar dejun.xdj
Browse files

Streams: using streamCompareID() instead of direct compare in block.c.

parent a2177cd2
...@@ -397,10 +397,7 @@ void handleClientsBlockedOnKeys(void) { ...@@ -397,10 +397,7 @@ void handleClientsBlockedOnKeys(void) {
} }
} }
if (s->last_id.ms > gt->ms || if (streamCompareID(&s->last_id, gt) > 0) {
(s->last_id.ms == gt->ms &&
s->last_id.seq > gt->seq))
{
streamID start = *gt; streamID start = *gt;
start.seq++; /* Can't overflow, it's an uint64_t */ start.seq++; /* Can't overflow, it's an uint64_t */
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment