clone.c 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
  1. // SPDX-License-Identifier: GPL-2.0+
  2. /*
  3. * Copyright (C) 2020 John Chau <john@harmon.hk>
  4. *
  5. */
  6. #include <common.h>
  7. #include <command.h>
  8. #include <malloc.h>
  9. #include <part.h>
  10. #include <blk.h>
  11. #include <vsprintf.h>
  12. #define BUFSIZE (1 * 1024 * 1024)
  13. static int do_clone(struct cmd_tbl *cmdtp, int flag, int argc, char * const argv[])
  14. {
  15. int srcdev, destdev;
  16. struct blk_desc *srcdesc, *destdesc;
  17. int srcbz, destbz, ret;
  18. char *unit, *buf;
  19. unsigned long wrcnt, rdcnt, requested, srcblk, destblk;
  20. unsigned long timer;
  21. const unsigned long buffersize = 1024 * 1024;
  22. if (argc < 6)
  23. return CMD_RET_USAGE;
  24. srcdev = blk_get_device_by_str(argv[1], argv[2], &srcdesc);
  25. destdev = blk_get_device_by_str(argv[3], argv[4], &destdesc);
  26. if (srcdev < 0) {
  27. printf("Unable to open source device\n");
  28. return 1;
  29. } else if (destdev < 0) {
  30. printf("Unable to open destination device\n");
  31. return 1;
  32. }
  33. requested = simple_strtoul(argv[5], &unit, 10);
  34. srcbz = srcdesc->blksz;
  35. destbz = destdesc->blksz;
  36. if ((srcbz * (buffersize / srcbz) != buffersize) &&
  37. (destbz * (buffersize / destbz) != buffersize)) {
  38. printf("failed: cannot match device block sizes\n");
  39. return 1;
  40. }
  41. if (requested == 0) {
  42. unsigned long a = srcdesc->lba * srcdesc->blksz;
  43. unsigned long b = destdesc->lba * destdesc->blksz;
  44. if (a > b)
  45. requested = a;
  46. else
  47. requested = b;
  48. } else {
  49. switch (unit[0]) {
  50. case 'g':
  51. case 'G':
  52. requested *= 1024;
  53. case 'm':
  54. case 'M':
  55. requested *= 1024;
  56. case 'k':
  57. case 'K':
  58. requested *= 1024;
  59. break;
  60. }
  61. }
  62. printf("Copying %ld bytes from %s:%s to %s:%s\n",
  63. requested, argv[1], argv[2], argv[3], argv[4]);
  64. wrcnt = 0;
  65. rdcnt = 0;
  66. buf = (char *)malloc(BUFSIZE);
  67. srcblk = 0;
  68. destblk = 0;
  69. timer = get_timer(0);
  70. while (wrcnt < requested) {
  71. unsigned long toread = BUFSIZE / srcbz;
  72. unsigned long towrite = BUFSIZE / destbz;
  73. unsigned long offset = 0;
  74. read:
  75. ret = blk_dread(srcdesc, srcblk, toread, buf + offset);
  76. if (ret < 0) {
  77. printf("Src read error @blk %ld\n", srcblk);
  78. goto exit;
  79. }
  80. rdcnt += ret * srcbz;
  81. srcblk += ret;
  82. if (ret < toread) {
  83. toread -= ret;
  84. offset += ret * srcbz;
  85. goto read;
  86. }
  87. offset = 0;
  88. write:
  89. ret = blk_dwrite(destdesc, destblk, towrite, buf + offset);
  90. if (ret < 0) {
  91. printf("Dest write error @blk %ld\n", srcblk);
  92. goto exit;
  93. }
  94. wrcnt += ret * destbz;
  95. destblk += ret;
  96. if (ret < towrite) {
  97. towrite -= ret;
  98. offset += ret * destbz;
  99. goto write;
  100. }
  101. }
  102. exit:
  103. timer = get_timer(timer);
  104. timer = 1000 * timer / CONFIG_SYS_HZ;
  105. printf("%ld read\n", rdcnt);
  106. printf("%ld written\n", wrcnt);
  107. printf("%ldms, %ldkB/s\n", timer, wrcnt / timer);
  108. free(buf);
  109. return 0;
  110. }
  111. U_BOOT_CMD(
  112. clone, 6, 1, do_clone,
  113. "simple storage cloning",
  114. "<src interface> <src dev> <dest interface> <dest dev> <size[K/M/G]>\n"
  115. "clone storage from 'src dev' on 'src interface' to 'dest dev' on 'dest interface' with maximum 'size' bytes (or 0 for clone to end)"
  116. );