summaryrefslogtreecommitdiff
path: root/adapters/ivykis.h
diff options
context:
space:
mode:
Diffstat (limited to 'adapters/ivykis.h')
-rw-r--r--adapters/ivykis.h74
1 files changed, 37 insertions, 37 deletions
diff --git a/adapters/ivykis.h b/adapters/ivykis.h
index 544723d..a8468d8 100644
--- a/adapters/ivykis.h
+++ b/adapters/ivykis.h
@@ -9,87 +9,87 @@
*
*/
-#ifndef __HIREDIS_IVYKIS_H__
-#define __HIREDIS_IVYKIS_H__
+#ifndef __HIREDICT_IVYKIS_H__
+#define __HIREDICT_IVYKIS_H__
#include <iv.h>
#include "../hiredict.h"
#include "../async.h"
-typedef struct redisIvykisEvents {
- redisAsyncContext *context;
+typedef struct redictIvykisEvents {
+ redictAsyncContext *context;
struct iv_fd fd;
-} redisIvykisEvents;
+} redictIvykisEvents;
-static void redisIvykisReadEvent(void *arg) {
- redisAsyncContext *context = (redisAsyncContext *)arg;
- redisAsyncHandleRead(context);
+static void redictIvykisReadEvent(void *arg) {
+ redictAsyncContext *context = (redictAsyncContext *)arg;
+ redictAsyncHandleRead(context);
}
-static void redisIvykisWriteEvent(void *arg) {
- redisAsyncContext *context = (redisAsyncContext *)arg;
- redisAsyncHandleWrite(context);
+static void redictIvykisWriteEvent(void *arg) {
+ redictAsyncContext *context = (redictAsyncContext *)arg;
+ redictAsyncHandleWrite(context);
}
-static void redisIvykisAddRead(void *privdata) {
- redisIvykisEvents *e = (redisIvykisEvents*)privdata;
- iv_fd_set_handler_in(&e->fd, redisIvykisReadEvent);
+static void redictIvykisAddRead(void *privdata) {
+ redictIvykisEvents *e = (redictIvykisEvents*)privdata;
+ iv_fd_set_handler_in(&e->fd, redictIvykisReadEvent);
}
-static void redisIvykisDelRead(void *privdata) {
- redisIvykisEvents *e = (redisIvykisEvents*)privdata;
+static void redictIvykisDelRead(void *privdata) {
+ redictIvykisEvents *e = (redictIvykisEvents*)privdata;
iv_fd_set_handler_in(&e->fd, NULL);
}
-static void redisIvykisAddWrite(void *privdata) {
- redisIvykisEvents *e = (redisIvykisEvents*)privdata;
- iv_fd_set_handler_out(&e->fd, redisIvykisWriteEvent);
+static void redictIvykisAddWrite(void *privdata) {
+ redictIvykisEvents *e = (redictIvykisEvents*)privdata;
+ iv_fd_set_handler_out(&e->fd, redictIvykisWriteEvent);
}
-static void redisIvykisDelWrite(void *privdata) {
- redisIvykisEvents *e = (redisIvykisEvents*)privdata;
+static void redictIvykisDelWrite(void *privdata) {
+ redictIvykisEvents *e = (redictIvykisEvents*)privdata;
iv_fd_set_handler_out(&e->fd, NULL);
}
-static void redisIvykisCleanup(void *privdata) {
- redisIvykisEvents *e = (redisIvykisEvents*)privdata;
+static void redictIvykisCleanup(void *privdata) {
+ redictIvykisEvents *e = (redictIvykisEvents*)privdata;
iv_fd_unregister(&e->fd);
hi_free(e);
}
-static int redisIvykisAttach(redisAsyncContext *ac) {
- redisContext *c = &(ac->c);
- redisIvykisEvents *e;
+static int redictIvykisAttach(redictAsyncContext *ac) {
+ redictContext *c = &(ac->c);
+ redictIvykisEvents *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 = (redisIvykisEvents*)hi_malloc(sizeof(*e));
+ e = (redictIvykisEvents*)hi_malloc(sizeof(*e));
if (e == NULL)
- return REDIS_ERR;
+ return REDICT_ERR;
e->context = ac;
/* Register functions to start/stop listening for events */
- ac->ev.addRead = redisIvykisAddRead;
- ac->ev.delRead = redisIvykisDelRead;
- ac->ev.addWrite = redisIvykisAddWrite;
- ac->ev.delWrite = redisIvykisDelWrite;
- ac->ev.cleanup = redisIvykisCleanup;
+ ac->ev.addRead = redictIvykisAddRead;
+ ac->ev.delRead = redictIvykisDelRead;
+ ac->ev.addWrite = redictIvykisAddWrite;
+ ac->ev.delWrite = redictIvykisDelWrite;
+ ac->ev.cleanup = redictIvykisCleanup;
ac->ev.data = e;
/* Initialize and install read/write events */
IV_FD_INIT(&e->fd);
e->fd.fd = c->fd;
- e->fd.handler_in = redisIvykisReadEvent;
- e->fd.handler_out = redisIvykisWriteEvent;
+ e->fd.handler_in = redictIvykisReadEvent;
+ e->fd.handler_out = redictIvykisWriteEvent;
e->fd.handler_err = NULL;
e->fd.cookie = e->context;
iv_fd_register(&e->fd);
- return REDIS_OK;
+ return REDICT_OK;
}
#endif