|
|
| version 1.7.2.2, 2014/02/24 22:02:19 | version 1.7.2.3, 2014/02/24 22:21:46 |
|---|---|
| Line 478 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); |