|
|
| version 1.7.2.1, 2014/02/24 21:55:35 | version 1.7.2.3, 2014/02/24 22:21:46 |
|---|---|
| Line 171 txAck(sched_task_t *task) | Line 171 txAck(sched_task_t *task) |
| schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_CALL, timeoutSession, NULL); | schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_CALL, timeoutSession, NULL); |
| schedEvent(TASK_ROOT(task), timeoutSession, NULL, 0, TASK_DATA(task), 0); | schedEvent(TASK_ROOT(task), timeoutSession, NULL, 0, TASK_DATA(task), 0); |
| EVERBOSE(2, "Finish WRQ request"); | EVERBOSE(2, "Finish WRQ request"); |
| schedResumeby(TASK_ROOT(task), CRITERIA_ID, 0); | |
| } | } |
| taskExit(task, NULL); | taskExit(task, NULL); |
| } | } |
| Line 477 DATA(sched_task_t *task) | Line 478 DATA(sched_task_t *task) |
| EVERBOSE(3, "DATA:: seq=%hu; len=%d", cli.seq, len); | EVERBOSE(3, "DATA:: seq=%hu; len=%d", cli.seq, len); |
| if (!bf) | if (len > 0) { |
| len = pwrite(cli.fd, RPACK_NEXT(pkt), len, (cli.seq - 1) * cli.siz); | if (!bf) |
| else | len = pwrite(cli.fd, RPACK_NEXT(pkt), len, (cli.seq - 1) * cli.siz); |
| len = bfwrite(cli.fd, RPACK_NEXT(pkt), len); | else |
| if (len == -1) { | len = bfwrite(cli.fd, RPACK_NEXT(pkt), len); |
| ESYSERR(0); | if (len == -1) { |
| code = htons(3); | ESYSERR(0); |
| goto end; | code = htons(3); |
| } else { | goto end; |
| rpack_rnext(pkt, len); | } else |
| EVERBOSE(3, "Written to file %s %d bytes", cli.file, len); | rpack_rnext(pkt, len); |
| } | } |
| EVERBOSE(3, "Written to file %s %d bytes", cli.file, len); | |
| schedEvent(TASK_ROOT(task), txAck, NULL, TASK_FD(task), TASK_DATA(task), 0); | schedEvent(TASK_ROOT(task), txAck, NULL, TASK_FD(task), TASK_DATA(task), 0); |
| taskExit(task, NULL); | taskExit(task, NULL); |