Diff for /ansh/src/daemon2.c between versions 1.1.1.1.2.1 and 1.1.1.1.2.2

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 */

Removed from v.1.1.1.1.2.1  
changed lines
  Added in v.1.1.1.1.2.2


FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>