--- libaitio/src/sock.c 2013/11/22 10:26:54 1.4.4.14 +++ libaitio/src/sock.c 2013/11/22 10:30:21 1.4.4.15 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: sock.c,v 1.4.4.14 2013/11/22 10:26:54 misho Exp $ +* $Id: sock.c,v 1.4.4.15 2013/11/22 10:30:21 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -90,6 +90,8 @@ io_acceptClient(sched_task_t *task) sock_cli_t *cli = NULL; sock_t *s = (sock_t*) TASK_ARG(task); + ioUpdTimerSocket(cli, (void*) cli->cli_func); + if (s->sock_type == SOCK_STREAM) { if ((c = accept(TASK_FD(task), &sa.sa, &salen)) == -1) { LOGERR; @@ -139,6 +141,8 @@ io_txNet(sched_task_t *task) sock_cli_t *cli = TASK_ARG(task); sock_t *s = (sock_t*) cli->cli_parent; + ioUpdTimerSocket(cli, (void*) cli->cli_func); + if (s->sock_type == SOCK_STREAM) wlen = send(TASK_FD(task), TASK_DATA(task), TASK_DATLEN(task), 0); else @@ -174,6 +178,8 @@ io_rxNet(sched_task_t *task) sockaddr_t sa; socklen_t salen = sizeof sa.ss; + ioUpdTimerSocket(cli, (void*) cli->cli_func); + memset(AIT_GET_BUF(&cli->cli_buf[0]), 0, AIT_LEN(&cli->cli_buf[0])); if (s->sock_type == SOCK_STREAM) rlen = recv(TASK_FD(task), AIT_GET_BUF(&cli->cli_buf[0]), @@ -200,6 +206,8 @@ io_rxPty(sched_task_t *task) { int rlen; sock_cli_t *cli = TASK_ARG(task); + + ioUpdTimerSocket(cli, (void*) cli->cli_func); memset(AIT_GET_BUF(&cli->cli_buf[1]), 0, AIT_LEN(&cli->cli_buf[1])); rlen = read(TASK_FD(task), AIT_GET_BUF(&cli->cli_buf[1]), AIT_LEN(&cli->cli_buf[1]));