|
|
@ -4853,6 +4853,7 @@ static void *stratum_thread(void *userdata) |
|
|
|
|
|
|
|
|
|
|
|
while (42) { |
|
|
|
while (42) { |
|
|
|
struct timeval timeout; |
|
|
|
struct timeval timeout; |
|
|
|
|
|
|
|
int sel_ret; |
|
|
|
fd_set rd; |
|
|
|
fd_set rd; |
|
|
|
char *s; |
|
|
|
char *s; |
|
|
|
|
|
|
|
|
|
|
@ -4887,8 +4888,8 @@ static void *stratum_thread(void *userdata) |
|
|
|
* every minute so if we fail to receive any for 90 seconds we |
|
|
|
* every minute so if we fail to receive any for 90 seconds we |
|
|
|
* assume the connection has been dropped and treat this pool |
|
|
|
* assume the connection has been dropped and treat this pool |
|
|
|
* as dead */ |
|
|
|
* as dead */ |
|
|
|
if (!sock_full(pool) && select(pool->sock + 1, &rd, NULL, NULL, &timeout) < 1) { |
|
|
|
if (!sock_full(pool) && (sel_ret = select(pool->sock + 1, &rd, NULL, NULL, &timeout)) < 1) { |
|
|
|
applog(LOG_DEBUG, "Stratum select timeout on pool %d", pool->pool_no); |
|
|
|
applog(LOG_DEBUG, "Stratum select failed on pool %d with value %d", pool->pool_no, sel_ret); |
|
|
|
s = NULL; |
|
|
|
s = NULL; |
|
|
|
} else |
|
|
|
} else |
|
|
|
s = recv_line(pool); |
|
|
|
s = recv_line(pool); |
|
|
|