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

Set path in response

Browse Source
This commit is contained in:
Antonio Andelic 2023-09-26 07:41:05 +00:00
parent ce583cb7fe
commit 01f64be558
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Coordination/KeeperStorage.cpp
View File

@ -956,6 +956,9 @@ struct KeeperStorageCreateRequestProcessor final : public KeeperStorageRequestPr
std::string path_created = request.path;
if (request.is_sequential)
{
if (request.not_exists)
return {KeeperStorage::Delta{zxid, Coordination::Error::ZBADARGUMENTS}};
auto seq_num = parent_node->seq_num;
std::stringstream seq_num_str; // STYLE_CHECK_ALLOW_STD_STRING_STREAM
@ -1037,7 +1040,11 @@ struct KeeperStorageCreateRequestProcessor final : public KeeperStorageRequestPr
Coordination::ZooKeeperCreateResponse & response = dynamic_cast<Coordination::ZooKeeperCreateResponse &>(*response_ptr);
if (storage.uncommitted_state.deltas.begin()->zxid != zxid)
{
response.path_created = zk_request->getPath();
response.error = Coordination::Error::ZOK;
return response_ptr;
}
if (const auto result = storage.commit(zxid); result != Coordination::Error::ZOK)
{