1
0

dfs_jffs2.c 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733
  1. /*
  2. * File : rtthread.h
  3. * This file is part of RT-Thread RTOS
  4. * COPYRIGHT (C) 2006-2012, RT-Thread Development Team
  5. *
  6. * The license and distribution terms for this file may be
  7. * found in the file LICENSE in this distribution or at
  8. * http://www.rt-thread.org/license/LICENSE.
  9. *
  10. * Change Logs:
  11. * Date Author Notes
  12. * 2012-1-7 prife the first version
  13. */
  14. #include <rtthread.h>
  15. #include <rtdevice.h>
  16. #include "cyg/infra/cyg_type.h"
  17. #include "cyg/fileio/fileio.h"
  18. #include "codes.h"
  19. #undef mode_t
  20. #include <dfs_fs.h>
  21. #include <dfs_def.h>
  22. #include "dfs_jffs2.h"
  23. #include "jffs2_config.h"
  24. #include "porting.h"
  25. #include <string.h>
  26. #if DEVICE_PART_MAX > 1
  27. #error "support only one jffs2 partition on a flash device!"
  28. #endif
  29. /* make sure the following struct var had been initilased to 0! */
  30. struct device_part
  31. {
  32. struct cyg_mtab_entry * mte;
  33. struct rt_mtd_device *dev;
  34. };
  35. static struct device_part device_partition[DEVICE_PART_MAX] = {0};
  36. static struct rt_mutex jffs2_lock;
  37. #define jffs2_mount jffs2_fste.mount
  38. #define jffs2_umount jffs2_fste.umount
  39. #define jffs2_open jffs2_fste.open
  40. #define jffs2_file_unlink jffs2_fste.unlink
  41. #define jffs2_mkdir jffs2_fste.mkdir
  42. #define jffs2_rmdir jffs2_fste.rmdir
  43. #define jffs2_rename jffs2_fste.rename
  44. #define jffs2_link jffs2_fste.link
  45. #define jffs2_opendir jffs2_fste.opendir
  46. #define jffs2_chdir jffs2_fste.chdir
  47. #define jffs2_ops_stat jffs2_fste.stat
  48. #define jffs2_getinfo jffs2_fste.getinfo
  49. #define jffs2_setinfo jffs2_fste.setinfo
  50. #define jffs2_file_read jffs2_fileops.fo_read
  51. #define jffs2_file_write jffs2_fileops.fo_write
  52. #define jffs2_file_lseek jffs2_fileops.fo_lseek
  53. #define jffs2_file_ioctl jffs2_fileops.fo_ioctl
  54. #define jffs2_file_select jffs2_fileops.fo_select
  55. #define jffs2_file_fsync jffs2_fileops.fo_fsync
  56. #define jffs2_file_colse jffs2_fileops.fo_close
  57. #define jffs2_file_fstat jffs2_fileops.fo_fstat
  58. #define jffs2_file_getinfo jffs2_fileops.fo_getinfo
  59. #define jffs2_file_setinfo jffs2_fileops.fo_setinfo
  60. #define jffs2_dir_read jffs2_dirops.fo_read
  61. //#define jffs2_dir_write jffs2_dirops.fo_write
  62. #define jffs2_dir_lseek jffs2_dirops.fo_lseek
  63. //#define jffs2_dir_ioctl jffs2_dirops.fo_ioctl
  64. #define jffs2_dir_select jffs2_dirops.fo_select
  65. //#define jffs2_dir_fsync jffs2_dirops.fo_fsync
  66. #define jffs2_dir_colse jffs2_dirops.fo_close
  67. //#define jffs2_dir_fstat jffs2_dirops.fo_fstat
  68. //#define jffs2_dir_getinfo jffs2_dirops.fo_getinfo
  69. //#define jffs2_dir_setinfo jffs2_dirops.fo_setinfo
  70. /*
  71. * RT-Thread Device Interface for jffs2
  72. */
  73. /* these code is in src/flashio.c */
  74. static int jffs2_result_to_dfs(int result)
  75. {
  76. int status = -1;
  77. if (result < 0)
  78. result = -result;
  79. switch (result)
  80. {
  81. case ENOERR:/** no error */
  82. break;
  83. case EACCES:/** Tried to open read-only file for writing, or files sharing mode
  84. does not allow specified operations, or given path is directory */
  85. status = -DFS_STATUS_EINVAL;
  86. break;/* no suitable */
  87. case EEXIST: /** _O_CREAT and _O_EXCL flags specified, but filename already exists */
  88. status = -DFS_STATUS_EEXIST;
  89. break;
  90. case EINVAL: /** Invalid oflag or pmode argument */
  91. status = -DFS_STATUS_EINVAL;
  92. break;
  93. case EMFILE: /** No more file handles available(too many open files) */
  94. rt_kprintf("dfs_jffs2.c error: no more file handles available\r\n");
  95. status = -1;
  96. break;//fixme
  97. case ENOENT: /** file or path not found */
  98. status = -DFS_STATUS_ENOENT;
  99. break;
  100. case EBADF: /** invalid file handle */
  101. status = -DFS_STATUS_EBADF;
  102. break;
  103. case ENOMEM:/** no enough memory */
  104. status = -DFS_STATUS_ENOMEM;
  105. break;
  106. case EIO: /** I/O error from lower level flash operation */
  107. status = -DFS_STATUS_EIO;
  108. break;
  109. case ENOTDIR: /** Not a directory */
  110. status = -DFS_STATUS_ENOTDIR;
  111. break;
  112. case EISDIR: /** Is a directory */
  113. status = -DFS_STATUS_EISDIR;
  114. break;
  115. case ENOSPC: /**//* No space left on device */
  116. status = -DFS_STATUS_ENOSPC;
  117. break;
  118. default:
  119. rt_kprintf("dfs_jffs2.c error: %d\r\n", result);
  120. status = -1;
  121. break; /* unknown error! */
  122. }
  123. return status;
  124. }
  125. /*
  126. * RT-Thread DFS Interface for jffs2
  127. */
  128. static int dfs_jffs2_mount(struct dfs_filesystem* fs,
  129. unsigned long rwflag,
  130. const void* data)
  131. {
  132. unsigned index;
  133. struct cyg_mtab_entry * mte;
  134. int result;
  135. /* find a empty entry in partition table */
  136. for (index = 0; index < DEVICE_PART_MAX; index ++)
  137. {
  138. if (device_partition[index].dev == RT_NULL)
  139. break;
  140. }
  141. if (index == DEVICE_PART_MAX)
  142. return -DFS_STATUS_ENOSPC;
  143. mte = rt_malloc(sizeof(struct cyg_mtab_entry));
  144. if (mte == RT_NULL)
  145. return -DFS_STATUS_ENOMEM;
  146. mte->name = fs->path;
  147. mte->fsname = "jffs2";
  148. mte->devname = NULL;
  149. /* note that, i use mte->data to store rtt's device
  150. * while, in jffs2_mount, mte->data will be copy into
  151. * s_dev in struct super_block, and mte->data will be
  152. * filled with jffs2_sb(see the source of jffs2_mount.
  153. */
  154. mte->data = (CYG_ADDRWORD)fs->dev_id;
  155. device_partition[index].dev = RT_MTD_DEVICE(fs->dev_id);
  156. /* after jffs2_mount, mte->data will not be dev_id any more */
  157. result = jffs2_mount(NULL, mte);
  158. if (result != 0)
  159. {
  160. return jffs2_result_to_dfs(result);
  161. }
  162. /* save this pointer */
  163. device_partition[index].mte = mte;
  164. return 0;
  165. }
  166. static int _find_fs(struct cyg_mtab_entry ** mte, rt_device_t dev_id)
  167. {
  168. unsigned index;
  169. /* find device index */
  170. for (index = 0; index < DEVICE_PART_MAX; index++)
  171. {
  172. if (device_partition[index].dev == RT_MTD_DEVICE(dev_id))
  173. {
  174. *mte = device_partition[index].mte;
  175. return 0;
  176. }
  177. }
  178. rt_kprintf("error, could not found the fs!");
  179. return -1;
  180. }
  181. static int dfs_jffs2_unmount(struct dfs_filesystem* fs)
  182. {
  183. int result;
  184. unsigned index;
  185. /* find device index, then umount it */
  186. for (index = 0; index < DEVICE_PART_MAX; index++)
  187. {
  188. if (device_partition[index].dev == RT_MTD_DEVICE(fs->dev_id))
  189. {
  190. result = jffs2_umount(device_partition[index].mte);
  191. if (result)
  192. return jffs2_result_to_dfs(result);
  193. rt_free(device_partition[index].mte);
  194. device_partition[index].dev = NULL;
  195. device_partition[index].mte = NULL;
  196. return DFS_STATUS_OK;
  197. }
  198. }
  199. return -DFS_STATUS_ENOENT;
  200. }
  201. static int dfs_jffs2_mkfs(const char* device_name)
  202. {
  203. /* just erase all blocks on this nand partition */
  204. return -DFS_STATUS_ENOSYS;
  205. }
  206. static int dfs_jffs2_statfs(struct dfs_filesystem* fs,
  207. struct statfs *buf)
  208. {
  209. /* since the limit of unsigned long, so the max size of flash device is 4G */
  210. struct cyg_mtab_entry * mte;
  211. struct jffs2_fs_info info;
  212. int result;
  213. result = _find_fs(&mte, fs->dev_id);
  214. if (result)
  215. return -DFS_STATUS_ENOENT;
  216. RT_ASSERT(mte->data != NULL);
  217. jffs2_get_info_from_sb((void *)mte->data, &info);
  218. buf->f_bsize = info.sector_size;
  219. buf->f_blocks = info.nr_blocks;
  220. buf->f_bfree = info.free_size; //fixme need test!
  221. // jffs2_sb = (struct super_block)(mte->data);
  222. // c = JFFS2_SB_INFO(jffs2_sb);
  223. //
  224. // buf->f_bsize = c->sector_size;
  225. // buf->f_blocks = c->nr_blocks;
  226. // buf->f_bfree = c->free_size; //fixme need test!
  227. return 0;
  228. }
  229. static const char jffs2_root_path[] = ".";
  230. static int dfs_jffs2_open(struct dfs_fd* file)
  231. {
  232. int oflag, mode;
  233. int result;
  234. cyg_file * jffs2_file;
  235. struct cyg_mtab_entry * mte;
  236. const char * name;
  237. oflag = file->flags;
  238. jffs2_file = rt_malloc(sizeof(cyg_file));
  239. if (jffs2_file == RT_NULL)
  240. return -DFS_STATUS_ENOMEM;
  241. /* just escape '/' provided by dfs code */
  242. name = file->path;
  243. if ((name[0] == '/') && (name[1] == 0))
  244. name = jffs2_root_path;
  245. else /* name[0] still will be '/' */
  246. name ++;
  247. result = _find_fs(&mte, file->fs->dev_id);
  248. if (result)
  249. {
  250. rt_free(jffs2_file);
  251. return -DFS_STATUS_ENOENT;
  252. }
  253. if (oflag & DFS_O_DIRECTORY) /* operations about dir */
  254. {
  255. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  256. if (oflag & DFS_O_CREAT) /* create a dir*/
  257. {
  258. /* fixme, should test file->path can end with '/' */
  259. result = jffs2_mkdir(mte, mte->root, name);
  260. if (result)
  261. {
  262. rt_mutex_release(&jffs2_lock);
  263. rt_free(jffs2_file);
  264. return jffs2_result_to_dfs(result);
  265. }
  266. }
  267. /* open dir */
  268. result = jffs2_opendir(mte, mte->root, name, jffs2_file);
  269. rt_mutex_release(&jffs2_lock);
  270. if (result)
  271. {
  272. rt_free(jffs2_file);
  273. return jffs2_result_to_dfs(result);
  274. }
  275. #ifdef CONFIG_JFFS2_NO_RELATIVEDIR
  276. jffs2_file->f_offset = 2;
  277. #endif
  278. /* save this pointer, it will be used by dfs_jffs2_getdents*/
  279. file->data = jffs2_file;
  280. return 0;
  281. }
  282. /* regular file operations */
  283. mode = 0;
  284. if (oflag & DFS_O_RDONLY) mode |= JFFS2_O_RDONLY;
  285. if (oflag & DFS_O_WRONLY) mode |= JFFS2_O_WRONLY;
  286. if (oflag & DFS_O_RDWR) mode |= JFFS2_O_RDWR;
  287. /* Opens the file, if it is existing. If not, a new file is created. */
  288. if (oflag & DFS_O_CREAT) mode |= JFFS2_O_CREAT;
  289. /* Creates a new file. If the file is existing, it is truncated and overwritten. */
  290. if (oflag & DFS_O_TRUNC) mode |= JFFS2_O_TRUNC;
  291. /* Creates a new file. The function fails if the file is already existing. */
  292. if (oflag & DFS_O_EXCL) mode |= JFFS2_O_EXCL;
  293. // if (oflag & DFS_O_APPEND) mode |= JFFS2_O_APPEND;
  294. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  295. result = jffs2_open(mte, 0, name, mode, jffs2_file);
  296. if (result != 0)
  297. {
  298. rt_mutex_release(&jffs2_lock);
  299. rt_free(jffs2_file);
  300. return jffs2_result_to_dfs(result);
  301. }
  302. /* save this pointer, it will be used when calling read()£¬write(),
  303. flush(), lessk(), and will be rt_free when calling close()*/
  304. file->data = jffs2_file;
  305. file->pos = jffs2_file->f_offset;
  306. file->size = 0;
  307. jffs2_file_lseek(jffs2_file, (off_t *)(&(file->size)), SEEK_END);
  308. jffs2_file->f_offset = (off_t)file->pos;
  309. rt_mutex_release(&jffs2_lock);
  310. if (oflag & DFS_O_APPEND)
  311. {
  312. file->pos = file->size;
  313. jffs2_file->f_offset = file->size;
  314. }
  315. return 0;
  316. }
  317. static int dfs_jffs2_close(struct dfs_fd* file)
  318. {
  319. int result;
  320. cyg_file * jffs2_file;
  321. RT_ASSERT(file->data != NULL);
  322. jffs2_file = (cyg_file *)(file->data);
  323. if (file->flags & DFS_O_DIRECTORY) /* operations about dir */
  324. {
  325. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  326. result = jffs2_dir_colse(jffs2_file);
  327. rt_mutex_release(&jffs2_lock);
  328. if (result)
  329. return jffs2_result_to_dfs(result);
  330. rt_free(jffs2_file);
  331. return 0;
  332. }
  333. /* regular file operations */
  334. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  335. result = jffs2_file_colse(jffs2_file);
  336. rt_mutex_release(&jffs2_lock);
  337. if (result)
  338. return jffs2_result_to_dfs(result);
  339. /* release memory */
  340. rt_free(jffs2_file);
  341. return 0;
  342. }
  343. static int dfs_jffs2_ioctl(struct dfs_fd* file, int cmd, void* args)
  344. {
  345. return -DFS_STATUS_ENOSYS;
  346. }
  347. static int dfs_jffs2_read(struct dfs_fd* file, void* buf, rt_size_t len)
  348. {
  349. cyg_file * jffs2_file;
  350. struct CYG_UIO_TAG uio_s;
  351. struct CYG_IOVEC_TAG iovec;
  352. int char_read;
  353. int result;
  354. RT_ASSERT(file->data != NULL);
  355. jffs2_file = (cyg_file *)(file->data);
  356. uio_s.uio_iov = &iovec;
  357. uio_s.uio_iov->iov_base = buf;
  358. uio_s.uio_iov->iov_len = len;
  359. uio_s.uio_iovcnt = 1; //must be 1
  360. //uio_s.uio_offset //not used...
  361. uio_s.uio_resid = uio_s.uio_iov->iov_len; //seem no use in jffs2;
  362. char_read = jffs2_file->f_offset; /* the current offset */
  363. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  364. result = jffs2_file_read(jffs2_file, &uio_s);
  365. rt_mutex_release(&jffs2_lock);
  366. if (result)
  367. return jffs2_result_to_dfs(result);
  368. /* update position */
  369. file->pos = jffs2_file->f_offset;
  370. char_read = jffs2_file->f_offset - char_read;
  371. return char_read;
  372. }
  373. static int dfs_jffs2_write(struct dfs_fd* file,
  374. const void* buf,
  375. rt_size_t len)
  376. {
  377. cyg_file * jffs2_file;
  378. struct CYG_UIO_TAG uio_s;
  379. struct CYG_IOVEC_TAG iovec;
  380. int char_write;
  381. int result;
  382. RT_ASSERT(file->data != NULL);
  383. jffs2_file = (cyg_file *)(file->data);
  384. uio_s.uio_iov = &iovec;
  385. uio_s.uio_iov->iov_base = (void *)buf;
  386. uio_s.uio_iov->iov_len = len;
  387. uio_s.uio_iovcnt = 1; //must be 1
  388. //uio_s.uio_offset //not used...
  389. uio_s.uio_resid = uio_s.uio_iov->iov_len; //seem no use in jffs2;
  390. char_write = jffs2_file->f_offset;
  391. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  392. result = jffs2_file_write(jffs2_file, &uio_s);
  393. rt_mutex_release(&jffs2_lock);
  394. if (result)
  395. return jffs2_result_to_dfs(result);
  396. /* update position */
  397. file->pos = jffs2_file->f_offset;
  398. char_write = jffs2_file->f_offset - char_write;
  399. return char_write;
  400. }
  401. static int dfs_jffs2_flush(struct dfs_fd* file)
  402. {
  403. /* infact, jffs2 not support, jffs2_fo_sync just return ok */
  404. return -DFS_STATUS_ENOSYS;
  405. }
  406. /* fixme warning: the offset is rt_off_t, so maybe the size of a file is must <= 2G*/
  407. static int dfs_jffs2_lseek(struct dfs_fd* file,
  408. rt_off_t offset)
  409. {
  410. cyg_file * jffs2_file;
  411. int result;
  412. RT_ASSERT(file->data != NULL);
  413. jffs2_file = (cyg_file *)(file->data);
  414. /* set offset as current offset */
  415. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  416. result = jffs2_file_lseek(jffs2_file, &offset, SEEK_SET);
  417. rt_mutex_release(&jffs2_lock);
  418. if (result)
  419. return jffs2_result_to_dfs(result);
  420. /* update file position */
  421. file->pos = offset;
  422. return offset;
  423. }
  424. /* return the size of struct dirent*/
  425. static int dfs_jffs2_getdents(struct dfs_fd* file,
  426. struct dirent* dirp,
  427. rt_uint32_t count)
  428. {
  429. cyg_file * jffs2_file;
  430. struct CYG_UIO_TAG uio_s;
  431. struct CYG_IOVEC_TAG iovec;
  432. struct jffs2_dirent jffs2_d;
  433. struct dirent * d;
  434. rt_uint32_t index;
  435. #if !defined (CYGPKG_FS_JFFS2_RET_DIRENT_DTYPE)
  436. struct jffs2_stat s;
  437. cyg_mtab_entry * mte;
  438. char * fullname;
  439. #endif
  440. int result;
  441. RT_ASSERT(file->data != RT_NULL);
  442. jffs2_file = (cyg_file*)(file->data);
  443. //set jffs2_d
  444. memset(&jffs2_d, 0, sizeof(struct jffs2_dirent));
  445. //set CYG_UIO_TAG uio_s
  446. uio_s.uio_iov = &iovec;
  447. uio_s.uio_iov->iov_base = &jffs2_d;
  448. uio_s.uio_iov->iov_len = sizeof(struct jffs2_dirent);;
  449. uio_s.uio_iovcnt = 1; //must be 1
  450. uio_s.uio_offset = 0;//not used...
  451. uio_s.uio_resid = uio_s.uio_iov->iov_len; //seem no use in jffs2;
  452. #if !defined (CYGPKG_FS_JFFS2_RET_DIRENT_DTYPE)
  453. result = _find_fs(&mte, file->fs->dev_id);
  454. if (result)
  455. return -DFS_STATUS_ENOENT;
  456. #endif
  457. /* make integer count, usually count is 1 */
  458. count = (count / sizeof(struct dirent)) * sizeof(struct dirent);
  459. if (count == 0)
  460. return -DFS_STATUS_EINVAL;
  461. index = 0;
  462. /* usually, the while loop should only be looped only once! */
  463. while (1)
  464. {
  465. d = dirp + index;
  466. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  467. result = jffs2_dir_read(jffs2_file, &uio_s);
  468. rt_mutex_release(&jffs2_lock);
  469. /* if met a error or all entry are read over, break while*/
  470. if (result || jffs2_d.d_name[0] == 0)
  471. break;
  472. #if defined (CYGPKG_FS_JFFS2_RET_DIRENT_DTYPE)
  473. switch(jffs2_d.d_type & JFFS2_S_IFMT)
  474. {
  475. case JFFS2_S_IFREG: d->d_type = DFS_DT_REG; break;
  476. case JFFS2_S_IFDIR: d->d_type = DFS_DT_DIR; break;
  477. default: d->d_type = DFS_DT_UNKNOWN; break;
  478. }
  479. #else
  480. fullname = rt_malloc(FILE_PATH_MAX);
  481. if(fullname == RT_NULL)
  482. return -DFS_STATUS_ENOMEM;
  483. /* make a right entry */
  484. if ((file->path[0] == '/') )
  485. {
  486. if (file->path[1] == 0)
  487. strcpy(fullname, jffs2_d.d_name);
  488. else
  489. rt_sprintf(fullname, "%s/%s", file->path+1, jffs2_d.d_name);
  490. }
  491. else
  492. rt_sprintf(fullname, "%s/%s", file->path, jffs2_d.d_name);
  493. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  494. result = jffs2_porting_stat(mte, mte->root, fullname, (void *)&s);
  495. rt_mutex_release(&jffs2_lock);
  496. if (result)
  497. return jffs2_result_to_dfs(result);
  498. rt_free(fullname);
  499. /* convert to dfs stat structure */
  500. switch(s.st_mode & JFFS2_S_IFMT)
  501. {
  502. case JFFS2_S_IFREG: d->d_type = DFS_DT_REG; break;
  503. case JFFS2_S_IFDIR: d->d_type = DFS_DT_DIR; break;
  504. default: d->d_type = DFS_DT_UNKNOWN; break;
  505. }
  506. #endif
  507. /* write the rest fields of struct dirent* dirp */
  508. d->d_namlen = rt_strlen(jffs2_d.d_name);
  509. d->d_reclen = (rt_uint16_t)sizeof(struct dirent);
  510. rt_strncpy(d->d_name, jffs2_d.d_name, d->d_namlen + 1);
  511. index ++;
  512. if (index * sizeof(struct dirent) >= count)
  513. break;
  514. }
  515. if (result)
  516. return jffs2_result_to_dfs(result);
  517. return index * sizeof(struct dirent);
  518. }
  519. static int dfs_jffs2_unlink(struct dfs_filesystem* fs, const char* path)
  520. {
  521. int result;
  522. struct jffs2_stat s;
  523. cyg_mtab_entry * mte;
  524. result = _find_fs(&mte, fs->dev_id);
  525. if (result)
  526. return -DFS_STATUS_ENOENT;
  527. /* deal path */
  528. if (path[0] == '/')
  529. path++;
  530. /* judge file type, dir is to be delete by rmdir, others by unlink */
  531. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  532. result = jffs2_porting_stat(mte, mte->root, path, (void *)&s);
  533. if (result)
  534. {
  535. rt_mutex_release(&jffs2_lock);
  536. return jffs2_result_to_dfs(result);
  537. }
  538. switch(s.st_mode & JFFS2_S_IFMT)
  539. {
  540. case JFFS2_S_IFREG:
  541. result = jffs2_file_unlink(mte, mte->root, path);
  542. break;
  543. case JFFS2_S_IFDIR:
  544. result = jffs2_rmdir(mte, mte->root, path);
  545. break;
  546. default:
  547. /* unknown file type */
  548. rt_mutex_release(&jffs2_lock);
  549. return -1;
  550. }
  551. rt_mutex_release(&jffs2_lock);
  552. if (result)
  553. return jffs2_result_to_dfs(result);
  554. return 0;
  555. }
  556. static int dfs_jffs2_rename(struct dfs_filesystem* fs,
  557. const char* oldpath,
  558. const char* newpath)
  559. {
  560. int result;
  561. cyg_mtab_entry * mte;
  562. result = _find_fs(&mte, fs->dev_id);
  563. if (result)
  564. return -DFS_STATUS_ENOENT;
  565. if (*oldpath == '/')
  566. oldpath += 1;
  567. if (*newpath == '/')
  568. newpath += 1;
  569. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  570. result = jffs2_rename(mte, mte->root, oldpath, mte->root, newpath);
  571. rt_mutex_release(&jffs2_lock);
  572. if (result)
  573. return jffs2_result_to_dfs(result);
  574. return 0;
  575. }
  576. static int dfs_jffs2_stat(struct dfs_filesystem* fs, const char *path, struct stat *st)
  577. {
  578. int result;
  579. struct jffs2_stat s;
  580. cyg_mtab_entry * mte;
  581. /* deal the path for jffs2 */
  582. RT_ASSERT(!((path[0] == '/') && (path[1] == 0)));
  583. if (path[0] == '/')
  584. path++;
  585. result = _find_fs(&mte, fs->dev_id);
  586. if (result)
  587. return -DFS_STATUS_ENOENT;
  588. rt_mutex_take(&jffs2_lock, RT_WAITING_FOREVER);
  589. result = jffs2_porting_stat(mte, mte->root, path, (void *)&s);
  590. rt_mutex_release(&jffs2_lock);
  591. if (result)
  592. return jffs2_result_to_dfs(result);
  593. /* convert to dfs stat structure */
  594. switch(s.st_mode & JFFS2_S_IFMT)
  595. {
  596. case JFFS2_S_IFREG:
  597. st->st_mode = DFS_S_IFREG | DFS_S_IRUSR | DFS_S_IRGRP | DFS_S_IROTH |
  598. DFS_S_IWUSR | DFS_S_IWGRP | DFS_S_IWOTH;
  599. break;
  600. case JFFS2_S_IFDIR:
  601. st->st_mode = DFS_S_IFDIR | DFS_S_IXUSR | DFS_S_IXGRP | DFS_S_IXOTH;
  602. break;
  603. default:
  604. st->st_mode = DFS_DT_UNKNOWN; //fixme
  605. break;
  606. }
  607. st->st_dev = 0;
  608. st->st_size = s.st_size;
  609. st->st_mtime = s.st_mtime;
  610. /*st->st_blksize = ;*/ //fixme: what's this field?
  611. return 0;
  612. }
  613. static const struct dfs_filesystem_operation dfs_jffs2_ops =
  614. {
  615. "jffs2", /* file system type: jffs2 */
  616. #if RTTHREAD_VERSION >= 10100
  617. DFS_FS_FLAG_DEFAULT, /* use Relative Path */
  618. #endif
  619. dfs_jffs2_mount,
  620. dfs_jffs2_unmount,
  621. dfs_jffs2_mkfs,
  622. dfs_jffs2_statfs,
  623. dfs_jffs2_open,
  624. dfs_jffs2_close,
  625. dfs_jffs2_ioctl,
  626. dfs_jffs2_read,
  627. dfs_jffs2_write,
  628. dfs_jffs2_flush,
  629. dfs_jffs2_lseek,
  630. dfs_jffs2_getdents,
  631. dfs_jffs2_unlink,
  632. dfs_jffs2_stat,
  633. dfs_jffs2_rename,
  634. };
  635. int dfs_jffs2_init(void)
  636. {
  637. /* register fatfs file system */
  638. dfs_register(&dfs_jffs2_ops);
  639. /* initialize mutex */
  640. if (rt_mutex_init(&jffs2_lock, "jffs2lock", RT_IPC_FLAG_FIFO) != RT_EOK)
  641. {
  642. rt_kprintf("init jffs2 lock mutex failed\n");
  643. }
  644. rt_kprintf("init jffs2 lock mutex okay\n");
  645. return 0;
  646. }