thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-25 00:52:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Slightly better

Browse Source
This commit is contained in:
alesapin 2021-05-27 11:15:46 +03:00
parent d1338230f4
commit 4d59590b7f
1 changed files with 22 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/Coordination/KeeperStorage.cpp
View File

@ -109,6 +109,7 @@ static bool fixupACL(
}
else if (request_acl.scheme == "world" && request_acl.id == "anyone")
{
/// We don't need to save default ACLs
valid_found = true;
}
else if (request_acl.scheme == "digest")
@ -226,6 +227,9 @@ struct KeeperStorageCreateRequest final : public KeeperStorageRequest
return true;
const auto & node_acls = it->value.acls;
if (node_acls.empty())
return true;
const auto & session_auths = storage.session_and_auth[session_id];
return checkACL(Coordination::ACL::Create, node_acls, session_auths);
}
@ -342,6 +346,9 @@ struct KeeperStorageGetRequest final : public KeeperStorageRequest
return true;
const auto & node_acls = it->value.acls;
if (node_acls.empty())
return true;
const auto & session_auths = storage.session_and_auth[session_id];
return checkACL(Coordination::ACL::Read, node_acls, session_auths);
}
@ -380,6 +387,9 @@ struct KeeperStorageRemoveRequest final : public KeeperStorageRequest
return true;
const auto & node_acls = it->value.acls;
if (node_acls.empty())
return true;
const auto & session_auths = storage.session_and_auth[session_id];
return checkACL(Coordination::ACL::Delete, node_acls, session_auths);
}
@ -491,6 +501,9 @@ struct KeeperStorageSetRequest final : public KeeperStorageRequest
return true;
const auto & node_acls = it->value.acls;
if (node_acls.empty())
return true;
const auto & session_auths = storage.session_and_auth[session_id];
return checkACL(Coordination::ACL::Write, node_acls, session_auths);
}
@ -565,6 +578,9 @@ struct KeeperStorageListRequest final : public KeeperStorageRequest
return true;
const auto & node_acls = it->value.acls;
if (node_acls.empty())
return true;
const auto & session_auths = storage.session_and_auth[session_id];
return checkACL(Coordination::ACL::Read, node_acls, session_auths);
}
@ -607,6 +623,9 @@ struct KeeperStorageCheckRequest final : public KeeperStorageRequest
return true;
const auto & node_acls = it->value.acls;
if (node_acls.empty())
return true;
const auto & session_auths = storage.session_and_auth[session_id];
return checkACL(Coordination::ACL::Read, node_acls, session_auths);
}
@ -898,6 +917,9 @@ KeeperStorage::ResponsesForSessions KeeperStorage::processRequest(const Coordina
ephemerals.erase(it);
}
clearDeadWatches(session_id);
auto auth_it = session_and_auth.find(session_id);
if (auth_it != session_and_auth.end())
session_and_auth.erase(auth_it);
/// Finish connection
auto response = std::make_shared<Coordination::ZooKeeperCloseResponse>();