at work

cworker.c

@@ -322,7 +322,15 @@ int cworker_handler(const cworker_t* worker, int socket) {
     jblock_outjson(&jb, &jsonstr);
     jblock_destroy(&jb);
 
-    write(socket, jsonstr, strlen(jsonstr));
+    size_t jsize = strlen(jsonstr);
+    ssize_t wsize = write(socket, jsonstr, jsize);
+    if (wsize < 0) {
+        log_error("Write error: %s", strerror(errno));
+    }
+    if (wsize != jsize && wsize >= 0 ) {
+        log_error("Wrote only %ld from %ld", (size_t)wsize, jsize);
+    }
+
     free(jsonstr);
     //free(name);
     free(msg);