From 491682a668dc5eeffdb6c989b819c1015c97b4f0 Mon Sep 17 00:00:00 2001
From: "dejun.xdj" <dejun.xdj@alibaba-inc.com>
Date: Sat, 14 Jul 2018 15:03:05 +0800
Subject: [PATCH] Streams: using streamCompareID() instead of direct compare in
 block.c.

---
 src/blocked.c | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/src/blocked.c b/src/blocked.c
index d8ae596d9..4a667501f 100644
--- a/src/blocked.c
+++ b/src/blocked.c
@@ -397,10 +397,7 @@ void handleClientsBlockedOnKeys(void) {
                             }
                         }
 
-                        if (s->last_id.ms > gt->ms ||
-                            (s->last_id.ms == gt->ms &&
-                             s->last_id.seq > gt->seq))
-                        {
+                        if (streamCompareID(&s->last_id, gt) > 0) {
                             streamID start = *gt;
                             start.seq++; /* Can't overflow, it's an uint64_t */