xref: /rk3399_rockchip-uboot/net/tftp.c (revision 7bc325a1b2dfda4a16789cc3b9387dbe1174af41)
1 /*
2  * Copyright 1994, 1995, 2000 Neil Russell.
3  * (See License)
4  * Copyright 2000, 2001 DENX Software Engineering, Wolfgang Denk, wd@denx.de
5  */
6 
7 #include <common.h>
8 #include <command.h>
9 #include <net.h>
10 #include "tftp.h"
11 #include "bootp.h"
12 
13 /* Well known TFTP port # */
14 #define WELL_KNOWN_PORT	69
15 /* Millisecs to timeout for lost pkt */
16 #define TIMEOUT		5000UL
17 #ifndef	CONFIG_NET_RETRY_COUNT
18 /* # of timeouts before giving up */
19 # define TIMEOUT_COUNT	10
20 #else
21 # define TIMEOUT_COUNT  (CONFIG_NET_RETRY_COUNT * 2)
22 #endif
23 /* Number of "loading" hashes per line (for checking the image size) */
24 #define HASHES_PER_LINE	65
25 
26 /*
27  *	TFTP operations.
28  */
29 #define TFTP_RRQ	1
30 #define TFTP_WRQ	2
31 #define TFTP_DATA	3
32 #define TFTP_ACK	4
33 #define TFTP_ERROR	5
34 #define TFTP_OACK	6
35 
36 static ulong TftpTimeoutMSecs = TIMEOUT;
37 static int TftpTimeoutCountMax = TIMEOUT_COUNT;
38 
39 /*
40  * These globals govern the timeout behavior when attempting a connection to a
41  * TFTP server. TftpRRQTimeoutMSecs specifies the number of milliseconds to
42  * wait for the server to respond to initial connection. Second global,
43  * TftpRRQTimeoutCountMax, gives the number of such connection retries.
44  * TftpRRQTimeoutCountMax must be non-negative and TftpRRQTimeoutMSecs must be
45  * positive. The globals are meant to be set (and restored) by code needing
46  * non-standard timeout behavior when initiating a TFTP transfer.
47  */
48 ulong TftpRRQTimeoutMSecs = TIMEOUT;
49 int TftpRRQTimeoutCountMax = TIMEOUT_COUNT;
50 
51 enum {
52 	TFTP_ERR_UNDEFINED           = 0,
53 	TFTP_ERR_FILE_NOT_FOUND      = 1,
54 	TFTP_ERR_ACCESS_DENIED       = 2,
55 	TFTP_ERR_DISK_FULL           = 3,
56 	TFTP_ERR_UNEXPECTED_OPCODE   = 4,
57 	TFTP_ERR_UNKNOWN_TRANSFER_ID  = 5,
58 	TFTP_ERR_FILE_ALREADY_EXISTS = 6,
59 };
60 
61 static IPaddr_t TftpServerIP;
62 /* The UDP port at their end */
63 static int	TftpServerPort;
64 /* The UDP port at our end */
65 static int	TftpOurPort;
66 static int	TftpTimeoutCount;
67 /* packet sequence number */
68 static ulong	TftpBlock;
69 /* last packet sequence number received */
70 static ulong	TftpLastBlock;
71 /* count of sequence number wraparounds */
72 static ulong	TftpBlockWrap;
73 /* memory offset due to wrapping */
74 static ulong	TftpBlockWrapOffset;
75 static int	TftpState;
76 #ifdef CONFIG_TFTP_TSIZE
77 /* The file size reported by the server */
78 static int	TftpTsize;
79 /* The number of hashes we printed */
80 static short	TftpNumchars;
81 #endif
82 
83 #define STATE_RRQ	1
84 #define STATE_DATA	2
85 #define STATE_TOO_LARGE	3
86 #define STATE_BAD_MAGIC	4
87 #define STATE_OACK	5
88 
89 /* default TFTP block size */
90 #define TFTP_BLOCK_SIZE		512
91 /* sequence number is 16 bit */
92 #define TFTP_SEQUENCE_SIZE	((ulong)(1<<16))
93 
94 #define DEFAULT_NAME_LEN	(8 + 4 + 1)
95 static char default_filename[DEFAULT_NAME_LEN];
96 
97 #ifndef CONFIG_TFTP_FILE_NAME_MAX_LEN
98 #define MAX_LEN 128
99 #else
100 #define MAX_LEN CONFIG_TFTP_FILE_NAME_MAX_LEN
101 #endif
102 
103 static char tftp_filename[MAX_LEN];
104 
105 #ifdef CONFIG_SYS_DIRECT_FLASH_TFTP
106 extern flash_info_t flash_info[];
107 #endif
108 
109 /* 512 is poor choice for ethernet, MTU is typically 1500.
110  * Minus eth.hdrs thats 1468.  Can get 2x better throughput with
111  * almost-MTU block sizes.  At least try... fall back to 512 if need be.
112  * (but those using CONFIG_IP_DEFRAG may want to set a larger block in cfg file)
113  */
114 #ifdef CONFIG_TFTP_BLOCKSIZE
115 #define TFTP_MTU_BLOCKSIZE CONFIG_TFTP_BLOCKSIZE
116 #else
117 #define TFTP_MTU_BLOCKSIZE 1468
118 #endif
119 
120 static unsigned short TftpBlkSize = TFTP_BLOCK_SIZE;
121 static unsigned short TftpBlkSizeOption = TFTP_MTU_BLOCKSIZE;
122 
123 #ifdef CONFIG_MCAST_TFTP
124 #include <malloc.h>
125 #define MTFTP_BITMAPSIZE	0x1000
126 static unsigned *Bitmap;
127 static int PrevBitmapHole, Mapsize = MTFTP_BITMAPSIZE;
128 static uchar ProhibitMcast = 0, MasterClient = 0;
129 static uchar Multicast = 0;
130 extern IPaddr_t Mcast_addr;
131 static int Mcast_port;
132 static ulong TftpEndingBlock; /* can get 'last' block before done..*/
133 
134 static void parse_multicast_oack(char *pkt, int len);
135 
136 static void
137 mcast_cleanup(void)
138 {
139 	if (Mcast_addr) eth_mcast_join(Mcast_addr, 0);
140 	if (Bitmap) free(Bitmap);
141 	Bitmap = NULL;
142 	Mcast_addr = Multicast = Mcast_port = 0;
143 	TftpEndingBlock = -1;
144 }
145 
146 #endif	/* CONFIG_MCAST_TFTP */
147 
148 static __inline__ void
149 store_block(unsigned block, uchar *src, unsigned len)
150 {
151 	ulong offset = block * TftpBlkSize + TftpBlockWrapOffset;
152 	ulong newsize = offset + len;
153 #ifdef CONFIG_SYS_DIRECT_FLASH_TFTP
154 	int i, rc = 0;
155 
156 	for (i = 0; i < CONFIG_SYS_MAX_FLASH_BANKS; i++) {
157 		/* start address in flash? */
158 		if (flash_info[i].flash_id == FLASH_UNKNOWN)
159 			continue;
160 		if (load_addr + offset >= flash_info[i].start[0]) {
161 			rc = 1;
162 			break;
163 		}
164 	}
165 
166 	if (rc) { /* Flash is destination for this packet */
167 		rc = flash_write((char *)src, (ulong)(load_addr+offset), len);
168 		if (rc) {
169 			flash_perror(rc);
170 			NetState = NETLOOP_FAIL;
171 			return;
172 		}
173 	}
174 	else
175 #endif /* CONFIG_SYS_DIRECT_FLASH_TFTP */
176 	{
177 		(void)memcpy((void *)(load_addr + offset), src, len);
178 	}
179 #ifdef CONFIG_MCAST_TFTP
180 	if (Multicast)
181 		ext2_set_bit(block, Bitmap);
182 #endif
183 
184 	if (NetBootFileXferSize < newsize)
185 		NetBootFileXferSize = newsize;
186 }
187 
188 static void TftpSend(void);
189 static void TftpTimeout(void);
190 
191 /**********************************************************************/
192 
193 static void
194 TftpSend(void)
195 {
196 	volatile uchar *pkt;
197 	volatile uchar *xp;
198 	int		len = 0;
199 	volatile ushort *s;
200 
201 #ifdef CONFIG_MCAST_TFTP
202 	/* Multicast TFTP.. non-MasterClients do not ACK data. */
203 	if (Multicast
204 	 && (TftpState == STATE_DATA)
205 	 && (MasterClient == 0))
206 		return;
207 #endif
208 	/*
209 	 *	We will always be sending some sort of packet, so
210 	 *	cobble together the packet headers now.
211 	 */
212 	pkt = NetTxPacket + NetEthHdrSize() + IP_HDR_SIZE;
213 
214 	switch (TftpState) {
215 
216 	case STATE_RRQ:
217 		xp = pkt;
218 		s = (ushort *)pkt;
219 		*s++ = htons(TFTP_RRQ);
220 		pkt = (uchar *)s;
221 		strcpy((char *)pkt, tftp_filename);
222 		pkt += strlen(tftp_filename) + 1;
223 		strcpy((char *)pkt, "octet");
224 		pkt += 5 /*strlen("octet")*/ + 1;
225 		strcpy((char *)pkt, "timeout");
226 		pkt += 7 /*strlen("timeout")*/ + 1;
227 		sprintf((char *)pkt, "%lu", TftpTimeoutMSecs / 1000);
228 		debug("send option \"timeout %s\"\n", (char *)pkt);
229 		pkt += strlen((char *)pkt) + 1;
230 #ifdef CONFIG_TFTP_TSIZE
231 		memcpy((char *)pkt, "tsize\0000\0", 8);
232 		pkt += 8;
233 #endif
234 		/* try for more effic. blk size */
235 		pkt += sprintf((char *)pkt, "blksize%c%d%c",
236 				0, TftpBlkSizeOption, 0);
237 #ifdef CONFIG_MCAST_TFTP
238 		/* Check all preconditions before even trying the option */
239 		if (!ProhibitMcast
240 		 && (Bitmap = malloc(Mapsize))
241 		 && eth_get_dev()->mcast) {
242 			free(Bitmap);
243 			Bitmap = NULL;
244 			pkt += sprintf((char *)pkt, "multicast%c%c", 0, 0);
245 		}
246 #endif /* CONFIG_MCAST_TFTP */
247 		len = pkt - xp;
248 		break;
249 
250 	case STATE_OACK:
251 #ifdef CONFIG_MCAST_TFTP
252 		/* My turn!  Start at where I need blocks I missed.*/
253 		if (Multicast)
254 			TftpBlock = ext2_find_next_zero_bit(Bitmap,
255 							    (Mapsize*8), 0);
256 		/*..falling..*/
257 #endif
258 	case STATE_DATA:
259 		xp = pkt;
260 		s = (ushort *)pkt;
261 		*s++ = htons(TFTP_ACK);
262 		*s++ = htons(TftpBlock);
263 		pkt = (uchar *)s;
264 		len = pkt - xp;
265 		break;
266 
267 	case STATE_TOO_LARGE:
268 		xp = pkt;
269 		s = (ushort *)pkt;
270 		*s++ = htons(TFTP_ERROR);
271 		*s++ = htons(3);
272 		pkt = (uchar *)s;
273 		strcpy((char *)pkt, "File too large");
274 		pkt += 14 /*strlen("File too large")*/ + 1;
275 		len = pkt - xp;
276 		break;
277 
278 	case STATE_BAD_MAGIC:
279 		xp = pkt;
280 		s = (ushort *)pkt;
281 		*s++ = htons(TFTP_ERROR);
282 		*s++ = htons(2);
283 		pkt = (uchar *)s;
284 		strcpy((char *)pkt, "File has bad magic");
285 		pkt += 18 /*strlen("File has bad magic")*/ + 1;
286 		len = pkt - xp;
287 		break;
288 	}
289 
290 	NetSendUDPPacket(NetServerEther, TftpServerIP, TftpServerPort,
291 			 TftpOurPort, len);
292 }
293 
294 
295 static void
296 TftpHandler(uchar *pkt, unsigned dest, IPaddr_t sip, unsigned src,
297 	    unsigned len)
298 {
299 	ushort proto;
300 	ushort *s;
301 	int i;
302 
303 	if (dest != TftpOurPort) {
304 #ifdef CONFIG_MCAST_TFTP
305 		if (Multicast
306 		 && (!Mcast_port || (dest != Mcast_port)))
307 #endif
308 		return;
309 	}
310 	if (TftpState != STATE_RRQ && src != TftpServerPort)
311 		return;
312 
313 	if (len < 2)
314 		return;
315 	len -= 2;
316 	/* warning: don't use increment (++) in ntohs() macros!! */
317 	s = (ushort *)pkt;
318 	proto = *s++;
319 	pkt = (uchar *)s;
320 	switch (ntohs(proto)) {
321 
322 	case TFTP_RRQ:
323 	case TFTP_WRQ:
324 	case TFTP_ACK:
325 		break;
326 	default:
327 		break;
328 
329 	case TFTP_OACK:
330 		debug("Got OACK: %s %s\n",
331 			pkt,
332 			pkt + strlen((char *)pkt) + 1);
333 		TftpState = STATE_OACK;
334 		TftpServerPort = src;
335 		/*
336 		 * Check for 'blksize' option.
337 		 * Careful: "i" is signed, "len" is unsigned, thus
338 		 * something like "len-8" may give a *huge* number
339 		 */
340 		for (i = 0; i+8 < len; i++) {
341 			if (strcmp((char *)pkt+i, "blksize") == 0) {
342 				TftpBlkSize = (unsigned short)
343 					simple_strtoul((char *)pkt+i+8, NULL,
344 						       10);
345 				debug("Blocksize ack: %s, %d\n",
346 					(char *)pkt+i+8, TftpBlkSize);
347 			}
348 #ifdef CONFIG_TFTP_TSIZE
349 			if (strcmp((char *)pkt+i, "tsize") == 0) {
350 				TftpTsize = simple_strtoul((char *)pkt+i+6,
351 							   NULL, 10);
352 				debug("size = %s, %d\n",
353 					 (char *)pkt+i+6, TftpTsize);
354 			}
355 #endif
356 		}
357 #ifdef CONFIG_MCAST_TFTP
358 		parse_multicast_oack((char *)pkt, len-1);
359 		if ((Multicast) && (!MasterClient))
360 			TftpState = STATE_DATA;	/* passive.. */
361 		else
362 #endif
363 		TftpSend(); /* Send ACK */
364 		break;
365 	case TFTP_DATA:
366 		if (len < 2)
367 			return;
368 		len -= 2;
369 		TftpBlock = ntohs(*(ushort *)pkt);
370 
371 		/*
372 		 * RFC1350 specifies that the first data packet will
373 		 * have sequence number 1. If we receive a sequence
374 		 * number of 0 this means that there was a wrap
375 		 * around of the (16 bit) counter.
376 		 */
377 		if (TftpBlock == 0) {
378 			TftpBlockWrap++;
379 			TftpBlockWrapOffset +=
380 				TftpBlkSize * TFTP_SEQUENCE_SIZE;
381 			printf("\n\t %lu MB received\n\t ",
382 				TftpBlockWrapOffset>>20);
383 		}
384 #ifdef CONFIG_TFTP_TSIZE
385 		else if (TftpTsize) {
386 			while (TftpNumchars <
387 			       NetBootFileXferSize * 50 / TftpTsize) {
388 				putc('#');
389 				TftpNumchars++;
390 			}
391 		}
392 #endif
393 		else {
394 			if (((TftpBlock - 1) % 10) == 0)
395 				putc('#');
396 			else if ((TftpBlock % (10 * HASHES_PER_LINE)) == 0)
397 				puts("\n\t ");
398 		}
399 
400 		if (TftpState == STATE_RRQ)
401 			debug("Server did not acknowledge timeout option!\n");
402 
403 		if (TftpState == STATE_RRQ || TftpState == STATE_OACK) {
404 			/* first block received */
405 			TftpState = STATE_DATA;
406 			TftpServerPort = src;
407 			TftpLastBlock = 0;
408 			TftpBlockWrap = 0;
409 			TftpBlockWrapOffset = 0;
410 
411 #ifdef CONFIG_MCAST_TFTP
412 			if (Multicast) { /* start!=1 common if mcast */
413 				TftpLastBlock = TftpBlock - 1;
414 			} else
415 #endif
416 			if (TftpBlock != 1) {	/* Assertion */
417 				printf("\nTFTP error: "
418 				       "First block is not block 1 (%ld)\n"
419 				       "Starting again\n\n",
420 					TftpBlock);
421 				NetStartAgain();
422 				break;
423 			}
424 		}
425 
426 		if (TftpBlock == TftpLastBlock) {
427 			/*
428 			 *	Same block again; ignore it.
429 			 */
430 			break;
431 		}
432 
433 		TftpLastBlock = TftpBlock;
434 		TftpTimeoutCountMax = TIMEOUT_COUNT;
435 		NetSetTimeout(TftpTimeoutMSecs, TftpTimeout);
436 
437 		store_block(TftpBlock - 1, pkt + 2, len);
438 
439 		/*
440 		 *	Acknoledge the block just received, which will prompt
441 		 *	the server for the next one.
442 		 */
443 #ifdef CONFIG_MCAST_TFTP
444 		/* if I am the MasterClient, actively calculate what my next
445 		 * needed block is; else I'm passive; not ACKING
446 		 */
447 		if (Multicast) {
448 			if (len < TftpBlkSize)  {
449 				TftpEndingBlock = TftpBlock;
450 			} else if (MasterClient) {
451 				TftpBlock = PrevBitmapHole =
452 					ext2_find_next_zero_bit(
453 						Bitmap,
454 						(Mapsize*8),
455 						PrevBitmapHole);
456 				if (TftpBlock > ((Mapsize*8) - 1)) {
457 					printf("tftpfile too big\n");
458 					/* try to double it and retry */
459 					Mapsize <<= 1;
460 					mcast_cleanup();
461 					NetStartAgain();
462 					return;
463 				}
464 				TftpLastBlock = TftpBlock;
465 			}
466 		}
467 #endif
468 		TftpSend();
469 
470 #ifdef CONFIG_MCAST_TFTP
471 		if (Multicast) {
472 			if (MasterClient && (TftpBlock >= TftpEndingBlock)) {
473 				puts("\nMulticast tftp done\n");
474 				mcast_cleanup();
475 				NetState = NETLOOP_SUCCESS;
476 			}
477 		}
478 		else
479 #endif
480 		if (len < TftpBlkSize) {
481 			/*
482 			 *	We received the whole thing.  Try to
483 			 *	run it.
484 			 */
485 #ifdef CONFIG_TFTP_TSIZE
486 			/* Print hash marks for the last packet received */
487 			while (TftpTsize && TftpNumchars < 49) {
488 				putc('#');
489 				TftpNumchars++;
490 			}
491 #endif
492 			puts("\ndone\n");
493 			NetState = NETLOOP_SUCCESS;
494 		}
495 		break;
496 
497 	case TFTP_ERROR:
498 		printf("\nTFTP error: '%s' (%d)\n",
499 		       pkt + 2, ntohs(*(ushort *)pkt));
500 
501 		switch (ntohs(*(ushort *)pkt)) {
502 		case TFTP_ERR_FILE_NOT_FOUND:
503 		case TFTP_ERR_ACCESS_DENIED:
504 			puts("Not retrying...\n");
505 			eth_halt();
506 			NetState = NETLOOP_FAIL;
507 			break;
508 		case TFTP_ERR_UNDEFINED:
509 		case TFTP_ERR_DISK_FULL:
510 		case TFTP_ERR_UNEXPECTED_OPCODE:
511 		case TFTP_ERR_UNKNOWN_TRANSFER_ID:
512 		case TFTP_ERR_FILE_ALREADY_EXISTS:
513 		default:
514 			puts("Starting again\n\n");
515 #ifdef CONFIG_MCAST_TFTP
516 			mcast_cleanup();
517 #endif
518 			NetStartAgain();
519 			break;
520 		}
521 		break;
522 	}
523 }
524 
525 
526 static void
527 TftpTimeout(void)
528 {
529 	if (++TftpTimeoutCount > TftpTimeoutCountMax) {
530 		puts("\nRetry count exceeded; starting again\n");
531 #ifdef CONFIG_MCAST_TFTP
532 		mcast_cleanup();
533 #endif
534 		NetStartAgain();
535 	} else {
536 		puts("T ");
537 		NetSetTimeout(TftpTimeoutMSecs, TftpTimeout);
538 		TftpSend();
539 	}
540 }
541 
542 
543 void
544 TftpStart(void)
545 {
546 	char *ep;             /* Environment pointer */
547 
548 	/*
549 	 * Allow the user to choose TFTP blocksize and timeout.
550 	 * TFTP protocol has a minimal timeout of 1 second.
551 	 */
552 	ep = getenv("tftpblocksize");
553 	if (ep != NULL)
554 		TftpBlkSizeOption = simple_strtol(ep, NULL, 10);
555 
556 	ep = getenv("tftptimeout");
557 	if (ep != NULL)
558 		TftpTimeoutMSecs = simple_strtol(ep, NULL, 10);
559 
560 	if (TftpTimeoutMSecs < 1000) {
561 		printf("TFTP timeout (%ld ms) too low, "
562 			"set minimum = 1000 ms\n",
563 			TftpTimeoutMSecs);
564 		TftpTimeoutMSecs = 1000;
565 	}
566 
567 	debug("TFTP blocksize = %i, timeout = %ld ms\n",
568 		TftpBlkSizeOption, TftpTimeoutMSecs);
569 
570 	TftpServerIP = NetServerIP;
571 	if (BootFile[0] == '\0') {
572 		sprintf(default_filename, "%02lX%02lX%02lX%02lX.img",
573 			NetOurIP & 0xFF,
574 			(NetOurIP >>  8) & 0xFF,
575 			(NetOurIP >> 16) & 0xFF,
576 			(NetOurIP >> 24) & 0xFF);
577 
578 		strncpy(tftp_filename, default_filename, MAX_LEN);
579 		tftp_filename[MAX_LEN-1] = 0;
580 
581 		printf("*** Warning: no boot file name; using '%s'\n",
582 			tftp_filename);
583 	} else {
584 		char *p = strchr(BootFile, ':');
585 
586 		if (p == NULL) {
587 			strncpy(tftp_filename, BootFile, MAX_LEN);
588 			tftp_filename[MAX_LEN-1] = 0;
589 		} else {
590 			TftpServerIP = string_to_ip(BootFile);
591 			strncpy(tftp_filename, p + 1, MAX_LEN);
592 			tftp_filename[MAX_LEN-1] = 0;
593 		}
594 	}
595 
596 #if defined(CONFIG_NET_MULTI)
597 	printf("Using %s device\n", eth_get_name());
598 #endif
599 	printf("TFTP from server %pI4"
600 		"; our IP address is %pI4", &TftpServerIP, &NetOurIP);
601 
602 	/* Check if we need to send across this subnet */
603 	if (NetOurGatewayIP && NetOurSubnetMask) {
604 	    IPaddr_t OurNet	= NetOurIP    & NetOurSubnetMask;
605 	    IPaddr_t ServerNet	= TftpServerIP & NetOurSubnetMask;
606 
607 	    if (OurNet != ServerNet)
608 		printf("; sending through gateway %pI4", &NetOurGatewayIP);
609 	}
610 	putc('\n');
611 
612 	printf("Filename '%s'.", tftp_filename);
613 
614 	if (NetBootFileSize) {
615 		printf(" Size is 0x%x Bytes = ", NetBootFileSize<<9);
616 		print_size(NetBootFileSize<<9, "");
617 	}
618 
619 	putc('\n');
620 
621 	printf("Load address: 0x%lx\n", load_addr);
622 
623 	puts("Loading: *\b");
624 
625 	TftpTimeoutCountMax = TftpRRQTimeoutCountMax;
626 
627 	NetSetTimeout(TftpTimeoutMSecs, TftpTimeout);
628 	NetSetHandler(TftpHandler);
629 
630 	TftpServerPort = WELL_KNOWN_PORT;
631 	TftpTimeoutCount = 0;
632 	TftpState = STATE_RRQ;
633 	/* Use a pseudo-random port unless a specific port is set */
634 	TftpOurPort = 1024 + (get_timer(0) % 3072);
635 
636 #ifdef CONFIG_TFTP_PORT
637 	ep = getenv("tftpdstp");
638 	if (ep != NULL)
639 		TftpServerPort = simple_strtol(ep, NULL, 10);
640 	ep = getenv("tftpsrcp");
641 	if (ep != NULL)
642 		TftpOurPort = simple_strtol(ep, NULL, 10);
643 #endif
644 	TftpBlock = 0;
645 
646 	/* zero out server ether in case the server ip has changed */
647 	memset(NetServerEther, 0, 6);
648 	/* Revert TftpBlkSize to dflt */
649 	TftpBlkSize = TFTP_BLOCK_SIZE;
650 #ifdef CONFIG_MCAST_TFTP
651 	mcast_cleanup();
652 #endif
653 #ifdef CONFIG_TFTP_TSIZE
654 	TftpTsize = 0;
655 	TftpNumchars = 0;
656 #endif
657 
658 	TftpSend();
659 }
660 
661 #ifdef CONFIG_MCAST_TFTP
662 /* Credits: atftp project.
663  */
664 
665 /* pick up BcastAddr, Port, and whether I am [now] the master-client. *
666  * Frame:
667  *    +-------+-----------+---+-------~~-------+---+
668  *    |  opc  | multicast | 0 | addr, port, mc | 0 |
669  *    +-------+-----------+---+-------~~-------+---+
670  * The multicast addr/port becomes what I listen to, and if 'mc' is '1' then
671  * I am the new master-client so must send ACKs to DataBlocks.  If I am not
672  * master-client, I'm a passive client, gathering what DataBlocks I may and
673  * making note of which ones I got in my bitmask.
674  * In theory, I never go from master->passive..
675  * .. this comes in with pkt already pointing just past opc
676  */
677 static void parse_multicast_oack(char *pkt, int len)
678 {
679 	int i;
680 	IPaddr_t addr;
681 	char *mc_adr, *port,  *mc;
682 
683 	mc_adr = port = mc = NULL;
684 	/* march along looking for 'multicast\0', which has to start at least
685 	 * 14 bytes back from the end.
686 	 */
687 	for (i = 0; i < len-14; i++)
688 		if (strcmp(pkt+i, "multicast") == 0)
689 			break;
690 	if (i >= (len-14)) /* non-Multicast OACK, ign. */
691 		return;
692 
693 	i += 10; /* strlen multicast */
694 	mc_adr = pkt+i;
695 	for (; i < len; i++) {
696 		if (*(pkt+i) == ',') {
697 			*(pkt+i) = '\0';
698 			if (port) {
699 				mc = pkt+i+1;
700 				break;
701 			} else {
702 				port = pkt+i+1;
703 			}
704 		}
705 	}
706 	if (!port || !mc_adr || !mc) return;
707 	if (Multicast && MasterClient) {
708 		printf("I got a OACK as master Client, WRONG!\n");
709 		return;
710 	}
711 	/* ..I now accept packets destined for this MCAST addr, port */
712 	if (!Multicast) {
713 		if (Bitmap) {
714 			printf("Internal failure! no mcast.\n");
715 			free(Bitmap);
716 			Bitmap = NULL;
717 			ProhibitMcast = 1;
718 			return ;
719 		}
720 		/* I malloc instead of pre-declare; so that if the file ends
721 		 * up being too big for this bitmap I can retry
722 		 */
723 		Bitmap = malloc(Mapsize);
724 		if (!Bitmap) {
725 			printf("No Bitmap, no multicast. Sorry.\n");
726 			ProhibitMcast = 1;
727 			return;
728 		}
729 		memset(Bitmap, 0, Mapsize);
730 		PrevBitmapHole = 0;
731 		Multicast = 1;
732 	}
733 	addr = string_to_ip(mc_adr);
734 	if (Mcast_addr != addr) {
735 		if (Mcast_addr)
736 			eth_mcast_join(Mcast_addr, 0);
737 		Mcast_addr = addr;
738 		if (eth_mcast_join(Mcast_addr, 1)) {
739 			printf("Fail to set mcast, revert to TFTP\n");
740 			ProhibitMcast = 1;
741 			mcast_cleanup();
742 			NetStartAgain();
743 		}
744 	}
745 	MasterClient = (unsigned char)simple_strtoul((char *)mc, NULL, 10);
746 	Mcast_port = (unsigned short)simple_strtoul(port, NULL, 10);
747 	printf("Multicast: %s:%d [%d]\n", mc_adr, Mcast_port, MasterClient);
748 	return;
749 }
750 
751 #endif /* Multicast TFTP */
752