]>
Commit | Line | Data |
---|---|---|
fe8c2806 | 1 | /* |
2f09413f LC |
2 | * Copyright 1994, 1995, 2000 Neil Russell. |
3 | * (See License) | |
4 | * Copyright 2000, 2001 DENX Software Engineering, Wolfgang Denk, [email protected] | |
e59e3562 LC |
5 | * Copyright 2011 Comelit Group SpA, |
6 | * Luca Ceresoli <[email protected]> | |
fe8c2806 WD |
7 | */ |
8 | ||
9 | #include <common.h> | |
10 | #include <command.h> | |
0efe1bcf | 11 | #include <efi_loader.h> |
55d5fd9a | 12 | #include <mapmem.h> |
fe8c2806 | 13 | #include <net.h> |
34696958 | 14 | #include <net/tftp.h> |
fe8c2806 | 15 | #include "bootp.h" |
13dfe943 JH |
16 | #ifdef CONFIG_SYS_DIRECT_FLASH_TFTP |
17 | #include <flash.h> | |
18 | #endif | |
fe8c2806 | 19 | |
a156c47e SG |
20 | DECLARE_GLOBAL_DATA_PTR; |
21 | ||
2f09413f LC |
22 | /* Well known TFTP port # */ |
23 | #define WELL_KNOWN_PORT 69 | |
24 | /* Millisecs to timeout for lost pkt */ | |
af2ca59e | 25 | #define TIMEOUT 5000UL |
fe8c2806 | 26 | #ifndef CONFIG_NET_RETRY_COUNT |
2f09413f | 27 | /* # of timeouts before giving up */ |
af2ca59e | 28 | # define TIMEOUT_COUNT 10 |
fe8c2806 WD |
29 | #else |
30 | # define TIMEOUT_COUNT (CONFIG_NET_RETRY_COUNT * 2) | |
31 | #endif | |
2f09413f LC |
32 | /* Number of "loading" hashes per line (for checking the image size) */ |
33 | #define HASHES_PER_LINE 65 | |
fe8c2806 WD |
34 | |
35 | /* | |
36 | * TFTP operations. | |
37 | */ | |
38 | #define TFTP_RRQ 1 | |
39 | #define TFTP_WRQ 2 | |
40 | #define TFTP_DATA 3 | |
41 | #define TFTP_ACK 4 | |
42 | #define TFTP_ERROR 5 | |
fbe4b5cb | 43 | #define TFTP_OACK 6 |
fe8c2806 | 44 | |
8885c5fe JH |
45 | static ulong timeout_ms = TIMEOUT; |
46 | static int timeout_count_max = TIMEOUT_COUNT; | |
85b19802 | 47 | static ulong time_start; /* Record time we started tftp */ |
e83cc063 BS |
48 | |
49 | /* | |
50 | * These globals govern the timeout behavior when attempting a connection to a | |
8885c5fe | 51 | * TFTP server. tftp_timeout_ms specifies the number of milliseconds to |
e83cc063 | 52 | * wait for the server to respond to initial connection. Second global, |
8885c5fe JH |
53 | * tftp_timeout_count_max, gives the number of such connection retries. |
54 | * tftp_timeout_count_max must be non-negative and tftp_timeout_ms must be | |
e83cc063 BS |
55 | * positive. The globals are meant to be set (and restored) by code needing |
56 | * non-standard timeout behavior when initiating a TFTP transfer. | |
57 | */ | |
8885c5fe JH |
58 | ulong tftp_timeout_ms = TIMEOUT; |
59 | int tftp_timeout_count_max = TIMEOUT_COUNT; | |
e83cc063 | 60 | |
aafda38f RB |
61 | enum { |
62 | TFTP_ERR_UNDEFINED = 0, | |
63 | TFTP_ERR_FILE_NOT_FOUND = 1, | |
64 | TFTP_ERR_ACCESS_DENIED = 2, | |
65 | TFTP_ERR_DISK_FULL = 3, | |
66 | TFTP_ERR_UNEXPECTED_OPCODE = 4, | |
67 | TFTP_ERR_UNKNOWN_TRANSFER_ID = 5, | |
68 | TFTP_ERR_FILE_ALREADY_EXISTS = 6, | |
69 | }; | |
70 | ||
049a95a7 | 71 | static struct in_addr tftp_remote_ip; |
2f09413f | 72 | /* The UDP port at their end */ |
8885c5fe | 73 | static int tftp_remote_port; |
2f09413f | 74 | /* The UDP port at our end */ |
8885c5fe JH |
75 | static int tftp_our_port; |
76 | static int timeout_count; | |
2f09413f | 77 | /* packet sequence number */ |
8885c5fe | 78 | static ulong tftp_cur_block; |
2f09413f | 79 | /* last packet sequence number received */ |
8885c5fe | 80 | static ulong tftp_prev_block; |
2f09413f | 81 | /* count of sequence number wraparounds */ |
8885c5fe | 82 | static ulong tftp_block_wrap; |
2f09413f | 83 | /* memory offset due to wrapping */ |
8885c5fe JH |
84 | static ulong tftp_block_wrap_offset; |
85 | static int tftp_state; | |
a156c47e SG |
86 | static ulong tftp_load_addr; |
87 | #ifdef CONFIG_LMB | |
88 | static ulong tftp_load_size; | |
89 | #endif | |
4fccb818 | 90 | #ifdef CONFIG_TFTP_TSIZE |
2f09413f | 91 | /* The file size reported by the server */ |
8885c5fe | 92 | static int tftp_tsize; |
2f09413f | 93 | /* The number of hashes we printed */ |
8885c5fe | 94 | static short tftp_tsize_num_hash; |
4fccb818 | 95 | #endif |
1fb7cd49 | 96 | #ifdef CONFIG_CMD_TFTPPUT |
8885c5fe JH |
97 | /* 1 if writing, else 0 */ |
98 | static int tftp_put_active; | |
99 | /* 1 if we have sent the last block */ | |
100 | static int tftp_put_final_block_sent; | |
1fb7cd49 | 101 | #else |
8885c5fe | 102 | #define tftp_put_active 0 |
1fb7cd49 | 103 | #endif |
3f85ce27 | 104 | |
e3fb0abe | 105 | #define STATE_SEND_RRQ 1 |
fe8c2806 WD |
106 | #define STATE_DATA 2 |
107 | #define STATE_TOO_LARGE 3 | |
108 | #define STATE_BAD_MAGIC 4 | |
fbe4b5cb | 109 | #define STATE_OACK 5 |
e59e3562 | 110 | #define STATE_RECV_WRQ 6 |
1fb7cd49 | 111 | #define STATE_SEND_WRQ 7 |
fe8c2806 | 112 | |
2f09413f LC |
113 | /* default TFTP block size */ |
114 | #define TFTP_BLOCK_SIZE 512 | |
115 | /* sequence number is 16 bit */ | |
116 | #define TFTP_SEQUENCE_SIZE ((ulong)(1<<16)) | |
3f85ce27 | 117 | |
fe8c2806 WD |
118 | #define DEFAULT_NAME_LEN (8 + 4 + 1) |
119 | static char default_filename[DEFAULT_NAME_LEN]; | |
a93907c4 JCPV |
120 | |
121 | #ifndef CONFIG_TFTP_FILE_NAME_MAX_LEN | |
122 | #define MAX_LEN 128 | |
123 | #else | |
124 | #define MAX_LEN CONFIG_TFTP_FILE_NAME_MAX_LEN | |
125 | #endif | |
126 | ||
127 | static char tftp_filename[MAX_LEN]; | |
fe8c2806 | 128 | |
85eb5caf WD |
129 | /* 512 is poor choice for ethernet, MTU is typically 1500. |
130 | * Minus eth.hdrs thats 1468. Can get 2x better throughput with | |
53a5c424 | 131 | * almost-MTU block sizes. At least try... fall back to 512 if need be. |
89ba81d1 | 132 | * (but those using CONFIG_IP_DEFRAG may want to set a larger block in cfg file) |
53a5c424 | 133 | */ |
89ba81d1 AR |
134 | #ifdef CONFIG_TFTP_BLOCKSIZE |
135 | #define TFTP_MTU_BLOCKSIZE CONFIG_TFTP_BLOCKSIZE | |
136 | #else | |
53a5c424 | 137 | #define TFTP_MTU_BLOCKSIZE 1468 |
89ba81d1 AR |
138 | #endif |
139 | ||
8885c5fe JH |
140 | static unsigned short tftp_block_size = TFTP_BLOCK_SIZE; |
141 | static unsigned short tftp_block_size_option = TFTP_MTU_BLOCKSIZE; | |
53a5c424 | 142 | |
a156c47e | 143 | static inline int store_block(int block, uchar *src, unsigned int len) |
fe8c2806 | 144 | { |
8885c5fe | 145 | ulong offset = block * tftp_block_size + tftp_block_wrap_offset; |
3f85ce27 | 146 | ulong newsize = offset + len; |
a156c47e | 147 | ulong store_addr = tftp_load_addr + offset; |
6d0f6bcf | 148 | #ifdef CONFIG_SYS_DIRECT_FLASH_TFTP |
fe8c2806 WD |
149 | int i, rc = 0; |
150 | ||
c718b143 | 151 | for (i = 0; i < CONFIG_SYS_MAX_FLASH_BANKS; i++) { |
fe8c2806 | 152 | /* start address in flash? */ |
be1b0d27 JF |
153 | if (flash_info[i].flash_id == FLASH_UNKNOWN) |
154 | continue; | |
a156c47e | 155 | if (store_addr >= flash_info[i].start[0]) { |
fe8c2806 WD |
156 | rc = 1; |
157 | break; | |
158 | } | |
159 | } | |
160 | ||
161 | if (rc) { /* Flash is destination for this packet */ | |
a156c47e | 162 | rc = flash_write((char *)src, store_addr, len); |
fe8c2806 | 163 | if (rc) { |
c718b143 | 164 | flash_perror(rc); |
a156c47e | 165 | return rc; |
fe8c2806 | 166 | } |
13dfe943 | 167 | } else |
6d0f6bcf | 168 | #endif /* CONFIG_SYS_DIRECT_FLASH_TFTP */ |
fe8c2806 | 169 | { |
a156c47e SG |
170 | void *ptr; |
171 | ||
172 | #ifdef CONFIG_LMB | |
173 | if (store_addr < tftp_load_addr || | |
174 | store_addr + len > tftp_load_addr + tftp_load_size) { | |
175 | puts("\nTFTP error: "); | |
176 | puts("trying to overwrite reserved memory...\n"); | |
177 | return -1; | |
178 | } | |
179 | #endif | |
180 | ptr = map_sysmem(store_addr, len); | |
55d5fd9a JH |
181 | memcpy(ptr, src, len); |
182 | unmap_sysmem(ptr); | |
fe8c2806 WD |
183 | } |
184 | ||
1411157d JH |
185 | if (net_boot_file_size < newsize) |
186 | net_boot_file_size = newsize; | |
a156c47e SG |
187 | |
188 | return 0; | |
fe8c2806 WD |
189 | } |
190 | ||
e4cde2f7 | 191 | /* Clear our state ready for a new transfer */ |
165099e7 | 192 | static void new_transfer(void) |
e4cde2f7 | 193 | { |
8885c5fe JH |
194 | tftp_prev_block = 0; |
195 | tftp_block_wrap = 0; | |
196 | tftp_block_wrap_offset = 0; | |
e4cde2f7 | 197 | #ifdef CONFIG_CMD_TFTPPUT |
8885c5fe | 198 | tftp_put_final_block_sent = 0; |
e4cde2f7 SG |
199 | #endif |
200 | } | |
201 | ||
1fb7cd49 SG |
202 | #ifdef CONFIG_CMD_TFTPPUT |
203 | /** | |
204 | * Load the next block from memory to be sent over tftp. | |
205 | * | |
206 | * @param block Block number to send | |
207 | * @param dst Destination buffer for data | |
208 | * @param len Number of bytes in block (this one and every other) | |
209 | * @return number of bytes loaded | |
210 | */ | |
211 | static int load_block(unsigned block, uchar *dst, unsigned len) | |
212 | { | |
213 | /* We may want to get the final block from the previous set */ | |
8885c5fe | 214 | ulong offset = ((int)block - 1) * len + tftp_block_wrap_offset; |
1fb7cd49 SG |
215 | ulong tosend = len; |
216 | ||
1411157d | 217 | tosend = min(net_boot_file_size - offset, tosend); |
1fb7cd49 SG |
218 | (void)memcpy(dst, (void *)(save_addr + offset), tosend); |
219 | debug("%s: block=%d, offset=%ld, len=%d, tosend=%ld\n", __func__, | |
8885c5fe | 220 | block, offset, len, tosend); |
1fb7cd49 SG |
221 | return tosend; |
222 | } | |
223 | #endif | |
224 | ||
8885c5fe JH |
225 | static void tftp_send(void); |
226 | static void tftp_timeout_handler(void); | |
fe8c2806 WD |
227 | |
228 | /**********************************************************************/ | |
229 | ||
f5329bbc SG |
230 | static void show_block_marker(void) |
231 | { | |
232 | #ifdef CONFIG_TFTP_TSIZE | |
8885c5fe JH |
233 | if (tftp_tsize) { |
234 | ulong pos = tftp_cur_block * tftp_block_size + | |
235 | tftp_block_wrap_offset; | |
7628afeb MK |
236 | if (pos > tftp_tsize) |
237 | pos = tftp_tsize; | |
f5329bbc | 238 | |
8885c5fe | 239 | while (tftp_tsize_num_hash < pos * 50 / tftp_tsize) { |
f5329bbc | 240 | putc('#'); |
8885c5fe | 241 | tftp_tsize_num_hash++; |
f5329bbc | 242 | } |
1fb7cd49 | 243 | } else |
f5329bbc | 244 | #endif |
1fb7cd49 | 245 | { |
8885c5fe | 246 | if (((tftp_cur_block - 1) % 10) == 0) |
f5329bbc | 247 | putc('#'); |
8885c5fe | 248 | else if ((tftp_cur_block % (10 * HASHES_PER_LINE)) == 0) |
f5329bbc SG |
249 | puts("\n\t "); |
250 | } | |
251 | } | |
252 | ||
e4cde2f7 SG |
253 | /** |
254 | * restart the current transfer due to an error | |
255 | * | |
256 | * @param msg Message to print for user | |
257 | */ | |
258 | static void restart(const char *msg) | |
259 | { | |
260 | printf("\n%s; starting again\n", msg); | |
bc0571fc | 261 | net_start_again(); |
e4cde2f7 SG |
262 | } |
263 | ||
264 | /* | |
265 | * Check if the block number has wrapped, and update progress | |
266 | * | |
267 | * TODO: The egregious use of global variables in this file should be tidied. | |
268 | */ | |
269 | static void update_block_number(void) | |
270 | { | |
271 | /* | |
272 | * RFC1350 specifies that the first data packet will | |
273 | * have sequence number 1. If we receive a sequence | |
274 | * number of 0 this means that there was a wrap | |
275 | * around of the (16 bit) counter. | |
276 | */ | |
8885c5fe JH |
277 | if (tftp_cur_block == 0 && tftp_prev_block != 0) { |
278 | tftp_block_wrap++; | |
279 | tftp_block_wrap_offset += tftp_block_size * TFTP_SEQUENCE_SIZE; | |
280 | timeout_count = 0; /* we've done well, reset the timeout */ | |
e4cde2f7 SG |
281 | } else { |
282 | show_block_marker(); | |
283 | } | |
284 | } | |
285 | ||
f5329bbc SG |
286 | /* The TFTP get or put is complete */ |
287 | static void tftp_complete(void) | |
288 | { | |
289 | #ifdef CONFIG_TFTP_TSIZE | |
290 | /* Print hash marks for the last packet received */ | |
8885c5fe | 291 | while (tftp_tsize && tftp_tsize_num_hash < 49) { |
f5329bbc | 292 | putc('#'); |
8885c5fe | 293 | tftp_tsize_num_hash++; |
f5329bbc | 294 | } |
8104f546 | 295 | puts(" "); |
8885c5fe | 296 | print_size(tftp_tsize, ""); |
f5329bbc | 297 | #endif |
85b19802 SG |
298 | time_start = get_timer(time_start); |
299 | if (time_start > 0) { | |
300 | puts("\n\t "); /* Line up with "Loading: " */ | |
1411157d | 301 | print_size(net_boot_file_size / |
85b19802 SG |
302 | time_start * 1000, "/s"); |
303 | } | |
f5329bbc | 304 | puts("\ndone\n"); |
22f6e99d | 305 | net_set_state(NETLOOP_SUCCESS); |
f5329bbc SG |
306 | } |
307 | ||
8885c5fe | 308 | static void tftp_send(void) |
fe8c2806 | 309 | { |
1fb7cd49 | 310 | uchar *pkt; |
db288a96 JH |
311 | uchar *xp; |
312 | int len = 0; | |
313 | ushort *s; | |
fe8c2806 WD |
314 | |
315 | /* | |
316 | * We will always be sending some sort of packet, so | |
317 | * cobble together the packet headers now. | |
318 | */ | |
1203fcce | 319 | pkt = net_tx_packet + net_eth_hdr_size() + IP_UDP_HDR_SIZE; |
fe8c2806 | 320 | |
8885c5fe | 321 | switch (tftp_state) { |
e3fb0abe | 322 | case STATE_SEND_RRQ: |
1fb7cd49 | 323 | case STATE_SEND_WRQ: |
fe8c2806 | 324 | xp = pkt; |
7bc5ee07 | 325 | s = (ushort *)pkt; |
8c6914f1 | 326 | #ifdef CONFIG_CMD_TFTPPUT |
8885c5fe | 327 | *s++ = htons(tftp_state == STATE_SEND_RRQ ? TFTP_RRQ : |
1fb7cd49 | 328 | TFTP_WRQ); |
8c6914f1 SG |
329 | #else |
330 | *s++ = htons(TFTP_RRQ); | |
331 | #endif | |
7bc5ee07 | 332 | pkt = (uchar *)s; |
c718b143 | 333 | strcpy((char *)pkt, tftp_filename); |
fe8c2806 | 334 | pkt += strlen(tftp_filename) + 1; |
c718b143 | 335 | strcpy((char *)pkt, "octet"); |
fe8c2806 | 336 | pkt += 5 /*strlen("octet")*/ + 1; |
c718b143 | 337 | strcpy((char *)pkt, "timeout"); |
fbe4b5cb | 338 | pkt += 7 /*strlen("timeout")*/ + 1; |
8885c5fe | 339 | sprintf((char *)pkt, "%lu", timeout_ms / 1000); |
0ebf04c6 | 340 | debug("send option \"timeout %s\"\n", (char *)pkt); |
fbe4b5cb | 341 | pkt += strlen((char *)pkt) + 1; |
4fccb818 | 342 | #ifdef CONFIG_TFTP_TSIZE |
1411157d JH |
343 | pkt += sprintf((char *)pkt, "tsize%c%u%c", |
344 | 0, net_boot_file_size, 0); | |
4fccb818 | 345 | #endif |
53a5c424 | 346 | /* try for more effic. blk size */ |
c718b143 | 347 | pkt += sprintf((char *)pkt, "blksize%c%d%c", |
8885c5fe | 348 | 0, tftp_block_size_option, 0); |
fe8c2806 WD |
349 | len = pkt - xp; |
350 | break; | |
351 | ||
fbe4b5cb | 352 | case STATE_OACK: |
e59e3562 LC |
353 | |
354 | case STATE_RECV_WRQ: | |
53a5c424 | 355 | case STATE_DATA: |
fe8c2806 | 356 | xp = pkt; |
7bc5ee07 | 357 | s = (ushort *)pkt; |
1fb7cd49 | 358 | s[0] = htons(TFTP_ACK); |
8885c5fe | 359 | s[1] = htons(tftp_cur_block); |
1fb7cd49 SG |
360 | pkt = (uchar *)(s + 2); |
361 | #ifdef CONFIG_CMD_TFTPPUT | |
8885c5fe JH |
362 | if (tftp_put_active) { |
363 | int toload = tftp_block_size; | |
364 | int loaded = load_block(tftp_cur_block, pkt, toload); | |
1fb7cd49 SG |
365 | |
366 | s[0] = htons(TFTP_DATA); | |
367 | pkt += loaded; | |
8885c5fe | 368 | tftp_put_final_block_sent = (loaded < toload); |
1fb7cd49 SG |
369 | } |
370 | #endif | |
fe8c2806 WD |
371 | len = pkt - xp; |
372 | break; | |
373 | ||
374 | case STATE_TOO_LARGE: | |
375 | xp = pkt; | |
7bc5ee07 WD |
376 | s = (ushort *)pkt; |
377 | *s++ = htons(TFTP_ERROR); | |
1fb7cd49 SG |
378 | *s++ = htons(3); |
379 | ||
7bc5ee07 | 380 | pkt = (uchar *)s; |
c718b143 | 381 | strcpy((char *)pkt, "File too large"); |
fe8c2806 WD |
382 | pkt += 14 /*strlen("File too large")*/ + 1; |
383 | len = pkt - xp; | |
384 | break; | |
385 | ||
386 | case STATE_BAD_MAGIC: | |
387 | xp = pkt; | |
7bc5ee07 WD |
388 | s = (ushort *)pkt; |
389 | *s++ = htons(TFTP_ERROR); | |
390 | *s++ = htons(2); | |
391 | pkt = (uchar *)s; | |
c718b143 | 392 | strcpy((char *)pkt, "File has bad magic"); |
fe8c2806 WD |
393 | pkt += 18 /*strlen("File has bad magic")*/ + 1; |
394 | len = pkt - xp; | |
395 | break; | |
396 | } | |
397 | ||
8885c5fe JH |
398 | net_send_udp_packet(net_server_ethaddr, tftp_remote_ip, |
399 | tftp_remote_port, tftp_our_port, len); | |
fe8c2806 WD |
400 | } |
401 | ||
39bccd21 | 402 | #ifdef CONFIG_CMD_TFTPPUT |
1fb7cd49 | 403 | static void icmp_handler(unsigned type, unsigned code, unsigned dest, |
049a95a7 JH |
404 | struct in_addr sip, unsigned src, uchar *pkt, |
405 | unsigned len) | |
1fb7cd49 SG |
406 | { |
407 | if (type == ICMP_NOT_REACH && code == ICMP_NOT_REACH_PORT) { | |
408 | /* Oh dear the other end has gone away */ | |
409 | restart("TFTP server died"); | |
410 | } | |
411 | } | |
39bccd21 | 412 | #endif |
1fb7cd49 | 413 | |
049a95a7 JH |
414 | static void tftp_handler(uchar *pkt, unsigned dest, struct in_addr sip, |
415 | unsigned src, unsigned len) | |
fe8c2806 | 416 | { |
61fdd4f7 KP |
417 | __be16 proto; |
418 | __be16 *s; | |
ff13ac8c | 419 | int i; |
fe8c2806 | 420 | |
8885c5fe | 421 | if (dest != tftp_our_port) { |
0bdd8acc | 422 | return; |
fe8c2806 | 423 | } |
8885c5fe JH |
424 | if (tftp_state != STATE_SEND_RRQ && src != tftp_remote_port && |
425 | tftp_state != STATE_RECV_WRQ && tftp_state != STATE_SEND_WRQ) | |
fe8c2806 | 426 | return; |
fe8c2806 | 427 | |
7bc325a1 | 428 | if (len < 2) |
fe8c2806 | 429 | return; |
fe8c2806 WD |
430 | len -= 2; |
431 | /* warning: don't use increment (++) in ntohs() macros!! */ | |
61fdd4f7 | 432 | s = (__be16 *)pkt; |
7bc5ee07 WD |
433 | proto = *s++; |
434 | pkt = (uchar *)s; | |
fe8c2806 | 435 | switch (ntohs(proto)) { |
fe8c2806 | 436 | case TFTP_RRQ: |
1fb7cd49 SG |
437 | break; |
438 | ||
fe8c2806 | 439 | case TFTP_ACK: |
1fb7cd49 | 440 | #ifdef CONFIG_CMD_TFTPPUT |
8885c5fe JH |
441 | if (tftp_put_active) { |
442 | if (tftp_put_final_block_sent) { | |
1fb7cd49 SG |
443 | tftp_complete(); |
444 | } else { | |
445 | /* | |
446 | * Move to the next block. We want our block | |
447 | * count to wrap just like the other end! | |
448 | */ | |
449 | int block = ntohs(*s); | |
8885c5fe | 450 | int ack_ok = (tftp_cur_block == block); |
1fb7cd49 | 451 | |
8885c5fe | 452 | tftp_cur_block = (unsigned short)(block + 1); |
1fb7cd49 SG |
453 | update_block_number(); |
454 | if (ack_ok) | |
8885c5fe | 455 | tftp_send(); /* Send next data block */ |
1fb7cd49 SG |
456 | } |
457 | } | |
458 | #endif | |
fe8c2806 | 459 | break; |
1fb7cd49 | 460 | |
fe8c2806 WD |
461 | default: |
462 | break; | |
463 | ||
e59e3562 LC |
464 | #ifdef CONFIG_CMD_TFTPSRV |
465 | case TFTP_WRQ: | |
466 | debug("Got WRQ\n"); | |
049a95a7 | 467 | tftp_remote_ip = sip; |
8885c5fe JH |
468 | tftp_remote_port = src; |
469 | tftp_our_port = 1024 + (get_timer(0) % 3072); | |
e4cde2f7 | 470 | new_transfer(); |
8885c5fe | 471 | tftp_send(); /* Send ACK(0) */ |
e59e3562 LC |
472 | break; |
473 | #endif | |
474 | ||
fbe4b5cb | 475 | case TFTP_OACK: |
d371708a | 476 | debug("Got OACK: %s %s\n", |
8885c5fe JH |
477 | pkt, pkt + strlen((char *)pkt) + 1); |
478 | tftp_state = STATE_OACK; | |
479 | tftp_remote_port = src; | |
60174746 WD |
480 | /* |
481 | * Check for 'blksize' option. | |
482 | * Careful: "i" is signed, "len" is unsigned, thus | |
483 | * something like "len-8" may give a *huge* number | |
484 | */ | |
c718b143 | 485 | for (i = 0; i+8 < len; i++) { |
8885c5fe JH |
486 | if (strcmp((char *)pkt + i, "blksize") == 0) { |
487 | tftp_block_size = (unsigned short) | |
488 | simple_strtoul((char *)pkt + i + 8, | |
489 | NULL, 10); | |
0ebf04c6 | 490 | debug("Blocksize ack: %s, %d\n", |
8885c5fe | 491 | (char *)pkt + i + 8, tftp_block_size); |
ff13ac8c | 492 | } |
4fccb818 | 493 | #ifdef CONFIG_TFTP_TSIZE |
2e320257 | 494 | if (strcmp((char *)pkt+i, "tsize") == 0) { |
8885c5fe | 495 | tftp_tsize = simple_strtoul((char *)pkt + i + 6, |
2f09413f | 496 | NULL, 10); |
4fccb818 | 497 | debug("size = %s, %d\n", |
8885c5fe | 498 | (char *)pkt + i + 6, tftp_tsize); |
4fccb818 RG |
499 | } |
500 | #endif | |
53a5c424 | 501 | } |
1fb7cd49 | 502 | #ifdef CONFIG_CMD_TFTPPUT |
8885c5fe | 503 | if (tftp_put_active) { |
1fb7cd49 | 504 | /* Get ready to send the first block */ |
8885c5fe JH |
505 | tftp_state = STATE_DATA; |
506 | tftp_cur_block++; | |
1fb7cd49 SG |
507 | } |
508 | #endif | |
8885c5fe | 509 | tftp_send(); /* Send ACK or first data block */ |
fbe4b5cb | 510 | break; |
fe8c2806 WD |
511 | case TFTP_DATA: |
512 | if (len < 2) | |
513 | return; | |
514 | len -= 2; | |
8885c5fe | 515 | tftp_cur_block = ntohs(*(__be16 *)pkt); |
3f85ce27 | 516 | |
e4cde2f7 | 517 | update_block_number(); |
fe8c2806 | 518 | |
8885c5fe | 519 | if (tftp_state == STATE_SEND_RRQ) |
0ebf04c6 | 520 | debug("Server did not acknowledge timeout option!\n"); |
fbe4b5cb | 521 | |
8885c5fe JH |
522 | if (tftp_state == STATE_SEND_RRQ || tftp_state == STATE_OACK || |
523 | tftp_state == STATE_RECV_WRQ) { | |
3f85ce27 | 524 | /* first block received */ |
8885c5fe JH |
525 | tftp_state = STATE_DATA; |
526 | tftp_remote_port = src; | |
e4cde2f7 | 527 | new_transfer(); |
fe8c2806 | 528 | |
8885c5fe JH |
529 | if (tftp_cur_block != 1) { /* Assertion */ |
530 | puts("\nTFTP error: "); | |
531 | printf("First block is not block 1 (%ld)\n", | |
532 | tftp_cur_block); | |
533 | puts("Starting again\n\n"); | |
bc0571fc | 534 | net_start_again(); |
fe8c2806 WD |
535 | break; |
536 | } | |
537 | } | |
538 | ||
8885c5fe JH |
539 | if (tftp_cur_block == tftp_prev_block) { |
540 | /* Same block again; ignore it. */ | |
fe8c2806 WD |
541 | break; |
542 | } | |
543 | ||
8885c5fe | 544 | tftp_prev_block = tftp_cur_block; |
f5fb7346 | 545 | timeout_count_max = tftp_timeout_count_max; |
bc0571fc | 546 | net_set_timeout_handler(timeout_ms, tftp_timeout_handler); |
fe8c2806 | 547 | |
a156c47e SG |
548 | if (store_block(tftp_cur_block - 1, pkt + 2, len)) { |
549 | eth_halt(); | |
550 | net_set_state(NETLOOP_FAIL); | |
551 | break; | |
552 | } | |
fe8c2806 WD |
553 | |
554 | /* | |
4d69e98c | 555 | * Acknowledge the block just received, which will prompt |
20478cea | 556 | * the remote for the next one. |
fe8c2806 | 557 | */ |
8885c5fe | 558 | tftp_send(); |
fe8c2806 | 559 | |
8885c5fe | 560 | if (len < tftp_block_size) |
f5329bbc | 561 | tftp_complete(); |
fe8c2806 WD |
562 | break; |
563 | ||
564 | case TFTP_ERROR: | |
c718b143 | 565 | printf("\nTFTP error: '%s' (%d)\n", |
61fdd4f7 | 566 | pkt + 2, ntohs(*(__be16 *)pkt)); |
aafda38f | 567 | |
61fdd4f7 | 568 | switch (ntohs(*(__be16 *)pkt)) { |
aafda38f RB |
569 | case TFTP_ERR_FILE_NOT_FOUND: |
570 | case TFTP_ERR_ACCESS_DENIED: | |
571 | puts("Not retrying...\n"); | |
572 | eth_halt(); | |
22f6e99d | 573 | net_set_state(NETLOOP_FAIL); |
aafda38f RB |
574 | break; |
575 | case TFTP_ERR_UNDEFINED: | |
576 | case TFTP_ERR_DISK_FULL: | |
577 | case TFTP_ERR_UNEXPECTED_OPCODE: | |
578 | case TFTP_ERR_UNKNOWN_TRANSFER_ID: | |
579 | case TFTP_ERR_FILE_ALREADY_EXISTS: | |
580 | default: | |
581 | puts("Starting again\n\n"); | |
bc0571fc | 582 | net_start_again(); |
aafda38f RB |
583 | break; |
584 | } | |
fe8c2806 WD |
585 | break; |
586 | } | |
587 | } | |
588 | ||
589 | ||
8885c5fe | 590 | static void tftp_timeout_handler(void) |
fe8c2806 | 591 | { |
8885c5fe | 592 | if (++timeout_count > timeout_count_max) { |
e4cde2f7 | 593 | restart("Retry count exceeded"); |
fe8c2806 | 594 | } else { |
c718b143 | 595 | puts("T "); |
bc0571fc | 596 | net_set_timeout_handler(timeout_ms, tftp_timeout_handler); |
8885c5fe JH |
597 | if (tftp_state != STATE_RECV_WRQ) |
598 | tftp_send(); | |
fe8c2806 WD |
599 | } |
600 | } | |
601 | ||
a156c47e SG |
602 | /* Initialize tftp_load_addr and tftp_load_size from load_addr and lmb */ |
603 | static int tftp_init_load_addr(void) | |
604 | { | |
605 | #ifdef CONFIG_LMB | |
606 | struct lmb lmb; | |
607 | phys_size_t max_size; | |
608 | ||
9cc2323f | 609 | lmb_init_and_reserve(&lmb, gd->bd, (void *)gd->fdt_blob); |
a156c47e | 610 | |
65304aad | 611 | max_size = lmb_get_free_size(&lmb, load_addr); |
a156c47e SG |
612 | if (!max_size) |
613 | return -1; | |
614 | ||
615 | tftp_load_size = max_size; | |
616 | #endif | |
617 | tftp_load_addr = load_addr; | |
618 | return 0; | |
619 | } | |
fe8c2806 | 620 | |
8885c5fe | 621 | void tftp_start(enum proto_t protocol) |
fe8c2806 | 622 | { |
f5fb7346 | 623 | #if CONFIG_NET_TFTP_VARS |
ecb0ccd9 | 624 | char *ep; /* Environment pointer */ |
89ba81d1 | 625 | |
c96f86ee WD |
626 | /* |
627 | * Allow the user to choose TFTP blocksize and timeout. | |
628 | * TFTP protocol has a minimal timeout of 1 second. | |
629 | */ | |
f5fb7346 | 630 | |
00caae6d | 631 | ep = env_get("tftpblocksize"); |
2cb53608 | 632 | if (ep != NULL) |
8885c5fe | 633 | tftp_block_size_option = simple_strtol(ep, NULL, 10); |
c96f86ee | 634 | |
00caae6d | 635 | ep = env_get("tftptimeout"); |
2cb53608 | 636 | if (ep != NULL) |
8885c5fe | 637 | timeout_ms = simple_strtol(ep, NULL, 10); |
c96f86ee | 638 | |
af2ca59e BM |
639 | if (timeout_ms < 1000) { |
640 | printf("TFTP timeout (%ld ms) too low, set min = 1000 ms\n", | |
8885c5fe | 641 | timeout_ms); |
af2ca59e | 642 | timeout_ms = 1000; |
c96f86ee WD |
643 | } |
644 | ||
00caae6d | 645 | ep = env_get("tftptimeoutcountmax"); |
f5fb7346 AA |
646 | if (ep != NULL) |
647 | tftp_timeout_count_max = simple_strtol(ep, NULL, 10); | |
648 | ||
649 | if (tftp_timeout_count_max < 0) { | |
650 | printf("TFTP timeout count max (%d ms) negative, set to 0\n", | |
651 | tftp_timeout_count_max); | |
652 | tftp_timeout_count_max = 0; | |
653 | } | |
654 | #endif | |
655 | ||
c96f86ee | 656 | debug("TFTP blocksize = %i, timeout = %ld ms\n", |
8885c5fe | 657 | tftp_block_size_option, timeout_ms); |
ecb0ccd9 | 658 | |
049a95a7 | 659 | tftp_remote_ip = net_server_ip; |
6ab12830 | 660 | if (!net_parse_bootfile(&tftp_remote_ip, tftp_filename, MAX_LEN)) { |
ea45cb0a | 661 | sprintf(default_filename, "%02X%02X%02X%02X.img", |
049a95a7 JH |
662 | net_ip.s_addr & 0xFF, |
663 | (net_ip.s_addr >> 8) & 0xFF, | |
664 | (net_ip.s_addr >> 16) & 0xFF, | |
665 | (net_ip.s_addr >> 24) & 0xFF); | |
a93907c4 | 666 | |
0c17b1b7 VZ |
667 | strncpy(tftp_filename, default_filename, DEFAULT_NAME_LEN); |
668 | tftp_filename[DEFAULT_NAME_LEN - 1] = 0; | |
fe8c2806 | 669 | |
c718b143 | 670 | printf("*** Warning: no boot file name; using '%s'\n", |
8885c5fe | 671 | tftp_filename); |
fe8c2806 WD |
672 | } |
673 | ||
c718b143 | 674 | printf("Using %s device\n", eth_get_name()); |
1fb7cd49 | 675 | printf("TFTP %s server %pI4; our IP address is %pI4", |
8c6914f1 SG |
676 | #ifdef CONFIG_CMD_TFTPPUT |
677 | protocol == TFTPPUT ? "to" : "from", | |
678 | #else | |
8885c5fe | 679 | "from", |
8c6914f1 | 680 | #endif |
8885c5fe | 681 | &tftp_remote_ip, &net_ip); |
fe8c2806 WD |
682 | |
683 | /* Check if we need to send across this subnet */ | |
049a95a7 JH |
684 | if (net_gateway.s_addr && net_netmask.s_addr) { |
685 | struct in_addr our_net; | |
686 | struct in_addr remote_net; | |
687 | ||
688 | our_net.s_addr = net_ip.s_addr & net_netmask.s_addr; | |
689 | remote_net.s_addr = tftp_remote_ip.s_addr & net_netmask.s_addr; | |
690 | if (our_net.s_addr != remote_net.s_addr) | |
691 | printf("; sending through gateway %pI4", &net_gateway); | |
fe8c2806 | 692 | } |
c718b143 | 693 | putc('\n'); |
fe8c2806 | 694 | |
c718b143 | 695 | printf("Filename '%s'.", tftp_filename); |
fe8c2806 | 696 | |
1411157d JH |
697 | if (net_boot_file_expected_size_in_blocks) { |
698 | printf(" Size is 0x%x Bytes = ", | |
699 | net_boot_file_expected_size_in_blocks << 9); | |
700 | print_size(net_boot_file_expected_size_in_blocks << 9, ""); | |
fe8c2806 WD |
701 | } |
702 | ||
c718b143 | 703 | putc('\n'); |
1fb7cd49 | 704 | #ifdef CONFIG_CMD_TFTPPUT |
8885c5fe JH |
705 | tftp_put_active = (protocol == TFTPPUT); |
706 | if (tftp_put_active) { | |
1fb7cd49 SG |
707 | printf("Save address: 0x%lx\n", save_addr); |
708 | printf("Save size: 0x%lx\n", save_size); | |
1411157d | 709 | net_boot_file_size = save_size; |
1fb7cd49 | 710 | puts("Saving: *\b"); |
8885c5fe | 711 | tftp_state = STATE_SEND_WRQ; |
1fb7cd49 SG |
712 | new_transfer(); |
713 | } else | |
714 | #endif | |
715 | { | |
a156c47e SG |
716 | if (tftp_init_load_addr()) { |
717 | eth_halt(); | |
718 | net_set_state(NETLOOP_FAIL); | |
719 | puts("\nTFTP error: "); | |
720 | puts("trying to overwrite reserved memory...\n"); | |
721 | return; | |
722 | } | |
723 | printf("Load address: 0x%lx\n", tftp_load_addr); | |
1fb7cd49 | 724 | puts("Loading: *\b"); |
8885c5fe | 725 | tftp_state = STATE_SEND_RRQ; |
64b8d7a6 | 726 | #ifdef CONFIG_CMD_BOOTEFI |
0efe1bcf | 727 | efi_set_bootdev("Net", "", tftp_filename); |
64b8d7a6 | 728 | #endif |
1fb7cd49 | 729 | } |
fe8c2806 | 730 | |
85b19802 | 731 | time_start = get_timer(0); |
8885c5fe | 732 | timeout_count_max = tftp_timeout_count_max; |
e83cc063 | 733 | |
bc0571fc | 734 | net_set_timeout_handler(timeout_ms, tftp_timeout_handler); |
049a95a7 | 735 | net_set_udp_handler(tftp_handler); |
39bccd21 | 736 | #ifdef CONFIG_CMD_TFTPPUT |
1fb7cd49 | 737 | net_set_icmp_handler(icmp_handler); |
39bccd21 | 738 | #endif |
8885c5fe JH |
739 | tftp_remote_port = WELL_KNOWN_PORT; |
740 | timeout_count = 0; | |
ecb0ccd9 | 741 | /* Use a pseudo-random port unless a specific port is set */ |
8885c5fe | 742 | tftp_our_port = 1024 + (get_timer(0) % 3072); |
53a5c424 | 743 | |
ecb0ccd9 | 744 | #ifdef CONFIG_TFTP_PORT |
00caae6d | 745 | ep = env_get("tftpdstp"); |
7bc325a1 | 746 | if (ep != NULL) |
8885c5fe | 747 | tftp_remote_port = simple_strtol(ep, NULL, 10); |
00caae6d | 748 | ep = env_get("tftpsrcp"); |
7bc325a1 | 749 | if (ep != NULL) |
8885c5fe | 750 | tftp_our_port = simple_strtol(ep, NULL, 10); |
ecb0ccd9 | 751 | #endif |
8885c5fe | 752 | tftp_cur_block = 0; |
fe8c2806 | 753 | |
73a8b27c | 754 | /* zero out server ether in case the server ip has changed */ |
0adb5b76 | 755 | memset(net_server_ethaddr, 0, 6); |
8885c5fe JH |
756 | /* Revert tftp_block_size to dflt */ |
757 | tftp_block_size = TFTP_BLOCK_SIZE; | |
4fccb818 | 758 | #ifdef CONFIG_TFTP_TSIZE |
8885c5fe JH |
759 | tftp_tsize = 0; |
760 | tftp_tsize_num_hash = 0; | |
4fccb818 | 761 | #endif |
73a8b27c | 762 | |
8885c5fe | 763 | tftp_send(); |
fe8c2806 WD |
764 | } |
765 | ||
e59e3562 | 766 | #ifdef CONFIG_CMD_TFTPSRV |
8885c5fe | 767 | void tftp_start_server(void) |
e59e3562 LC |
768 | { |
769 | tftp_filename[0] = 0; | |
770 | ||
a156c47e SG |
771 | if (tftp_init_load_addr()) { |
772 | eth_halt(); | |
773 | net_set_state(NETLOOP_FAIL); | |
774 | puts("\nTFTP error: trying to overwrite reserved memory...\n"); | |
775 | return; | |
776 | } | |
e59e3562 | 777 | printf("Using %s device\n", eth_get_name()); |
049a95a7 | 778 | printf("Listening for TFTP transfer on %pI4\n", &net_ip); |
a156c47e | 779 | printf("Load address: 0x%lx\n", tftp_load_addr); |
e59e3562 LC |
780 | |
781 | puts("Loading: *\b"); | |
782 | ||
f5fb7346 | 783 | timeout_count_max = tftp_timeout_count_max; |
8885c5fe JH |
784 | timeout_count = 0; |
785 | timeout_ms = TIMEOUT; | |
bc0571fc | 786 | net_set_timeout_handler(timeout_ms, tftp_timeout_handler); |
e59e3562 | 787 | |
8885c5fe JH |
788 | /* Revert tftp_block_size to dflt */ |
789 | tftp_block_size = TFTP_BLOCK_SIZE; | |
790 | tftp_cur_block = 0; | |
791 | tftp_our_port = WELL_KNOWN_PORT; | |
e59e3562 LC |
792 | |
793 | #ifdef CONFIG_TFTP_TSIZE | |
8885c5fe JH |
794 | tftp_tsize = 0; |
795 | tftp_tsize_num_hash = 0; | |
e59e3562 LC |
796 | #endif |
797 | ||
8885c5fe | 798 | tftp_state = STATE_RECV_WRQ; |
049a95a7 | 799 | net_set_udp_handler(tftp_handler); |
8e52533d AR |
800 | |
801 | /* zero out server ether in case the server ip has changed */ | |
0adb5b76 | 802 | memset(net_server_ethaddr, 0, 6); |
e59e3562 LC |
803 | } |
804 | #endif /* CONFIG_CMD_TFTPSRV */ | |
805 |