dany/antd-tunnel-plugin
1
0
Fork 0
mirror of https://github.com/lxsang/antd-tunnel-plugin synced 2024-11-16 09:48:21 +01:00
Code Issues Projects Releases Wiki Activity

increase timeout on tunnel

Browse Source
This commit is contained in:
lxsang 2020-12-28 12:17:27 +01:00
parent 15e086441d
commit 4e35fa3738
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tunnel.c
View File

@ -21,6 +21,7 @@
#define SOCK_DIR_NAME "channels" #define SOCK_DIR_NAME "channels"
#define PING_INTERVAL 10u // 10s #define PING_INTERVAL 10u // 10s
#define PROCESS_TIMEOUT 30000u //30 ms
#define MAX_CHANNEL_ID 65535u #define MAX_CHANNEL_ID 65535u
@ -908,7 +909,7 @@ void *handle(void *rq_data)
{ {
argv[0] = (void *)rq->client; argv[0] = (void *)rq->client;
timeout.tv_sec = 0; timeout.tv_sec = 0;
timeout.tv_usec = 500; // 5 ms timeout.tv_usec = PROCESS_TIMEOUT;
FD_ZERO(&fd_in); FD_ZERO(&fd_in);
FD_SET(client->sock, &fd_in); FD_SET(client->sock, &fd_in);
@ -924,7 +925,7 @@ void *handle(void *rq_data)
break; break;
case 0: case 0:
timeout.tv_sec = 0; timeout.tv_sec = 0;
timeout.tv_usec = 500; // 5 ms timeout.tv_usec = PROCESS_TIMEOUT;
select(0, NULL, NULL, NULL, &timeout); select(0, NULL, NULL, NULL, &timeout);
break; break;
default: default:
@ -1033,6 +1034,12 @@ void *handle(void *rq_data)
} }
free(h); free(h);
} }
else
{
timeout.tv_sec = 0;
timeout.tv_usec = PROCESS_TIMEOUT;
select(0, NULL, NULL, NULL, &timeout);
}
} }
// check whether we need to send ping message to client // check whether we need to send ping message to client
if (difftime(time(NULL), client->last_io) > (double)PING_INTERVAL) if (difftime(time(NULL), client->last_io) > (double)PING_INTERVAL)
@ -1063,6 +1070,5 @@ void *handle(void *rq_data)
task->handle = handle; task->handle = handle;
task->type = HEAVY; task->type = HEAVY;
task->access_time = time(NULL); task->access_time = time(NULL);
select(0, NULL, NULL, NULL, &timeout);
return task; return task;
} }