File tree Expand file tree Collapse file tree 1 file changed +1
-6
lines changed Expand file tree Collapse file tree 1 file changed +1
-6
lines changed Original file line number Diff line number Diff line change @@ -710,9 +710,6 @@ server_recv_cb(EV_P_ ev_io *w, int revents)
710
710
if (server -> stage == STAGE_STREAM ) {
711
711
remote = server -> remote ;
712
712
buf = remote -> buf ;
713
-
714
- // Only timer the watcher if a valid connection is established
715
- ev_timer_again (EV_A_ & server -> recv_ctx -> watcher );
716
713
}
717
714
718
715
ssize_t r = recv (server -> fd , buf -> data , SOCKET_BUF_SIZE , 0 );
@@ -1122,8 +1119,6 @@ remote_recv_cb(EV_P_ ev_io *w, int revents)
1122
1119
return ;
1123
1120
}
1124
1121
1125
- ev_timer_again (EV_A_ & server -> recv_ctx -> watcher );
1126
-
1127
1122
ssize_t r = recv (remote -> fd , server -> buf -> data , SOCKET_BUF_SIZE , 0 );
1128
1123
1129
1124
if (r == 0 ) {
@@ -1408,7 +1403,7 @@ new_server(int fd, listen_ctx_t *listener)
1408
1403
ev_io_init (& server -> recv_ctx -> io , server_recv_cb , fd , EV_READ );
1409
1404
ev_io_init (& server -> send_ctx -> io , server_send_cb , fd , EV_WRITE );
1410
1405
ev_timer_init (& server -> recv_ctx -> watcher , server_timeout_cb ,
1411
- request_timeout , listener -> timeout );
1406
+ request_timeout , 0 );
1412
1407
1413
1408
cork_dllist_add (& connections , & server -> entries );
1414
1409
You can’t perform that action at this time.
0 commit comments