msh_file.c 27 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145
  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. #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 (strstr(pg_name, ".sh") != RT_NULL || 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 (strlen(pathname) + 1 + 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(argv[1], type);
  450. }
  451. else if (argc == 4)
  452. {
  453. if (strcmp(argv[1], "-t") == 0)
  454. {
  455. type = argv[2];
  456. result = dfs_mkfs(argv[3], type);
  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 (strcmp(fstype, "nfs") == 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 = 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 ((strcmp(argv[1], "--help") == 0) || (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], 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. static int cmd_tail(int argc, char **argv)
  653. {
  654. int fd;
  655. char c = RT_NULL;
  656. char *file_name = RT_NULL;
  657. rt_uint32_t total_lines = 0;
  658. rt_uint32_t target_line = 0;
  659. rt_uint32_t current_line = 0;
  660. rt_uint32_t required_lines = 0;
  661. rt_uint32_t start_line = 0;
  662. if (argc < 2)
  663. {
  664. rt_kprintf("Usage: tail [-n numbers] <filename>\n");
  665. return -1;
  666. }
  667. else if (argc == 2)
  668. {
  669. required_lines = 10; /* default: 10 lines from tail */
  670. file_name = argv[1];
  671. }
  672. else if (rt_strcmp(argv[1], "-n") == 0)
  673. {
  674. if (argv[2][0] != '+')
  675. {
  676. required_lines = atoi(argv[2]);
  677. }
  678. else
  679. {
  680. start_line = atoi(&argv[2][1]); /* eg: +100, to get the 100 */
  681. }
  682. file_name = argv[3];
  683. }
  684. else
  685. {
  686. rt_kprintf("Usage: tail [-n numbers] <filename>\n");
  687. return -1;
  688. }
  689. fd = open(file_name, O_RDONLY);
  690. if (fd < 0)
  691. {
  692. rt_kprintf("File doesn't exist\n");
  693. return -1;
  694. }
  695. while ((read(fd, &c, sizeof(char))) > 0)
  696. {
  697. if(total_lines == 0)
  698. {
  699. total_lines++;
  700. }
  701. if (c == '\n')
  702. {
  703. total_lines++;
  704. }
  705. }
  706. rt_kprintf("\nTotal Number of lines:%d\n", total_lines);
  707. if (start_line != 0)
  708. {
  709. if (total_lines >= start_line)
  710. {
  711. required_lines = total_lines - start_line + 1;
  712. }
  713. else
  714. {
  715. rt_kprintf("\nError:Required lines are more than total number of lines\n");
  716. close(fd);
  717. return -1;
  718. }
  719. }
  720. if (required_lines > total_lines)
  721. {
  722. rt_kprintf("\nError:Required lines are more than total number of lines\n");
  723. close(fd);
  724. return -1;
  725. }
  726. rt_kprintf("Required Number of lines:%d\n", required_lines);
  727. target_line = total_lines - required_lines;
  728. lseek(fd, 0, SEEK_SET); /* back to head */
  729. while ((read(fd, &c, sizeof(char))) > 0)
  730. {
  731. if (current_line >= target_line)
  732. {
  733. rt_kprintf("%c", c);
  734. }
  735. if (c == '\n')
  736. {
  737. current_line++;
  738. }
  739. }
  740. rt_kprintf("\n");
  741. close(fd);
  742. return 0;
  743. }
  744. MSH_CMD_EXPORT_ALIAS(cmd_tail, tail, print the last N - lines data of the given file);
  745. #ifdef RT_USING_DFS_V2
  746. static void directory_setattr(const char *pathname, struct dfs_attr *attr, char f, char v)
  747. {
  748. DIR *dir = NULL;
  749. struct dirent *dirent = NULL;
  750. char *full_path;
  751. if (pathname == RT_NULL)
  752. return;
  753. full_path = (char *)rt_malloc(DFS_PATH_MAX);
  754. if (full_path == RT_NULL)
  755. return;
  756. dir = opendir(pathname);
  757. if (dir == RT_NULL)
  758. {
  759. if (f == 0)
  760. {
  761. rt_kprintf("cannot open '%s'\n", pathname);
  762. }
  763. rt_free(full_path);
  764. return;
  765. }
  766. while (1)
  767. {
  768. dirent = readdir(dir);
  769. if (dirent == RT_NULL)
  770. break;
  771. if (rt_strcmp(".", dirent->d_name) != 0 &&
  772. rt_strcmp("..", dirent->d_name) != 0)
  773. {
  774. if (strlen(pathname) + 1 + strlen(dirent->d_name) > DFS_PATH_MAX)
  775. {
  776. rt_kprintf("'%s/%s' setattr failed, path too long.\n", pathname, dirent->d_name);
  777. continue;
  778. }
  779. rt_sprintf(full_path, "%s/%s", pathname, dirent->d_name);
  780. if (dirent->d_type == DT_REG)
  781. {
  782. if (dfs_file_setattr(full_path, attr) != 0)
  783. {
  784. if (f == 0)
  785. {
  786. rt_kprintf("'%s' setattr failed, no such file or directory\n", full_path);
  787. }
  788. }
  789. else if (v)
  790. {
  791. rt_kprintf("'%s' setattr 0x%X\n", full_path, attr->st_mode);
  792. }
  793. }
  794. else if (dirent->d_type == DT_DIR)
  795. {
  796. directory_setattr(full_path, attr, f, v);
  797. }
  798. }
  799. }
  800. closedir(dir);
  801. rt_free(full_path);
  802. if (dfs_file_setattr(pathname, attr) != 0)
  803. {
  804. if (f == 0)
  805. {
  806. rt_kprintf("'%s' setattr failed, no such file or directory\n", pathname);
  807. }
  808. }
  809. else if (v)
  810. {
  811. rt_kprintf("'%s' setattr 0x%X\n", pathname, attr->st_mode);
  812. }
  813. }
  814. static int cmd_chmod(int argc, char **argv)
  815. {
  816. if (argc < 3)
  817. {
  818. rt_kprintf("Usage: chmod [OPTION]... MODE[,MODE]... FILE...\n");
  819. rt_kprintf(" chmod [-f|v|r] [u|g|o|a][+/-/=][r|w|x] file...\n");
  820. rt_kprintf(" -f suppress most error messages\n");
  821. rt_kprintf(" -v output a diagnostic for every file processed\n");
  822. rt_kprintf(" -r change files and directories recursively\n");
  823. rt_kprintf("Change the mode of each FILE to MODE.\n");
  824. }
  825. else
  826. {
  827. int argv_c = 1;
  828. char f = 0, r = 0, v = 0;
  829. if (argv[argv_c][0] == '-')
  830. {
  831. for (int i = 1; argv[argv_c][i]; i++)
  832. {
  833. switch (argv[argv_c][i])
  834. {
  835. case 'f':
  836. f = 1;
  837. break;
  838. case 'r':
  839. r = 1;
  840. break;
  841. case 'v':
  842. v = 1;
  843. break;
  844. default:
  845. rt_kprintf("Error: Bad option: %c\n", argv[argv_c][i]);
  846. return 0;
  847. }
  848. }
  849. argv_c++;
  850. }
  851. if (argc - argv_c > 1)
  852. {
  853. int U = 1, G = 2, O = 4, ALL = 7;
  854. int off[5] = {0, 6, 3, 0, 0};
  855. int ADD = 1, SUB = 2, SET = 4;
  856. int R = 4, W = 2, X = 1;
  857. int user[3] = {0}, change[3] = {0}, mode[3] = {0};
  858. struct dfs_attr attr;
  859. char *cmd = argv[argv_c];
  860. int index = 0, num = 0;
  861. while (cmd[index] != '\0')
  862. {
  863. switch (cmd[index])
  864. {
  865. case 'u':
  866. user[num] |= U;
  867. break;
  868. case 'g':
  869. user[num] |= G;
  870. break;
  871. case 'o':
  872. user[num] |= O;
  873. break;
  874. case 'a':
  875. user[num] |= ALL;
  876. break;
  877. case ',':
  878. if (num < 2)
  879. num++;
  880. break;
  881. }
  882. index++;
  883. }
  884. index = 0;
  885. num = 0;
  886. while (cmd[index] != '\0')
  887. {
  888. switch (cmd[index])
  889. {
  890. case '+':
  891. change[num] = ADD;
  892. break;
  893. case '-':
  894. change[num] = SUB;
  895. break;
  896. case '=':
  897. change[num] = SET;
  898. break;
  899. case ',':
  900. if (num < 2)
  901. num++;
  902. break;
  903. }
  904. index++;
  905. }
  906. index = 0;
  907. num = 0;
  908. while (cmd[index] != '\0')
  909. {
  910. switch (cmd[index])
  911. {
  912. case 'r':
  913. mode[num] |= R;
  914. break;
  915. case 'w':
  916. mode[num] |= W;
  917. break;
  918. case 'x':
  919. mode[num] |= X;
  920. break;
  921. case ',':
  922. if (num < 2)
  923. num++;
  924. break;
  925. }
  926. index++;
  927. }
  928. attr.st_mode = 0;
  929. for (int i = 0; i <= num; i++)
  930. {
  931. if (change[i] == ADD)
  932. {
  933. if (user[i] & U)
  934. {
  935. attr.st_mode |= mode[i] << off[user[i] & U];
  936. }
  937. if (user[i] & G)
  938. {
  939. attr.st_mode |= mode[i] << off[user[i] & G];
  940. }
  941. if (user[i] & O)
  942. {
  943. attr.st_mode |= mode[i] << off[user[i] & O];
  944. }
  945. }
  946. else if (change[i] == SUB)
  947. {
  948. if (user[i] & U)
  949. {
  950. attr.st_mode &= ~(mode[i] << off[user[i] & U]);
  951. }
  952. if (user[i] & G)
  953. {
  954. attr.st_mode &= ~(mode[i] << off[user[i] & G]);
  955. }
  956. if (user[i] & O)
  957. {
  958. attr.st_mode &= ~(mode[i] << off[user[i] & O]);
  959. }
  960. }
  961. else if (change[i] == SET)
  962. {
  963. if (user[i] & U)
  964. {
  965. attr.st_mode &= ~(7 << off[user[i] & U]);
  966. attr.st_mode |= mode[i] << off[user[i] & U];
  967. }
  968. if (user[i] & G)
  969. {
  970. attr.st_mode &= ~(7 << off[user[i] & G]);
  971. attr.st_mode |= mode[i] << off[user[i] & G];
  972. }
  973. if (user[i] & O)
  974. {
  975. attr.st_mode &= ~(7 << off[user[i] & O]);
  976. attr.st_mode |= mode[i] << off[user[i] & O];
  977. }
  978. }
  979. }
  980. argv_c++;
  981. for (int i = argv_c; i < argc; i++)
  982. {
  983. if (r)
  984. {
  985. struct stat s;
  986. if (stat(argv[i], &s) == 0)
  987. {
  988. if (S_ISDIR(s.st_mode))
  989. {
  990. directory_setattr(argv[i], &attr, f, v);
  991. }
  992. else if (f == 0)
  993. {
  994. rt_kprintf("'%s' is not a directory\n", argv[i]);
  995. }
  996. }
  997. }
  998. else
  999. {
  1000. if (dfs_file_setattr(argv[i], &attr) != 0)
  1001. {
  1002. if (f == 0)
  1003. {
  1004. rt_kprintf("'%s' setattr failed, no such file or directory\n", argv[i]);
  1005. }
  1006. }
  1007. else if (v)
  1008. {
  1009. rt_kprintf("'%s' setattr 0x%X\n", argv[i], attr.st_mode);
  1010. }
  1011. }
  1012. }
  1013. }
  1014. }
  1015. return 0;
  1016. }
  1017. MSH_CMD_EXPORT_ALIAS(cmd_chmod, chmod, Change the file attr.);
  1018. #endif
  1019. #endif /* defined(RT_USING_FINSH) && defined(DFS_USING_POSIX) */