tracking pending invalidation message of flushdb sent by (#11068)

trackingHandlePendingKeyInvalidations should use proto.

1 files changed, 11 insertions, 5 deletions

diff --git a/src/tracking.c b/src/tracking.c
index c98421edb..7dc025068 100644
--- a/src/tracking.c
+++ b/src/tracking.c
@@ -423,9 +423,15 @@ void trackingHandlePendingKeyInvalidations() {
         robj *key = listNodeValue(ln);
         /* current_client maybe freed, so we need to send invalidation
          * message only when current_client is still alive */
-        if (server.current_client != NULL)
-            sendTrackingMessage(server.current_client,(char *)key->ptr,sdslen(key->ptr),0);
-        decrRefCount(key);
+        if (server.current_client != NULL) {
+            if (key != NULL) {
+                sendTrackingMessage(server.current_client,(char *)key->ptr,sdslen(key->ptr),0);
+            } else {
+                sendTrackingMessage(server.current_client,shared.null[server.current_client->resp]->ptr,
+                    sdslen(shared.null[server.current_client->resp]->ptr),1);
+            }
+        }
+        if (key != NULL) decrRefCount(key);
     }
     listEmpty(server.tracking_pending_keys);
 }
@@ -455,8 +461,8 @@ void trackingInvalidateKeysOnFlush(int async) {
             client *c = listNodeValue(ln);
             if (c->flags & CLIENT_TRACKING) {
                 if (c == server.current_client) {
-                    incrRefCount(shared.null[c->resp]);
-                    listAddNodeTail(server.tracking_pending_keys,shared.null[c->resp]);
+                    /* We use a special NULL to indicate that we should send null */
+                    listAddNodeTail(server.tracking_pending_keys,NULL);
                 } else {
                     sendTrackingMessage(c,shared.null[c->resp]->ptr,sdslen(shared.null[c->resp]->ptr),1);
                 }