--- ansh/src/daemon2.c 2011/10/10 09:11:48 1.1.1.1.2.1 +++ ansh/src/daemon2.c 2011/10/10 13:56:30 1.1.1.1.2.2 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ - * $Id: daemon2.c,v 1.1.1.1.2.1 2011/10/10 09:11:48 misho Exp $ + * $Id: daemon2.c,v 1.1.1.1.2.2 2011/10/10 13:56:30 misho Exp $ * *************************************************************************/ #include "global.h" @@ -31,7 +31,7 @@ pktTx(sched_task_t *task) } } - if ((wlen = pktSend(TASK_FD(task), proc->proc_id, proc->proc_flg, Crypted, proc->proc_buf_[FD2NET], + if ((wlen = pktSend(TASK_FD(task), proc->proc_flg, Crypted, proc->proc_buf_[FD2NET], proc->proc_rlen_[FD2NET], &proc->proc_ea)) != ANSH_FLG_ERR) { proc->proc_flg = ANSH_FLG_OK; proc->proc_rlen_[FD2NET] = 0; @@ -135,7 +135,7 @@ fdTx(sched_task_t *task) proc->proc_flg = ANSH_FLG_EOF; proc->proc_rlen_[FD2NET] = 0; - schedWrite(TASK_ROOT(task), pktTx, proc, proc->proc_sock); + schedCallOnce(TASK_ROOT(task), pktTx, proc, proc->proc_sock); return NULL; } @@ -156,7 +156,7 @@ fdTx(sched_task_t *task) proc->proc_flg = ANSH_FLG_EOF; proc->proc_rlen_[FD2NET] = 0; - schedWrite(TASK_ROOT(task), pktTx, proc, proc->proc_sock); + schedCallOnce(TASK_ROOT(task), pktTx, proc, proc->proc_sock); return NULL; default: proc->proc_flg = ANSH_FLG_OK; @@ -195,7 +195,7 @@ fdRx(sched_task_t *task) proc->proc_flg = ANSH_FLG_EOF; proc->proc_rlen_[FD2NET] = 0; - schedWrite(TASK_ROOT(task), pktTx, proc, proc->proc_sock); + schedCallOnce(TASK_ROOT(task), pktTx, proc, proc->proc_sock); return NULL; } @@ -219,7 +219,7 @@ fdRx(sched_task_t *task) proc->proc_flg = ANSH_FLG_EOF; proc->proc_rlen_[FD2NET] = 0; - schedWrite(TASK_ROOT(task), pktTx, proc, proc->proc_sock); + schedCallOnce(TASK_ROOT(task), pktTx, proc, proc->proc_sock); return NULL; default: proc->proc_flg = ANSH_FLG_OK; @@ -227,7 +227,8 @@ fdRx(sched_task_t *task) } VERB(3) LOG("Readed %d bytes - %s", rlen, proc->proc_buf_[FD2NET]); - schedWrite(TASK_ROOT(task), pktTx, proc, proc->proc_sock); + LOG("fd=%d\n", proc->proc_sock); + schedCallOnce(TASK_ROOT(task), pktTx, proc, proc->proc_sock); schedRead(TASK_ROOT(task), fdRx, proc, proc->proc_pty); /* if Timeout defined, go arm timer */