Correctly handle node messages

src/stratifier.c

@@ -3972,13 +3972,12 @@ retry:
 	} while (!umsg);
 
 	buf = umsg->buf;
-	if (likely(buf[0] == '{')) {
+	if (buf[0] == '{') {
-		/* The bulk of the messages will be received json from the
+		json_t *val = json_loads(buf, JSON_DISABLE_EOF_CHECK, NULL);
-		 * connector so look for this first. The srecv_process frees
+
-		 * the buf heap ram */
+		/* This is a message for a node */
 		Close(umsg->sockd);
-		ckmsgq_add(sdata->srecvs, umsg->buf);
+		ckmsgq_add(sdata->srecvs, val);
-		umsg->buf = NULL;
 		goto retry;
 	}
 	if (cmdmatch(buf, "ping")) {