mirror/lwip
1
0
Fork 0
mirror of https://github.com/lwip-tcpip/lwip.git synced 2024-12-25 18:14:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

TFTP server handle retransmit Data packets

Browse Source 
Signed-off-by: goldsimon <goldsimon@gmx.de>
This commit is contained in:
Jens Nielsen 2018-04-23 16:04:11 +02:00 committed by goldsimon
parent 91bc7a02c9
commit c34120e855
1 changed files with 19 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/apps/tftp/tftp_server.c
View File

@ -294,18 +294,27 @@ recv(void *arg, struct udp_pcb *upcb, struct pbuf *p, const ip_addr_t *addr, u16
} }
blknum = lwip_ntohs(sbuf[1]); blknum = lwip_ntohs(sbuf[1]);
pbuf_remove_header(p, TFTP_HEADER_LENGTH); if (blknum == tftp_state.blknum) {
pbuf_remove_header(p, TFTP_HEADER_LENGTH);
ret = tftp_state.ctx->write(tftp_state.handle, p); ret = tftp_state.ctx->write(tftp_state.handle, p);
if (ret < 0) { if (ret < 0) {
send_error(addr, port, TFTP_ERROR_ACCESS_VIOLATION, "error writing file"); send_error(addr, port, TFTP_ERROR_ACCESS_VIOLATION, "error writing file");
close_handle(); close_handle();
} else { } else {
send_ack(blknum);
}
if (p->tot_len < TFTP_MAX_PAYLOAD_SIZE) {
close_handle();
} else {
tftp_state.blknum++;
}
} else if ((u16_t)(blknum + 1) == tftp_state.blknum) {
/* retransmit of previous block, ack again (casting to u16_t to care for overflow) */
send_ack(blknum); send_ack(blknum);
} } else {
send_error(addr, port, TFTP_ERROR_UNKNOWN_TRFR_ID, "Wrong block number");
if (p->tot_len < TFTP_MAX_PAYLOAD_SIZE) {
close_handle();
} }
break; break;
} }