Add multiplex, a bunch of cleanup

Signed-off-by: Andrew Opalach <andrew@akon.city>

2 files changed, 2 insertions, 1 deletions

diff --git a/src/curl/http.c b/src/curl/http.c
index 5674a18..c58d5a6 100644
--- a/src/curl/http.c
+++ b/src/curl/http.c
@@ -31,6 +31,7 @@ static void http_handle_events(struct aki_curl *curl)
             CURLcode code = msg->data.result;
             if (code != CURLE_OK) {
                 al_log_error("http", "Curl error: %s.", curl_easy_strerror(code));
+                http->callback(http->userdata, AKI_HTTP_ERROR, NULL, -1);
                 return;
             }
             if (!aki_curl_remove_handle(curl)) return;
diff --git a/src/curl/websocket.c b/src/curl/websocket.c
index 7e1d9b9..4d480c3 100644
--- a/src/curl/websocket.c
+++ b/src/curl/websocket.c
@@ -28,7 +28,7 @@ static size_t stream_write_callback(char *buffer, size_t size, size_t nmemb, voi
     struct aki_websocket *ws = (struct aki_websocket *)userdata;
     const struct curl_ws_frame *m = curl_ws_meta(ws->curl.handle);
     size_t frame_size = m->offset + m->len + m->bytesleft;
-    al_log_debug("ws", "frame_size: %zu, bytesleft: %zu", frame_size, m->bytesleft);
+    al_log_debug("ws", "frame_size: %zu, bytesleft: %zu.", frame_size, m->bytesleft);
     aki_buffer_ensure_space(&ws->frame, frame_size);
     al_memcpy(aki_buffer_get_ptr(&ws->frame, m->offset), buffer, m->len);
     if (m->bytesleft == 0) {