Bug fix
This commit is contained in:
@@ -3909,6 +3909,8 @@ int socket_pool_connect_ipv6(SocketPool *pool, bool secure,
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#include <stdio.h> // TODO: remove
|
||||||
|
|
||||||
SocketEvent socket_pool_wait(SocketPool *pool)
|
SocketEvent socket_pool_wait(SocketPool *pool)
|
||||||
{
|
{
|
||||||
for (;;) {
|
for (;;) {
|
||||||
@@ -3927,6 +3929,7 @@ SocketEvent socket_pool_wait(SocketPool *pool)
|
|||||||
if (socket_died(sock)) {
|
if (socket_died(sock)) {
|
||||||
void *user_data = socket_get_user_data(sock);
|
void *user_data = socket_get_user_data(sock);
|
||||||
socket_free(sock);
|
socket_free(sock);
|
||||||
|
pool->num_socks--;
|
||||||
return (SocketEvent) { SOCKET_EVENT_DIED, -1, user_data };
|
return (SocketEvent) { SOCKET_EVENT_DIED, -1, user_data };
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -215,6 +215,8 @@ int socket_pool_connect_ipv6(SocketPool *pool, bool secure,
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#include <stdio.h> // TODO: remove
|
||||||
|
|
||||||
SocketEvent socket_pool_wait(SocketPool *pool)
|
SocketEvent socket_pool_wait(SocketPool *pool)
|
||||||
{
|
{
|
||||||
for (;;) {
|
for (;;) {
|
||||||
@@ -233,6 +235,7 @@ SocketEvent socket_pool_wait(SocketPool *pool)
|
|||||||
if (socket_died(sock)) {
|
if (socket_died(sock)) {
|
||||||
void *user_data = socket_get_user_data(sock);
|
void *user_data = socket_get_user_data(sock);
|
||||||
socket_free(sock);
|
socket_free(sock);
|
||||||
|
pool->num_socks--;
|
||||||
return (SocketEvent) { SOCKET_EVENT_DIED, -1, user_data };
|
return (SocketEvent) { SOCKET_EVENT_DIED, -1, user_data };
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user