version 1.1.1.1.2.1, 2011/10/10 09:11:48
|
version 1.1.1.1.2.2, 2011/10/10 13:56:30
|
Line 31 pktTx(sched_task_t *task)
|
Line 31 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_rlen_[FD2NET], &proc->proc_ea)) != ANSH_FLG_ERR) { |
proc->proc_flg = ANSH_FLG_OK; |
proc->proc_flg = ANSH_FLG_OK; |
proc->proc_rlen_[FD2NET] = 0; |
proc->proc_rlen_[FD2NET] = 0; |
Line 135 fdTx(sched_task_t *task)
|
Line 135 fdTx(sched_task_t *task)
|
proc->proc_flg = ANSH_FLG_EOF; |
proc->proc_flg = ANSH_FLG_EOF; |
proc->proc_rlen_[FD2NET] = 0; |
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; |
return NULL; |
} |
} |
|
|
Line 156 fdTx(sched_task_t *task)
|
Line 156 fdTx(sched_task_t *task)
|
proc->proc_flg = ANSH_FLG_EOF; |
proc->proc_flg = ANSH_FLG_EOF; |
proc->proc_rlen_[FD2NET] = 0; |
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; |
return NULL; |
default: |
default: |
proc->proc_flg = ANSH_FLG_OK; |
proc->proc_flg = ANSH_FLG_OK; |
Line 195 fdRx(sched_task_t *task)
|
Line 195 fdRx(sched_task_t *task)
|
proc->proc_flg = ANSH_FLG_EOF; |
proc->proc_flg = ANSH_FLG_EOF; |
proc->proc_rlen_[FD2NET] = 0; |
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; |
return NULL; |
} |
} |
|
|
Line 219 fdRx(sched_task_t *task)
|
Line 219 fdRx(sched_task_t *task)
|
proc->proc_flg = ANSH_FLG_EOF; |
proc->proc_flg = ANSH_FLG_EOF; |
proc->proc_rlen_[FD2NET] = 0; |
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; |
return NULL; |
default: |
default: |
proc->proc_flg = ANSH_FLG_OK; |
proc->proc_flg = ANSH_FLG_OK; |
Line 227 fdRx(sched_task_t *task)
|
Line 227 fdRx(sched_task_t *task)
|
} |
} |
VERB(3) LOG("Readed %d bytes - %s", rlen, proc->proc_buf_[FD2NET]); |
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); |
schedRead(TASK_ROOT(task), fdRx, proc, proc->proc_pty); |
|
|
/* if Timeout defined, go arm timer */ |
/* if Timeout defined, go arm timer */ |