From bb3475e8eb379ee18f3d8f37caa8040b852a6213 Mon Sep 17 00:00:00 2001 From: "Anna (navi) Figueiredo Gomes" Date: Sat, 23 Mar 2024 01:21:46 +0100 Subject: all: rename redis -> redict symbols and comments Signed-off-by: Anna (navi) Figueiredo Gomes --- adapters/libev.h | 94 ++++++++++++++++++++++++++++---------------------------- 1 file changed, 47 insertions(+), 47 deletions(-) (limited to 'adapters/libev.h') diff --git a/adapters/libev.h b/adapters/libev.h index 265e642..9aa841e 100644 --- a/adapters/libev.h +++ b/adapters/libev.h @@ -11,44 +11,44 @@ * */ -#ifndef __HIREDIS_LIBEV_H__ -#define __HIREDIS_LIBEV_H__ +#ifndef __HIREDICT_LIBEV_H__ +#define __HIREDICT_LIBEV_H__ #include #include #include #include "../hiredict.h" #include "../async.h" -typedef struct redisLibevEvents { - redisAsyncContext *context; +typedef struct redictLibevEvents { + redictAsyncContext *context; struct ev_loop *loop; int reading, writing; ev_io rev, wev; ev_timer timer; -} redisLibevEvents; +} redictLibevEvents; -static void redisLibevReadEvent(EV_P_ ev_io *watcher, int revents) { +static void redictLibevReadEvent(EV_P_ ev_io *watcher, int revents) { #if EV_MULTIPLICITY ((void)EV_A); #endif ((void)revents); - redisLibevEvents *e = (redisLibevEvents*)watcher->data; - redisAsyncHandleRead(e->context); + redictLibevEvents *e = (redictLibevEvents*)watcher->data; + redictAsyncHandleRead(e->context); } -static void redisLibevWriteEvent(EV_P_ ev_io *watcher, int revents) { +static void redictLibevWriteEvent(EV_P_ ev_io *watcher, int revents) { #if EV_MULTIPLICITY ((void)EV_A); #endif ((void)revents); - redisLibevEvents *e = (redisLibevEvents*)watcher->data; - redisAsyncHandleWrite(e->context); + redictLibevEvents *e = (redictLibevEvents*)watcher->data; + redictAsyncHandleWrite(e->context); } -static void redisLibevAddRead(void *privdata) { - redisLibevEvents *e = (redisLibevEvents*)privdata; +static void redictLibevAddRead(void *privdata) { + redictLibevEvents *e = (redictLibevEvents*)privdata; #if EV_MULTIPLICITY struct ev_loop *loop = e->loop; #endif @@ -58,8 +58,8 @@ static void redisLibevAddRead(void *privdata) { } } -static void redisLibevDelRead(void *privdata) { - redisLibevEvents *e = (redisLibevEvents*)privdata; +static void redictLibevDelRead(void *privdata) { + redictLibevEvents *e = (redictLibevEvents*)privdata; #if EV_MULTIPLICITY struct ev_loop *loop = e->loop; #endif @@ -69,8 +69,8 @@ static void redisLibevDelRead(void *privdata) { } } -static void redisLibevAddWrite(void *privdata) { - redisLibevEvents *e = (redisLibevEvents*)privdata; +static void redictLibevAddWrite(void *privdata) { + redictLibevEvents *e = (redictLibevEvents*)privdata; #if EV_MULTIPLICITY struct ev_loop *loop = e->loop; #endif @@ -80,8 +80,8 @@ static void redisLibevAddWrite(void *privdata) { } } -static void redisLibevDelWrite(void *privdata) { - redisLibevEvents *e = (redisLibevEvents*)privdata; +static void redictLibevDelWrite(void *privdata) { + redictLibevEvents *e = (redictLibevEvents*)privdata; #if EV_MULTIPLICITY struct ev_loop *loop = e->loop; #endif @@ -91,39 +91,39 @@ static void redisLibevDelWrite(void *privdata) { } } -static void redisLibevStopTimer(void *privdata) { - redisLibevEvents *e = (redisLibevEvents*)privdata; +static void redictLibevStopTimer(void *privdata) { + redictLibevEvents *e = (redictLibevEvents*)privdata; #if EV_MULTIPLICITY struct ev_loop *loop = e->loop; #endif ev_timer_stop(EV_A_ &e->timer); } -static void redisLibevCleanup(void *privdata) { - redisLibevEvents *e = (redisLibevEvents*)privdata; - redisLibevDelRead(privdata); - redisLibevDelWrite(privdata); - redisLibevStopTimer(privdata); +static void redictLibevCleanup(void *privdata) { + redictLibevEvents *e = (redictLibevEvents*)privdata; + redictLibevDelRead(privdata); + redictLibevDelWrite(privdata); + redictLibevStopTimer(privdata); hi_free(e); } -static void redisLibevTimeout(EV_P_ ev_timer *timer, int revents) { +static void redictLibevTimeout(EV_P_ ev_timer *timer, int revents) { #if EV_MULTIPLICITY ((void)EV_A); #endif ((void)revents); - redisLibevEvents *e = (redisLibevEvents*)timer->data; - redisAsyncHandleTimeout(e->context); + redictLibevEvents *e = (redictLibevEvents*)timer->data; + redictAsyncHandleTimeout(e->context); } -static void redisLibevSetTimeout(void *privdata, struct timeval tv) { - redisLibevEvents *e = (redisLibevEvents*)privdata; +static void redictLibevSetTimeout(void *privdata, struct timeval tv) { + redictLibevEvents *e = (redictLibevEvents*)privdata; #if EV_MULTIPLICITY struct ev_loop *loop = e->loop; #endif if (!ev_is_active(&e->timer)) { - ev_init(&e->timer, redisLibevTimeout); + ev_init(&e->timer, redictLibevTimeout); e->timer.data = e; } @@ -131,18 +131,18 @@ static void redisLibevSetTimeout(void *privdata, struct timeval tv) { ev_timer_again(EV_A_ &e->timer); } -static int redisLibevAttach(EV_P_ redisAsyncContext *ac) { - redisContext *c = &(ac->c); - redisLibevEvents *e; +static int redictLibevAttach(EV_P_ redictAsyncContext *ac) { + redictContext *c = &(ac->c); + redictLibevEvents *e; /* Nothing should be attached when something is already attached */ if (ac->ev.data != NULL) - return REDIS_ERR; + return REDICT_ERR; /* Create container for context and r/w events */ - e = (redisLibevEvents*)hi_calloc(1, sizeof(*e)); + e = (redictLibevEvents*)hi_calloc(1, sizeof(*e)); if (e == NULL) - return REDIS_ERR; + return REDICT_ERR; e->context = ac; #if EV_MULTIPLICITY @@ -154,18 +154,18 @@ static int redisLibevAttach(EV_P_ redisAsyncContext *ac) { e->wev.data = e; /* Register functions to start/stop listening for events */ - ac->ev.addRead = redisLibevAddRead; - ac->ev.delRead = redisLibevDelRead; - ac->ev.addWrite = redisLibevAddWrite; - ac->ev.delWrite = redisLibevDelWrite; - ac->ev.cleanup = redisLibevCleanup; - ac->ev.scheduleTimer = redisLibevSetTimeout; + ac->ev.addRead = redictLibevAddRead; + ac->ev.delRead = redictLibevDelRead; + ac->ev.addWrite = redictLibevAddWrite; + ac->ev.delWrite = redictLibevDelWrite; + ac->ev.cleanup = redictLibevCleanup; + ac->ev.scheduleTimer = redictLibevSetTimeout; ac->ev.data = e; /* Initialize read/write events */ - ev_io_init(&e->rev,redisLibevReadEvent,c->fd,EV_READ); - ev_io_init(&e->wev,redisLibevWriteEvent,c->fd,EV_WRITE); - return REDIS_OK; + ev_io_init(&e->rev,redictLibevReadEvent,c->fd,EV_READ); + ev_io_init(&e->wev,redictLibevWriteEvent,c->fd,EV_WRITE); + return REDICT_OK; } #endif -- cgit v1.2.3