add response

Author: BohuTANG

src/Makefile

@@ -1,7 +1,7 @@
 CC = gcc 
-CFLAGS = -Wall -g
+CFLAGS = -Wall -g -std=c99
 
-OBJS = ae.o  anet.o request.o zmalloc.o
+OBJS = ae.o  anet.o request.o response.o zmalloc.o
 SVR_OBJS= svr.o
 
 all :svr

src/response.c

@@ -0,0 +1,85 @@
+ /*Copyright (c) 2011, BohuTANG <overred.shuttler at gmail dot com>
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ *   * Redistributions of source code must retain the above copyright notice,
+ *     this list of conditions and the following disclaimer.
+ *   * Redistributions in binary form must reproduce the above copyright
+ *     notice, this list of conditions and the following disclaimer in the
+ *     documentation and/or other materials provided with the distribution.
+ *   * Neither the name of Redis nor the names of its contributors may be used
+ *     to endorse or promote products derived from this software without
+ *     specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+ * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
+ * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+ * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+ * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
+ * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
+ * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+ * POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+#include "response.h"
+
+struct response *response_new(int argc,int status)
+{
+	struct response *res;
+	res=calloc(1,sizeof(struct response));
+	res->argv=calloc(argc,sizeof(char*));
+	res->argc=argc;
+	res->status=status;
+	return res;
+}
+
+void response_detch(struct response *res,char *ackbuf)
+{
+	int i;
+	if(res->status==200)
+		strcat(ackbuf,"+OK\r\n");
+	else
+		strcat(ackbuf,"-OK\r\n");
+
+	for(i=0;i<res->argc;i++){
+		char ls[16]={0};
+		int l=strlen(res->argv[i]);
+		sprintf(ls,"$%d\r\n",l);
+		strcat(ackbuf,ls);
+
+		strcat(ackbuf,res->argv[i]);
+		strcat(ackbuf,"\r\n");
+	}
+}
+
+void response_dump(struct response *res)
+{
+	int i;
+	if(!res)
+		return;
+
+	printf("response-dump--->");
+	printf("argc:<%d>\n",res->argc);
+	for(i=0;i<res->argc;i++){
+		printf("		argv[%d]:<%s>\n",i,res->argv[i]);
+	}
+	printf("\n");
+}
+
+void response_free(struct response *res)
+{
+	if(res){
+		free(res->argv);
+	}
+}
+
+
+

src/response.h

@@ -0,0 +1,15 @@
+#ifndef _RESPONSE_H
+#define _RESPONSE_H
+struct response{
+	int argc;
+	int status;
+	char *ackbuf;
+	char **argv;
+};
+
+struct response *response_new(int argc,int status);
+void response_detch(struct response *response,char *ackbuf);
+void response_dump(struct response *response);
+void response_free(struct response *response);
+
+#endif

src/svr.c

@@ -35,6 +35,7 @@
 #include "anet.h"
 #include "ae.h"
 #include "request.h"
+#include "response.h"
 
 #define GET "get"
 #define SET "set"
@@ -66,6 +67,7 @@ void _ReadHandler(aeEventLoop *el, int fd, void *privdata, int mask)
 	}else{
 		int ret;
 		struct request *req=request_new(buf);
+		struct response *resp;
 		ret=request_parse(req);
 		if(ret){
 			request_dump(req);
@@ -75,11 +77,17 @@ void _ReadHandler(aeEventLoop *el, int fd, void *privdata, int mask)
 				/*to do nessDB's set*/
 			}
 			/*and others operations*/
+			resp=response_new(1,200);
+			resp->argv[0]="wow,nessDB";
+
+			response_detch(resp,sent_buf);
+			response_dump(resp);
+			write(fd,sent_buf,strlen(sent_buf));
+
+			response_free(resp);
+
 		}
 		request_free(req);
-		
-		sprintf(sent_buf,"%s\r\n","+OK");
-		write(fd,sent_buf,strlen(sent_buf));
 	}
 }