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

1. update node size in set processor.

Browse Source
This commit is contained in:
zhanglistar 2021-12-11 22:24:59 +08:00
parent de3aad085d
commit 2af221df18
1 changed files with 1 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/Coordination/KeeperStorage.cpp
View File

@ -133,21 +133,6 @@ static bool fixupACL(
return valid_found; return valid_found;
} }
//uint64_t KeeperStorage::Node::sizeInBytes() const
//{
// uint64_t total_size{0};
// for (const auto & child : children)
// total_size += child.size();
//
// total_size += data.size();
//
// total_size += sizeof(acl_id);
// total_size += sizeof(is_sequental);
// total_size += sizeof(stat);
// total_size += sizeof(seq_num);
// return total_size;
//}
static KeeperStorage::ResponsesForSessions processWatchesImpl(const String & path, KeeperStorage::Watches & watches, KeeperStorage::Watches & list_watches, Coordination::Event event_type) static KeeperStorage::ResponsesForSessions processWatchesImpl(const String & path, KeeperStorage::Watches & watches, KeeperStorage::Watches & list_watches, Coordination::Event event_type)
{ {
KeeperStorage::ResponsesForSessions result; KeeperStorage::ResponsesForSessions result;
@ -625,11 +610,11 @@ struct KeeperStorageSetRequestProcessor final : public KeeperStorageRequestProce
auto itr = container.updateValue(request.path, [zxid, request] (KeeperStorage::Node & value) auto itr = container.updateValue(request.path, [zxid, request] (KeeperStorage::Node & value)
{ {
value.data = request.data;
value.stat.version++; value.stat.version++;
value.stat.mzxid = zxid; value.stat.mzxid = zxid;
value.stat.mtime = std::chrono::system_clock::now().time_since_epoch() / std::chrono::milliseconds(1); value.stat.mtime = std::chrono::system_clock::now().time_since_epoch() / std::chrono::milliseconds(1);
value.stat.dataLength = request.data.length(); value.stat.dataLength = request.data.length();
value.size_bytes += request.data.size() - value.data.size();
value.data = request.data; value.data = request.data;
}); });