tyler.durden
/
icinga2
mirror of https://github.com/Icinga/icinga2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update sate sync 

fix a crash, possibly two
This commit is contained in:
Jean Flach 2018-11-15 10:30:41 +01:00 committed by Michael Friedrich
parent d8737b238a
commit 9b9cf6d5b0
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/redis/rediswriter-objects.cpp
View File

@ -588,6 +588,7 @@ void RedisWriter::SendStatusUpdate(const ConfigObject::Ptr& object)
Dictionary::Ptr objectAttrs = SerializeState(object);
std::vector<String> streamadd({"XADD", streamname, "*"});
ObjectLock olock(objectAttrs);
for (const Dictionary::Pair& kv : objectAttrs) {
streamadd.emplace_back(kv.first);
streamadd.emplace_back(kv.second);
@ -640,10 +641,12 @@ Dictionary::Ptr RedisWriter::SerializeState(const Object::Ptr& object)
// TODO: Is it possible there is no last checkresult?
CheckResult::Ptr cr = checkable->GetLastCheckResult();
attrs->Set("output", JsonEncode(cr->GetOutput()));
//attrs->Set("long_output", ) TODO
attrs->Set("performance_data", JsonEncode(cr->GetOutput()));
attrs->Set("command", JsonEncode(cr->GetCommand()));
if (cr) {
attrs->Set("output", JsonEncode(cr->GetOutput()));
//attrs->Set("long_output", ) TODO
attrs->Set("performance_data", JsonEncode(cr->GetOutput()));
attrs->Set("command", JsonEncode(cr->GetCommand()));
}
//attrs->Set("is_problem", !checkable->IsReachable() && !checkable->IsAcknowledged()); TODO
//attrs->Set("is_handled"); TODO
attrs->Set("is_flapping", checkable->IsFlapping());