|
|
@ -492,7 +492,8 @@ void *receiver(void *arg) |
|
|
|
client = event.data.ptr; |
|
|
|
client = event.data.ptr; |
|
|
|
/* Recheck this client still exists in the same form when it
|
|
|
|
/* Recheck this client still exists in the same form when it
|
|
|
|
* was queued. */ |
|
|
|
* was queued. */ |
|
|
|
if (unlikely(client != ref_client_by_id(cdata, client->id))) |
|
|
|
client = ref_client_by_id(cdata, client->id); |
|
|
|
|
|
|
|
if (unlikely(!client)) |
|
|
|
continue; |
|
|
|
continue; |
|
|
|
if (event.events & (EPOLLERR | EPOLLHUP | EPOLLRDHUP)) { |
|
|
|
if (event.events & (EPOLLERR | EPOLLHUP | EPOLLRDHUP)) { |
|
|
|
/* Client disconnected */ |
|
|
|
/* Client disconnected */ |
|
|
|