|
|
| version 1.2.2.1, 2011/10/31 15:49:37 | version 1.3.2.1, 2012/01/23 16:13:07 |
|---|---|
| Line 151 icmpRx(sched_task_t *task) | Line 151 icmpRx(sched_task_t *task) |
| proc->proc_rlen_[NET2FD] = rlen; | proc->proc_rlen_[NET2FD] = rlen; |
| memset(proc->proc_buf_[NET2FD], 0, proc->proc_blen); | memset(proc->proc_buf_[NET2FD], 0, proc->proc_blen); |
| memcpy(proc->proc_buf_[NET2FD], buf, proc->proc_rlen_[NET2FD]); | memcpy(proc->proc_buf_[NET2FD], buf, proc->proc_rlen_[NET2FD]); |
| schedWrite(TASK_ROOT(task), fdTx, proc, proc->proc_pty); | schedWrite(TASK_ROOT(task), fdTx, proc, proc->proc_pty, NULL, 0); |
| end: | end: |
| free(buf); | free(buf); |
| schedRead(TASK_ROOT(task), icmpRx, NULL, proc ? proc->proc_sock : TASK_FD(task)); | schedRead(TASK_ROOT(task), icmpRx, NULL, proc ? proc->proc_sock : TASK_FD(task), NULL, 0); |
| return NULL; | return NULL; |
| } | } |
| Line 177 fdTx(sched_task_t *task) | Line 177 fdTx(sched_task_t *task) |
| /* if Timeout defined, disarm timer */ | /* if Timeout defined, disarm timer */ |
| if (Timeout) | if (Timeout) |
| schedCancelby(TASK_ROOT(task), &TASK_ROOT(task)->root_timer, CRITERIA_CALL, TOfunc, NULL); | schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_CALL, TOfunc, NULL); |
| wlen = write(TASK_FD(task), proc->proc_buf_[NET2FD], proc->proc_rlen_[NET2FD]); | wlen = write(TASK_FD(task), proc->proc_buf_[NET2FD], proc->proc_rlen_[NET2FD]); |
| switch (wlen) { | switch (wlen) { |
| Line 194 fdTx(sched_task_t *task) | Line 194 fdTx(sched_task_t *task) |
| /* if Timeout defined, go arm timer */ | /* if Timeout defined, go arm timer */ |
| if (Timeout) { | if (Timeout) { |
| tv.tv_sec = Timeout; | tv.tv_sec = Timeout; |
| schedTimer(TASK_ROOT(task), TOfunc, proc, tv); | schedTimer(TASK_ROOT(task), TOfunc, proc, tv, NULL, 0); |
| } | } |
| return NULL; | return NULL; |
| } | } |
| Line 216 fdRx(sched_task_t *task) | Line 216 fdRx(sched_task_t *task) |
| /* if Timeout defined, disarm timer */ | /* if Timeout defined, disarm timer */ |
| if (Timeout) | if (Timeout) |
| schedCancelby(TASK_ROOT(task), &TASK_ROOT(task)->root_timer, CRITERIA_CALL, TOfunc, NULL); | schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_CALL, TOfunc, NULL); |
| memset(proc->proc_buf_[FD2NET], 0, proc->proc_blen); | memset(proc->proc_buf_[FD2NET], 0, proc->proc_blen); |
| rlen = read(TASK_FD(task), proc->proc_buf_[FD2NET], | rlen = read(TASK_FD(task), proc->proc_buf_[FD2NET], |
| Line 233 fdRx(sched_task_t *task) | Line 233 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), icmpTx, proc, proc->proc_sock); | schedWrite(TASK_ROOT(task), icmpTx, proc, proc->proc_sock, NULL, 0); |
| schedRead(TASK_ROOT(task), fdRx, proc, proc->proc_pty); | schedRead(TASK_ROOT(task), fdRx, proc, proc->proc_pty, NULL, 0); |
| /* if Timeout defined, go arm timer */ | /* if Timeout defined, go arm timer */ |
| if (Timeout) { | if (Timeout) { |
| tv.tv_sec = Timeout; | tv.tv_sec = Timeout; |
| schedTimer(TASK_ROOT(task), TOfunc, proc, tv); | schedTimer(TASK_ROOT(task), TOfunc, proc, tv, NULL, 0); |
| } | } |
| return NULL; | return NULL; |
| } | } |
| Line 276 spawnLogin(sched_task_t *task, struct tagProc *proc) | Line 276 spawnLogin(sched_task_t *task, struct tagProc *proc) |
| fcntl(proc->proc_pty, F_SETFL, flg | O_NONBLOCK); | fcntl(proc->proc_pty, F_SETFL, flg | O_NONBLOCK); |
| VERB(3) LOG("Parent know child pid %d", proc->proc_pid); | VERB(3) LOG("Parent know child pid %d", proc->proc_pid); |
| schedRead(TASK_ROOT(task), fdRx, proc, proc->proc_pty); | schedRead(TASK_ROOT(task), fdRx, proc, proc->proc_pty, NULL, 0); |
| /* if Timeout defined, go arm timer */ | /* if Timeout defined, go arm timer */ |
| if (Timeout) { | if (Timeout) { |
| tv.tv_sec = Timeout; | tv.tv_sec = Timeout; |
| schedTimer(TASK_ROOT(task), TOfunc, proc, tv); | schedTimer(TASK_ROOT(task), TOfunc, proc, tv, NULL, 0); |
| } | } |
| break; | break; |
| } | } |