|
|
|
|
@ -79,7 +79,7 @@ static SCLogRedisContext *SCLogRedisContextAlloc(void)
|
|
|
|
|
static int SCConfLogReopenAsyncRedis(LogFileCtx *log_ctx);
|
|
|
|
|
#include <hiredis/adapters/libevent.h>
|
|
|
|
|
|
|
|
|
|
/** \brief SCLogRedisAsyncContextAlloc() - Allocates and initalizes redis context with async
|
|
|
|
|
/** \brief SCLogRedisAsyncContextAlloc() - Allocates and initializes redis context with async
|
|
|
|
|
*/
|
|
|
|
|
static SCLogRedisContext *SCLogRedisContextAsyncAlloc(void)
|
|
|
|
|
{
|
|
|
|
|
@ -102,7 +102,7 @@ static SCLogRedisContext *SCLogRedisContextAsyncAlloc(void)
|
|
|
|
|
/** \brief SCRedisAsyncCommandCallback() Callback when reply from redis happens.
|
|
|
|
|
* \param ac redis async context
|
|
|
|
|
* \param r redis reply
|
|
|
|
|
* \param privvata opaque datq with pointer to LogFileCtx
|
|
|
|
|
* \param privdata opaque data with pointer to LogFileCtx
|
|
|
|
|
*/
|
|
|
|
|
static void SCRedisAsyncCommandCallback(redisAsyncContext *ac, void *r, void *privdata)
|
|
|
|
|
{
|
|
|
|
|
@ -124,7 +124,7 @@ static void SCRedisAsyncCommandCallback(redisAsyncContext *ac, void *r, void *pr
|
|
|
|
|
* This is used to check if redis is connected.
|
|
|
|
|
* \param ac redis async context
|
|
|
|
|
* \param r redis reply
|
|
|
|
|
* \param privvata opaque datq with pointer to LogFileCtx
|
|
|
|
|
* \param privdata opaque data with pointer to LogFileCtx
|
|
|
|
|
*/
|
|
|
|
|
static void SCRedisAsyncEchoCommandCallback(redisAsyncContext *ac, void *r, void *privdata)
|
|
|
|
|
{
|
|
|
|
|
@ -162,7 +162,7 @@ static void SCLogAsyncRedisSendEcho(SCLogRedisContext * ctx)
|
|
|
|
|
* This is used to terminate connection with redis.
|
|
|
|
|
* \param ac redis async context
|
|
|
|
|
* \param r redis reply
|
|
|
|
|
* \param privvata opaque datq with pointer to LogFileCtx
|
|
|
|
|
* \param privdata opaque data with pointer to LogFileCtx
|
|
|
|
|
*/
|
|
|
|
|
static void SCRedisAsyncQuitCommandCallback(redisAsyncContext *ac, void *r, void *privdata)
|
|
|
|
|
{
|
|
|
|
|
|