]> git.kernelconcepts.de Git - karo-tx-uboot.git/blob - common/cmd_bootce.c
Fix various bugs in WinCE boot protocol handler
[karo-tx-uboot.git] / common / cmd_bootce.c
1 /*
2  * Copyright (C) 2012 Lothar Waßmann <LW@KARO-electronics.de>
3  * based on: code from RedBoot (C) Uwe Steinkohl <US@KARO-electronics.de>
4  *
5  * See file CREDITS for list of people who contributed to this
6  * project.
7  *
8  * This program is free software; you can redistribute it and/or
9  * modify it under the terms of the GNU General Public License as
10  * published by the Free Software Foundation; either version 2 of
11  * the License, or (at your option) any later version.
12  *
13  * This program is distributed in the hope that it will be useful,
14  * but WITHOUT ANY WARRANTY; without even the implied warranty of
15  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
16  * GNU General Public License for more details.
17  *
18  * You should have received a copy of the GNU General Public License
19  * along with this program; if not, write to the Free Software
20  * Foundation, Inc., 59 Temple Place, Suite 330, Boston,
21  * MA 02111-1307 USA
22  */
23
24 #include <common.h>
25 #include <command.h>
26 #include <net.h>
27 #include <wince.h>
28 #include <nand.h>
29 #include <malloc.h>
30 #include <asm/errno.h>
31 #include <jffs2/load_kernel.h>
32
33 DECLARE_GLOBAL_DATA_PTR;
34
35 #define WINCE_VRAM_BASE         0x80000000
36 #define CE_FIX_ADDRESS(a)       ((void *)((a) - WINCE_VRAM_BASE + CONFIG_SYS_SDRAM_BASE))
37
38 #ifndef INT_MAX
39 #define INT_MAX                 ((int)(~0U >> 1))
40 #endif
41
42 /* Bin image parse states */
43 #define CE_PS_RTI_ADDR          0
44 #define CE_PS_RTI_LEN           1
45 #define CE_PS_E_ADDR            2
46 #define CE_PS_E_LEN             3
47 #define CE_PS_E_CHKSUM          4
48 #define CE_PS_E_DATA            5
49
50 #define CE_MIN(a, b)            (((a) < (b)) ? (a) : (b))
51 #define CE_MAX(a, b)            (((a) > (b)) ? (a) : (b))
52
53 static ce_bin __attribute__ ((aligned (32))) g_bin;
54 static ce_net __attribute__ ((aligned (32))) g_net;
55 static IPaddr_t server_ip;
56
57 static void ce_init_bin(ce_bin *bin, unsigned char *dataBuffer)
58 {
59         memset(bin, 0, sizeof(*bin));
60
61         bin->data = dataBuffer;
62         bin->parseState = CE_PS_RTI_ADDR;
63         bin->parsePtr = (unsigned char *)bin;
64 }
65
66 static int ce_is_bin_image(void *image, int imglen)
67 {
68         if (imglen < CE_BIN_SIGN_LEN) {
69                 return 0;
70         }
71
72         return memcmp(image, CE_BIN_SIGN, CE_BIN_SIGN_LEN) == 0;
73 }
74
75 static const struct ce_magic {
76         char magic[8];
77         size_t size;
78         ce_std_driver_globals drv_glb;
79 } ce_magic_template = {
80         .magic = "KARO_CE6",
81         .size = sizeof(ce_std_driver_globals),
82         .drv_glb = {
83                 .header = {
84                         .signature = STD_DRV_GLB_SIGNATURE,
85                         .oalVersion = 1,
86                         .bspVersion = 2,
87                 },
88         },
89 };
90
91 #ifdef DEBUG
92 static void __attribute__((unused)) ce_dump_block(void *ptr, int length)
93 {
94         char *p = ptr;
95         int i;
96         int j;
97
98         for (i = 0; i < length; i++) {
99                 if (!(i % 16)) {
100                         printf("\n%p: ", ptr + i);
101                 }
102
103                 printf("%02x ", p[i]);
104                 if (!((i + 1) % 16)){
105                         printf("      ");
106                         for (j = i - 15; j <= i; j++){
107                                 if((p[j] > 0x1f) && (p[j] < 0x7f)) {
108                                         printf("%c", p[j]);
109                                 } else {
110                                         printf(".");
111                                 }
112                         }
113                 }
114         }
115         printf("\n");
116 }
117 #else
118 static inline void ce_dump_block(void *ptr, int length)
119 {
120 }
121 #endif
122
123 static void ce_setup_std_drv_globals(ce_std_driver_globals *std_drv_glb)
124 {
125         char *mtdparts = getenv("mtdparts");
126         size_t max_len = ALIGN((unsigned long)std_drv_glb, SZ_4K) -
127                 (unsigned long)&std_drv_glb->mtdparts;
128
129         if (eth_get_dev()) {
130                 memcpy(&std_drv_glb->kitl.mac, eth_get_dev()->enetaddr,
131                         sizeof(std_drv_glb->kitl.mac));
132         }
133         snprintf(std_drv_glb->deviceId, sizeof(std_drv_glb->deviceId),
134                 "Triton%02X", eth_get_dev()->enetaddr[5]);
135
136         NetCopyIP(&std_drv_glb->kitl.ipAddress, &NetOurIP);
137         std_drv_glb->kitl.ipMask = getenv_IPaddr("netmask");
138         std_drv_glb->kitl.ipRoute = getenv_IPaddr("gatewayip");
139
140         if (mtdparts) {
141                 strncpy(std_drv_glb->mtdparts, mtdparts, max_len);
142                 std_drv_glb->mtdparts[max_len - 1] = '\0';
143         } else {
144                 printf("Failed to get mtdparts environment variable\n");
145         }
146 }
147
148 static void ce_prepare_run_bin(ce_bin *bin)
149 {
150         ce_driver_globals *drv_glb;
151         struct ce_magic *ce_magic = (void *)CONFIG_SYS_SDRAM_BASE + 0x160;
152         ce_std_driver_globals *std_drv_glb = &ce_magic->drv_glb;
153
154         /* Clear os RAM area (if needed) */
155         if (bin->edbgConfig.flags & EDBG_FL_CLEANBOOT) {
156                 debug("cleaning memory from %p to %p\n",
157                         bin->eRamStart, bin->eRamStart + bin->eRamLen);
158
159                 printf("Preparing clean boot ... ");
160                 memset(bin->eRamStart, 0, bin->eRamLen);
161                 printf("ok\n");
162         }
163
164         /* Prepare driver globals (if needed) */
165         if (bin->eDrvGlb) {
166                 debug("Copying CE MAGIC from %p to %p..%p\n",
167                         &ce_magic_template, ce_magic,
168                         (void *)ce_magic + sizeof(*ce_magic) - 1);
169                 memcpy(ce_magic, &ce_magic_template, sizeof(*ce_magic));
170
171                 ce_setup_std_drv_globals(std_drv_glb);
172                 ce_magic->size = sizeof(*std_drv_glb) +
173                         strlen(std_drv_glb->mtdparts) + 1;
174                 ce_dump_block(ce_magic, offsetof(struct ce_magic, drv_glb) +
175                         ce_magic->size);
176
177                 drv_glb = bin->eDrvGlb;
178                 memset(drv_glb, 0, sizeof(*drv_glb));
179
180                 drv_glb->signature = DRV_GLB_SIGNATURE;
181
182                 /* Local ethernet MAC address */
183                 memcpy(drv_glb->macAddr, std_drv_glb->kitl.mac,
184                         sizeof(drv_glb->macAddr));
185                 debug("got MAC address %pM from environment\n",
186                         drv_glb->macAddr);
187
188                 /* Local IP address */
189                 drv_glb->ipAddr = getenv_IPaddr("ipaddr");
190
191                 /* Subnet mask */
192                 drv_glb->ipMask = getenv_IPaddr("netmask");
193
194                 /* Gateway config */
195                 drv_glb->ipGate = getenv_IPaddr("gatewayip");
196 #ifdef DEBUG
197                 debug("got IP address %pI4 from environment\n",
198                         &drv_glb->ipAddr);
199                 debug("got IP mask %pI4 from environment\n",
200                         &drv_glb->ipMask);
201                 debug("got gateway address %pI4 from environment\n",
202                         &drv_glb->ipGate);
203 #endif
204                 /* EDBG services config */
205                 memcpy(&drv_glb->edbgConfig, &bin->edbgConfig,
206                         sizeof(bin->edbgConfig));
207         }
208
209         /*
210          * Make sure, all the above makes it into SDRAM because
211          * WinCE switches the cache & MMU off, obviously without
212          * flushing it first!
213          */
214         flush_dcache_all();
215 }
216
217 static int ce_lookup_ep_bin(ce_bin *bin)
218 {
219         ce_rom_hdr *header;
220         ce_toc_entry *tentry;
221         e32_rom *e32;
222         unsigned int i;
223         uint32_t *sig = (uint32_t *)(bin->rtiPhysAddr + ROM_SIGNATURE_OFFSET);
224
225         debug("Looking for TOC signature at %p\n", sig);
226
227         /* Check image Table Of Contents (TOC) signature */
228         if (*sig != ROM_SIGNATURE) {
229                 printf("Error: Did not find image TOC signature!\n");
230                 printf("Expected %08x at address %p; found %08x instead\n",
231                         ROM_SIGNATURE, sig, *sig);
232                 return 0;
233         }
234
235         /* Lookup entry point */
236         header = CE_FIX_ADDRESS(*(unsigned int *)(bin->rtiPhysAddr +
237                                                 ROM_SIGNATURE_OFFSET +
238                                                 sizeof(unsigned int)));
239         tentry = (ce_toc_entry *)(header + 1);
240
241         for (i = 0; i < header->nummods; i++) {
242                 // Look for 'nk.exe' module
243                 if (strcmp(CE_FIX_ADDRESS(tentry[i].fileName), "nk.exe") == 0) {
244                         // Save entry point and RAM addresses
245
246                         e32 = CE_FIX_ADDRESS(tentry[i].e32Offset);
247
248                         bin->eEntryPoint = CE_FIX_ADDRESS(tentry[i].loadOffset) +
249                                 e32->e32_entryrva;
250                         bin->eRamStart = CE_FIX_ADDRESS(header->ramStart);
251                         bin->eRamLen = header->ramEnd - header->ramStart;
252                         // Save driver_globals address
253                         // Must follow RAM section in CE config.bib file
254                         //
255                         // eg.
256                         //
257                         // RAM          80900000        03200000        RAM
258                         // DRV_GLB      83B00000        00001000        RESERVED
259                         //
260                         bin->eDrvGlb = CE_FIX_ADDRESS(header->ramEnd);
261                         return 1;
262                 }
263         }
264
265         // Error: Did not find 'nk.exe' module
266         return 0;
267 }
268
269 static int ce_parse_bin(ce_bin *bin)
270 {
271         unsigned char *pbData = bin->data;
272         int len = bin->dataLen;
273         int copyLen;
274
275         debug("starting ce image parsing:\n\tbin->binLen: 0x%08X\n", bin->binLen);
276
277         if (len) {
278                 if (bin->binLen == 0) {
279                         // Check for the .BIN signature first
280                         if (!ce_is_bin_image(pbData, len)) {
281                                 printf("Error: Invalid or corrupted .BIN image!\n");
282                                 return CE_PR_ERROR;
283                         }
284
285                         printf("Loading Windows CE .BIN image ...\n");
286                         // Skip signature
287                         len -= CE_BIN_SIGN_LEN;
288                         pbData += CE_BIN_SIGN_LEN;
289                 }
290
291                 while (len) {
292                         switch (bin->parseState) {
293                         case CE_PS_RTI_ADDR:
294                         case CE_PS_RTI_LEN:
295                         case CE_PS_E_ADDR:
296                         case CE_PS_E_LEN:
297                         case CE_PS_E_CHKSUM:
298                                 copyLen = CE_MIN(sizeof(unsigned int) - bin->parseLen, len);
299                                 memcpy(&bin->parsePtr[bin->parseLen], pbData, copyLen);
300
301                                 bin->parseLen += copyLen;
302                                 len -= copyLen;
303                                 pbData += copyLen;
304
305                                 if (bin->parseLen == sizeof(unsigned int)) {
306                                         if (bin->parseState == CE_PS_RTI_ADDR)
307                                                 bin->rtiPhysAddr = CE_FIX_ADDRESS(bin->rtiPhysAddr);
308                                         else if (bin->parseState == CE_PS_E_ADDR &&
309                                                 bin->ePhysAddr)
310                                                 bin->ePhysAddr = CE_FIX_ADDRESS(bin->ePhysAddr);
311
312                                         bin->parseState++;
313                                         bin->parseLen = 0;
314                                         bin->parsePtr += sizeof(unsigned int);
315
316                                         if (bin->parseState == CE_PS_E_DATA) {
317                                                 if (bin->ePhysAddr) {
318                                                         bin->parsePtr = bin->ePhysAddr;
319                                                         bin->parseChkSum = 0;
320                                                 } else {
321                                                         /* EOF */
322                                                         len = 0;
323                                                         bin->endOfBin = 1;
324                                                 }
325                                         }
326                                 }
327                                 break;
328
329                         case CE_PS_E_DATA:
330                                 debug("ePhysAddr=%p physlen=%08x parselen=%08x\n",
331                                         bin->ePhysAddr, bin->ePhysLen, bin->parseLen);
332                                 if (bin->ePhysAddr) {
333                                         copyLen = CE_MIN(bin->ePhysLen - bin->parseLen, len);
334                                         bin->parseLen += copyLen;
335                                         len -= copyLen;
336
337                                         while (copyLen--) {
338                                                 bin->parseChkSum += *pbData;
339                                                 *bin->parsePtr++ = *pbData++;
340                                         }
341
342                                         if (bin->parseLen == bin->ePhysLen) {
343                                                 printf("Section [%02d]: address %p, size 0x%08X, checksum %s\n",
344                                                         bin->section,
345                                                         bin->ePhysAddr,
346                                                         bin->ePhysLen,
347                                                         (bin->eChkSum == bin->parseChkSum) ? "ok" : "fail");
348
349                                                 if (bin->eChkSum != bin->parseChkSum) {
350                                                         printf("Error: Checksum error, corrupted .BIN file!\n");
351                                                         printf("checksum calculated: 0x%08x from file: 0x%08x\n",
352                                                                 bin->parseChkSum, bin->eChkSum);
353                                                         bin->binLen = 0;
354                                                         return CE_PR_ERROR;
355                                                 }
356
357                                                 bin->section++;
358                                                 bin->parseState = CE_PS_E_ADDR;
359                                                 bin->parseLen = 0;
360                                                 bin->parsePtr = (unsigned char *)&bin->ePhysAddr;
361                                         }
362                                 } else {
363                                         bin->parseLen = 0;
364                                         bin->endOfBin = 1;
365                                         len = 0;
366                                 }
367                                 break;
368                         }
369                 }
370         }
371
372         if (bin->endOfBin) {
373                 if (!ce_lookup_ep_bin(bin)) {
374                         printf("Error: entry point not found!\n");
375                         bin->binLen = 0;
376                         return CE_PR_ERROR;
377                 }
378
379                 printf("Entry point: %p, address range: %p-%p\n",
380                         bin->eEntryPoint,
381                         bin->rtiPhysAddr,
382                         bin->rtiPhysAddr + bin->rtiPhysLen);
383
384                 return CE_PR_EOF;
385         }
386
387         /* Need more data */
388         bin->binLen += bin->dataLen;
389         return CE_PR_MORE;
390 }
391
392 static int ce_bin_load(void *image, int imglen)
393 {
394         ce_init_bin(&g_bin, image);
395         g_bin.dataLen = imglen;
396         if (ce_parse_bin(&g_bin) == CE_PR_EOF) {
397                 ce_prepare_run_bin(&g_bin);
398                 return 1;
399         }
400
401         return 0;
402 }
403
404 static void ce_run_bin(void (*entry)(void))
405 {
406         printf("Launching Windows CE ...\n");
407 #ifdef TEST_LAUNCH
408 return;
409 #endif
410         entry();
411 }
412
413 static int do_bootce(cmd_tbl_t *cmdtp, int flag, int argc, char *const argv[])
414 {
415         void *addr;
416         size_t image_size;
417
418         if (argc > 1) {
419                 addr = (void *)simple_strtoul(argv[1], NULL, 16);
420                 image_size = INT_MAX;           /* actually we do not know the image size */
421         } else if (getenv("fileaddr") != NULL) {
422                 addr = (void *)getenv_ulong("fileaddr", 16, 0);
423                 image_size = getenv_ulong("filesize", 16, INT_MAX);
424         } else {
425                 return CMD_RET_USAGE;
426         }
427
428         printf ("## Booting Windows CE Image from address %p ...\n", addr);
429
430         /* check if there is a valid windows CE image */
431         if (ce_is_bin_image(addr, image_size)) {
432                 if (!ce_bin_load(addr, image_size)) {
433                         /* Ops! Corrupted .BIN image! */
434                         /* Handle error here ...      */
435                         printf("corrupted .BIN image !!!\n");
436                         return CMD_RET_FAILURE;
437                 }
438                 if (getenv_yesno("autostart") != 1) {
439                         /*
440                          * just use bootce to load the image to SDRAM;
441                          * Do not start it automatically.
442                          */
443                         setenv_addr("fileaddr", g_bin.eEntryPoint);
444                         return CMD_RET_SUCCESS;
445                 }
446                 ce_run_bin(g_bin.eEntryPoint);          /* start the image */
447         } else {
448                 printf("Image does not seem to be a valid Windows CE image!\n");
449                 return CMD_RET_FAILURE;
450         }
451         return CMD_RET_FAILURE; /* never reached - just to keep compiler happy */
452 }
453 U_BOOT_CMD(
454         bootce, 2, 0, do_bootce,
455         "Boot a Windows CE image from RAM\n",
456         "[addr]\n"
457         "\taddr\t\tboot image from address addr (default ${fileaddr})\n"
458 );
459
460 static int ce_nand_load(ce_bin *bin, loff_t *offset, void *buf, size_t max_len)
461 {
462         int ret;
463         size_t len = max_len;
464         nand_info_t *nand = &nand_info[0];
465
466         while (nand_block_isbad(nand, *offset & ~(max_len - 1))) {
467                 printf("Skipping bad block 0x%08llx\n",
468                         *offset & ~(max_len - 1));
469                 *offset += max_len;
470                 if (*offset + max_len > nand->size)
471                         return -EINVAL;
472         }
473
474         ret = nand_read(nand, *offset, &len, buf);
475         if (ret < 0)
476                 return ret;
477
478         bin->dataLen = len;
479         return len;
480 }
481
482 static int do_nbootce(cmd_tbl_t *cmdtp, int flag, int argc, char *const argv[])
483 {
484         int ret;
485         struct mtd_device *dev;
486         struct part_info *part_info;
487         u8 part_num;
488         loff_t offset;
489         char *end;
490         void *buffer;
491         size_t bufsize = nand_info[0].erasesize, len;
492
493         if (argc < 2 || argc > 3)
494                 return CMD_RET_USAGE;
495
496         ret = mtdparts_init();
497         if (ret)
498                 return CMD_RET_FAILURE;
499
500         offset = simple_strtoul(argv[1], &end, 16);
501         if (*end != '\0') {
502                 ret = find_dev_and_part(argv[1], &dev, &part_num,
503                                         &part_info);
504                 if (ret != 0) {
505                         printf("Partition '%s' not found\n", argv[1]);
506                         return CMD_RET_FAILURE;
507                 }
508                 offset = part_info->offset;
509                 printf ("## Booting Windows CE Image from NAND partition %s at offset %08llx\n",
510                         argv[1], offset);
511         } else {
512                 printf ("## Booting Windows CE Image from NAND offset %08llx\n",
513                         offset);
514         }
515
516         buffer = malloc(bufsize);
517         if (buffer == NULL) {
518                 printf("Failed to allocate %u byte buffer\n", bufsize);
519                 return CMD_RET_FAILURE;
520         }
521
522         ce_init_bin(&g_bin, buffer);
523
524         ret = ce_nand_load(&g_bin, &offset, buffer, bufsize);
525         if (ret < 0) {
526                 printf("Failed to read NAND: %d\n", ret);
527                 goto err;
528         }
529         len = ret;
530         /* check if there is a valid windows CE image header */
531         if (ce_is_bin_image(buffer, len)) {
532                 do {
533                         ret = ce_parse_bin(&g_bin);
534                         switch (ret) {
535                         case CE_PR_MORE:
536                         {
537                                 if (ctrlc()) {
538                                         printf("NBOOTCE - canceled by user\n");
539                                         goto err;
540                                 }
541                                 offset += len;
542                                 len = ce_nand_load(&g_bin, &offset, buffer,
543                                                 bufsize);
544                                 if (len < 0) {
545                                         printf("Nand read error: %d\n", len);
546                                         ret = len;
547                                         goto err;
548                                 }
549                         }
550                         break;
551
552                         case CE_PR_EOF:
553                         case CE_PR_ERROR:
554                                 break;
555                         }
556                 } while (ret == CE_PR_MORE);
557                 free(buffer);
558                 if (ret != CE_PR_EOF)
559                         return CMD_RET_FAILURE;
560
561                 if (getenv_yesno("autostart") != 1) {
562                         /*
563                          * just use bootce to load the image to SDRAM;
564                          * Do not start it automatically.
565                          */
566                         setenv_addr("fileaddr", g_bin.eEntryPoint);
567                         return CMD_RET_SUCCESS;
568                 }
569                 ce_run_bin(g_bin.eEntryPoint);          /* start the image */
570         } else {
571                 printf("Image does not seem to be a valid Windows CE image!\n");
572         }
573 err:
574         free(buffer);
575         return CMD_RET_FAILURE;
576 }
577 U_BOOT_CMD(
578         nbootce, 2, 0, do_nbootce,
579         "Boot a Windows CE image from NAND\n",
580         "off|partitition\n"
581         "\toff\t\t- flash offset (hex)\n"
582         "\tpartition\t- partition name\n"
583 );
584
585 static int ce_send_write_ack(ce_net *net)
586 {
587         int ret;
588         unsigned short wdata[2];
589         int retries = 0;
590
591         wdata[0] = htons(EDBG_CMD_WRITE_ACK);
592         wdata[1] = htons(net->blockNum);
593         net->dataLen = sizeof(wdata);
594         memcpy(net->data, wdata, net->dataLen);
595
596         do {
597                 ret = bootme_send_frame(net->data, net->dataLen);
598                 if (ret) {
599                         printf("Failed to send write ack %d; retries=%d\n",
600                                 ret, retries);
601                 }
602         } while (ret != 0 && retries-- > 0);
603         return ret;
604 }
605
606 static enum bootme_state ce_process_download(ce_net *net, ce_bin *bin)
607 {
608         int ret = net->state;
609
610         if (net->dataLen >= 4) {
611                 unsigned short command;
612                 unsigned short blknum;
613
614                 memcpy(&command, net->data, sizeof(command));
615                 command = ntohs(command);
616                 debug("command found: 0x%04X\n", command);
617
618                 if (net->state == BOOTME_DOWNLOAD) {
619                         unsigned short nxt = net->blockNum + 1;
620
621                         memcpy(&blknum, &net->data[2], sizeof(blknum));
622                         blknum = ntohs(blknum);
623                         if (blknum == nxt) {
624                                 net->blockNum = blknum;
625                         } else {
626                                 int rc = ce_send_write_ack(net);
627
628                                 if (net->verbose)
629                                         printf("Dropping out of sequence packet with ID %d (expected %d)\n",
630                                                 blknum, nxt);
631                                 if (rc != 0)
632                                         return rc;
633
634                                 return ret;
635                         }
636                 }
637
638                 switch (command) {
639                 case EDBG_CMD_WRITE_REQ:
640                         if (net->state == BOOTME_INIT) {
641                                 // Check file name for WRITE request
642                                 // CE EShell uses "boot.bin" file name
643                                 if (strncmp((char *)&net->data[2],
644                                                 "boot.bin", 8) == 0) {
645                                         // Some diag output
646                                         if (net->verbose) {
647                                                 printf("Locked Down download link, IP: %pI4\n",
648                                                         &NetServerIP);
649                                                 printf("Sending BOOTME request [%d] to %pI4\n",
650                                                         net->seqNum, &NetServerIP);
651                                         }
652
653                                         // Lock down EShell download link
654                                         ret = BOOTME_DOWNLOAD;
655                                 } else {
656                                         // Unknown link
657                                         printf("Unknown link\n");
658                                 }
659
660                                 if (ret == BOOTME_DOWNLOAD) {
661                                         int rc = ce_send_write_ack(net);
662                                         if (rc != 0)
663                                                 return rc;
664                                 }
665                         }
666                         break;
667
668                 case EDBG_CMD_WRITE:
669                         /* Fixup data len */
670                         bin->data = &net->data[4];
671                         bin->dataLen = net->dataLen - 4;
672                         ret = ce_parse_bin(bin);
673                         if (ret != CE_PR_ERROR) {
674                                 int rc = ce_send_write_ack(net);
675                                 if (rc)
676                                         return rc;
677                                 if (ret == CE_PR_EOF)
678                                         ret = BOOTME_DONE;
679                         } else {
680                                 ret = BOOTME_ERROR;
681                         }
682                         break;
683
684                 case EDBG_CMD_READ_REQ:
685                         printf("Ignoring EDBG_CMD_READ_REQ\n");
686                         /* Read requests are not supported
687                          * Do nothing ...
688                          */
689                         break;
690
691                 case EDBG_CMD_ERROR:
692                         printf("Error: unknown error on the host side\n");
693
694                         bin->binLen = 0;
695                         ret = BOOTME_ERROR;
696                         break;
697
698                 default:
699                         printf("unknown command 0x%04X\n", command);
700                         net->state = BOOTME_ERROR;
701                 }
702         }
703         return ret;
704 }
705
706 static enum bootme_state ce_process_edbg(ce_net *net, ce_bin *bin)
707 {
708         enum bootme_state ret = net->state;
709         eth_dbg_hdr header;
710
711         if (net->dataLen < sizeof(header)) {
712                 /* Bad packet */
713                 printf("Invalid packet size %u\n", net->dataLen);
714                 net->dataLen = 0;
715                 return ret;
716         }
717         memcpy(&header, net->data, sizeof(header));
718         if (header.id != EDBG_ID) {
719                 /* Bad packet */
720                 printf("Bad EDBG ID %08x\n", header.id);
721                 net->dataLen = 0;
722                 return ret;
723         }
724
725         if (header.service != EDBG_SVC_ADMIN) {
726                 /* Unknown service */
727                 printf("Bad EDBG service %02x\n", header.service);
728                 net->dataLen = 0;
729                 return ret;
730         }
731
732         if (net->state == BOOTME_INIT) {
733                 /* Some diag output */
734                 if (net->verbose) {
735                         printf("Locked Down EDBG service link, IP: %pI4\n",
736                                 &NetServerIP);
737                 }
738
739                 /* Lock down EDBG link */
740                 net->state = BOOTME_DEBUG;
741         }
742
743         switch (header.cmd) {
744         case EDBG_CMD_JUMPIMG:
745                 net->gotJumpingRequest = 1;
746
747                 if (net->verbose) {
748                         printf("Received JUMPING command\n");
749                 }
750                 /* Just pass through and copy CONFIG structure */
751                 ret = BOOTME_DONE;
752         case EDBG_CMD_OS_CONFIG:
753                 /* Copy config structure */
754                 memcpy(&bin->edbgConfig, &net->data[sizeof(header)],
755                         sizeof(edbg_os_config_data));
756                 if (net->verbose) {
757                         printf("Received CONFIG command\n");
758                         if (bin->edbgConfig.flags & EDBG_FL_DBGMSG) {
759                                 printf("--> Enabling DBGMSG service, IP: %pI4, port: %d\n",
760                                         &bin->edbgConfig.dbgMsgIPAddr,
761                                         ntohs(bin->edbgConfig.dbgMsgPort));
762                         }
763
764                         if (bin->edbgConfig.flags & EDBG_FL_PPSH) {
765                                 printf("--> Enabling PPSH service, IP: %pI4, port: %d\n",
766                                         &bin->edbgConfig.ppshIPAddr,
767                                         ntohs(bin->edbgConfig.ppshPort));
768                         }
769
770                         if (bin->edbgConfig.flags & EDBG_FL_KDBG) {
771                                 printf("--> Enabling KDBG service, IP: %pI4, port: %d\n",
772                                         &bin->edbgConfig.kdbgIPAddr,
773                                         ntohs(bin->edbgConfig.kdbgPort));
774                         }
775
776                         if (bin->edbgConfig.flags & EDBG_FL_CLEANBOOT) {
777                                 printf("--> Force clean boot\n");
778                         }
779                 }
780                 break;
781
782         default:
783                 if (net->verbose) {
784                         printf("Received unknown command: %08X\n", header.cmd);
785                 }
786                 return BOOTME_ERROR;
787         }
788
789         /* Respond with ack */
790         header.flags = EDBG_FL_FROM_DEV | EDBG_FL_ACK;
791         memcpy(net->data, &header, sizeof(header));
792         net->dataLen = EDBG_DATA_OFFSET;
793
794         int retries = 10;
795         int rc;
796         do {
797                 rc = bootme_send_frame(net->data, net->dataLen);
798                 if (rc != 0) {
799                         printf("Failed to send ACK: %d\n", rc);
800                 }
801         } while (rc && retries-- > 0);
802         return rc ?: ret;
803 }
804
805 static enum bootme_state ce_edbg_handler(const void *buf, size_t len)
806 {
807         if (len == 0)
808                 return BOOTME_DONE;
809
810         g_net.data = (void *)buf;
811         g_net.dataLen = len;
812
813         return ce_process_edbg(&g_net, &g_bin);
814 }
815
816 static void ce_init_edbg_link(ce_net *net)
817 {
818         /* Initialize EDBG link for commands */
819         net->state = BOOTME_INIT;
820 }
821
822 static enum bootme_state ce_download_handler(const void *buf, size_t len)
823 {
824         g_net.data = (void *)buf;
825         g_net.dataLen = len;
826
827         g_net.state = ce_process_download(&g_net, &g_bin);
828         return g_net.state;
829 }
830
831 static int ce_send_bootme(ce_net *net)
832 {
833         eth_dbg_hdr *header;
834         edbg_bootme_data *data;
835         unsigned char txbuf[PKTSIZE_ALIGN];
836 #ifdef DEBUG
837         int     i;
838         unsigned char   *pkt;
839 #endif
840         /* Fill out BOOTME packet */
841         net->data = txbuf;
842
843         memset(net->data, 0, PKTSIZE);
844         header = (eth_dbg_hdr *)net->data;
845         data = (edbg_bootme_data *)header->data;
846
847         header->id = EDBG_ID;
848         header->service = EDBG_SVC_ADMIN;
849         header->flags = EDBG_FL_FROM_DEV;
850         header->seqNum = net->seqNum++;
851         header->cmd = EDBG_CMD_BOOTME;
852
853         data->versionMajor = 0;
854         data->versionMinor = 0;
855         data->cpuId = EDBG_CPU_TYPE_ARM;
856         data->bootmeVer = EDBG_CURRENT_BOOTME_VERSION;
857         data->bootFlags = 0;
858         data->downloadPort = 0;
859         data->svcPort = 0;
860
861         /* MAC address from environment*/
862         if (!eth_getenv_enetaddr("ethaddr", data->macAddr)) {
863                 printf("'ethaddr' is not set or invalid\n");
864                 memset(data->macAddr, 0, sizeof(data->macAddr));
865         }
866
867         /* IP address from active config */
868         NetCopyIP(&data->ipAddr, &NetOurIP);
869
870         // Device name string (NULL terminated). Should include
871         // platform and number based on Ether address (e.g. Odo42, CEPCLS2346, etc)
872
873         // We will use lower MAC address segment to create device name
874         // eg. MAC '00-0C-C6-69-09-05', device name 'Triton05'
875
876         strncpy(data->platformId, "Triton", sizeof(data->platformId));
877         snprintf(data->deviceName, sizeof(data->deviceName), "%s%02X",
878                 data->platformId, data->macAddr[5]);
879
880 #ifdef DEBUG
881         printf("header->id: %08X\n", header->id);
882         printf("header->service: %08X\n", header->service);
883         printf("header->flags: %08X\n", header->flags);
884         printf("header->seqNum: %08X\n", header->seqNum);
885         printf("header->cmd: %08X\n\n", header->cmd);
886
887         printf("data->versionMajor: %08X\n", data->versionMajor);
888         printf("data->versionMinor: %08X\n", data->versionMinor);
889         printf("data->cpuId: %08X\n", data->cpuId);
890         printf("data->bootmeVer: %08X\n", data->bootmeVer);
891         printf("data->bootFlags: %08X\n", data->bootFlags);
892         printf("data->svcPort: %08X\n\n", ntohs(data->svcPort));
893
894         printf("data->macAddr: %pM\n", data->macAddr);
895         printf("data->ipAddr: %pI4\n", &data->ipAddr);
896         printf("data->platformId: %s\n", data->platformId);
897         printf("data->deviceName: %s\n", data->deviceName);
898 #endif
899         // Some diag output ...
900         if (net->verbose) {
901                 printf("Sending BOOTME request [%d] to %pI4\n", net->seqNum,
902                         &server_ip);
903         }
904
905         net->dataLen = BOOTME_PKT_SIZE;
906 //      net->status = CE_PR_MORE;
907         net->state = BOOTME_INIT;
908 #ifdef DEBUG
909         debug("Start of buffer:      %p\n", net->data);
910         debug("Start of ethernet buffer:   %p\n", net->data);
911         debug("Start of CE header:         %p\n", header);
912         debug("Start of CE data:           %p\n", data);
913
914         pkt = net->data;
915         debug("packet to send (ceconnect): \n");
916         for (i = 0; i < net->dataLen; i++) {
917                 debug("0x%02X ", pkt[i]);
918                 if (!((i + 1) % 16))
919                         debug("\n");
920         }
921         debug("\n");
922 #endif
923         return BootMeRequest(server_ip, net->data, net->dataLen, 1);
924 }
925
926 static inline int ce_init_download_link(ce_net *net, ce_bin *bin, int verbose)
927 {
928         if (!eth_get_dev()) {
929                 printf("No network interface available\n");
930                 return -ENODEV;
931         }
932         printf("Using device '%s'\n", eth_get_name());
933
934         /* Initialize EDBG link for download */
935         memset(net, 0, sizeof(*net));
936
937         net->verbose = verbose;
938
939         /* buffer will be dynamically assigned in ce_download_handler() */
940         ce_init_bin(bin, NULL);
941         return 0;
942 }
943
944 #define UINT_MAX ~0UL
945
946 static inline int ce_download_file(ce_net *net, ulong timeout)
947 {
948         ulong start = get_timer_masked();
949
950         while (net->state == BOOTME_INIT) {
951                 int ret;
952
953                 if (timeout && get_timer(start) > timeout) {
954                         printf("CELOAD - Canceled, timeout\n");
955                         return 1;
956                 }
957
958                 if (ctrlc()) {
959                         printf("CELOAD - canceled by user\n");
960                         return 1;
961                 }
962
963                 if (ce_send_bootme(&g_net)) {
964                         printf("CELOAD - error while sending BOOTME request\n");
965                         return 1;
966                 }
967                 if (net->verbose) {
968                         if (timeout) {
969                                 printf("Waiting for connection, timeout %lu sec\n",
970                                         DIV_ROUND_UP(timeout - get_timer(start),
971                                                 CONFIG_SYS_HZ));
972                         } else {
973                                 printf("Waiting for connection, enter ^C to abort\n");
974                         }
975                 }
976
977                 ret = BootMeDownload(ce_download_handler);
978                 if (ret == BOOTME_ERROR) {
979                         printf("CELOAD - aborted\n");
980                         return 1;
981                 }
982         }
983         return 0;
984 }
985
986 static void ce_disconnect(void)
987 {
988         net_set_udp_handler(NULL);
989         eth_halt();
990 }
991
992 static int do_ceconnect(cmd_tbl_t *cmdtp, int flag, int argc, char *const argv[])
993 {
994         int verbose = 0;
995         ulong timeout = 0;
996         int ret = 1;
997         int i;
998
999         server_ip = 0;
1000
1001         for (i = 1; i < argc; i++){
1002                 if (*argv[i] != '-')
1003                         break;
1004                 if (argv[i][1] == 'v') {
1005                         verbose = 1;
1006                 } else if (argv[i][1] == 't') {
1007                         i++;
1008                         if (argc > i) {
1009                                 timeout = simple_strtoul(argv[i],
1010                                                         NULL, 0);
1011                                 if (timeout >= UINT_MAX / CONFIG_SYS_HZ) {
1012                                         printf("Timeout value %lu out of range (max.: %lu)\n",
1013                                                 timeout, UINT_MAX / CONFIG_SYS_HZ - 1);
1014                                         return CMD_RET_USAGE;
1015                                 }
1016                                 timeout *= CONFIG_SYS_HZ;
1017                         } else {
1018                                 printf("Option requires an argument - t\n");
1019                                 return CMD_RET_USAGE;
1020                         }
1021                 } else if (argv[i][1] == 'h') {
1022                         i++;
1023                         if (argc > i) {
1024                                 server_ip = string_to_ip(argv[i]);
1025                                 printf("Using server %pI4\n", &server_ip);
1026                         } else {
1027                                 printf("Option requires an argument - h\n");
1028                                 return CMD_RET_USAGE;
1029                         }
1030                 }
1031         }
1032
1033         if (ce_init_download_link(&g_net, &g_bin, verbose) != 0)
1034                 goto err;
1035
1036         if (ce_download_file(&g_net, timeout))
1037                 goto err;
1038
1039         if (g_bin.binLen) {
1040                 // Try to receive edbg commands from host
1041                 ce_init_edbg_link(&g_net);
1042                 if (verbose)
1043                         printf("Waiting for EDBG commands ...\n");
1044
1045                 ret = BootMeDebugStart(ce_edbg_handler);
1046                 if (ret != BOOTME_DONE)
1047                         goto err;
1048
1049                 // Prepare WinCE image for execution
1050                 ce_prepare_run_bin(&g_bin);
1051
1052                 // Launch WinCE, if necessary
1053                 if (g_net.gotJumpingRequest)
1054                         ce_run_bin(g_bin.eEntryPoint);
1055         }
1056         ret = 0;
1057 err:
1058         ce_disconnect();
1059         return ret == 0 ? CMD_RET_SUCCESS : CMD_RET_FAILURE;
1060 }
1061 U_BOOT_CMD(
1062         ceconnect, 6, 1, do_ceconnect,
1063         "Set up a connection to the CE host PC over TCP/IP and download the run-time image\n",
1064         "[-v] [-t <timeout>] [-h host]\n"
1065         "  -v            - verbose operation\n"
1066         "  -t <timeout>  - max wait time (#sec) for the connection\n"
1067         "  -h <host>     - send BOOTME requests to <host> (default: broadcast address 255.255.255.255)"
1068 );