tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix cleanup in case of failure

Browse Source
This commit is contained in:
János Benjamin Antal 2022-01-24 10:30:30 +01:00
parent 9b7801379c
commit 4ae1202a68
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/query/stream/streams.cpp
View File

@ -263,13 +263,12 @@ void Streams::RegisterKafkaProcedures() {
procedure::MgpUniquePtr<mgp_value> topics_value{nullptr, mgp_value_destroy};
{
const auto success = procedure::TryOrSetError(
[&] {
return procedure::CreateMgpObject(topics_value, mgp_value_make_list, topic_names.release());
},
[&] { return procedure::CreateMgpObject(topics_value, mgp_value_make_list, topic_names.get()); },
result);
if (!success) {
return;
}
static_cast<void>(topic_names.release());
}
const auto bootstrap_servers_value =
@ -301,13 +300,12 @@ void Streams::RegisterKafkaProcedures() {
{
const auto success = procedure::TryOrSetError(
[&] {
return procedure::CreateMgpObject(configs_value, mgp_value_make_map, configs.release());
},
[&] { return procedure::CreateMgpObject(configs_value, mgp_value_make_map, configs.get()); },
result);
if (!success) {
return configs_value;
}
static_cast<void>(configs.release());
}
return configs_value;
};