bugfix for the issue 50 : throwing exception for protocol errors.

Author: nasr

common.h

@@ -4,6 +4,10 @@
 #ifndef REDIS_COMMON_H
 #define REDIS_COMMON_H
 
+static zend_class_entry *redis_ce;
+static zend_class_entry *redis_exception_ce;
+static zend_class_entry *spl_ce_RuntimeException = NULL;
+
 #define redis_sock_name "Redis Socket Buffer"
 #define REDIS_SOCK_STATUS_FAILED 0
 #define REDIS_SOCK_STATUS_DISCONNECTED 1

library.c

@@ -87,6 +87,11 @@ PHPAPI char *redis_sock_read(RedisSock *redis_sock, int *buf_len TSRMLS_DC)
         case '-':
             return NULL;
 
+        case '$':
+            *buf_len = atoi(inbuf + 1);
+            resp = redis_sock_read_bulk_reply(redis_sock, *buf_len TSRMLS_CC);
+            return resp;
+
         case '+':
         case ':':
 	    // Single Line Reply
@@ -97,18 +102,15 @@ PHPAPI char *redis_sock_read(RedisSock *redis_sock, int *buf_len TSRMLS_DC)
                 memcpy(resp, inbuf, *buf_len);
                 resp[*buf_len] = 0;
                 return resp;
-            } else {
-                printf("protocol error \n");
-                return NULL;
             }
 
-        case '$':
-            *buf_len = atoi(inbuf + 1);
-            resp = redis_sock_read_bulk_reply(redis_sock, *buf_len TSRMLS_CC);
-            return resp;
-
         default:
-            printf("protocol error, got '%c' as reply type byte\n", inbuf[0]);
+			zend_throw_exception_ex(
+				redis_exception_ce,
+				0 TSRMLS_CC,
+				"protocol error, got '%c' as reply type byte\n",
+				inbuf[0]
+			);
     }
 
     return NULL;

redis.c

@@ -35,9 +35,6 @@
 
 static int le_redis_sock;
 
-static zend_class_entry *redis_ce;
-static zend_class_entry *redis_exception_ce;
-static zend_class_entry *spl_ce_RuntimeException = NULL;
 
 
 ZEND_DECLARE_MODULE_GLOBALS(redis)