msh_file.c 26 KB

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