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

Add disconnect

This commit is contained in:
Jean Flach 2018-10-17 14:33:57 +02:00 committed by Michael Friedrich
parent d96dcf869e
commit 64515b81e3
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/redis/redisconnection.cpp
View File

@ -23,6 +23,7 @@
#include <hiredis/hiredis.h> #include <hiredis/hiredis.h>
#include <base/logger.hpp> #include <base/logger.hpp>
#include "base/utility.hpp" #include "base/utility.hpp"
#include "redis/rediswriter.hpp"
using namespace icinga; using namespace icinga;
/* /*
@ -80,9 +81,14 @@ void RedisConnection::Connect() {
//TODO: Authentication, DB selection, error handling //TODO: Authentication, DB selection, error handling
} }
void RedisConnection::Disconnect()
{
redisAsyncDisconnect(m_Context);
}
void RedisConnection::DisconnectCallback(const redisAsyncContext *c, int status) { void RedisConnection::DisconnectCallback(const redisAsyncContext *c, int status) {
if (status == REDIS_OK) if (status == REDIS_OK)
Log(LogCritical, "RedisWriter") << "Redis disconnected by user"; Log(LogInformation, "RedisWriter") << "Redis disconnected by us";
else else
Log(LogCritical, "Rediswriter") << "Redis disconnected for reasons"; Log(LogCritical, "Rediswriter") << "Redis disconnected for reasons";

5
lib/redis/redisconnection.hpp
View File

@ -40,9 +40,10 @@ public:
void Start(); void Start();
void Connect(); void Connect();
void Disconnect();
void ExecuteQuery(const std::vector<String>& query, redisCallbackFn *fn = nullptr, void *privdata = nullptr); void ExecuteQuery(const std::vector<String>& query, redisCallbackFn *fn = NULL, void *privdata = NULL);
void ExecuteQueries(const std::vector<std::vector<String> >& queries, redisCallbackFn *fn = nullptr, void *privdata = nullptr); void ExecuteQueries(const std::vector<std::vector<String> >& queries, redisCallbackFn *fn = NULL, void *privdata = NULL);
private: private: