msh_file.c 28 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169
  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. if(*src == '/') src++;
  235. rt_snprintf(dest, DFS_PATH_MAX - 1, "%s/%s", argv[2], src);
  236. }
  237. else
  238. {
  239. fd = open(argv[2], O_RDONLY, 0);
  240. if (fd >= 0)
  241. {
  242. close(fd);
  243. unlink(argv[2]);
  244. }
  245. dest = argv[2];
  246. }
  247. rename(argv[1], dest);
  248. if (dest != RT_NULL && dest != argv[2]) rt_free(dest);
  249. }
  250. return 0;
  251. }
  252. MSH_CMD_EXPORT_ALIAS(cmd_mv, mv, Rename SOURCE to DEST.);
  253. static int cmd_cat(int argc, char **argv)
  254. {
  255. int index;
  256. extern void cat(const char *filename);
  257. if (argc == 1)
  258. {
  259. rt_kprintf("Usage: cat [FILE]...\n");
  260. rt_kprintf("Concatenate FILE(s)\n");
  261. return 0;
  262. }
  263. for (index = 1; index < argc; index ++)
  264. {
  265. cat(argv[index]);
  266. }
  267. return 0;
  268. }
  269. MSH_CMD_EXPORT_ALIAS(cmd_cat, cat, Concatenate FILE(s));
  270. static void directory_delete_for_msh(const char *pathname, char f, char v)
  271. {
  272. DIR *dir = NULL;
  273. struct dirent *dirent = NULL;
  274. char *full_path;
  275. if (pathname == RT_NULL)
  276. return;
  277. full_path = (char *)rt_malloc(DFS_PATH_MAX);
  278. if (full_path == RT_NULL)
  279. return;
  280. dir = opendir(pathname);
  281. if (dir == RT_NULL)
  282. {
  283. if (f == 0)
  284. {
  285. rt_kprintf("cannot remove '%s'\n", pathname);
  286. }
  287. rt_free(full_path);
  288. return;
  289. }
  290. while (1)
  291. {
  292. dirent = readdir(dir);
  293. if (dirent == RT_NULL)
  294. break;
  295. if (rt_strcmp(".", dirent->d_name) != 0 &&
  296. rt_strcmp("..", dirent->d_name) != 0)
  297. {
  298. if (rt_strlen(pathname) + 1 + rt_strlen(dirent->d_name) > DFS_PATH_MAX)
  299. {
  300. rt_kprintf("cannot remove '%s/%s', path too long.\n", pathname, dirent->d_name);
  301. continue;
  302. }
  303. rt_sprintf(full_path, "%s/%s", pathname, dirent->d_name);
  304. if (dirent->d_type != DT_DIR)
  305. {
  306. if (unlink(full_path) != 0)
  307. {
  308. if (f == 0)
  309. rt_kprintf("cannot remove '%s'\n", full_path);
  310. }
  311. else if (v)
  312. {
  313. rt_kprintf("removed '%s'\n", full_path);
  314. }
  315. }
  316. else
  317. {
  318. directory_delete_for_msh(full_path, f, v);
  319. }
  320. }
  321. }
  322. closedir(dir);
  323. rt_free(full_path);
  324. if (rmdir(pathname) != 0)
  325. {
  326. if (f == 0)
  327. rt_kprintf("cannot remove '%s'\n", pathname);
  328. }
  329. else if (v)
  330. {
  331. rt_kprintf("removed directory '%s'\n", pathname);
  332. }
  333. }
  334. static int cmd_rm(int argc, char **argv)
  335. {
  336. int index, n;
  337. char f = 0, r = 0, v = 0;
  338. if (argc == 1)
  339. {
  340. rt_kprintf("Usage: rm option(s) FILE...\n");
  341. rt_kprintf("Remove (unlink) the FILE(s).\n");
  342. return 0;
  343. }
  344. if (argv[1][0] == '-')
  345. {
  346. for (n = 0; argv[1][n]; n++)
  347. {
  348. switch (argv[1][n])
  349. {
  350. case 'f':
  351. f = 1;
  352. break;
  353. case 'r':
  354. r = 1;
  355. break;
  356. case 'v':
  357. v = 1;
  358. break;
  359. case '-':
  360. break;
  361. default:
  362. rt_kprintf("Error: Bad option: %c\n", argv[1][n]);
  363. return 0;
  364. }
  365. }
  366. argc -= 1;
  367. argv = argv + 1;
  368. }
  369. for (index = 1; index < argc; index ++)
  370. {
  371. struct stat s;
  372. #ifdef RT_USING_DFS_V2
  373. if (dfs_file_lstat(argv[index], &s) == 0)
  374. #else
  375. if (stat(argv[index], &s) == 0)
  376. #endif
  377. {
  378. if (S_ISDIR(s.st_mode))
  379. {
  380. if (r == 0)
  381. rt_kprintf("cannot remove '%s': Is a directory\n", argv[index]);
  382. else
  383. directory_delete_for_msh(argv[index], f, v);
  384. }
  385. else
  386. {
  387. if (unlink(argv[index]) != 0)
  388. {
  389. if (f == 0)
  390. rt_kprintf("cannot remove '%s'\n", argv[index]);
  391. }
  392. else if (v)
  393. {
  394. rt_kprintf("removed '%s'\n", argv[index]);
  395. }
  396. }
  397. }
  398. else if (f == 0)
  399. {
  400. rt_kprintf("cannot remove '%s': No such file or directory\n", argv[index]);
  401. }
  402. }
  403. return 0;
  404. }
  405. MSH_CMD_EXPORT_ALIAS(cmd_rm, rm, Remove(unlink) the FILE(s).);
  406. #ifdef DFS_USING_WORKDIR
  407. static int cmd_cd(int argc, char **argv)
  408. {
  409. if (argc == 1)
  410. {
  411. rt_kprintf("%s\n", working_directory);
  412. }
  413. else if (argc == 2)
  414. {
  415. if (chdir(argv[1]) != 0)
  416. {
  417. rt_kprintf("No such directory: %s\n", argv[1]);
  418. }
  419. }
  420. return 0;
  421. }
  422. MSH_CMD_EXPORT_ALIAS(cmd_cd, cd, Change the shell working directory.);
  423. static int cmd_pwd(int argc, char **argv)
  424. {
  425. rt_kprintf("%s\n", working_directory);
  426. return 0;
  427. }
  428. MSH_CMD_EXPORT_ALIAS(cmd_pwd, pwd, Print the name of the current working directory.);
  429. #endif
  430. static int cmd_mkdir(int argc, char **argv)
  431. {
  432. if (argc == 1)
  433. {
  434. rt_kprintf("Usage: mkdir [OPTION] DIRECTORY\n");
  435. rt_kprintf("Create the DIRECTORY, if they do not already exist.\n");
  436. }
  437. else
  438. {
  439. mkdir(argv[1], 0);
  440. }
  441. return 0;
  442. }
  443. MSH_CMD_EXPORT_ALIAS(cmd_mkdir, mkdir, Create the DIRECTORY.);
  444. static int cmd_mkfs(int argc, char **argv)
  445. {
  446. int result = 0;
  447. char *type = "elm"; /* use the default file system type as 'fatfs' */
  448. if (argc == 2)
  449. {
  450. result = dfs_mkfs(type, argv[1]);
  451. }
  452. else if (argc == 4)
  453. {
  454. if (rt_strcmp(argv[1], "-t") == 0)
  455. {
  456. type = argv[2];
  457. result = dfs_mkfs(type, argv[3]);
  458. }
  459. }
  460. else
  461. {
  462. rt_kprintf("Usage: mkfs [-t type] device\n");
  463. return 0;
  464. }
  465. if (result != RT_EOK)
  466. {
  467. rt_kprintf("mkfs failed, result=%d\n", result);
  468. }
  469. return 0;
  470. }
  471. MSH_CMD_EXPORT_ALIAS(cmd_mkfs, mkfs, format disk with file system);
  472. /*
  473. * If no argument is specified, display the mount history;
  474. * If there are 3 arguments, mount the filesystem.
  475. * The order of the arguments is:
  476. * argv[1]: device name
  477. * argv[2]: mountpoint path
  478. * argv[3]: filesystem type
  479. */
  480. static int cmd_mount(int argc, char **argv)
  481. {
  482. if (argc == 1)
  483. {
  484. #ifdef RT_USING_DFS_V2
  485. /* display the mount history */
  486. rt_kprintf("filesystem device mountpoint refcount\n");
  487. rt_kprintf("---------- ------ ---------- --------\n");
  488. dfs_mnt_list(RT_NULL);
  489. #else
  490. extern struct dfs_filesystem filesystem_table[];
  491. struct dfs_filesystem *iter;
  492. /* display the mount history */
  493. rt_kprintf("filesystem device mountpoint\n");
  494. rt_kprintf("---------- ------ ----------\n");
  495. for (iter = &filesystem_table[0];
  496. iter < &filesystem_table[DFS_FILESYSTEMS_MAX]; iter++)
  497. {
  498. if ((iter != NULL) && (iter->path != NULL))
  499. {
  500. rt_kprintf("%-10s %-6s %-s\n",
  501. iter->ops->name, iter->dev_id->parent.name, iter->path);
  502. }
  503. }
  504. #endif
  505. return 0;
  506. }
  507. else if (argc == 4)
  508. {
  509. char *device = argv[1];
  510. char *path = argv[2];
  511. char *fstype = argv[3];
  512. char *data = 0;
  513. /* mount a filesystem to the specified directory */
  514. rt_kprintf("mount device %s(%s) onto %s ... ", device, fstype, path);
  515. if (rt_strcmp(fstype, "nfs") == 0 || rt_strcmp(fstype, "9p") == 0)
  516. {
  517. data = argv[1];
  518. device = 0;
  519. }
  520. if (dfs_mount(device, path, fstype, 0, data) == 0)
  521. {
  522. rt_kprintf("succeed!\n");
  523. return 0;
  524. }
  525. else
  526. {
  527. rt_kprintf("failed!\n");
  528. return -1;
  529. }
  530. }
  531. else if (argc == 3)
  532. {
  533. char *path = argv[1];
  534. char *fstype = argv[2];
  535. /* mount a filesystem to the specified directory */
  536. rt_kprintf("mount (%s) onto %s ... ", fstype, path);
  537. if (dfs_mount(NULL, path, fstype, 0, 0) == 0)
  538. {
  539. rt_kprintf("succeed!\n");
  540. return 0;
  541. }
  542. else
  543. {
  544. rt_kprintf("failed!\n");
  545. return -1;
  546. }
  547. }
  548. else
  549. {
  550. rt_kprintf("Usage: mount <device> <mountpoint> <fstype>.\n");
  551. return -1;
  552. }
  553. }
  554. MSH_CMD_EXPORT_ALIAS(cmd_mount, mount, mount <device> <mountpoint> <fstype>);
  555. /* unmount the filesystem from the specified mountpoint */
  556. static int cmd_umount(int argc, char **argv)
  557. {
  558. #ifndef RT_USING_DFS_V2
  559. char *path = argv[1];
  560. if (argc != 2)
  561. {
  562. rt_kprintf("Usage: unmount <mountpoint>.\n");
  563. return -1;
  564. }
  565. rt_kprintf("unmount %s ... ", path);
  566. if (dfs_unmount(path) < 0)
  567. {
  568. rt_kprintf("failed!\n");
  569. return -1;
  570. }
  571. else
  572. {
  573. rt_kprintf("succeed!\n");
  574. return 0;
  575. }
  576. #else
  577. int flags = 0;
  578. char *path = argv[1];
  579. if (argc < 2)
  580. {
  581. rt_kprintf("Usage: unmount [-f] <mountpoint>.\n");
  582. return -1;
  583. }
  584. if (argc > 2)
  585. {
  586. flags = rt_strcmp(argv[1], "-f") == 0 ? MNT_FORCE : 0;
  587. path = argv[2];
  588. }
  589. rt_kprintf("unmount %s ... ", path);
  590. if (dfs_umount(path, flags) < 0)
  591. {
  592. rt_kprintf("failed!\n");
  593. return -1;
  594. }
  595. else
  596. {
  597. rt_kprintf("succeed!\n");
  598. return 0;
  599. }
  600. #endif
  601. }
  602. MSH_CMD_EXPORT_ALIAS(cmd_umount, umount, Unmount the mountpoint);
  603. static int cmd_df(int argc, char **argv)
  604. {
  605. #ifndef RT_USING_DFS_V2
  606. extern int df(const char *path);
  607. if (argc != 2)
  608. {
  609. df("/");
  610. }
  611. else
  612. {
  613. if ((rt_strcmp(argv[1], "--help") == 0) || (rt_strcmp(argv[1], "-h") == 0))
  614. {
  615. rt_kprintf("df [path]\n");
  616. }
  617. else
  618. {
  619. df(argv[1]);
  620. }
  621. }
  622. #endif
  623. return 0;
  624. }
  625. MSH_CMD_EXPORT_ALIAS(cmd_df, df, disk free);
  626. static int cmd_echo(int argc, char **argv)
  627. {
  628. if (argc == 2)
  629. {
  630. rt_kprintf("%s\n", argv[1]);
  631. }
  632. else if (argc == 3)
  633. {
  634. int fd;
  635. fd = open(argv[2], O_RDWR | O_APPEND | O_CREAT, 0);
  636. if (fd >= 0)
  637. {
  638. write(fd, argv[1], rt_strlen(argv[1]));
  639. close(fd);
  640. }
  641. else
  642. {
  643. rt_kprintf("open file:%s failed!\n", argv[2]);
  644. }
  645. }
  646. else
  647. {
  648. rt_kprintf("Usage: echo \"string\" [filename]\n");
  649. }
  650. return 0;
  651. }
  652. MSH_CMD_EXPORT_ALIAS(cmd_echo, echo, echo string to file);
  653. /**
  654. * @brief Print the last part of a file (tail command).
  655. *
  656. * @note Supported Usage:
  657. * 1. tail <file> : Print last 10 lines.
  658. * 2. tail -n <num> <file> : Print last <num> lines.
  659. * 3. tail -n +<num> <file> : Print starting from line <num>.
  660. *
  661. * @param argc Argument count
  662. * @param argv Argument vector
  663. * @return 0 on success, -1 on failure
  664. */
  665. static int cmd_tail(int argc, char **argv)
  666. {
  667. int fd;
  668. char c = RT_NULL;
  669. char *file_name = RT_NULL;
  670. rt_uint32_t total_lines = 0;
  671. rt_uint32_t target_line = 0;
  672. rt_uint32_t current_line = 0;
  673. rt_uint32_t required_lines = 0;
  674. rt_uint32_t start_line = 0;
  675. if (argc < 2)
  676. {
  677. rt_kprintf("Usage: tail [-n [+]numbers] <filename>\n");
  678. return -1;
  679. }
  680. else if (argc == 2)
  681. {
  682. required_lines = 10; /* default: 10 lines from tail */
  683. file_name = argv[1];
  684. }
  685. else if (rt_strcmp(argv[1], "-n") == 0)
  686. {
  687. /*
  688. * Check if enough arguments are provided to avoid crash.
  689. * The command requires: "tail" + "-n" + "number" + "file" = 4 args.
  690. */
  691. if (argc < 4)
  692. {
  693. rt_kprintf("Error: Missing arguments.\n");
  694. rt_kprintf("Usage: tail -n [+]numbers <filename>\n");
  695. return -1;
  696. }
  697. /* Check for explicit start line syntax (e.g., +100) */
  698. if (argv[2][0] != '+')
  699. {
  700. required_lines = atoi(argv[2]);
  701. }
  702. else
  703. {
  704. start_line = atoi(&argv[2][1]); /* eg: +100, skip '+' to get 100 */
  705. }
  706. file_name = argv[3];
  707. }
  708. else
  709. {
  710. rt_kprintf("Usage: tail [-n [+]numbers] <filename>\n");
  711. return -1;
  712. }
  713. fd = open(file_name, O_RDONLY);
  714. if (fd < 0)
  715. {
  716. rt_kprintf("File doesn't exist\n");
  717. return -1;
  718. }
  719. while ((read(fd, &c, sizeof(char))) > 0)
  720. {
  721. if(total_lines == 0)
  722. {
  723. total_lines++;
  724. }
  725. if (c == '\n')
  726. {
  727. total_lines++;
  728. }
  729. }
  730. rt_kprintf("\nTotal Number of lines:%ld\n", total_lines);
  731. if (start_line != 0)
  732. {
  733. if (total_lines >= start_line)
  734. {
  735. required_lines = total_lines - start_line + 1;
  736. }
  737. else
  738. {
  739. rt_kprintf("\nError:Required lines are more than total number of lines\n");
  740. close(fd);
  741. return -1;
  742. }
  743. }
  744. if (required_lines > total_lines)
  745. {
  746. rt_kprintf("\nError:Required lines are more than total number of lines\n");
  747. close(fd);
  748. return -1;
  749. }
  750. rt_kprintf("Required Number of lines:%ld\n", required_lines);
  751. target_line = total_lines - required_lines;
  752. lseek(fd, 0, SEEK_SET); /* back to head */
  753. while ((read(fd, &c, sizeof(char))) > 0)
  754. {
  755. if (current_line >= target_line)
  756. {
  757. rt_kprintf("%c", c);
  758. }
  759. if (c == '\n')
  760. {
  761. current_line++;
  762. }
  763. }
  764. rt_kprintf("\n");
  765. close(fd);
  766. return 0;
  767. }
  768. MSH_CMD_EXPORT_ALIAS(cmd_tail, tail, Print the last N lines. Usage: tail -n [+]numbers <filename>);
  769. #ifdef RT_USING_DFS_V2
  770. static void directory_setattr(const char *pathname, struct dfs_attr *attr, char f, char v)
  771. {
  772. DIR *dir = NULL;
  773. struct dirent *dirent = NULL;
  774. char *full_path;
  775. if (pathname == RT_NULL)
  776. return;
  777. full_path = (char *)rt_malloc(DFS_PATH_MAX);
  778. if (full_path == RT_NULL)
  779. return;
  780. dir = opendir(pathname);
  781. if (dir == RT_NULL)
  782. {
  783. if (f == 0)
  784. {
  785. rt_kprintf("cannot open '%s'\n", pathname);
  786. }
  787. rt_free(full_path);
  788. return;
  789. }
  790. while (1)
  791. {
  792. dirent = readdir(dir);
  793. if (dirent == RT_NULL)
  794. break;
  795. if (rt_strcmp(".", dirent->d_name) != 0 &&
  796. rt_strcmp("..", dirent->d_name) != 0)
  797. {
  798. if (rt_strlen(pathname) + 1 + rt_strlen(dirent->d_name) > DFS_PATH_MAX)
  799. {
  800. rt_kprintf("'%s/%s' setattr failed, path too long.\n", pathname, dirent->d_name);
  801. continue;
  802. }
  803. rt_sprintf(full_path, "%s/%s", pathname, dirent->d_name);
  804. if (dirent->d_type == DT_REG)
  805. {
  806. if (dfs_file_setattr(full_path, attr) != 0)
  807. {
  808. if (f == 0)
  809. {
  810. rt_kprintf("'%s' setattr failed, no such file or directory\n", full_path);
  811. }
  812. }
  813. else if (v)
  814. {
  815. rt_kprintf("'%s' setattr 0x%X\n", full_path, attr->st_mode);
  816. }
  817. }
  818. else if (dirent->d_type == DT_DIR)
  819. {
  820. directory_setattr(full_path, attr, f, v);
  821. }
  822. }
  823. }
  824. closedir(dir);
  825. rt_free(full_path);
  826. if (dfs_file_setattr(pathname, attr) != 0)
  827. {
  828. if (f == 0)
  829. {
  830. rt_kprintf("'%s' setattr failed, no such file or directory\n", pathname);
  831. }
  832. }
  833. else if (v)
  834. {
  835. rt_kprintf("'%s' setattr 0x%X\n", pathname, attr->st_mode);
  836. }
  837. }
  838. static int cmd_chmod(int argc, char **argv)
  839. {
  840. if (argc < 3)
  841. {
  842. rt_kprintf("Usage: chmod [OPTION]... MODE[,MODE]... FILE...\n");
  843. rt_kprintf(" chmod [-f|v|r] [u|g|o|a][+/-/=][r|w|x] file...\n");
  844. rt_kprintf(" -f suppress most error messages\n");
  845. rt_kprintf(" -v output a diagnostic for every file processed\n");
  846. rt_kprintf(" -r change files and directories recursively\n");
  847. rt_kprintf("Change the mode of each FILE to MODE.\n");
  848. }
  849. else
  850. {
  851. int argv_c = 1;
  852. char f = 0, r = 0, v = 0;
  853. if (argv[argv_c][0] == '-')
  854. {
  855. for (int i = 1; argv[argv_c][i]; i++)
  856. {
  857. switch (argv[argv_c][i])
  858. {
  859. case 'f':
  860. f = 1;
  861. break;
  862. case 'r':
  863. r = 1;
  864. break;
  865. case 'v':
  866. v = 1;
  867. break;
  868. default:
  869. rt_kprintf("Error: Bad option: %c\n", argv[argv_c][i]);
  870. return 0;
  871. }
  872. }
  873. argv_c++;
  874. }
  875. if (argc - argv_c > 1)
  876. {
  877. int U = 1, G = 2, O = 4, ALL = 7;
  878. int off[5] = {0, 6, 3, 0, 0};
  879. int ADD = 1, SUB = 2, SET = 4;
  880. int R = 4, W = 2, X = 1;
  881. int user[3] = {0}, change[3] = {0}, mode[3] = {0};
  882. struct dfs_attr attr;
  883. char *cmd = argv[argv_c];
  884. int index = 0, num = 0;
  885. while (cmd[index] != '\0')
  886. {
  887. switch (cmd[index])
  888. {
  889. case 'u':
  890. user[num] |= U;
  891. break;
  892. case 'g':
  893. user[num] |= G;
  894. break;
  895. case 'o':
  896. user[num] |= O;
  897. break;
  898. case 'a':
  899. user[num] |= ALL;
  900. break;
  901. case ',':
  902. if (num < 2)
  903. num++;
  904. break;
  905. }
  906. index++;
  907. }
  908. index = 0;
  909. num = 0;
  910. while (cmd[index] != '\0')
  911. {
  912. switch (cmd[index])
  913. {
  914. case '+':
  915. change[num] = ADD;
  916. break;
  917. case '-':
  918. change[num] = SUB;
  919. break;
  920. case '=':
  921. change[num] = SET;
  922. break;
  923. case ',':
  924. if (num < 2)
  925. num++;
  926. break;
  927. }
  928. index++;
  929. }
  930. index = 0;
  931. num = 0;
  932. while (cmd[index] != '\0')
  933. {
  934. switch (cmd[index])
  935. {
  936. case 'r':
  937. mode[num] |= R;
  938. break;
  939. case 'w':
  940. mode[num] |= W;
  941. break;
  942. case 'x':
  943. mode[num] |= X;
  944. break;
  945. case ',':
  946. if (num < 2)
  947. num++;
  948. break;
  949. }
  950. index++;
  951. }
  952. attr.st_mode = 0;
  953. for (int i = 0; i <= num; i++)
  954. {
  955. if (change[i] == ADD)
  956. {
  957. if (user[i] & U)
  958. {
  959. attr.st_mode |= mode[i] << off[user[i] & U];
  960. }
  961. if (user[i] & G)
  962. {
  963. attr.st_mode |= mode[i] << off[user[i] & G];
  964. }
  965. if (user[i] & O)
  966. {
  967. attr.st_mode |= mode[i] << off[user[i] & O];
  968. }
  969. }
  970. else if (change[i] == SUB)
  971. {
  972. if (user[i] & U)
  973. {
  974. attr.st_mode &= ~(mode[i] << off[user[i] & U]);
  975. }
  976. if (user[i] & G)
  977. {
  978. attr.st_mode &= ~(mode[i] << off[user[i] & G]);
  979. }
  980. if (user[i] & O)
  981. {
  982. attr.st_mode &= ~(mode[i] << off[user[i] & O]);
  983. }
  984. }
  985. else if (change[i] == SET)
  986. {
  987. if (user[i] & U)
  988. {
  989. attr.st_mode &= ~(7 << off[user[i] & U]);
  990. attr.st_mode |= mode[i] << off[user[i] & U];
  991. }
  992. if (user[i] & G)
  993. {
  994. attr.st_mode &= ~(7 << off[user[i] & G]);
  995. attr.st_mode |= mode[i] << off[user[i] & G];
  996. }
  997. if (user[i] & O)
  998. {
  999. attr.st_mode &= ~(7 << off[user[i] & O]);
  1000. attr.st_mode |= mode[i] << off[user[i] & O];
  1001. }
  1002. }
  1003. }
  1004. argv_c++;
  1005. for (int i = argv_c; i < argc; i++)
  1006. {
  1007. if (r)
  1008. {
  1009. struct stat s;
  1010. if (stat(argv[i], &s) == 0)
  1011. {
  1012. if (S_ISDIR(s.st_mode))
  1013. {
  1014. directory_setattr(argv[i], &attr, f, v);
  1015. }
  1016. else if (f == 0)
  1017. {
  1018. rt_kprintf("'%s' is not a directory\n", argv[i]);
  1019. }
  1020. }
  1021. }
  1022. else
  1023. {
  1024. if (dfs_file_setattr(argv[i], &attr) != 0)
  1025. {
  1026. if (f == 0)
  1027. {
  1028. rt_kprintf("'%s' setattr failed, no such file or directory\n", argv[i]);
  1029. }
  1030. }
  1031. else if (v)
  1032. {
  1033. rt_kprintf("'%s' setattr 0x%X\n", argv[i], attr.st_mode);
  1034. }
  1035. }
  1036. }
  1037. }
  1038. }
  1039. return 0;
  1040. }
  1041. MSH_CMD_EXPORT_ALIAS(cmd_chmod, chmod, Change the file attr.);
  1042. #endif
  1043. #endif /* defined(RT_USING_FINSH) && defined(DFS_USING_POSIX) */