mirror of https://github.com/Icinga/icinga2.git
parent
62c1a64788
commit
dd7862f08a
|
@ -146,6 +146,8 @@ void RedisWriter::UpdateSubscriptions(void)
|
||||||
Log(LogInformation, "RedisWriter")
|
Log(LogInformation, "RedisWriter")
|
||||||
<< "SCAN " << cursor << " MATCH icinga:subscription:* COUNT 1000: " << reply->str;
|
<< "SCAN " << cursor << " MATCH icinga:subscription:* COUNT 1000: " << reply->str;
|
||||||
|
|
||||||
|
freeReplyObject(reply);
|
||||||
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -174,6 +176,8 @@ void RedisWriter::UpdateSubscriptions(void)
|
||||||
Log(LogInformation, "RedisWriter")
|
Log(LogInformation, "RedisWriter")
|
||||||
<< "GET " << keyReply->str << ": " << vreply->str;
|
<< "GET " << keyReply->str << ": " << vreply->str;
|
||||||
|
|
||||||
|
freeReplyObject(vreply);
|
||||||
|
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -282,6 +286,8 @@ void RedisWriter::HandleEvent(const Dictionary::Ptr& event)
|
||||||
Log(LogInformation, "RedisWriter")
|
Log(LogInformation, "RedisWriter")
|
||||||
<< "LPUSH icinga:event:" << kv.first << " " << body << ": " << reply->str;
|
<< "LPUSH icinga:event:" << kv.first << " " << body << ": " << reply->str;
|
||||||
|
|
||||||
|
freeReplyObject(reply);
|
||||||
|
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue