diff options
Diffstat (limited to 'src/curl')
| -rw-r--r-- | src/curl/http.c | 1 | ||||
| -rw-r--r-- | src/curl/websocket.c | 2 |
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) { |