From 437eea80fce125b800142bd00ab701000f78e57e Mon Sep 17 00:00:00 2001
From: Pieter Noordhuis <pcnoordhuis@gmail.com>
Date: Mon, 1 Nov 2010 09:52:17 +0100
Subject: [PATCH] Make error ptr accessible from async context

---
 async.c | 12 +++++++++++-
 async.h |  3 +++
 2 files changed, 14 insertions(+), 1 deletion(-)

diff --git a/async.c b/async.c
index 3ea957b..31e7f15 100644
--- a/async.c
+++ b/async.c
@@ -40,9 +40,18 @@ static redisAsyncContext *redisAsyncInitialize(redisContext *c) {
     return ac;
 }
 
+/* We want the error field to be accessible directly instead of requiring
+ * an indirection to the redisContext struct. */
+static void __redisAsyncCopyError(redisAsyncContext *ac) {
+    redisContext *c = &(ac->c);
+    if (c->error != NULL)
+        ac->error = c->error;
+}
+
 redisAsyncContext *redisAsyncConnect(const char *ip, int port) {
     redisContext *c = redisConnectNonBlock(ip,port);
     redisAsyncContext *ac = redisAsyncInitialize(c);
+    __redisAsyncCopyError(ac);
     return ac;
 }
 
@@ -78,7 +87,8 @@ static void __redisAsyncDisconnect(redisAsyncContext *ac) {
     if (ac->evCleanup) ac->evCleanup(ac->data);
 
     /* Execute callback with proper status */
-    status = (c->error == NULL) ? REDIS_OK : REDIS_ERR;
+    __redisAsyncCopyError(ac);
+    status = (ac->error == NULL) ? REDIS_OK : REDIS_ERR;
     if (ac->onDisconnect) ac->onDisconnect(ac,status);
 
     /* Cleanup self */
diff --git a/async.h b/async.h
index 1678240..3f29c10 100644
--- a/async.h
+++ b/async.h
@@ -54,6 +54,9 @@ typedef struct redisAsyncContext {
     /* Hold the regular context, so it can be realloc'ed. */
     redisContext c;
 
+    /* Hold a reference to the error object so it can be used directly. */
+    char *error;
+
     /* Called when the library expects to start reading/writing.
      * The supplied functions should be idempotent. */
     void (*evAddRead)(void *privdata);