From 0eca302c75912a27406e948998ba93146c636d05 Mon Sep 17 00:00:00 2001 From: a00817524 Date: Wed, 8 Nov 2023 20:15:56 +0000 Subject: [PATCH] removing unwanted loc --- src/db.cpp | 8 -------- 1 file changed, 8 deletions(-) diff --git a/src/db.cpp b/src/db.cpp index a20ea0a3f..383637454 100644 --- a/src/db.cpp +++ b/src/db.cpp @@ -3072,8 +3072,6 @@ void redisDbPersistentData::bulkDirectStorageInsert(char **rgKeys, size_t *rgcbK void redisDbPersistentData::commitChanges(const redisDbPersistentDataSnapshot **psnapshotFree) { - - std::unordered_set setcBlocked; if (m_pdbSnapshotStorageFlush) { dictIterator *di = dictGetIterator(m_dictChangedStorageFlush); @@ -3094,12 +3092,6 @@ void redisDbPersistentData::commitChanges(const redisDbPersistentDataSnapshot ** auto *tok = m_spstorage->begin_endWriteBatch(serverTL->el, storageLoadCallback); if (tok != nullptr) { - for (client *c : setcBlocked) //need to check how to push client to blocked list - { - if (!(c->flags & CLIENT_BLOCKED)) - blockClient(c, BLOCKED_STORAGE); - } - // tok->setc = std::move(setcBlocked); tok->db = this; tok->type = StorageToken::TokenType::BatchWrite; }