在 Dfs 中使用 cat cp 等命令時(shí)拔掉 U盤 死機(jī)問(wèn)題

一、問(wèn)題現(xiàn)象

1、使用ls、cp、mv、cat、rm、mkdir、echo命令操作文件未結(jié)束之前拔掉U盤，自己寫(xiě)的自動(dòng)卸載U盤程序會(huì)出現(xiàn)死機(jī)現(xiàn)象。

二、問(wèn)題原因

1、每次進(jìn)行文件操作需要用到互斥鎖的，流程：文件系統(tǒng)上鎖–文件操作–文件系統(tǒng)解鎖。但是上述命令所調(diào)用的函數(shù)是沒(méi)有使用互斥鎖，操作文件的時(shí)候拔掉U盤觸發(fā)dfs_unmount函數(shù)卸載U盤，最終現(xiàn)象為兩個(gè)線程同時(shí)對(duì)U盤進(jìn)行文件操作發(fā)生異常。

三、解決方案

1、加上互斥鎖即可，系統(tǒng)中已經(jīng)有現(xiàn)成dfs的互斥鎖函數(shù)dfs_lock和dfs_unlock，調(diào)用即可。在ls、cp、mv、cat、rm、mkdir、echo所調(diào)用的函數(shù)前進(jìn)行dfs_lock，調(diào)用完成后dfs_unlock就可以解決問(wèn)題。

2、按照上述進(jìn)行解決其實(shí)使用cat時(shí)，拔掉U盤雖然不會(huì)死機(jī)，但是仍然會(huì)有異常發(fā)生，具體我會(huì)在后面講到。

修改后的代碼，我就不一一截圖，直接上修改過(guò)的函數(shù)，這些函數(shù)都是在msh.c。

int cmd_ls(int argc, char **argv) { extern void ls(const char *pathname); dfs_lock(); if (argc == 1) { #ifdef DFS_USING_WORKDIR ls(working_directory); #else ls("/"); #endif } else { ls(argv[1]); } dfs_unlock(); return 0; } int cmd_cp(int argc, char **argv) { void copy(const char *src, const char *dst); dfs_lock(); if (argc != 3) { rt_kprintf("Usage: cp SOURCE DEST\n"); rt_kprintf("Copy SOURCE to DEST.\n"); } else { copy(argv[1], argv[2]); } dfs_unlock(); return 0; } int cmd_mv(int argc, char **argv) { int res = 0; dfs_lock(); if (argc != 3) { rt_kprintf("Usage: mv SOURCE DEST\n"); rt_kprintf("Rename SOURCE to DEST, or move SOURCE(s) to DIRECTORY.\n"); } else { int fd; char *dest = RT_NULL; rt_kprintf("%s => %s\n", argv[1], argv[2]); fd = open(argv[2], O_DIRECTORY, 0); if (fd >= 0) { char *src; close(fd); /* it's a directory */ dest = (char *)rt_malloc(DFS_PATH_MAX); if (dest == RT_NULL) { rt_kprintf("out of memory\n"); res = -RT_ENOMEM; goto end; } src = argv[1] + rt_strlen(argv[1]); while (src != argv[1]) { if (*src == '/') break; src --; } rt_snprintf(dest, DFS_PATH_MAX - 1, "%s/%s", argv[2], src); } else { fd = open(argv[2], O_RDONLY, 0); if (fd >= 0) { close(fd); unlink(argv[2]); } dest = argv[2]; } rename(argv[1], dest); if (dest != RT_NULL && dest != argv[2]) rt_free(dest); } end: dfs_unlock(); return res; } int cmd_cat(int argc, char **argv) { int index; extern void cat(const char *filename); dfs_lock(); if (argc == 1) { rt_kprintf("Usage: cat [FILE]...\n"); rt_kprintf("Concatenate FILE(s)\n"); goto end; } for (index = 1; index < argc; index ++) { cat(argv[index]); } end: dfs_unlock(); return 0; } int cmd_rm(int argc, char **argv) { int index, n; char f = 0, r = 0, v = 0; dfs_lock(); if (argc == 1) { rt_kprintf("Usage: rm option(s) FILE...\n"); rt_kprintf("Remove (unlink) the FILE(s).\n"); goto end; } if (argv[1][0] == '-') { for (n = 0; argv[1][n]; n++) { switch (argv[1][n]) { case 'f': f = 1; break; case 'r': r = 1; break; case 'v': v = 1; break; case '-': break; default: rt_kprintf("Error: Bad option: %c\n", argv[1][n]); goto end; } } argc -= 1; argv = argv + 1; } for (index = 1; index < argc; index ++) { struct stat s; if (stat (argv[index], &s) == 0) { if (s.st_mode & S_IFDIR) { if (r == 0) rt_kprintf("cannot remove '%s': Is a directory\n", argv[index]); else directory_delete_for_msh(argv[index], f, v); } else if (s.st_mode & S_IFREG) { if (unlink(argv[index]) != 0) { if (f == 0) rt_kprintf("cannot remove '%s'\n", argv[index]); } else if (v) { rt_kprintf("removed '%s'\n", argv[index]); } } } else if (f == 0) { rt_kprintf("cannot remove '%s': No such file or directory\n", argv[index]); } } end: dfs_unlock(); return 0; } int cmd_mkdir(int argc, char **argv) { dfs_lock(); if (argc == 1) { rt_kprintf("Usage: mkdir [OPTION] DIRECTORY\n"); rt_kprintf("Create the DIRECTORY, if they do not already exist.\n"); } else { mkdir(argv[1], 0); } dfs_unlock(); return 0; } int cmd_df(int argc, char** argv) { dfs_lock(); if (argc != 2) { df("/"); } else { if ((strcmp(argv[1], "--help") == 0) || (strcmp(argv[1], "-h") == 0)) { rt_kprintf("df [path]\n"); } else { df(argv[1]); } } dfs_unlock(); return 0; } int cmd_echo(int argc, char** argv) { dfs_lock(); if (argc == 2) { rt_kprintf("%s\n", argv[1]); } else if (argc == 3) { int fd; fd = open(argv[2], O_RDWR | O_APPEND | O_CREAT, 0); if (fd >= 0) { write (fd, argv[1], strlen(argv[1])); close(fd); } else { rt_kprintf("open file:%s failed!\n", argv[2]); } } else { rt_kprintf("Usage: echo \"string\" [filename]\n"); } dfs_unlock(); return 0; }

四、cat問(wèn)題現(xiàn)象

1、使用cat命令讀取U盤文件并打印讀到的數(shù)據(jù)時(shí)突然拔掉U盤，正常會(huì)因?yàn)樽x取失敗而停止輸出，實(shí)際上則不斷的打印最后讀到的一串?dāng)?shù)據(jù)。

五、cat問(wèn)題原因

1、cat命令實(shí)質(zhì)調(diào)用的核心函數(shù)是dfs_file_read，這個(gè)函數(shù)返回一個(gè)長(zhǎng)度值，如果返回值小于0說(shuō)明發(fā)生錯(cuò)誤，但是接收這個(gè)返回值的卻是一個(gè)uint32_t變量，導(dǎo)致出錯(cuò)時(shí)無(wú)法識(shí)別錯(cuò)誤，反而識(shí)別成讀取到長(zhǎng)度非常大的數(shù)據(jù)，所以在不斷打印。

六、cat解決方案

1、將length改成int類型即可

版權(quán)聲明：本文內(nèi)容由網(wǎng)絡(luò)用戶投稿，版權(quán)歸原作者所有，本站不擁有其著作權(quán)，亦不承擔(dān)相應(yīng)法律責(zé)任。如果您發(fā)現(xiàn)本站中有涉嫌抄襲或描述失實(shí)的內(nèi)容，請(qǐng)聯(lián)系我們jiasou666@gmail.com 處理，核實(shí)后本網(wǎng)站將在24小時(shí)內(nèi)刪除侵權(quán)內(nèi)容。

版權(quán)聲明：本文內(nèi)容由網(wǎng)絡(luò)用戶投稿，版權(quán)歸原作者所有，本站不擁有其著作權(quán)，亦不承擔(dān)相應(yīng)法律責(zé)任。如果您發(fā)現(xiàn)本站中有涉嫌抄襲或描述失實(shí)的內(nèi)容，請(qǐng)聯(lián)系我們jiasou666@gmail.com 處理，核實(shí)后本網(wǎng)站將在24小時(shí)內(nèi)刪除侵權(quán)內(nèi)容。