Fix pingserver (#154)

* add error handler to ping server

* allow 'ping' as an alternative to 'PING'

* use strncasecmp() which is better

src/protocol/data/ping/compose.c

@@ -42,7 +42,7 @@ compose_req(struct buf **buf)
 {
     log_verb("composing request to buf %p", buf);
 
-    if (buf_wsize(*buf) < sizeof(REQUEST) && dbuf_double(buf) != CC_OK) {
+    if (buf_wsize(*buf) < REQ_LEN && dbuf_double(buf) != CC_OK) {
         log_debug("failed to double buf %p");
         INCR(compose_req_metrics, request_compose_ex);
 

src/protocol/data/ping/parse.c

@@ -46,7 +46,7 @@ parse_req(struct buf *buf)
         return PARSE_EUNFIN;
     }
 
-    if (cc_memcmp(buf->rpos, REQUEST, REQ_LEN) == 0) {
+    if (strncasecmp(buf->rpos, REQUEST, REQ_LEN) == 0) {
         buf->rpos += REQ_LEN;
         INCR(parse_req_metrics, request_parse);
         return PARSE_OK;

src/server/pingserver/data/process.c

@@ -42,3 +42,17 @@ pingserver_process_write(struct buf_sock *s)
 
     return 0;
 }
+
+int
+pingserver_process_error(struct buf_sock *s)
+{
+    log_verb("post-error processing");
+
+    /* normalize buffer size */
+    buf_reset(s->rbuf);
+    dbuf_shrink(&s->rbuf);
+    buf_reset(s->wbuf);
+    dbuf_shrink(&s->wbuf);
+
+    return 0;
+}

src/server/pingserver/data/process.h

@@ -4,3 +4,4 @@
 
 int pingserver_process_read(struct buf_sock *s);
 int pingserver_process_write(struct buf_sock *s);
+int pingserver_process_error(struct buf_sock *s);

src/server/pingserver/main.c

@@ -15,7 +15,8 @@
 
 struct processor worker_processor = {
     pingserver_process_read,
-    pingserver_process_write
+    pingserver_process_write,
+    pingserver_process_error,
 };
 
 static void