This is an automated email from the ASF dual-hosted git repository.
fgerlits pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
The following commit(s) were added to refs/heads/main by this push:
new 9ff2963 MINIFICPP-1482 - Fix transient failure
9ff2963 is described below
commit 9ff2963f8d513cabb45326d0b4fc9ba47a741ceb
Author: Adam Debreceni <[email protected]>
AuthorDate: Thu May 13 10:30:48 2021 +0200
MINIFICPP-1482 - Fix transient failure
Signed-off-by: Ferenc Gerlits <[email protected]>
---
extensions/http-curl/tests/C2RequestClassTest.cpp | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/extensions/http-curl/tests/C2RequestClassTest.cpp
b/extensions/http-curl/tests/C2RequestClassTest.cpp
index 9fd8ba7..7cbcc95 100644
--- a/extensions/http-curl/tests/C2RequestClassTest.cpp
+++ b/extensions/http-curl/tests/C2RequestClassTest.cpp
@@ -33,7 +33,7 @@ class C2AcknowledgeHandler : public ServerAwareHandler {
std::string req = readPayload(conn);
rapidjson::Document root;
root.Parse(req.data(), req.size());
- if (root.HasMember("operationId")) {
+ if (root.IsObject() && root.HasMember("operationId")) {
std::lock_guard<std::mutex> guard(mtx_);
acknowledged_operations_.insert(root["operationId"].GetString());
}
@@ -61,7 +61,7 @@ class C2HeartbeatHandler : public ServerAwareHandler {
rapidjson::Document root;
root.Parse(req.data(), req.size());
utils::optional<std::string> agent_class;
- if (root["agentInfo"].HasMember("agentClass")) {
+ if (root.IsObject() && root["agentInfo"].HasMember("agentClass")) {
agent_class = root["agentInfo"]["agentClass"].GetString();
}
{
