Remove use of send_recv_proc internally from ckpool.c

src/ckpool.c

@@ -476,12 +476,12 @@ retry:
 		}
 	} else if (cmdmatch(buf, "stratifierstats")) {
 		LOGDEBUG("Listener received stratifierstats request");
-		msg = send_recv_proc(ckp->stratifier, "stats");
+		msg = stratifier_stats(ckp, ckp->sdata);
 		send_unix_msg(sockd, msg);
 		dealloc(msg);
 	} else if (cmdmatch(buf, "connectorstats")) {
 		LOGDEBUG("Listener received connectorstats request");
-		msg = send_recv_proc(ckp->connector, "stats");
+		msg = connector_stats(ckp->cdata, 0);
 		send_unix_msg(sockd, msg);
 		dealloc(msg);
 	} else if (cmdmatch(buf, "ckdbflush")) {

src/connector.c

@@ -1293,11 +1293,12 @@ static void drop_passthrough_client(cdata_t *cdata, const int64_t id)
 	send_client(cdata, id, msg);
 }
 
-static char *connector_stats(cdata_t *cdata, const int runtime)
+char *connector_stats(void *data, const int runtime)
 {
 	json_t *val = json_object(), *subval;
 	client_instance_t *client;
 	int objects, generated;
+	cdata_t *cdata = data;
 	sender_send_t *send;
 	int64_t memsize;
 	char *buf;

src/connector.h

@@ -12,6 +12,7 @@
 
 void connector_upstream_msg(ckpool_t *ckp, char *msg);
 void connector_add_message(ckpool_t *ckp, json_t *val);
+char *connector_stats(void *data, const int runtime);
 void *connector(void *arg);
 
 #endif /* CONNECTOR_H */

src/stratifier.c

@@ -3570,10 +3570,11 @@ static void ckmsgq_stats(ckmsgq_t *ckmsgq, const int size, json_t **val)
 	JSON_CPACK(*val, "{si,si,si}", "count", objects, "memory", memsize, "generated", generated);
 }
 
-static char *stratifier_stats(ckpool_t *ckp, sdata_t *sdata)
+char *stratifier_stats(ckpool_t *ckp, void *data)
 {
 	json_t *val = json_object(), *subval;
 	int objects, generated;
+	sdata_t *sdata = data;
 	int64_t memsize;
 	char *buf;
 

src/stratifier.h

@@ -13,6 +13,7 @@
 void parse_remote_txns(ckpool_t *ckp, const json_t *val);
 #define parse_upstream_txns(ckp, val) parse_remote_txns(ckp, val)
 void parse_upstream_auth(ckpool_t *ckp, json_t *val);
+char *stratifier_stats(ckpool_t *ckp, void *data);
 void stratifier_add_recv(ckpool_t *ckp, json_t *val);
 void *stratifier(void *arg);