msh_file.c 28 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168
  1. /*
  2. * Copyright (c) 2006-2025 RT-Thread Development Team
  3. *
  4. * SPDX-License-Identifier: Apache-2.0
  5. *
  6. * Change Logs:
  7. * Date Author Notes
  8. * 2015-09-25 Bernard the first verion for FinSH
  9. * 2021-06-09 Meco Man implement tail command
  10. */
  11. #include <rtthread.h>
  12. #if defined(RT_USING_FINSH) && defined(DFS_USING_POSIX)
  13. #include <finsh.h>
  14. #include "msh.h"
  15. #include <dfs_file.h>
  16. #include <unistd.h>
  17. #include <fcntl.h>
  18. #ifdef RT_USING_DFS_V2
  19. #include <dfs_mnt.h>
  20. #endif
  21. #ifdef RT_USING_SMART
  22. #include "lwp.h"
  23. #endif /* RT_USING_SMART */
  24. static int msh_readline(int fd, char *line_buf, int size)
  25. {
  26. char ch;
  27. int index = 0;
  28. do
  29. {
  30. if (read(fd, &ch, 1) != 1)
  31. {
  32. /* nothing in this file */
  33. return 0;
  34. }
  35. }
  36. while (ch == '\n' || ch == '\r');
  37. /* set the first character */
  38. line_buf[index ++] = ch;
  39. while (index < size)
  40. {
  41. if (read(fd, &ch, 1) == 1)
  42. {
  43. if (ch == '\n' || ch == '\r')
  44. {
  45. line_buf[index] = '\0';
  46. break;
  47. }
  48. line_buf[index++] = ch;
  49. }
  50. else
  51. {
  52. line_buf[index] = '\0';
  53. break;
  54. }
  55. }
  56. return index;
  57. }
  58. int msh_exec_script(const char *cmd_line, int size)
  59. {
  60. int ret;
  61. int fd = -1;
  62. char *pg_name;
  63. int length, cmd_length = 0;
  64. if (size == 0) return -RT_ERROR;
  65. /* get the length of command0 */
  66. while ((cmd_line[cmd_length] != ' ' && cmd_line[cmd_length] != '\t') && cmd_length < size)
  67. cmd_length ++;
  68. /* get name length */
  69. length = cmd_length + 32;
  70. /* allocate program name memory */
  71. pg_name = (char *) rt_malloc(length);
  72. if (pg_name == RT_NULL) return -RT_ENOMEM;
  73. /* copy command0 */
  74. rt_memcpy(pg_name, cmd_line, cmd_length);
  75. pg_name[cmd_length] = '\0';
  76. if (rt_strstr(pg_name, ".sh") != RT_NULL || rt_strstr(pg_name, ".SH") != RT_NULL)
  77. {
  78. /* try to open program */
  79. fd = open(pg_name, O_RDONLY, 0);
  80. /* search in /bin path */
  81. if (fd < 0)
  82. {
  83. rt_snprintf(pg_name, length - 1, "/bin/%.*s", cmd_length, cmd_line);
  84. fd = open(pg_name, O_RDONLY, 0);
  85. }
  86. }
  87. rt_free(pg_name);
  88. if (fd >= 0)
  89. {
  90. /* found script */
  91. char *line_buf;
  92. int length;
  93. line_buf = (char *) rt_malloc(RT_CONSOLEBUF_SIZE);
  94. if (line_buf == RT_NULL)
  95. {
  96. close(fd);
  97. return -RT_ENOMEM;
  98. }
  99. /* read line by line and then exec it */
  100. do
  101. {
  102. length = msh_readline(fd, line_buf, RT_CONSOLEBUF_SIZE);
  103. if (length > 0)
  104. {
  105. char ch = '\0';
  106. int index;
  107. for (index = 0; index < length; index ++)
  108. {
  109. ch = line_buf[index];
  110. if (ch == ' ' || ch == '\t') continue;
  111. else break;
  112. }
  113. if (ch != '#') /* not a comment */
  114. msh_exec(line_buf, length);
  115. }
  116. }
  117. while (length > 0);
  118. close(fd);
  119. rt_free(line_buf);
  120. ret = 0;
  121. }
  122. else
  123. {
  124. ret = -1;
  125. }
  126. return ret;
  127. }
  128. #ifdef DFS_USING_WORKDIR
  129. extern char working_directory[];
  130. #endif
  131. static int cmd_ls(int argc, char **argv)
  132. {
  133. extern void ls(const char *pathname);
  134. if (argc == 1)
  135. {
  136. #ifdef DFS_USING_WORKDIR
  137. #ifdef RT_USING_SMART
  138. ls(lwp_getcwd());
  139. #else
  140. ls(working_directory);
  141. #endif
  142. #else
  143. ls("/");
  144. #endif
  145. }
  146. else
  147. {
  148. ls(argv[1]);
  149. }
  150. return 0;
  151. }
  152. MSH_CMD_EXPORT_ALIAS(cmd_ls, ls, List information about the FILEs.);
  153. #ifdef RT_USING_DFS_V2
  154. static int cmd_ln(int argc, char **argv)
  155. {
  156. if (argc < 3)
  157. {
  158. rt_kprintf("Usage: ln target link_name\n");
  159. rt_kprintf("Make symbolic link between files.\n");
  160. }
  161. else
  162. {
  163. for(int i = 0; i + 3 <= argc; i ++)
  164. {
  165. dfs_file_symlink(argv[1], argv[2 + i]);
  166. }
  167. }
  168. return 0;
  169. }
  170. MSH_CMD_EXPORT_ALIAS(cmd_ln, ln, Make symbolic link between files);
  171. static int cmd_link(int argc, char **argv)
  172. {
  173. if (argc < 3)
  174. {
  175. rt_kprintf("Usage: link target link_name\n");
  176. rt_kprintf("Make link between files.\n");
  177. }
  178. else
  179. {
  180. for(int i = 0; i + 3 <= argc; i ++)
  181. {
  182. dfs_file_link(argv[1], argv[2 + i]);
  183. }
  184. }
  185. return 0;
  186. }
  187. MSH_CMD_EXPORT_ALIAS(cmd_link, link, Make link between files);
  188. #endif
  189. static int cmd_cp(int argc, char **argv)
  190. {
  191. void copy(const char *src, const char *dst);
  192. if (argc != 3)
  193. {
  194. rt_kprintf("Usage: cp SOURCE DEST\n");
  195. rt_kprintf("Copy SOURCE to DEST.\n");
  196. }
  197. else
  198. {
  199. copy(argv[1], argv[2]);
  200. }
  201. return 0;
  202. }
  203. MSH_CMD_EXPORT_ALIAS(cmd_cp, cp, Copy SOURCE to DEST.);
  204. static int cmd_mv(int argc, char **argv)
  205. {
  206. if (argc != 3)
  207. {
  208. rt_kprintf("Usage: mv SOURCE DEST\n");
  209. rt_kprintf("Rename SOURCE to DEST, or move SOURCE(s) to DIRECTORY.\n");
  210. }
  211. else
  212. {
  213. int fd;
  214. char *dest = RT_NULL;
  215. rt_kprintf("%s => %s\n", argv[1], argv[2]);
  216. fd = open(argv[2], O_DIRECTORY, 0);
  217. if (fd >= 0)
  218. {
  219. char *src;
  220. close(fd);
  221. /* it's a directory */
  222. dest = (char *)rt_malloc(DFS_PATH_MAX);
  223. if (dest == RT_NULL)
  224. {
  225. rt_kprintf("out of memory\n");
  226. return -RT_ENOMEM;
  227. }
  228. src = argv[1] + rt_strlen(argv[1]);
  229. while (src != argv[1])
  230. {
  231. if (*src == '/') break;
  232. src --;
  233. }
  234. rt_snprintf(dest, DFS_PATH_MAX - 1, "%s/%s", argv[2], src);
  235. }
  236. else
  237. {
  238. fd = open(argv[2], O_RDONLY, 0);
  239. if (fd >= 0)
  240. {
  241. close(fd);
  242. unlink(argv[2]);
  243. }
  244. dest = argv[2];
  245. }
  246. rename(argv[1], dest);
  247. if (dest != RT_NULL && dest != argv[2]) rt_free(dest);
  248. }
  249. return 0;
  250. }
  251. MSH_CMD_EXPORT_ALIAS(cmd_mv, mv, Rename SOURCE to DEST.);
  252. static int cmd_cat(int argc, char **argv)
  253. {
  254. int index;
  255. extern void cat(const char *filename);
  256. if (argc == 1)
  257. {
  258. rt_kprintf("Usage: cat [FILE]...\n");
  259. rt_kprintf("Concatenate FILE(s)\n");
  260. return 0;
  261. }
  262. for (index = 1; index < argc; index ++)
  263. {
  264. cat(argv[index]);
  265. }
  266. return 0;
  267. }
  268. MSH_CMD_EXPORT_ALIAS(cmd_cat, cat, Concatenate FILE(s));
  269. static void directory_delete_for_msh(const char *pathname, char f, char v)
  270. {
  271. DIR *dir = NULL;
  272. struct dirent *dirent = NULL;
  273. char *full_path;
  274. if (pathname == RT_NULL)
  275. return;
  276. full_path = (char *)rt_malloc(DFS_PATH_MAX);
  277. if (full_path == RT_NULL)
  278. return;
  279. dir = opendir(pathname);
  280. if (dir == RT_NULL)
  281. {
  282. if (f == 0)
  283. {
  284. rt_kprintf("cannot remove '%s'\n", pathname);
  285. }
  286. rt_free(full_path);
  287. return;
  288. }
  289. while (1)
  290. {
  291. dirent = readdir(dir);
  292. if (dirent == RT_NULL)
  293. break;
  294. if (rt_strcmp(".", dirent->d_name) != 0 &&
  295. rt_strcmp("..", dirent->d_name) != 0)
  296. {
  297. if (rt_strlen(pathname) + 1 + rt_strlen(dirent->d_name) > DFS_PATH_MAX)
  298. {
  299. rt_kprintf("cannot remove '%s/%s', path too long.\n", pathname, dirent->d_name);
  300. continue;
  301. }
  302. rt_sprintf(full_path, "%s/%s", pathname, dirent->d_name);
  303. if (dirent->d_type != DT_DIR)
  304. {
  305. if (unlink(full_path) != 0)
  306. {
  307. if (f == 0)
  308. rt_kprintf("cannot remove '%s'\n", full_path);
  309. }
  310. else if (v)
  311. {
  312. rt_kprintf("removed '%s'\n", full_path);
  313. }
  314. }
  315. else
  316. {
  317. directory_delete_for_msh(full_path, f, v);
  318. }
  319. }
  320. }
  321. closedir(dir);
  322. rt_free(full_path);
  323. if (rmdir(pathname) != 0)
  324. {
  325. if (f == 0)
  326. rt_kprintf("cannot remove '%s'\n", pathname);
  327. }
  328. else if (v)
  329. {
  330. rt_kprintf("removed directory '%s'\n", pathname);
  331. }
  332. }
  333. static int cmd_rm(int argc, char **argv)
  334. {
  335. int index, n;
  336. char f = 0, r = 0, v = 0;
  337. if (argc == 1)
  338. {
  339. rt_kprintf("Usage: rm option(s) FILE...\n");
  340. rt_kprintf("Remove (unlink) the FILE(s).\n");
  341. return 0;
  342. }
  343. if (argv[1][0] == '-')
  344. {
  345. for (n = 0; argv[1][n]; n++)
  346. {
  347. switch (argv[1][n])
  348. {
  349. case 'f':
  350. f = 1;
  351. break;
  352. case 'r':
  353. r = 1;
  354. break;
  355. case 'v':
  356. v = 1;
  357. break;
  358. case '-':
  359. break;
  360. default:
  361. rt_kprintf("Error: Bad option: %c\n", argv[1][n]);
  362. return 0;
  363. }
  364. }
  365. argc -= 1;
  366. argv = argv + 1;
  367. }
  368. for (index = 1; index < argc; index ++)
  369. {
  370. struct stat s;
  371. #ifdef RT_USING_DFS_V2
  372. if (dfs_file_lstat(argv[index], &s) == 0)
  373. #else
  374. if (stat(argv[index], &s) == 0)
  375. #endif
  376. {
  377. if (S_ISDIR(s.st_mode))
  378. {
  379. if (r == 0)
  380. rt_kprintf("cannot remove '%s': Is a directory\n", argv[index]);
  381. else
  382. directory_delete_for_msh(argv[index], f, v);
  383. }
  384. else
  385. {
  386. if (unlink(argv[index]) != 0)
  387. {
  388. if (f == 0)
  389. rt_kprintf("cannot remove '%s'\n", argv[index]);
  390. }
  391. else if (v)
  392. {
  393. rt_kprintf("removed '%s'\n", argv[index]);
  394. }
  395. }
  396. }
  397. else if (f == 0)
  398. {
  399. rt_kprintf("cannot remove '%s': No such file or directory\n", argv[index]);
  400. }
  401. }
  402. return 0;
  403. }
  404. MSH_CMD_EXPORT_ALIAS(cmd_rm, rm, Remove(unlink) the FILE(s).);
  405. #ifdef DFS_USING_WORKDIR
  406. static int cmd_cd(int argc, char **argv)
  407. {
  408. if (argc == 1)
  409. {
  410. rt_kprintf("%s\n", working_directory);
  411. }
  412. else if (argc == 2)
  413. {
  414. if (chdir(argv[1]) != 0)
  415. {
  416. rt_kprintf("No such directory: %s\n", argv[1]);
  417. }
  418. }
  419. return 0;
  420. }
  421. MSH_CMD_EXPORT_ALIAS(cmd_cd, cd, Change the shell working directory.);
  422. static int cmd_pwd(int argc, char **argv)
  423. {
  424. rt_kprintf("%s\n", working_directory);
  425. return 0;
  426. }
  427. MSH_CMD_EXPORT_ALIAS(cmd_pwd, pwd, Print the name of the current working directory.);
  428. #endif
  429. static int cmd_mkdir(int argc, char **argv)
  430. {
  431. if (argc == 1)
  432. {
  433. rt_kprintf("Usage: mkdir [OPTION] DIRECTORY\n");
  434. rt_kprintf("Create the DIRECTORY, if they do not already exist.\n");
  435. }
  436. else
  437. {
  438. mkdir(argv[1], 0);
  439. }
  440. return 0;
  441. }
  442. MSH_CMD_EXPORT_ALIAS(cmd_mkdir, mkdir, Create the DIRECTORY.);
  443. static int cmd_mkfs(int argc, char **argv)
  444. {
  445. int result = 0;
  446. char *type = "elm"; /* use the default file system type as 'fatfs' */
  447. if (argc == 2)
  448. {
  449. result = dfs_mkfs(type, argv[1]);
  450. }
  451. else if (argc == 4)
  452. {
  453. if (rt_strcmp(argv[1], "-t") == 0)
  454. {
  455. type = argv[2];
  456. result = dfs_mkfs(type, argv[3]);
  457. }
  458. }
  459. else
  460. {
  461. rt_kprintf("Usage: mkfs [-t type] device\n");
  462. return 0;
  463. }
  464. if (result != RT_EOK)
  465. {
  466. rt_kprintf("mkfs failed, result=%d\n", result);
  467. }
  468. return 0;
  469. }
  470. MSH_CMD_EXPORT_ALIAS(cmd_mkfs, mkfs, format disk with file system);
  471. /*
  472. * If no argument is specified, display the mount history;
  473. * If there are 3 arguments, mount the filesystem.
  474. * The order of the arguments is:
  475. * argv[1]: device name
  476. * argv[2]: mountpoint path
  477. * argv[3]: filesystem type
  478. */
  479. static int cmd_mount(int argc, char **argv)
  480. {
  481. if (argc == 1)
  482. {
  483. #ifdef RT_USING_DFS_V2
  484. /* display the mount history */
  485. rt_kprintf("filesystem device mountpoint refcount\n");
  486. rt_kprintf("---------- ------ ---------- --------\n");
  487. dfs_mnt_list(RT_NULL);
  488. #else
  489. extern struct dfs_filesystem filesystem_table[];
  490. struct dfs_filesystem *iter;
  491. /* display the mount history */
  492. rt_kprintf("filesystem device mountpoint\n");
  493. rt_kprintf("---------- ------ ----------\n");
  494. for (iter = &filesystem_table[0];
  495. iter < &filesystem_table[DFS_FILESYSTEMS_MAX]; iter++)
  496. {
  497. if ((iter != NULL) && (iter->path != NULL))
  498. {
  499. rt_kprintf("%-10s %-6s %-s\n",
  500. iter->ops->name, iter->dev_id->parent.name, iter->path);
  501. }
  502. }
  503. #endif
  504. return 0;
  505. }
  506. else if (argc == 4)
  507. {
  508. char *device = argv[1];
  509. char *path = argv[2];
  510. char *fstype = argv[3];
  511. char *data = 0;
  512. /* mount a filesystem to the specified directory */
  513. rt_kprintf("mount device %s(%s) onto %s ... ", device, fstype, path);
  514. if (rt_strcmp(fstype, "nfs") == 0 || rt_strcmp(fstype, "9p") == 0)
  515. {
  516. data = argv[1];
  517. device = 0;
  518. }
  519. if (dfs_mount(device, path, fstype, 0, data) == 0)
  520. {
  521. rt_kprintf("succeed!\n");
  522. return 0;
  523. }
  524. else
  525. {
  526. rt_kprintf("failed!\n");
  527. return -1;
  528. }
  529. }
  530. else if (argc == 3)
  531. {
  532. char *path = argv[1];
  533. char *fstype = argv[2];
  534. /* mount a filesystem to the specified directory */
  535. rt_kprintf("mount (%s) onto %s ... ", fstype, path);
  536. if (dfs_mount(NULL, path, fstype, 0, 0) == 0)
  537. {
  538. rt_kprintf("succeed!\n");
  539. return 0;
  540. }
  541. else
  542. {
  543. rt_kprintf("failed!\n");
  544. return -1;
  545. }
  546. }
  547. else
  548. {
  549. rt_kprintf("Usage: mount <device> <mountpoint> <fstype>.\n");
  550. return -1;
  551. }
  552. }
  553. MSH_CMD_EXPORT_ALIAS(cmd_mount, mount, mount <device> <mountpoint> <fstype>);
  554. /* unmount the filesystem from the specified mountpoint */
  555. static int cmd_umount(int argc, char **argv)
  556. {
  557. #ifndef RT_USING_DFS_V2
  558. char *path = argv[1];
  559. if (argc != 2)
  560. {
  561. rt_kprintf("Usage: unmount <mountpoint>.\n");
  562. return -1;
  563. }
  564. rt_kprintf("unmount %s ... ", path);
  565. if (dfs_unmount(path) < 0)
  566. {
  567. rt_kprintf("failed!\n");
  568. return -1;
  569. }
  570. else
  571. {
  572. rt_kprintf("succeed!\n");
  573. return 0;
  574. }
  575. #else
  576. int flags = 0;
  577. char *path = argv[1];
  578. if (argc < 2)
  579. {
  580. rt_kprintf("Usage: unmount [-f] <mountpoint>.\n");
  581. return -1;
  582. }
  583. if (argc > 2)
  584. {
  585. flags = rt_strcmp(argv[1], "-f") == 0 ? MNT_FORCE : 0;
  586. path = argv[2];
  587. }
  588. rt_kprintf("unmount %s ... ", path);
  589. if (dfs_umount(path, flags) < 0)
  590. {
  591. rt_kprintf("failed!\n");
  592. return -1;
  593. }
  594. else
  595. {
  596. rt_kprintf("succeed!\n");
  597. return 0;
  598. }
  599. #endif
  600. }
  601. MSH_CMD_EXPORT_ALIAS(cmd_umount, umount, Unmount the mountpoint);
  602. static int cmd_df(int argc, char **argv)
  603. {
  604. #ifndef RT_USING_DFS_V2
  605. extern int df(const char *path);
  606. if (argc != 2)
  607. {
  608. df("/");
  609. }
  610. else
  611. {
  612. if ((rt_strcmp(argv[1], "--help") == 0) || (rt_strcmp(argv[1], "-h") == 0))
  613. {
  614. rt_kprintf("df [path]\n");
  615. }
  616. else
  617. {
  618. df(argv[1]);
  619. }
  620. }
  621. #endif
  622. return 0;
  623. }
  624. MSH_CMD_EXPORT_ALIAS(cmd_df, df, disk free);
  625. static int cmd_echo(int argc, char **argv)
  626. {
  627. if (argc == 2)
  628. {
  629. rt_kprintf("%s\n", argv[1]);
  630. }
  631. else if (argc == 3)
  632. {
  633. int fd;
  634. fd = open(argv[2], O_RDWR | O_APPEND | O_CREAT, 0);
  635. if (fd >= 0)
  636. {
  637. write(fd, argv[1], rt_strlen(argv[1]));
  638. close(fd);
  639. }
  640. else
  641. {
  642. rt_kprintf("open file:%s failed!\n", argv[2]);
  643. }
  644. }
  645. else
  646. {
  647. rt_kprintf("Usage: echo \"string\" [filename]\n");
  648. }
  649. return 0;
  650. }
  651. MSH_CMD_EXPORT_ALIAS(cmd_echo, echo, echo string to file);
  652. /**
  653. * @brief Print the last part of a file (tail command).
  654. *
  655. * @note Supported Usage:
  656. * 1. tail <file> : Print last 10 lines.
  657. * 2. tail -n <num> <file> : Print last <num> lines.
  658. * 3. tail -n +<num> <file> : Print starting from line <num>.
  659. *
  660. * @param argc Argument count
  661. * @param argv Argument vector
  662. * @return 0 on success, -1 on failure
  663. */
  664. static int cmd_tail(int argc, char **argv)
  665. {
  666. int fd;
  667. char c = RT_NULL;
  668. char *file_name = RT_NULL;
  669. rt_uint32_t total_lines = 0;
  670. rt_uint32_t target_line = 0;
  671. rt_uint32_t current_line = 0;
  672. rt_uint32_t required_lines = 0;
  673. rt_uint32_t start_line = 0;
  674. if (argc < 2)
  675. {
  676. rt_kprintf("Usage: tail [-n [+]numbers] <filename>\n");
  677. return -1;
  678. }
  679. else if (argc == 2)
  680. {
  681. required_lines = 10; /* default: 10 lines from tail */
  682. file_name = argv[1];
  683. }
  684. else if (rt_strcmp(argv[1], "-n") == 0)
  685. {
  686. /*
  687. * Check if enough arguments are provided to avoid crash.
  688. * The command requires: "tail" + "-n" + "number" + "file" = 4 args.
  689. */
  690. if (argc < 4)
  691. {
  692. rt_kprintf("Error: Missing arguments.\n");
  693. rt_kprintf("Usage: tail -n [+]numbers <filename>\n");
  694. return -1;
  695. }
  696. /* Check for explicit start line syntax (e.g., +100) */
  697. if (argv[2][0] != '+')
  698. {
  699. required_lines = atoi(argv[2]);
  700. }
  701. else
  702. {
  703. start_line = atoi(&argv[2][1]); /* eg: +100, skip '+' to get 100 */
  704. }
  705. file_name = argv[3];
  706. }
  707. else
  708. {
  709. rt_kprintf("Usage: tail [-n [+]numbers] <filename>\n");
  710. return -1;
  711. }
  712. fd = open(file_name, O_RDONLY);
  713. if (fd < 0)
  714. {
  715. rt_kprintf("File doesn't exist\n");
  716. return -1;
  717. }
  718. while ((read(fd, &c, sizeof(char))) > 0)
  719. {
  720. if(total_lines == 0)
  721. {
  722. total_lines++;
  723. }
  724. if (c == '\n')
  725. {
  726. total_lines++;
  727. }
  728. }
  729. rt_kprintf("\nTotal Number of lines:%ld\n", total_lines);
  730. if (start_line != 0)
  731. {
  732. if (total_lines >= start_line)
  733. {
  734. required_lines = total_lines - start_line + 1;
  735. }
  736. else
  737. {
  738. rt_kprintf("\nError:Required lines are more than total number of lines\n");
  739. close(fd);
  740. return -1;
  741. }
  742. }
  743. if (required_lines > total_lines)
  744. {
  745. rt_kprintf("\nError:Required lines are more than total number of lines\n");
  746. close(fd);
  747. return -1;
  748. }
  749. rt_kprintf("Required Number of lines:%ld\n", required_lines);
  750. target_line = total_lines - required_lines;
  751. lseek(fd, 0, SEEK_SET); /* back to head */
  752. while ((read(fd, &c, sizeof(char))) > 0)
  753. {
  754. if (current_line >= target_line)
  755. {
  756. rt_kprintf("%c", c);
  757. }
  758. if (c == '\n')
  759. {
  760. current_line++;
  761. }
  762. }
  763. rt_kprintf("\n");
  764. close(fd);
  765. return 0;
  766. }
  767. MSH_CMD_EXPORT_ALIAS(cmd_tail, tail, Print the last N lines. Usage: tail -n [+]numbers <filename>);
  768. #ifdef RT_USING_DFS_V2
  769. static void directory_setattr(const char *pathname, struct dfs_attr *attr, char f, char v)
  770. {
  771. DIR *dir = NULL;
  772. struct dirent *dirent = NULL;
  773. char *full_path;
  774. if (pathname == RT_NULL)
  775. return;
  776. full_path = (char *)rt_malloc(DFS_PATH_MAX);
  777. if (full_path == RT_NULL)
  778. return;
  779. dir = opendir(pathname);
  780. if (dir == RT_NULL)
  781. {
  782. if (f == 0)
  783. {
  784. rt_kprintf("cannot open '%s'\n", pathname);
  785. }
  786. rt_free(full_path);
  787. return;
  788. }
  789. while (1)
  790. {
  791. dirent = readdir(dir);
  792. if (dirent == RT_NULL)
  793. break;
  794. if (rt_strcmp(".", dirent->d_name) != 0 &&
  795. rt_strcmp("..", dirent->d_name) != 0)
  796. {
  797. if (rt_strlen(pathname) + 1 + rt_strlen(dirent->d_name) > DFS_PATH_MAX)
  798. {
  799. rt_kprintf("'%s/%s' setattr failed, path too long.\n", pathname, dirent->d_name);
  800. continue;
  801. }
  802. rt_sprintf(full_path, "%s/%s", pathname, dirent->d_name);
  803. if (dirent->d_type == DT_REG)
  804. {
  805. if (dfs_file_setattr(full_path, attr) != 0)
  806. {
  807. if (f == 0)
  808. {
  809. rt_kprintf("'%s' setattr failed, no such file or directory\n", full_path);
  810. }
  811. }
  812. else if (v)
  813. {
  814. rt_kprintf("'%s' setattr 0x%X\n", full_path, attr->st_mode);
  815. }
  816. }
  817. else if (dirent->d_type == DT_DIR)
  818. {
  819. directory_setattr(full_path, attr, f, v);
  820. }
  821. }
  822. }
  823. closedir(dir);
  824. rt_free(full_path);
  825. if (dfs_file_setattr(pathname, attr) != 0)
  826. {
  827. if (f == 0)
  828. {
  829. rt_kprintf("'%s' setattr failed, no such file or directory\n", pathname);
  830. }
  831. }
  832. else if (v)
  833. {
  834. rt_kprintf("'%s' setattr 0x%X\n", pathname, attr->st_mode);
  835. }
  836. }
  837. static int cmd_chmod(int argc, char **argv)
  838. {
  839. if (argc < 3)
  840. {
  841. rt_kprintf("Usage: chmod [OPTION]... MODE[,MODE]... FILE...\n");
  842. rt_kprintf(" chmod [-f|v|r] [u|g|o|a][+/-/=][r|w|x] file...\n");
  843. rt_kprintf(" -f suppress most error messages\n");
  844. rt_kprintf(" -v output a diagnostic for every file processed\n");
  845. rt_kprintf(" -r change files and directories recursively\n");
  846. rt_kprintf("Change the mode of each FILE to MODE.\n");
  847. }
  848. else
  849. {
  850. int argv_c = 1;
  851. char f = 0, r = 0, v = 0;
  852. if (argv[argv_c][0] == '-')
  853. {
  854. for (int i = 1; argv[argv_c][i]; i++)
  855. {
  856. switch (argv[argv_c][i])
  857. {
  858. case 'f':
  859. f = 1;
  860. break;
  861. case 'r':
  862. r = 1;
  863. break;
  864. case 'v':
  865. v = 1;
  866. break;
  867. default:
  868. rt_kprintf("Error: Bad option: %c\n", argv[argv_c][i]);
  869. return 0;
  870. }
  871. }
  872. argv_c++;
  873. }
  874. if (argc - argv_c > 1)
  875. {
  876. int U = 1, G = 2, O = 4, ALL = 7;
  877. int off[5] = {0, 6, 3, 0, 0};
  878. int ADD = 1, SUB = 2, SET = 4;
  879. int R = 4, W = 2, X = 1;
  880. int user[3] = {0}, change[3] = {0}, mode[3] = {0};
  881. struct dfs_attr attr;
  882. char *cmd = argv[argv_c];
  883. int index = 0, num = 0;
  884. while (cmd[index] != '\0')
  885. {
  886. switch (cmd[index])
  887. {
  888. case 'u':
  889. user[num] |= U;
  890. break;
  891. case 'g':
  892. user[num] |= G;
  893. break;
  894. case 'o':
  895. user[num] |= O;
  896. break;
  897. case 'a':
  898. user[num] |= ALL;
  899. break;
  900. case ',':
  901. if (num < 2)
  902. num++;
  903. break;
  904. }
  905. index++;
  906. }
  907. index = 0;
  908. num = 0;
  909. while (cmd[index] != '\0')
  910. {
  911. switch (cmd[index])
  912. {
  913. case '+':
  914. change[num] = ADD;
  915. break;
  916. case '-':
  917. change[num] = SUB;
  918. break;
  919. case '=':
  920. change[num] = SET;
  921. break;
  922. case ',':
  923. if (num < 2)
  924. num++;
  925. break;
  926. }
  927. index++;
  928. }
  929. index = 0;
  930. num = 0;
  931. while (cmd[index] != '\0')
  932. {
  933. switch (cmd[index])
  934. {
  935. case 'r':
  936. mode[num] |= R;
  937. break;
  938. case 'w':
  939. mode[num] |= W;
  940. break;
  941. case 'x':
  942. mode[num] |= X;
  943. break;
  944. case ',':
  945. if (num < 2)
  946. num++;
  947. break;
  948. }
  949. index++;
  950. }
  951. attr.st_mode = 0;
  952. for (int i = 0; i <= num; i++)
  953. {
  954. if (change[i] == ADD)
  955. {
  956. if (user[i] & U)
  957. {
  958. attr.st_mode |= mode[i] << off[user[i] & U];
  959. }
  960. if (user[i] & G)
  961. {
  962. attr.st_mode |= mode[i] << off[user[i] & G];
  963. }
  964. if (user[i] & O)
  965. {
  966. attr.st_mode |= mode[i] << off[user[i] & O];
  967. }
  968. }
  969. else if (change[i] == SUB)
  970. {
  971. if (user[i] & U)
  972. {
  973. attr.st_mode &= ~(mode[i] << off[user[i] & U]);
  974. }
  975. if (user[i] & G)
  976. {
  977. attr.st_mode &= ~(mode[i] << off[user[i] & G]);
  978. }
  979. if (user[i] & O)
  980. {
  981. attr.st_mode &= ~(mode[i] << off[user[i] & O]);
  982. }
  983. }
  984. else if (change[i] == SET)
  985. {
  986. if (user[i] & U)
  987. {
  988. attr.st_mode &= ~(7 << off[user[i] & U]);
  989. attr.st_mode |= mode[i] << off[user[i] & U];
  990. }
  991. if (user[i] & G)
  992. {
  993. attr.st_mode &= ~(7 << off[user[i] & G]);
  994. attr.st_mode |= mode[i] << off[user[i] & G];
  995. }
  996. if (user[i] & O)
  997. {
  998. attr.st_mode &= ~(7 << off[user[i] & O]);
  999. attr.st_mode |= mode[i] << off[user[i] & O];
  1000. }
  1001. }
  1002. }
  1003. argv_c++;
  1004. for (int i = argv_c; i < argc; i++)
  1005. {
  1006. if (r)
  1007. {
  1008. struct stat s;
  1009. if (stat(argv[i], &s) == 0)
  1010. {
  1011. if (S_ISDIR(s.st_mode))
  1012. {
  1013. directory_setattr(argv[i], &attr, f, v);
  1014. }
  1015. else if (f == 0)
  1016. {
  1017. rt_kprintf("'%s' is not a directory\n", argv[i]);
  1018. }
  1019. }
  1020. }
  1021. else
  1022. {
  1023. if (dfs_file_setattr(argv[i], &attr) != 0)
  1024. {
  1025. if (f == 0)
  1026. {
  1027. rt_kprintf("'%s' setattr failed, no such file or directory\n", argv[i]);
  1028. }
  1029. }
  1030. else if (v)
  1031. {
  1032. rt_kprintf("'%s' setattr 0x%X\n", argv[i], attr.st_mode);
  1033. }
  1034. }
  1035. }
  1036. }
  1037. }
  1038. return 0;
  1039. }
  1040. MSH_CMD_EXPORT_ALIAS(cmd_chmod, chmod, Change the file attr.);
  1041. #endif
  1042. #endif /* defined(RT_USING_FINSH) && defined(DFS_USING_POSIX) */