|
|
| version 1.4.2.2, 2014/02/21 08:40:00 | version 1.5, 2014/02/21 09:02:28 |
|---|---|
| Line 76 txData(sched_task_t *task) | Line 76 txData(sched_task_t *task) |
| len = pread(cli.fd, RPACK_NEXT(pkt), len, (cli.seq - 1) * cli.siz); | len = pread(cli.fd, RPACK_NEXT(pkt), len, (cli.seq - 1) * cli.siz); |
| if (len == -1) { | if (len == -1) { |
| ESYSERR(0); | ESYSERR(0); |
| code = htole16(3); | code = htons(3); |
| goto end; | goto end; |
| } else { | } else { |
| rpack_rnext(pkt, len); | rpack_rnext(pkt, len); |
| Line 94 end: | Line 94 end: |
| n = htons(TFTP_OPC_ERROR); | n = htons(TFTP_OPC_ERROR); |
| rpack_uint16(pkt, &n, 0); | rpack_uint16(pkt, &n, 0); |
| rpack_uint16(pkt, &code, 0); | rpack_uint16(pkt, &code, 0); |
| rpack_rdata(pkt, errs[le16toh(code)].err_msg, strlen(errs[le16toh(code)].err_msg) + 1); | rpack_rdata(pkt, errs[ntohs(code)].err_msg, strlen(errs[ntohs(code)].err_msg) + 1); |
| schedEvent(TASK_ROOT(task), txPkt, (void*) -1, TASK_FD(task), | schedEvent(TASK_ROOT(task), txPkt, (void*) -1, TASK_FD(task), |
| TASK_DATA(task), RPACK_OFF(pkt)); | TASK_DATA(task), RPACK_OFF(pkt)); |
| Line 256 RQ(sched_task_t *task) | Line 256 RQ(sched_task_t *task) |
| strlcpy(cli.mode, TFTP_MODE_OCTET, sizeof cli.mode); | strlcpy(cli.mode, TFTP_MODE_OCTET, sizeof cli.mode); |
| else if (!strcasecmp(str, TFTP_MODE_MAIL)) { | else if (!strcasecmp(str, TFTP_MODE_MAIL)) { |
| strlcpy(cli.mode, TFTP_MODE_MAIL, sizeof cli.mode); | strlcpy(cli.mode, TFTP_MODE_MAIL, sizeof cli.mode); |
| code = htole16(4); | code = htons(4); |
| goto end; | goto end; |
| } else { | } else { |
| code = htole16(1); | code = htons(1); |
| goto end; | goto end; |
| } | } |
| } | } |
| Line 281 RQ(sched_task_t *task) | Line 281 RQ(sched_task_t *task) |
| cli.fd = open(cli.file, code, 0644); | cli.fd = open(cli.file, code, 0644); |
| if (cli.fd == -1) { | if (cli.fd == -1) { |
| if (errno == EACCES) | if (errno == EACCES) |
| code = htole16(2); | code = htons(2); |
| else if (errno == ENFILE) | else if (errno == ENFILE) |
| code = htole16(3); | code = htons(3); |
| else if (errno == EEXIST) | else if (errno == EEXIST) |
| code = htole16(6); | code = htons(6); |
| else | else |
| code = htole16(0); | code = htons(0); |
| ESYSERR(0); | ESYSERR(0); |
| goto end; | goto end; |
| } else | } else |
| Line 330 end: | Line 330 end: |
| RPACK_REWIND(pkt); | RPACK_REWIND(pkt); |
| rpack_uint16(pkt, NULL, 0); | rpack_uint16(pkt, NULL, 0); |
| rpack_uint16(pkt, &code, 0); | rpack_uint16(pkt, &code, 0); |
| rpack_rdata(pkt, errs[le16toh(code)].err_msg, strlen(errs[le16toh(code)].err_msg) + 1); | rpack_rdata(pkt, errs[ntohs(code)].err_msg, strlen(errs[ntohs(code)].err_msg) + 1); |
| schedEvent(TASK_ROOT(task), txPkt, (void*) -1, TASK_FD(task), | schedEvent(TASK_ROOT(task), txPkt, (void*) -1, TASK_FD(task), |
| TASK_DATA(task), RPACK_OFF(pkt)); | TASK_DATA(task), RPACK_OFF(pkt)); |
| Line 349 ACK(sched_task_t *task) | Line 349 ACK(sched_task_t *task) |
| RPACK_REWIND(pkt); | RPACK_REWIND(pkt); |
| code = rpack_uint16(pkt, NULL, 0); | code = rpack_uint16(pkt, NULL, 0); |
| if (ntohs(code) != TFTP_OPC_ACK) { | if (ntohs(code) != TFTP_OPC_ACK) { |
| code = htole16(5); | code = htons(5); |
| goto end; | goto end; |
| } | } |
| code = rpack_uint16(pkt, NULL, 0); | code = rpack_uint16(pkt, NULL, 0); |
| if (ntohs(code) > cli.seq || (ntohs(code) < (cli.seq - 1))) { | if (ntohs(code) > cli.seq || (ntohs(code) < (cli.seq - 1))) { |
| code = htole16(5); | code = htons(5); |
| goto end; | goto end; |
| } else if (ntohs(code) == cli.seq) { | } else if (ntohs(code) == cli.seq) { |
| /* check for rollover seq id */ | /* check for rollover seq id */ |
| Line 382 end: | Line 382 end: |
| RPACK_REWIND(pkt); | RPACK_REWIND(pkt); |
| rpack_uint16(pkt, NULL, 0); | rpack_uint16(pkt, NULL, 0); |
| rpack_uint16(pkt, &code, 0); | rpack_uint16(pkt, &code, 0); |
| rpack_rdata(pkt, errs[le16toh(code)].err_msg, strlen(errs[le16toh(code)].err_msg) + 1); | rpack_rdata(pkt, errs[ntohs(code)].err_msg, strlen(errs[ntohs(code)].err_msg) + 1); |
| schedEvent(TASK_ROOT(task), txPkt, (void*) -1, TASK_FD(task), | schedEvent(TASK_ROOT(task), txPkt, (void*) -1, TASK_FD(task), |
| TASK_DATA(task), RPACK_OFF(pkt)); | TASK_DATA(task), RPACK_OFF(pkt)); |
| Line 402 DATA(sched_task_t *task) | Line 402 DATA(sched_task_t *task) |
| RPACK_REWIND(pkt); | RPACK_REWIND(pkt); |
| code = rpack_uint16(pkt, NULL, 0); | code = rpack_uint16(pkt, NULL, 0); |
| if (ntohs(code) != TFTP_OPC_DATA) { | if (ntohs(code) != TFTP_OPC_DATA) { |
| code = htole16(5); | code = htons(5); |
| goto end; | goto end; |
| } | } |
| code = rpack_uint16(pkt, NULL, 0); | code = rpack_uint16(pkt, NULL, 0); |
| if (ntohs(code) < cli.seq || ntohs(code) > cli.seq + 1) { | if (ntohs(code) < cli.seq || ntohs(code) > cli.seq + 1) { |
| code = htole16(5); | code = htons(5); |
| goto end; | goto end; |
| } else | } else |
| cli.seq = ntohs(code); | cli.seq = ntohs(code); |
| Line 425 DATA(sched_task_t *task) | Line 425 DATA(sched_task_t *task) |
| len = pwrite(cli.fd, RPACK_NEXT(pkt), len, (cli.seq - 1) * cli.siz); | len = pwrite(cli.fd, RPACK_NEXT(pkt), len, (cli.seq - 1) * cli.siz); |
| if (len == -1) { | if (len == -1) { |
| ESYSERR(0); | ESYSERR(0); |
| code = htole16(3); | code = htons(3); |
| goto end; | goto end; |
| } else { | } else { |
| rpack_rnext(pkt, len); | rpack_rnext(pkt, len); |
| Line 439 end: | Line 439 end: |
| RPACK_REWIND(pkt); | RPACK_REWIND(pkt); |
| rpack_uint16(pkt, NULL, 0); | rpack_uint16(pkt, NULL, 0); |
| rpack_uint16(pkt, &code, 0); | rpack_uint16(pkt, &code, 0); |
| rpack_rdata(pkt, errs[le16toh(code)].err_msg, strlen(errs[le16toh(code)].err_msg) + 1); | rpack_rdata(pkt, errs[ntohs(code)].err_msg, strlen(errs[ntohs(code)].err_msg) + 1); |
| schedEvent(TASK_ROOT(task), txPkt, (void*) -1, TASK_FD(task), | schedEvent(TASK_ROOT(task), txPkt, (void*) -1, TASK_FD(task), |
| TASK_DATA(task), RPACK_OFF(pkt)); | TASK_DATA(task), RPACK_OFF(pkt)); |
| Line 477 rxPkt(sched_task_t *task) | Line 477 rxPkt(sched_task_t *task) |
| RPACK_REWIND(pkt); | RPACK_REWIND(pkt); |
| code = htons(TFTP_OPC_ERROR); | code = htons(TFTP_OPC_ERROR); |
| rpack_uint16(pkt, &code, 0); | rpack_uint16(pkt, &code, 0); |
| code = htole16(4); | code = htons(4); |
| rpack_uint16(pkt, &code, 0); | rpack_uint16(pkt, &code, 0); |
| rpack_rdata(pkt, errs[4].err_msg, strlen(errs[4].err_msg) + 1); | rpack_rdata(pkt, errs[4].err_msg, strlen(errs[4].err_msg) + 1); |
| Line 505 rxPkt(sched_task_t *task) | Line 505 rxPkt(sched_task_t *task) |
| RPACK_REWIND(pkt); | RPACK_REWIND(pkt); |
| code = htons(TFTP_OPC_ERROR); | code = htons(TFTP_OPC_ERROR); |
| rpack_uint16(pkt, &code, 0); | rpack_uint16(pkt, &code, 0); |
| code = htole16(4); | code = htons(4); |
| rpack_uint16(pkt, &code, 0); | rpack_uint16(pkt, &code, 0); |
| rpack_rdata(pkt, errs[4].err_msg, strlen(errs[4].err_msg) + 1); | rpack_rdata(pkt, errs[4].err_msg, strlen(errs[4].err_msg) + 1); |