Skip to content

Commit

Permalink
removing unwanted loc
Browse files Browse the repository at this point in the history
  • Loading branch information
a00817524 committed Nov 8, 2023
1 parent b7ae81d commit 0eca302
Showing 1 changed file with 0 additions and 8 deletions.
8 changes: 0 additions & 8 deletions src/db.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3072,8 +3072,6 @@ void redisDbPersistentData::bulkDirectStorageInsert(char **rgKeys, size_t *rgcbK

void redisDbPersistentData::commitChanges(const redisDbPersistentDataSnapshot **psnapshotFree)
{

std::unordered_set<client *> setcBlocked;
if (m_pdbSnapshotStorageFlush)
{
dictIterator *di = dictGetIterator(m_dictChangedStorageFlush);
Expand All @@ -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;
}
Expand Down

0 comments on commit 0eca302

Please sign in to comment.