|
|
|
@ -303,7 +303,7 @@ static int websocket_dequeue(struct websocket_conn *wc) { |
|
|
|
if (!wc) |
|
|
|
return 0; |
|
|
|
|
|
|
|
int is_http = 0; |
|
|
|
bool is_http = false; |
|
|
|
|
|
|
|
mutex_lock(&wc->lock); |
|
|
|
struct websocket_output *wo; |
|
|
|
@ -340,7 +340,7 @@ static int websocket_dequeue(struct websocket_conn *wc) { |
|
|
|
(unsigned long) to_send); |
|
|
|
|
|
|
|
if (wo->protocol == LWS_WRITE_HTTP) |
|
|
|
is_http = 1; |
|
|
|
is_http = true; |
|
|
|
} |
|
|
|
|
|
|
|
next: |
|
|
|
@ -350,12 +350,11 @@ next: |
|
|
|
|
|
|
|
mutex_unlock(&wc->lock); |
|
|
|
|
|
|
|
int ret = 0; |
|
|
|
if (is_http) |
|
|
|
if (lws_http_transaction_completed(wsi) == 1) // may destroy `wc` |
|
|
|
ret = -1; |
|
|
|
return -1; |
|
|
|
|
|
|
|
return ret; |
|
|
|
return 0; |
|
|
|
} |
|
|
|
|
|
|
|
void websocket_http_response(struct websocket_conn *wc, int status, const char *content_type, |
|
|
|
|