inode-v23.c
上传用户:lgb322
上传日期:2013-02-24
资源大小:30529k
文件大小:47k
源码类别:

嵌入式Linux

开发平台:

Unix_Linux

  1. /*
  2.  * JFFS -- Journalling Flash File System, Linux implementation.
  3.  *
  4.  * Copyright (C) 1999, 2000  Axis Communications AB.
  5.  *
  6.  * Created by Finn Hakansson <finn@axis.com>.
  7.  *
  8.  * This is free software; you can redistribute it and/or modify it
  9.  * under the terms of the GNU General Public License as published by
  10.  * the Free Software Foundation; either version 2 of the License, or
  11.  * (at your option) any later version.
  12.  *
  13.  * $Id: inode-v23.c,v 1.72 2002/01/31 11:42:57 cdavies Exp $
  14.  *
  15.  * Ported to Linux 2.3.x and MTD:
  16.  * Copyright (C) 2000  Alexander Larsson (alex@cendio.se), Cendio Systems AB
  17.  *
  18.  * Copyright 2000, 2001  Red Hat, Inc.
  19.  */
  20. /* inode.c -- Contains the code that is called from the VFS.  */
  21. /* TODO-ALEX:
  22.  * uid and gid are just 16 bit.
  23.  * jffs_file_write reads from user-space pointers without xx_from_user
  24.  * maybe other stuff do to.
  25.  */
  26. /* Argh. Some architectures have kernel_thread in asm/processor.h
  27.    Some have it in unistd.h and you need to define __KERNEL_SYSCALLS__
  28.    Pass me a baseball bat and the person responsible.
  29.    dwmw2
  30. */
  31. #define __KERNEL_SYSCALLS__
  32. #include <linux/sched.h>
  33. #include <linux/unistd.h>
  34. #include <linux/module.h>
  35. #include <linux/init.h>
  36. #include <linux/types.h>
  37. #include <linux/errno.h>
  38. #include <linux/slab.h>
  39. #include <linux/jffs.h>
  40. #include <linux/fs.h>
  41. #include <linux/locks.h>
  42. #include <linux/smp_lock.h>
  43. #include <linux/ioctl.h>
  44. #include <linux/stat.h>
  45. #include <linux/blkdev.h>
  46. #include <linux/quotaops.h>
  47. #include <linux/compatmac.h>
  48. #include <asm/semaphore.h>
  49. #include <asm/byteorder.h>
  50. #include <asm/uaccess.h>
  51. #include "jffs_fm.h"
  52. #include "intrep.h"
  53. #if CONFIG_JFFS_PROC_FS
  54. #include "jffs_proc.h"
  55. #endif
  56. #if LINUX_VERSION_CODE < KERNEL_VERSION(2,5,2)
  57. #define minor(x) MINOR(x)
  58. #define major(x) MAJOR(x)
  59. #endif
  60. static int jffs_remove(struct inode *dir, struct dentry *dentry, int type);
  61. static struct super_operations jffs_ops;
  62. static struct file_operations jffs_file_operations;
  63. static struct inode_operations jffs_file_inode_operations;
  64. static struct file_operations jffs_dir_operations;
  65. static struct inode_operations jffs_dir_inode_operations;
  66. static struct address_space_operations jffs_address_operations;
  67. kmem_cache_t     *node_cache = NULL;
  68. kmem_cache_t     *fm_cache = NULL;
  69. /* Called by the VFS at mount time to initialize the whole file system.  */
  70. static struct super_block *
  71. jffs_read_super(struct super_block *sb, void *data, int silent)
  72. {
  73. kdev_t dev = sb->s_dev;
  74. struct inode *root_inode;
  75. struct jffs_control *c;
  76. D1(printk(KERN_NOTICE "JFFS: Trying to mount device %s.n",
  77.   kdevname(dev)));
  78. if (major(dev) != MTD_BLOCK_MAJOR) {
  79. printk(KERN_WARNING "JFFS: Trying to mount a "
  80.        "non-mtd device.n");
  81. return 0;
  82. }
  83. sb->s_blocksize = PAGE_CACHE_SIZE;
  84. sb->s_blocksize_bits = PAGE_CACHE_SHIFT;
  85. sb->u.generic_sbp = (void *) 0;
  86. sb->s_maxbytes = 0xFFFFFFFF;
  87. /* Build the file system.  */
  88. if (jffs_build_fs(sb) < 0) {
  89. goto jffs_sb_err1;
  90. }
  91. /*
  92.  * set up enough so that we can read an inode
  93.  */
  94. sb->s_magic = JFFS_MAGIC_SB_BITMASK;
  95. sb->s_op = &jffs_ops;
  96. root_inode = iget(sb, JFFS_MIN_INO);
  97. if (!root_inode)
  98.         goto jffs_sb_err2;
  99. /* Get the root directory of this file system.  */
  100. if (!(sb->s_root = d_alloc_root(root_inode))) {
  101. goto jffs_sb_err3;
  102. }
  103. c = (struct jffs_control *) sb->u.generic_sbp;
  104. #ifdef CONFIG_JFFS_PROC_FS
  105. /* Set up the jffs proc file system.  */
  106. if (jffs_register_jffs_proc_dir(dev, c) < 0) {
  107. printk(KERN_WARNING "JFFS: Failed to initialize the JFFS "
  108. "proc file system for device %s.n",
  109. kdevname(dev));
  110. }
  111. #endif
  112. /* Set the Garbage Collection thresholds */
  113. /* GC if free space goes below 5% of the total size */
  114. c->gc_minfree_threshold = c->fmc->flash_size / 20;
  115. if (c->gc_minfree_threshold < c->fmc->sector_size)
  116. c->gc_minfree_threshold = c->fmc->sector_size;
  117. /* GC if dirty space exceeds 33% of the total size. */
  118. c->gc_maxdirty_threshold = c->fmc->flash_size / 3;
  119. if (c->gc_maxdirty_threshold < c->fmc->sector_size)
  120. c->gc_maxdirty_threshold = c->fmc->sector_size;
  121. c->thread_pid = kernel_thread (jffs_garbage_collect_thread, 
  122.         (void *) c, 
  123.         CLONE_FS | CLONE_FILES | CLONE_SIGHAND);
  124. D1(printk(KERN_NOTICE "JFFS: GC thread pid=%d.n", (int) c->thread_pid));
  125. D1(printk(KERN_NOTICE "JFFS: Successfully mounted device %s.n",
  126.        kdevname(dev)));
  127. return sb;
  128. jffs_sb_err3:
  129. iput(root_inode);
  130. jffs_sb_err2:
  131. jffs_cleanup_control((struct jffs_control *)sb->u.generic_sbp);
  132. jffs_sb_err1:
  133. printk(KERN_WARNING "JFFS: Failed to mount device %s.n",
  134.        kdevname(dev));
  135. return 0;
  136. }
  137. /* This function is called when the file system is umounted.  */
  138. static void
  139. jffs_put_super(struct super_block *sb)
  140. {
  141. struct jffs_control *c = (struct jffs_control *) sb->u.generic_sbp;
  142. D1(kdev_t dev = sb->s_dev);
  143. D2(printk("jffs_put_super()n"));
  144. #ifdef CONFIG_JFFS_PROC_FS
  145. jffs_unregister_jffs_proc_dir(c);
  146. #endif
  147. if (c->gc_task) {
  148. D1(printk (KERN_NOTICE "jffs_put_super(): Telling gc thread to die.n"));
  149. send_sig(SIGKILL, c->gc_task, 1);
  150. }
  151. wait_for_completion(&c->gc_thread_comp);
  152. D1(printk (KERN_NOTICE "jffs_put_super(): Successfully waited on thread.n"));
  153. jffs_cleanup_control((struct jffs_control *)sb->u.generic_sbp);
  154. D1(printk(KERN_NOTICE "JFFS: Successfully unmounted device %s.n",
  155.        kdevname(dev)));
  156. }
  157. /* This function is called when user commands like chmod, chgrp and
  158.    chown are executed. System calls like trunc() results in a call
  159.    to this function.  */
  160. static int
  161. jffs_setattr(struct dentry *dentry, struct iattr *iattr)
  162. {
  163. struct inode *inode = dentry->d_inode;
  164. struct jffs_raw_inode raw_inode;
  165. struct jffs_control *c;
  166. struct jffs_fmcontrol *fmc;
  167. struct jffs_file *f;
  168. struct jffs_node *new_node;
  169. int update_all;
  170. int res;
  171. int recoverable = 0;
  172. if ((res = inode_change_ok(inode, iattr)))
  173. return res;
  174. c = (struct jffs_control *)inode->i_sb->u.generic_sbp;
  175. fmc = c->fmc;
  176. D3(printk (KERN_NOTICE "notify_change(): down biglockn"));
  177. down(&fmc->biglock);
  178. f = jffs_find_file(c, inode->i_ino);
  179. ASSERT(if (!f) {
  180. printk("jffs_setattr(): Invalid inode number: %lun",
  181.        inode->i_ino);
  182. D3(printk (KERN_NOTICE "notify_change(): up biglockn"));
  183. up(&fmc->biglock);
  184. return -EINVAL;
  185. });
  186. D1(printk("***jffs_setattr(): file: "%s", ino: %un",
  187.   f->name, f->ino));
  188. update_all = iattr->ia_valid & ATTR_FORCE;
  189. if ( (update_all || iattr->ia_valid & ATTR_SIZE)
  190.      && (iattr->ia_size + 128 < f->size) ) {
  191. /* We're shrinking the file by more than 128 bytes.
  192.    We'll be able to GC and recover this space, so
  193.    allow it to go into the reserved space. */
  194. recoverable = 1;
  195.         }
  196. if (!(new_node = jffs_alloc_node())) {
  197. D(printk("jffs_setattr(): Allocation failed!n"));
  198. D3(printk (KERN_NOTICE "notify_change(): up biglockn"));
  199. up(&fmc->biglock);
  200. return -ENOMEM;
  201. }
  202. new_node->data_offset = 0;
  203. new_node->removed_size = 0;
  204. raw_inode.magic = JFFS_MAGIC_BITMASK;
  205. raw_inode.ino = f->ino;
  206. raw_inode.pino = f->pino;
  207. raw_inode.mode = f->mode;
  208. raw_inode.uid = f->uid;
  209. raw_inode.gid = f->gid;
  210. raw_inode.atime = f->atime;
  211. raw_inode.mtime = f->mtime;
  212. raw_inode.ctime = f->ctime;
  213. raw_inode.dsize = 0;
  214. raw_inode.offset = 0;
  215. raw_inode.rsize = 0;
  216. raw_inode.dsize = 0;
  217. raw_inode.nsize = f->nsize;
  218. raw_inode.nlink = f->nlink;
  219. raw_inode.spare = 0;
  220. raw_inode.rename = 0;
  221. raw_inode.deleted = 0;
  222. if (update_all || iattr->ia_valid & ATTR_MODE) {
  223. raw_inode.mode = iattr->ia_mode;
  224. inode->i_mode = iattr->ia_mode;
  225. }
  226. if (update_all || iattr->ia_valid & ATTR_UID) {
  227. raw_inode.uid = iattr->ia_uid;
  228. inode->i_uid = iattr->ia_uid;
  229. }
  230. if (update_all || iattr->ia_valid & ATTR_GID) {
  231. raw_inode.gid = iattr->ia_gid;
  232. inode->i_gid = iattr->ia_gid;
  233. }
  234. if (update_all || iattr->ia_valid & ATTR_SIZE) {
  235. int len;
  236. D1(printk("jffs_notify_change(): Changing size "
  237.   "to %lu bytes!n", (long)iattr->ia_size));
  238. raw_inode.offset = iattr->ia_size;
  239. /* Calculate how many bytes need to be removed from
  240.    the end.  */
  241. if (f->size < iattr->ia_size) {
  242. len = 0;
  243. }
  244. else {
  245. len = f->size - iattr->ia_size;
  246. }
  247. raw_inode.rsize = len;
  248. /* The updated node will be a removal node, with
  249.    base at the new size and size of the nbr of bytes
  250.    to be removed.  */
  251. new_node->data_offset = iattr->ia_size;
  252. new_node->removed_size = len;
  253. inode->i_size = iattr->ia_size;
  254. inode->i_blocks = (inode->i_size + 511) >> 9;
  255. if (len) {
  256. invalidate_inode_pages(inode);
  257. }
  258. inode->i_ctime = CURRENT_TIME;
  259. inode->i_mtime = inode->i_ctime;
  260. }
  261. if (update_all || iattr->ia_valid & ATTR_ATIME) {
  262. raw_inode.atime = iattr->ia_atime;
  263. inode->i_atime = iattr->ia_atime;
  264. }
  265. if (update_all || iattr->ia_valid & ATTR_MTIME) {
  266. raw_inode.mtime = iattr->ia_mtime;
  267. inode->i_mtime = iattr->ia_mtime;
  268. }
  269. if (update_all || iattr->ia_valid & ATTR_CTIME) {
  270. raw_inode.ctime = iattr->ia_ctime;
  271. inode->i_ctime = iattr->ia_ctime;
  272. }
  273. /* Write this node to the flash.  */
  274. if ((res = jffs_write_node(c, new_node, &raw_inode, f->name, 0, recoverable, f)) < 0) {
  275. D(printk("jffs_notify_change(): The write failed!n"));
  276. jffs_free_node(new_node);
  277. D3(printk (KERN_NOTICE "n_c(): up biglockn"));
  278. up(&c->fmc->biglock);
  279. return res;
  280. }
  281. jffs_insert_node(c, f, &raw_inode, 0, new_node);
  282. mark_inode_dirty(inode);
  283. D3(printk (KERN_NOTICE "n_c(): up biglockn"));
  284. up(&c->fmc->biglock);
  285. return 0;
  286. } /* jffs_notify_change()  */
  287. struct inode *
  288. jffs_new_inode(const struct inode * dir, struct jffs_raw_inode *raw_inode,
  289.        int * err)
  290. {
  291. struct super_block * sb;
  292. struct inode * inode;
  293. struct jffs_control *c;
  294. struct jffs_file *f;
  295. sb = dir->i_sb;
  296. inode = new_inode(sb);
  297. if (!inode) {
  298. *err = -ENOMEM;
  299. return NULL;
  300. }
  301. c = (struct jffs_control *)sb->u.generic_sbp;
  302. inode->i_ino = raw_inode->ino;
  303. inode->i_mode = raw_inode->mode;
  304. inode->i_nlink = raw_inode->nlink;
  305. inode->i_uid = raw_inode->uid;
  306. inode->i_gid = raw_inode->gid;
  307. inode->i_rdev = NODEV;
  308. inode->i_size = raw_inode->dsize;
  309. inode->i_atime = raw_inode->atime;
  310. inode->i_mtime = raw_inode->mtime;
  311. inode->i_ctime = raw_inode->ctime;
  312. inode->i_blksize = PAGE_SIZE;
  313. inode->i_blocks = (inode->i_size + 511) >> 9;
  314. inode->i_version = 0;
  315. f = jffs_find_file(c, raw_inode->ino);
  316. inode->u.generic_ip = (void *)f;
  317. insert_inode_hash(inode);
  318. return inode;
  319. }
  320. /* Get statistics of the file system.  */
  321. int
  322. jffs_statfs(struct super_block *sb, struct statfs *buf)
  323. {
  324. struct jffs_control *c = (struct jffs_control *) sb->u.generic_sbp;
  325. struct jffs_fmcontrol *fmc = c->fmc;
  326. D2(printk("jffs_statfs()n"));
  327. buf->f_type = JFFS_MAGIC_SB_BITMASK;
  328. buf->f_bsize = PAGE_CACHE_SIZE;
  329. buf->f_blocks = (fmc->flash_size / PAGE_CACHE_SIZE)
  330.        - (fmc->min_free_size / PAGE_CACHE_SIZE);
  331. buf->f_bfree = (jffs_free_size1(fmc) + jffs_free_size2(fmc) +
  332.        fmc->dirty_size - fmc->min_free_size)
  333.        >> PAGE_CACHE_SHIFT;
  334. buf->f_bavail = buf->f_bfree;
  335. /* Find out how many files there are in the filesystem.  */
  336. buf->f_files = jffs_foreach_file(c, jffs_file_count);
  337. buf->f_ffree = buf->f_bfree;
  338. /* buf->f_fsid = 0; */
  339. buf->f_namelen = JFFS_MAX_NAME_LEN;
  340. return 0;
  341. }
  342. /* Rename a file.  */
  343. int
  344. jffs_rename(struct inode *old_dir, struct dentry *old_dentry,
  345.     struct inode *new_dir, struct dentry *new_dentry)
  346. {
  347. struct jffs_raw_inode raw_inode;
  348. struct jffs_control *c;
  349. struct jffs_file *old_dir_f;
  350. struct jffs_file *new_dir_f;
  351. struct jffs_file *del_f;
  352. struct jffs_file *f;
  353. struct jffs_node *node;
  354. struct inode *inode;
  355. int result = 0;
  356. __u32 rename_data = 0;
  357. D2(printk("***jffs_rename()n"));
  358. D(printk("jffs_rename(): old_dir: 0x%p, old name: 0x%p, "
  359.  "new_dir: 0x%p, new name: 0x%pn",
  360.  old_dir, old_dentry->d_name.name,
  361.  new_dir, new_dentry->d_name.name));
  362. c = (struct jffs_control *)old_dir->i_sb->u.generic_sbp;
  363. ASSERT(if (!c) {
  364. printk(KERN_ERR "jffs_rename(): The old_dir inode "
  365.        "didn't have a reference to a jffs_file structn");
  366. return -EIO;
  367. });
  368. result = -ENOTDIR;
  369. if (!(old_dir_f = (struct jffs_file *)old_dir->u.generic_ip)) {
  370. D(printk("jffs_rename(): Old dir invalid.n"));
  371. goto jffs_rename_end;
  372. }
  373. /* Try to find the file to move.  */
  374. result = -ENOENT;
  375. if (!(f = jffs_find_child(old_dir_f, old_dentry->d_name.name,
  376.   old_dentry->d_name.len))) {
  377. goto jffs_rename_end;
  378. }
  379. /* Find the new directory.  */
  380. result = -ENOTDIR;
  381. if (!(new_dir_f = (struct jffs_file *)new_dir->u.generic_ip)) {
  382. D(printk("jffs_rename(): New dir invalid.n"));
  383. goto jffs_rename_end;
  384. }
  385. D3(printk (KERN_NOTICE "rename(): down biglockn"));
  386. down(&c->fmc->biglock);
  387. /* Create a node and initialize as much as needed.  */
  388. result = -ENOMEM;
  389. if (!(node = jffs_alloc_node())) {
  390. D(printk("jffs_rename(): Allocation failed: node == 0n"));
  391. goto jffs_rename_end;
  392. }
  393. node->data_offset = 0;
  394. node->removed_size = 0;
  395. /* Initialize the raw inode.  */
  396. raw_inode.magic = JFFS_MAGIC_BITMASK;
  397. raw_inode.ino = f->ino;
  398. raw_inode.pino = new_dir_f->ino;
  399. /*   raw_inode.version = f->highest_version + 1; */
  400. raw_inode.mode = f->mode;
  401. raw_inode.uid = current->fsuid;
  402. raw_inode.gid = current->fsgid;
  403. #if 0
  404. raw_inode.uid = f->uid;
  405. raw_inode.gid = f->gid;
  406. #endif
  407. raw_inode.atime = CURRENT_TIME;
  408. raw_inode.mtime = raw_inode.atime;
  409. raw_inode.ctime = f->ctime;
  410. raw_inode.offset = 0;
  411. raw_inode.dsize = 0;
  412. raw_inode.rsize = 0;
  413. raw_inode.nsize = new_dentry->d_name.len;
  414. raw_inode.nlink = f->nlink;
  415. raw_inode.spare = 0;
  416. raw_inode.rename = 0;
  417. raw_inode.deleted = 0;
  418. /* See if there already exists a file with the same name as
  419.    new_name.  */
  420. if ((del_f = jffs_find_child(new_dir_f, new_dentry->d_name.name,
  421.      new_dentry->d_name.len))) {
  422. raw_inode.rename = 1;
  423. raw_inode.dsize = sizeof(__u32);
  424. rename_data = del_f->ino;
  425. }
  426. /* Write the new node to the flash memory.  */
  427. if ((result = jffs_write_node(c, node, &raw_inode,
  428.       new_dentry->d_name.name,
  429.       (unsigned char*)&rename_data, 0, f)) < 0) {
  430. D(printk("jffs_rename(): Failed to write node to flash.n"));
  431. jffs_free_node(node);
  432. goto jffs_rename_end;
  433. }
  434. raw_inode.dsize = 0;
  435. if (raw_inode.rename) {
  436. /* The file with the same name must be deleted.  */
  437. //FIXME deadlock         down(&c->fmc->gclock);
  438. if ((result = jffs_remove(new_dir, new_dentry,
  439.   del_f->mode)) < 0) {
  440. /* This is really bad.  */
  441. printk(KERN_ERR "JFFS: An error occurred in "
  442.        "rename().n");
  443. }
  444. // up(&c->fmc->gclock);
  445. }
  446. if (old_dir_f != new_dir_f) {
  447. /* Remove the file from its old position in the
  448.    filesystem tree.  */
  449. jffs_unlink_file_from_tree(f);
  450. }
  451. /* Insert the new node into the file system.  */
  452. if ((result = jffs_insert_node(c, f, &raw_inode,
  453.        new_dentry->d_name.name, node)) < 0) {
  454. D(printk(KERN_ERR "jffs_rename(): jffs_insert_node() "
  455.  "failed!n"));
  456. }
  457. if (old_dir_f != new_dir_f) {
  458. /* Insert the file to its new position in the
  459.    file system.  */
  460. jffs_insert_file_into_tree(f);
  461. }
  462. /* This is a kind of update of the inode we're about to make
  463.    here.  This is what they do in ext2fs.  Kind of.  */
  464. if ((inode = iget(new_dir->i_sb, f->ino))) {
  465. inode->i_ctime = CURRENT_TIME;
  466. mark_inode_dirty(inode);
  467. iput(inode);
  468. }
  469. jffs_rename_end:
  470. D3(printk (KERN_NOTICE "rename(): up biglockn"));
  471. up(&c->fmc->biglock);
  472. return result;
  473. } /* jffs_rename()  */
  474. /* Read the contents of a directory.  Used by programs like `ls'
  475.    for instance.  */
  476. static int
  477. jffs_readdir(struct file *filp, void *dirent, filldir_t filldir)
  478. {
  479. struct jffs_file *f;
  480. struct dentry *dentry = filp->f_dentry;
  481. struct inode *inode = dentry->d_inode;
  482. struct jffs_control *c = (struct jffs_control *)inode->i_sb->u.generic_sbp;
  483. int j;
  484. int ddino;
  485. D3(printk (KERN_NOTICE "readdir(): down biglockn"));
  486. down(&c->fmc->biglock);
  487. D2(printk("jffs_readdir(): inode: 0x%p, filp: 0x%pn", inode, filp));
  488. if (filp->f_pos == 0) {
  489. D3(printk("jffs_readdir(): "." %lun", inode->i_ino));
  490. if (filldir(dirent, ".", 1, filp->f_pos, inode->i_ino, DT_DIR) < 0) {
  491. D3(printk (KERN_NOTICE "readdir(): up biglockn"));
  492. up(&c->fmc->biglock);
  493. return 0;
  494. }
  495. filp->f_pos = 1;
  496. }
  497. if (filp->f_pos == 1) {
  498. if (inode->i_ino == JFFS_MIN_INO) {
  499. ddino = JFFS_MIN_INO;
  500. }
  501. else {
  502. ddino = ((struct jffs_file *)
  503.  inode->u.generic_ip)->pino;
  504. }
  505. D3(printk("jffs_readdir(): ".." %un", ddino));
  506. if (filldir(dirent, "..", 2, filp->f_pos, ddino, DT_DIR) < 0) {
  507. D3(printk (KERN_NOTICE "readdir(): up biglockn"));
  508. up(&c->fmc->biglock);
  509. return 0;
  510. }
  511. filp->f_pos++;
  512. }
  513. f = ((struct jffs_file *)inode->u.generic_ip)->children;
  514. j = 2;
  515. while(f && (f->deleted || j++ < filp->f_pos )) {
  516. f = f->sibling_next;
  517. }
  518. while (f) {
  519. D3(printk("jffs_readdir(): "%s" ino: %un",
  520.   (f->name ? f->name : ""), f->ino));
  521. if (filldir(dirent, f->name, f->nsize,
  522.     filp->f_pos , f->ino, DT_UNKNOWN) < 0) {
  523.         D3(printk (KERN_NOTICE "readdir(): up biglockn"));
  524. up(&c->fmc->biglock);
  525. return 0;
  526. }
  527. filp->f_pos++;
  528. do {
  529. f = f->sibling_next;
  530. } while(f && f->deleted);
  531. }
  532. D3(printk (KERN_NOTICE "readdir(): up biglockn"));
  533. up(&c->fmc->biglock);
  534. return filp->f_pos;
  535. } /* jffs_readdir()  */
  536. /* Find a file in a directory. If the file exists, return its
  537.    corresponding dentry.  */
  538. static struct dentry *
  539. jffs_lookup(struct inode *dir, struct dentry *dentry)
  540. {
  541. struct jffs_file *d;
  542. struct jffs_file *f;
  543. struct jffs_control *c = (struct jffs_control *)dir->i_sb->u.generic_sbp;
  544. int len;
  545. int r = 0;
  546. const char *name;
  547. struct inode *inode = NULL;
  548. len = dentry->d_name.len;
  549. name = dentry->d_name.name;
  550. D3({
  551. char *s = (char *)kmalloc(len + 1, GFP_KERNEL);
  552. memcpy(s, name, len);
  553. s[len] = '';
  554. printk("jffs_lookup(): dir: 0x%p, name: "%s"n", dir, s);
  555. kfree(s);
  556. });
  557. D3(printk (KERN_NOTICE "lookup(): down biglockn"));
  558. down(&c->fmc->biglock);
  559. r = -ENAMETOOLONG;
  560. if (len > JFFS_MAX_NAME_LEN) {
  561. goto jffs_lookup_end;
  562. }
  563. r = -EACCES;
  564. if (!(d = (struct jffs_file *)dir->u.generic_ip)) {
  565. D(printk("jffs_lookup(): No such inode! (%lu)n",
  566.  dir->i_ino));
  567. goto jffs_lookup_end;
  568. }
  569. /* Get the corresponding inode to the file.  */
  570. /* iget calls jffs_read_inode, so we need to drop the biglock
  571.            before calling iget.  Unfortunately, the GC has a tendency
  572.            to sneak in here, because iget sometimes calls schedule ().
  573. */
  574. if ((len == 1) && (name[0] == '.')) {
  575. D3(printk (KERN_NOTICE "lookup(): up biglockn"));
  576. up(&c->fmc->biglock);
  577. if (!(inode = iget(dir->i_sb, d->ino))) {
  578. D(printk("jffs_lookup(): . iget() ==> NULLn"));
  579. goto jffs_lookup_end_no_biglock;
  580. }
  581. D3(printk (KERN_NOTICE "lookup(): down biglockn"));
  582. down(&c->fmc->biglock);
  583. } else if ((len == 2) && (name[0] == '.') && (name[1] == '.')) {
  584.         D3(printk (KERN_NOTICE "lookup(): up biglockn"));
  585. up(&c->fmc->biglock);
  586.   if (!(inode = iget(dir->i_sb, d->pino))) {
  587. D(printk("jffs_lookup(): .. iget() ==> NULLn"));
  588. goto jffs_lookup_end_no_biglock;
  589. }
  590. D3(printk (KERN_NOTICE "lookup(): down biglockn"));
  591. down(&c->fmc->biglock);
  592. } else if ((f = jffs_find_child(d, name, len))) {
  593.         D3(printk (KERN_NOTICE "lookup(): up biglockn"));
  594. up(&c->fmc->biglock);
  595. if (!(inode = iget(dir->i_sb, f->ino))) {
  596. D(printk("jffs_lookup(): iget() ==> NULLn"));
  597. goto jffs_lookup_end_no_biglock;
  598. }
  599. D3(printk (KERN_NOTICE "lookup(): down biglockn"));
  600. down(&c->fmc->biglock);
  601. } else {
  602. D3(printk("jffs_lookup(): Couldn't find the file. "
  603.   "f = 0x%p, name = "%s", d = 0x%p, d->ino = %un",
  604.   f, name, d, d->ino));
  605. inode = NULL;
  606. }
  607. d_add(dentry, inode);
  608. D3(printk (KERN_NOTICE "lookup(): up biglockn"));
  609. up(&c->fmc->biglock);
  610. return NULL;
  611. jffs_lookup_end:
  612. D3(printk (KERN_NOTICE "lookup(): up biglockn"));
  613. up(&c->fmc->biglock);
  614. jffs_lookup_end_no_biglock:
  615. return ERR_PTR(r);
  616. } /* jffs_lookup()  */
  617. /* Try to read a page of data from a file.  */
  618. static int
  619. jffs_do_readpage_nolock(struct file *file, struct page *page)
  620. {
  621. void *buf;
  622. unsigned long read_len;
  623. int result;
  624. struct inode *inode = (struct inode*)page->mapping->host;
  625. struct jffs_file *f = (struct jffs_file *)inode->u.generic_ip;
  626. struct jffs_control *c = (struct jffs_control *)inode->i_sb->u.generic_sbp;
  627. int r;
  628. loff_t offset;
  629. D2(printk("***jffs_readpage(): file = "%s", page->index = %lun",
  630.   (f->name ? f->name : ""), (long)page->index));
  631. get_page(page);
  632. /* Don't LockPage(page), should be locked already */
  633. buf = page_address(page);
  634. ClearPageUptodate(page);
  635. ClearPageError(page);
  636. D3(printk (KERN_NOTICE "readpage(): down biglockn"));
  637. down(&c->fmc->biglock);
  638. read_len = 0;
  639. result = 0;
  640. offset = page->index << PAGE_CACHE_SHIFT;
  641. if (offset < inode->i_size) {
  642. read_len = min_t(long, inode->i_size - offset, PAGE_SIZE);
  643. r = jffs_read_data(f, buf, offset, read_len);
  644. if (r != read_len) {
  645. result = -EIO;
  646. D(
  647.         printk("***jffs_readpage(): Read error! "
  648.        "Wanted to read %lu bytes but only "
  649.        "read %d bytes.n", read_len, r);
  650.   );
  651. }
  652. }
  653. /* This handles the case of partial or no read in above */
  654. if(read_len < PAGE_SIZE)
  655.         memset(buf + read_len, 0, PAGE_SIZE - read_len);
  656. D3(printk (KERN_NOTICE "readpage(): up biglockn"));
  657. up(&c->fmc->biglock);
  658. if (result) {
  659.         SetPageError(page);
  660. }else {
  661.         SetPageUptodate(page);         
  662. }
  663. flush_dcache_page(page);
  664. put_page(page);
  665. D3(printk("jffs_readpage(): Leaving...n"));
  666. return result;
  667. } /* jffs_do_readpage_nolock()  */
  668. static int jffs_readpage(struct file *file, struct page *page)
  669. {
  670. int ret = jffs_do_readpage_nolock(file, page);
  671. UnlockPage(page);
  672. return ret;
  673. }
  674. /* Create a new directory.  */
  675. static int
  676. jffs_mkdir(struct inode *dir, struct dentry *dentry, int mode)
  677. {
  678. struct jffs_raw_inode raw_inode;
  679. struct jffs_control *c;
  680. struct jffs_node *node;
  681. struct jffs_file *dir_f;
  682. struct inode *inode;
  683. int dir_mode;
  684. int result = 0;
  685. int err;
  686. D1({
  687.         int len = dentry->d_name.len;
  688. char *_name = (char *) kmalloc(len + 1, GFP_KERNEL);
  689. memcpy(_name, dentry->d_name.name, len);
  690. _name[len] = '';
  691. printk("***jffs_mkdir(): dir = 0x%p, name = "%s", "
  692.        "len = %d, mode = 0x%08xn", dir, _name, len, mode);
  693. kfree(_name);
  694. });
  695. dir_f = (struct jffs_file *)dir->u.generic_ip;
  696. ASSERT(if (!dir_f) {
  697. printk(KERN_ERR "jffs_mkdir(): No reference to a "
  698.        "jffs_file struct in inode.n");
  699. return -EIO;
  700. });
  701. c = dir_f->c;
  702. D3(printk (KERN_NOTICE "mkdir(): down biglockn"));
  703. down(&c->fmc->biglock);
  704. dir_mode = S_IFDIR | (mode & (S_IRWXUGO|S_ISVTX)
  705.       & ~current->fs->umask);
  706. if (dir->i_mode & S_ISGID) {
  707. dir_mode |= S_ISGID;
  708. }
  709. /* Create a node and initialize it as much as needed.  */
  710. if (!(node = jffs_alloc_node())) {
  711. D(printk("jffs_mkdir(): Allocation failed: node == 0n"));
  712. result = -ENOMEM;
  713. goto jffs_mkdir_end;
  714. }
  715. node->data_offset = 0;
  716. node->removed_size = 0;
  717. /* Initialize the raw inode.  */
  718. raw_inode.magic = JFFS_MAGIC_BITMASK;
  719. raw_inode.ino = c->next_ino++;
  720. raw_inode.pino = dir_f->ino;
  721. raw_inode.version = 1;
  722. raw_inode.mode = dir_mode;
  723. raw_inode.uid = current->fsuid;
  724. raw_inode.gid = (dir->i_mode & S_ISGID) ? dir->i_gid : current->fsgid;
  725. /* raw_inode.gid = current->fsgid; */
  726. raw_inode.atime = CURRENT_TIME;
  727. raw_inode.mtime = raw_inode.atime;
  728. raw_inode.ctime = raw_inode.atime;
  729. raw_inode.offset = 0;
  730. raw_inode.dsize = 0;
  731. raw_inode.rsize = 0;
  732. raw_inode.nsize = dentry->d_name.len;
  733. raw_inode.nlink = 1;
  734. raw_inode.spare = 0;
  735. raw_inode.rename = 0;
  736. raw_inode.deleted = 0;
  737. /* Write the new node to the flash.  */
  738. if ((result = jffs_write_node(c, node, &raw_inode,
  739.       dentry->d_name.name, 0, 0, NULL)) < 0) {
  740. D(printk("jffs_mkdir(): jffs_write_node() failed.n"));
  741. jffs_free_node(node);
  742. goto jffs_mkdir_end;
  743. }
  744. /* Insert the new node into the file system.  */
  745. if ((result = jffs_insert_node(c, 0, &raw_inode, dentry->d_name.name,
  746.        node)) < 0) {
  747. goto jffs_mkdir_end;
  748. }
  749. inode = jffs_new_inode(dir, &raw_inode, &err);
  750. if (inode == NULL) {
  751. result = err;
  752. goto jffs_mkdir_end;
  753. }
  754. inode->i_op = &jffs_dir_inode_operations;
  755. inode->i_fop = &jffs_dir_operations;
  756. mark_inode_dirty(dir);
  757. d_instantiate(dentry, inode);
  758. result = 0;
  759. jffs_mkdir_end:
  760. D3(printk (KERN_NOTICE "mkdir(): up biglockn"));
  761. up(&c->fmc->biglock);
  762. return result;
  763. } /* jffs_mkdir()  */
  764. /* Remove a directory.  */
  765. static int
  766. jffs_rmdir(struct inode *dir, struct dentry *dentry)
  767. {
  768. struct jffs_control *c = (struct jffs_control *)dir->i_sb->u.generic_sbp;
  769. int ret;
  770. D3(printk("***jffs_rmdir()n"));
  771. D3(printk (KERN_NOTICE "rmdir(): down biglockn"));
  772. down(&c->fmc->biglock);
  773. ret = jffs_remove(dir, dentry, S_IFDIR);
  774. D3(printk (KERN_NOTICE "rmdir(): up biglockn"));
  775. up(&c->fmc->biglock);
  776. return ret;
  777. }
  778. /* Remove any kind of file except for directories.  */
  779. static int
  780. jffs_unlink(struct inode *dir, struct dentry *dentry)
  781. {
  782. struct jffs_control *c = (struct jffs_control *)dir->i_sb->u.generic_sbp;
  783. int ret; 
  784. D3(printk("***jffs_unlink()n"));
  785. D3(printk (KERN_NOTICE "unlink(): down biglockn"));
  786. down(&c->fmc->biglock);
  787. ret = jffs_remove(dir, dentry, 0);
  788. D3(printk (KERN_NOTICE "unlink(): up biglockn"));
  789. up(&c->fmc->biglock);
  790. return ret;
  791. }
  792. /* Remove a JFFS entry, i.e. plain files, directories, etc.  Here we
  793.    shouldn't test for free space on the device.  */
  794. static int
  795. jffs_remove(struct inode *dir, struct dentry *dentry, int type)
  796. {
  797. struct jffs_raw_inode raw_inode;
  798. struct jffs_control *c;
  799. struct jffs_file *dir_f; /* The file-to-remove's parent.  */
  800. struct jffs_file *del_f; /* The file to remove.  */
  801. struct jffs_node *del_node;
  802. struct inode *inode = 0;
  803. int result = 0;
  804. D1({
  805. int len = dentry->d_name.len;
  806. const char *name = dentry->d_name.name;
  807. char *_name = (char *) kmalloc(len + 1, GFP_KERNEL);
  808. memcpy(_name, name, len);
  809. _name[len] = '';
  810. printk("***jffs_remove(): file = "%s", ino = %ldn", _name, dentry->d_inode->i_ino);
  811. kfree(_name);
  812. });
  813. dir_f = (struct jffs_file *) dir->u.generic_ip;
  814. c = dir_f->c;
  815. result = -ENOENT;
  816. if (!(del_f = jffs_find_child(dir_f, dentry->d_name.name,
  817.       dentry->d_name.len))) {
  818. D(printk("jffs_remove(): jffs_find_child() failed.n"));
  819. goto jffs_remove_end;
  820. }
  821. if (S_ISDIR(type)) {
  822. struct jffs_file *child = del_f->children;
  823. while(child) {
  824. if( !child->deleted ) {
  825. result = -ENOTEMPTY;
  826. goto jffs_remove_end;
  827. }
  828. child = child->sibling_next;
  829. }
  830. }            
  831. else if (S_ISDIR(del_f->mode)) {
  832. D(printk("jffs_remove(): node is a directory "
  833.  "but it shouldn't be.n"));
  834. result = -EPERM;
  835. goto jffs_remove_end;
  836. }
  837. inode = dentry->d_inode;
  838. result = -EIO;
  839. if (del_f->ino != inode->i_ino)
  840. goto jffs_remove_end;
  841. if (!inode->i_nlink) {
  842. printk("Deleting nonexistent file inode: %lu, nlink: %dn",
  843.        inode->i_ino, inode->i_nlink);
  844. inode->i_nlink=1;
  845. }
  846. /* Create a node for the deletion.  */
  847. result = -ENOMEM;
  848. if (!(del_node = jffs_alloc_node())) {
  849. D(printk("jffs_remove(): Allocation failed!n"));
  850. goto jffs_remove_end;
  851. }
  852. del_node->data_offset = 0;
  853. del_node->removed_size = 0;
  854. /* Initialize the raw inode.  */
  855. raw_inode.magic = JFFS_MAGIC_BITMASK;
  856. raw_inode.ino = del_f->ino;
  857. raw_inode.pino = del_f->pino;
  858. /*   raw_inode.version = del_f->highest_version + 1; */
  859. raw_inode.mode = del_f->mode;
  860. raw_inode.uid = current->fsuid;
  861. raw_inode.gid = current->fsgid;
  862. raw_inode.atime = CURRENT_TIME;
  863. raw_inode.mtime = del_f->mtime;
  864. raw_inode.ctime = raw_inode.atime;
  865. raw_inode.offset = 0;
  866. raw_inode.dsize = 0;
  867. raw_inode.rsize = 0;
  868. raw_inode.nsize = 0;
  869. raw_inode.nlink = del_f->nlink;
  870. raw_inode.spare = 0;
  871. raw_inode.rename = 0;
  872. raw_inode.deleted = 1;
  873. /* Write the new node to the flash memory.  */
  874. if (jffs_write_node(c, del_node, &raw_inode, 0, 0, 1, del_f) < 0) {
  875. jffs_free_node(del_node);
  876. result = -EIO;
  877. goto jffs_remove_end;
  878. }
  879. /* Update the file.  This operation will make the file disappear
  880.    from the in-memory file system structures.  */
  881. jffs_insert_node(c, del_f, &raw_inode, 0, del_node);
  882. dir->i_version = ++event;
  883. dir->i_ctime = dir->i_mtime = CURRENT_TIME;
  884. mark_inode_dirty(dir);
  885. inode->i_nlink--;
  886. inode->i_ctime = dir->i_ctime;
  887. mark_inode_dirty(inode);
  888. d_delete(dentry); /* This also frees the inode */
  889. result = 0;
  890. jffs_remove_end:
  891. return result;
  892. } /* jffs_remove()  */
  893. static int
  894. jffs_mknod(struct inode *dir, struct dentry *dentry, int mode, int rdev)
  895. {
  896. struct jffs_raw_inode raw_inode;
  897. struct jffs_file *dir_f;
  898. struct jffs_node *node = 0;
  899. struct jffs_control *c;
  900. struct inode *inode;
  901. int result = 0;
  902. kdev_t dev = to_kdev_t(rdev);
  903. int err;
  904. D1(printk("***jffs_mknod()n"));
  905. dir_f = (struct jffs_file *)dir->u.generic_ip;
  906. c = dir_f->c;
  907. D3(printk (KERN_NOTICE "mknod(): down biglockn"));
  908. down(&c->fmc->biglock);
  909. /* Create and initialize a new node.  */
  910. if (!(node = jffs_alloc_node())) {
  911. D(printk("jffs_mknod(): Allocation failed!n"));
  912. result = -ENOMEM;
  913. goto jffs_mknod_err;
  914. }
  915. node->data_offset = 0;
  916. node->removed_size = 0;
  917. /* Initialize the raw inode.  */
  918. raw_inode.magic = JFFS_MAGIC_BITMASK;
  919. raw_inode.ino = c->next_ino++;
  920. raw_inode.pino = dir_f->ino;
  921. raw_inode.version = 1;
  922. raw_inode.mode = mode;
  923. raw_inode.uid = current->fsuid;
  924. raw_inode.gid = (dir->i_mode & S_ISGID) ? dir->i_gid : current->fsgid;
  925. /* raw_inode.gid = current->fsgid; */
  926. raw_inode.atime = CURRENT_TIME;
  927. raw_inode.mtime = raw_inode.atime;
  928. raw_inode.ctime = raw_inode.atime;
  929. raw_inode.offset = 0;
  930. raw_inode.dsize = sizeof(kdev_t);
  931. raw_inode.rsize = 0;
  932. raw_inode.nsize = dentry->d_name.len;
  933. raw_inode.nlink = 1;
  934. raw_inode.spare = 0;
  935. raw_inode.rename = 0;
  936. raw_inode.deleted = 0;
  937. /* Write the new node to the flash.  */
  938. if ((err = jffs_write_node(c, node, &raw_inode, dentry->d_name.name,
  939.    (unsigned char *)&dev, 0, NULL)) < 0) {
  940. D(printk("jffs_mknod(): jffs_write_node() failed.n"));
  941. result = err;
  942. goto jffs_mknod_err;
  943. }
  944. /* Insert the new node into the file system.  */
  945. if ((err = jffs_insert_node(c, 0, &raw_inode, dentry->d_name.name,
  946.     node)) < 0) {
  947. result = err;
  948. goto jffs_mknod_end;
  949. }
  950. inode = jffs_new_inode(dir, &raw_inode, &err);
  951. if (inode == NULL) {
  952. result = err;
  953. goto jffs_mknod_end;
  954. }
  955. init_special_inode(inode, mode, rdev);
  956. d_instantiate(dentry, inode);
  957. goto jffs_mknod_end;
  958. jffs_mknod_err:
  959. if (node) {
  960. jffs_free_node(node);
  961. }
  962. jffs_mknod_end:
  963. D3(printk (KERN_NOTICE "mknod(): up biglockn"));
  964. up(&c->fmc->biglock);
  965. return result;
  966. } /* jffs_mknod()  */
  967. static int
  968. jffs_symlink(struct inode *dir, struct dentry *dentry, const char *symname)
  969. {
  970. struct jffs_raw_inode raw_inode;
  971. struct jffs_control *c;
  972. struct jffs_file *dir_f;
  973. struct jffs_node *node;
  974. struct inode *inode;
  975. int symname_len = strlen(symname);
  976. int err;
  977. D1({
  978. int len = dentry->d_name.len; 
  979. char *_name = (char *)kmalloc(len + 1, GFP_KERNEL);
  980. char *_symname = (char *)kmalloc(symname_len + 1, GFP_KERNEL);
  981. memcpy(_name, dentry->d_name.name, len);
  982. _name[len] = '';
  983. memcpy(_symname, symname, symname_len);
  984. _symname[symname_len] = '';
  985. printk("***jffs_symlink(): dir = 0x%p, "
  986.        "dentry->dname.name = "%s", "
  987.        "symname = "%s"n", dir, _name, _symname);
  988. kfree(_name);
  989. kfree(_symname);
  990. });
  991. dir_f = (struct jffs_file *)dir->u.generic_ip;
  992. ASSERT(if (!dir_f) {
  993. printk(KERN_ERR "jffs_symlink(): No reference to a "
  994.        "jffs_file struct in inode.n");
  995. return -EIO;
  996. });
  997. c = dir_f->c;
  998. /* Create a node and initialize it as much as needed.  */
  999. if (!(node = jffs_alloc_node())) {
  1000. D(printk("jffs_symlink(): Allocation failed: node = NULLn"));
  1001. return -ENOMEM;
  1002. }
  1003. D3(printk (KERN_NOTICE "symlink(): down biglockn"));
  1004. down(&c->fmc->biglock);
  1005. node->data_offset = 0;
  1006. node->removed_size = 0;
  1007. /* Initialize the raw inode.  */
  1008. raw_inode.magic = JFFS_MAGIC_BITMASK;
  1009. raw_inode.ino = c->next_ino++;
  1010. raw_inode.pino = dir_f->ino;
  1011. raw_inode.version = 1;
  1012. raw_inode.mode = S_IFLNK | S_IRWXUGO;
  1013. raw_inode.uid = current->fsuid;
  1014. raw_inode.gid = (dir->i_mode & S_ISGID) ? dir->i_gid : current->fsgid;
  1015. raw_inode.atime = CURRENT_TIME;
  1016. raw_inode.mtime = raw_inode.atime;
  1017. raw_inode.ctime = raw_inode.atime;
  1018. raw_inode.offset = 0;
  1019. raw_inode.dsize = symname_len;
  1020. raw_inode.rsize = 0;
  1021. raw_inode.nsize = dentry->d_name.len;
  1022. raw_inode.nlink = 1;
  1023. raw_inode.spare = 0;
  1024. raw_inode.rename = 0;
  1025. raw_inode.deleted = 0;
  1026. /* Write the new node to the flash.  */
  1027. if ((err = jffs_write_node(c, node, &raw_inode, dentry->d_name.name,
  1028.    (const unsigned char *)symname, 0, NULL)) < 0) {
  1029. D(printk("jffs_symlink(): jffs_write_node() failed.n"));
  1030. jffs_free_node(node);
  1031. goto jffs_symlink_end;
  1032. }
  1033. /* Insert the new node into the file system.  */
  1034. if ((err = jffs_insert_node(c, 0, &raw_inode, dentry->d_name.name,
  1035.     node)) < 0) {
  1036. goto jffs_symlink_end;
  1037. }
  1038. inode = jffs_new_inode(dir, &raw_inode, &err);
  1039. if (inode == NULL) {
  1040. goto jffs_symlink_end;
  1041. }
  1042. err = 0;
  1043. inode->i_op = &page_symlink_inode_operations;
  1044. inode->i_mapping->a_ops = &jffs_address_operations;
  1045. d_instantiate(dentry, inode);
  1046.  jffs_symlink_end:
  1047. D3(printk (KERN_NOTICE "symlink(): up biglockn"));
  1048. up(&c->fmc->biglock);
  1049. return err;
  1050. } /* jffs_symlink()  */
  1051. /* Create an inode inside a JFFS directory (dir) and return it.
  1052.  *
  1053.  * By the time this is called, we already have created
  1054.  * the directory cache entry for the new file, but it
  1055.  * is so far negative - it has no inode.
  1056.  *
  1057.  * If the create succeeds, we fill in the inode information
  1058.  * with d_instantiate().
  1059.  */
  1060. static int
  1061. jffs_create(struct inode *dir, struct dentry *dentry, int mode)
  1062. {
  1063. struct jffs_raw_inode raw_inode;
  1064. struct jffs_control *c;
  1065. struct jffs_node *node;
  1066. struct jffs_file *dir_f; /* JFFS representation of the directory.  */
  1067. struct inode *inode;
  1068. int err;
  1069. D1({
  1070. int len = dentry->d_name.len;
  1071. char *s = (char *)kmalloc(len + 1, GFP_KERNEL);
  1072. memcpy(s, dentry->d_name.name, len);
  1073. s[len] = '';
  1074. printk("jffs_create(): dir: 0x%p, name: "%s"n", dir, s);
  1075. kfree(s);
  1076. });
  1077. dir_f = (struct jffs_file *)dir->u.generic_ip;
  1078. ASSERT(if (!dir_f) {
  1079. printk(KERN_ERR "jffs_create(): No reference to a "
  1080.        "jffs_file struct in inode.n");
  1081. return -EIO;
  1082. });
  1083. c = dir_f->c;
  1084. /* Create a node and initialize as much as needed.  */
  1085. if (!(node = jffs_alloc_node())) {
  1086. D(printk("jffs_create(): Allocation failed: node == 0n"));
  1087. return -ENOMEM;
  1088. }
  1089. D3(printk (KERN_NOTICE "create(): down biglockn"));
  1090. down(&c->fmc->biglock);
  1091. node->data_offset = 0;
  1092. node->removed_size = 0;
  1093. /* Initialize the raw inode.  */
  1094. raw_inode.magic = JFFS_MAGIC_BITMASK;
  1095. raw_inode.ino = c->next_ino++;
  1096. raw_inode.pino = dir_f->ino;
  1097. raw_inode.version = 1;
  1098. raw_inode.mode = mode;
  1099. raw_inode.uid = current->fsuid;
  1100. raw_inode.gid = (dir->i_mode & S_ISGID) ? dir->i_gid : current->fsgid;
  1101. raw_inode.atime = CURRENT_TIME;
  1102. raw_inode.mtime = raw_inode.atime;
  1103. raw_inode.ctime = raw_inode.atime;
  1104. raw_inode.offset = 0;
  1105. raw_inode.dsize = 0;
  1106. raw_inode.rsize = 0;
  1107. raw_inode.nsize = dentry->d_name.len;
  1108. raw_inode.nlink = 1;
  1109. raw_inode.spare = 0;
  1110. raw_inode.rename = 0;
  1111. raw_inode.deleted = 0;
  1112. /* Write the new node to the flash.  */
  1113. if ((err = jffs_write_node(c, node, &raw_inode,
  1114.    dentry->d_name.name, 0, 0, NULL)) < 0) {
  1115. D(printk("jffs_create(): jffs_write_node() failed.n"));
  1116. jffs_free_node(node);
  1117. goto jffs_create_end;
  1118. }
  1119. /* Insert the new node into the file system.  */
  1120. if ((err = jffs_insert_node(c, 0, &raw_inode, dentry->d_name.name,
  1121.     node)) < 0) {
  1122. goto jffs_create_end;
  1123. }
  1124. /* Initialize an inode.  */
  1125. inode = jffs_new_inode(dir, &raw_inode, &err);
  1126. if (inode == NULL) {
  1127. goto jffs_create_end;
  1128. }
  1129. err = 0;
  1130. inode->i_op = &jffs_file_inode_operations;
  1131. inode->i_fop = &jffs_file_operations;
  1132. inode->i_mapping->a_ops = &jffs_address_operations;
  1133. inode->i_mapping->nrpages = 0;
  1134. d_instantiate(dentry, inode);
  1135.  jffs_create_end:
  1136. D3(printk (KERN_NOTICE "create(): up biglockn"));
  1137. up(&c->fmc->biglock);
  1138. return err;
  1139. } /* jffs_create()  */
  1140. /* Write, append or rewrite data to an existing file.  */
  1141. static ssize_t
  1142. jffs_file_write(struct file *filp, const char *buf, size_t count,
  1143. loff_t *ppos)
  1144. {
  1145. struct jffs_raw_inode raw_inode;
  1146. struct jffs_control *c;
  1147. struct jffs_file *f;
  1148. struct jffs_node *node;
  1149. struct dentry *dentry = filp->f_dentry;
  1150. struct inode *inode = dentry->d_inode;
  1151. int recoverable = 0;
  1152. size_t written = 0;
  1153. __u32 thiscount = count;
  1154. loff_t pos = *ppos;
  1155. int err;
  1156. inode = filp->f_dentry->d_inode;
  1157. D2(printk("***jffs_file_write(): inode: 0x%p (ino: %lu), "
  1158.   "filp: 0x%p, buf: 0x%p, count: %dn",
  1159.   inode, inode->i_ino, filp, buf, count));
  1160. #if 0
  1161. if (inode->i_sb->s_flags & MS_RDONLY) {
  1162. D(printk("jffs_file_write(): MS_RDONLYn"));
  1163. err = -EROFS;
  1164. goto out_isem;
  1165. }
  1166. #endif
  1167. err = -EINVAL;
  1168. if (!S_ISREG(inode->i_mode)) {
  1169. D(printk("jffs_file_write(): inode->i_mode == 0x%08xn",
  1170. inode->i_mode));
  1171. goto out_isem;
  1172. }
  1173. if (!(f = (struct jffs_file *)inode->u.generic_ip)) {
  1174. D(printk("jffs_file_write(): inode->u.generic_ip = 0x%pn",
  1175. inode->u.generic_ip));
  1176. goto out_isem;
  1177. }
  1178. c = f->c;
  1179. /*
  1180.  * This will never trigger with sane page sizes.  leave it in
  1181.  * anyway, since I'm thinking about how to merge larger writes
  1182.  * (the current idea is to poke a thread that does the actual
  1183.  * I/O and starts by doing a down(&inode->i_sem).  then we
  1184.  * would need to get the page cache pages and have a list of
  1185.  * I/O requests and do write-merging here.
  1186.  * -- prumpf
  1187.  */
  1188. thiscount = min(c->fmc->max_chunk_size - sizeof(struct jffs_raw_inode), count);
  1189. D3(printk (KERN_NOTICE "file_write(): down biglockn"));
  1190. down(&c->fmc->biglock);
  1191. /* Urgh. POSIX says we can do short writes if we feel like it. 
  1192.  * In practice, we can't. Nothing will cope. So we loop until
  1193.  * we're done.
  1194.  *
  1195.  * <_Anarchy_> posix and reality are not interconnected on this issue
  1196.  */
  1197. while (count) {
  1198. /* Things are going to be written so we could allocate and
  1199.    initialize the necessary data structures now.  */
  1200. if (!(node = jffs_alloc_node())) {
  1201. D(printk("jffs_file_write(): node == 0n"));
  1202. err = -ENOMEM;
  1203. goto out;
  1204. }
  1205. node->data_offset = pos;
  1206. node->removed_size = 0;
  1207. /* Initialize the raw inode.  */
  1208. raw_inode.magic = JFFS_MAGIC_BITMASK;
  1209. raw_inode.ino = f->ino;
  1210. raw_inode.pino = f->pino;
  1211. raw_inode.mode = f->mode;
  1212. raw_inode.uid = f->uid;
  1213. raw_inode.gid = f->gid;
  1214. raw_inode.atime = CURRENT_TIME;
  1215. raw_inode.mtime = raw_inode.atime;
  1216. raw_inode.ctime = f->ctime;
  1217. raw_inode.offset = pos;
  1218. raw_inode.dsize = thiscount;
  1219. raw_inode.rsize = 0;
  1220. raw_inode.nsize = f->nsize;
  1221. raw_inode.nlink = f->nlink;
  1222. raw_inode.spare = 0;
  1223. raw_inode.rename = 0;
  1224. raw_inode.deleted = 0;
  1225. if (pos < f->size) {
  1226. node->removed_size = raw_inode.rsize = min(thiscount, (__u32)(f->size - pos));
  1227. /* If this node is going entirely over the top of old data,
  1228.    we can allow it to go into the reserved space, because
  1229.    we know that GC can reclaim the space later.
  1230. */
  1231. if (pos + thiscount < f->size) {
  1232. /* If all the data we're overwriting are _real_,
  1233.    not just holes, then:
  1234.    recoverable = 1;
  1235. */
  1236. }
  1237. }
  1238. /* Write the new node to the flash.  */
  1239. /* NOTE: We would be quite happy if jffs_write_node() wrote a
  1240.    smaller node than we were expecting. There's no need for it
  1241.    to waste the space at the end of the flash just because it's
  1242.    a little smaller than what we asked for. But that's a whole
  1243.    new can of worms which I'm not going to open this week. 
  1244.    -- dwmw2.
  1245. */
  1246. if ((err = jffs_write_node(c, node, &raw_inode, f->name,
  1247.    (const unsigned char *)buf,
  1248.    recoverable, f)) < 0) {
  1249. D(printk("jffs_file_write(): jffs_write_node() failed.n"));
  1250. jffs_free_node(node);
  1251. goto out;
  1252. }
  1253. written += err;
  1254. buf += err;
  1255. count -= err;
  1256. pos += err;
  1257. /* Insert the new node into the file system.  */
  1258. if ((err = jffs_insert_node(c, f, &raw_inode, 0, node)) < 0) {
  1259. goto out;
  1260. }
  1261. D3(printk("jffs_file_write(): new f_pos %ld.n", (long)pos));
  1262. thiscount = min(c->fmc->max_chunk_size - sizeof(struct jffs_raw_inode), count);
  1263. }
  1264.  out:
  1265. D3(printk (KERN_NOTICE "file_write(): up biglockn"));
  1266. up(&c->fmc->biglock);
  1267. /* Fix things in the real inode.  */
  1268. if (pos > inode->i_size) {
  1269. inode->i_size = pos;
  1270. inode->i_blocks = (inode->i_size + 511) >> 9;
  1271. }
  1272. inode->i_ctime = inode->i_mtime = CURRENT_TIME;
  1273. mark_inode_dirty(inode);
  1274. invalidate_inode_pages(inode);
  1275.  out_isem:
  1276. return err;
  1277. } /* jffs_file_write()  */
  1278. static ssize_t
  1279. jffs_prepare_write(struct file *filp, struct page *page,
  1280.                   unsigned from, unsigned to)
  1281. {
  1282. /* FIXME: we should detect some error conditions here */
  1283. /* Bugger that. We should make sure the page is uptodate */
  1284. if (!Page_Uptodate(page) && (from || to < PAGE_CACHE_SIZE))
  1285. return jffs_do_readpage_nolock(filp, page);
  1286. return 0;
  1287. } /* jffs_prepare_write() */
  1288. static ssize_t
  1289. jffs_commit_write(struct file *filp, struct page *page,
  1290.                  unsigned from, unsigned to)
  1291. {
  1292.        void *addr = page_address(page) + from;
  1293.        /* XXX: PAGE_CACHE_SHIFT or PAGE_SHIFT */
  1294.        loff_t pos = (page->index<<PAGE_CACHE_SHIFT) + from;
  1295.        return jffs_file_write(filp, addr, to-from, &pos);
  1296. } /* jffs_commit_write() */
  1297. /* This is our ioctl() routine.  */
  1298. static int
  1299. jffs_ioctl(struct inode *inode, struct file *filp, unsigned int cmd,
  1300.    unsigned long arg)
  1301. {
  1302. struct jffs_control *c;
  1303. int ret = 0;
  1304. D2(printk("***jffs_ioctl(): cmd = 0x%08x, arg = 0x%08lxn",
  1305.   cmd, arg));
  1306. if (!(c = (struct jffs_control *)inode->i_sb->u.generic_sbp)) {
  1307. printk(KERN_ERR "JFFS: Bad inode in ioctl() call. "
  1308.        "(cmd = 0x%08x)n", cmd);
  1309. return -EIO;
  1310. }
  1311. D3(printk (KERN_NOTICE "ioctl(): down biglockn"));
  1312. down(&c->fmc->biglock);
  1313. switch (cmd) {
  1314. case JFFS_PRINT_HASH:
  1315. jffs_print_hash_table(c);
  1316. break;
  1317. case JFFS_PRINT_TREE:
  1318. jffs_print_tree(c->root, 0);
  1319. break;
  1320. case JFFS_GET_STATUS:
  1321. {
  1322. struct jffs_flash_status fst;
  1323. struct jffs_fmcontrol *fmc = c->fmc;
  1324. printk("Flash status -- ");
  1325. if (!access_ok(VERIFY_WRITE,
  1326.        (struct jffs_flash_status *)arg,
  1327.        sizeof(struct jffs_flash_status))) {
  1328. D(printk("jffs_ioctl(): Bad arg in "
  1329.  "JFFS_GET_STATUS ioctl!n"));
  1330. ret = -EFAULT;
  1331. break;
  1332. }
  1333. fst.size = fmc->flash_size;
  1334. fst.used = fmc->used_size;
  1335. fst.dirty = fmc->dirty_size;
  1336. fst.begin = fmc->head->offset;
  1337. fst.end = fmc->tail->offset + fmc->tail->size;
  1338. printk("size: %d, used: %d, dirty: %d, "
  1339.        "begin: %d, end: %dn",
  1340.        fst.size, fst.used, fst.dirty,
  1341.        fst.begin, fst.end);
  1342. if (copy_to_user((struct jffs_flash_status *)arg,
  1343.  &fst,
  1344.  sizeof(struct jffs_flash_status))) {
  1345. ret = -EFAULT;
  1346. }
  1347. }
  1348. break;
  1349. default:
  1350. ret = -ENOTTY;
  1351. }
  1352. D3(printk (KERN_NOTICE "ioctl(): up biglockn"));
  1353. up(&c->fmc->biglock);
  1354. return ret;
  1355. } /* jffs_ioctl()  */
  1356. static struct address_space_operations jffs_address_operations = {
  1357. readpage: jffs_readpage,
  1358. prepare_write: jffs_prepare_write,
  1359. commit_write: jffs_commit_write,
  1360. };
  1361. static int jffs_fsync(struct file *f, struct dentry *d, int datasync)
  1362. {
  1363. /* We currently have O_SYNC operations at all times.
  1364.    Do nothing.
  1365. */
  1366. return 0;
  1367. }
  1368. extern int generic_file_open(struct inode *, struct file *) __attribute__((weak));
  1369. extern loff_t generic_file_llseek(struct file *, loff_t, int) __attribute__((weak));
  1370. static struct file_operations jffs_file_operations =
  1371. {
  1372. open: generic_file_open,
  1373. llseek: generic_file_llseek,
  1374. read: generic_file_read,
  1375. write: generic_file_write,
  1376. ioctl: jffs_ioctl,
  1377. mmap: generic_file_mmap,
  1378. fsync: jffs_fsync,
  1379. };
  1380. static struct inode_operations jffs_file_inode_operations =
  1381. {
  1382. lookup:  jffs_lookup,          /* lookup */
  1383. setattr: jffs_setattr,
  1384. };
  1385. static struct file_operations jffs_dir_operations =
  1386. {
  1387. readdir: jffs_readdir,
  1388. };
  1389. static struct inode_operations jffs_dir_inode_operations =
  1390. {
  1391. create:   jffs_create,
  1392. lookup:   jffs_lookup,
  1393. unlink:   jffs_unlink,
  1394. symlink:  jffs_symlink,
  1395. mkdir:    jffs_mkdir,
  1396. rmdir:    jffs_rmdir,
  1397. mknod:    jffs_mknod,
  1398. rename:   jffs_rename,
  1399. setattr:  jffs_setattr,
  1400. };
  1401. /* Initialize an inode for the VFS.  */
  1402. static void
  1403. jffs_read_inode(struct inode *inode)
  1404. {
  1405. struct jffs_file *f;
  1406. struct jffs_control *c;
  1407. D3(printk("jffs_read_inode(): inode->i_ino == %lun", inode->i_ino));
  1408. if (!inode->i_sb) {
  1409. D(printk("jffs_read_inode(): !inode->i_sb ==> "
  1410.  "No super block!n"));
  1411. return;
  1412. }
  1413. c = (struct jffs_control *)inode->i_sb->u.generic_sbp;
  1414. D3(printk (KERN_NOTICE "read_inode(): down biglockn"));
  1415. down(&c->fmc->biglock);
  1416. if (!(f = jffs_find_file(c, inode->i_ino))) {
  1417. D(printk("jffs_read_inode(): No such inode (%lu).n",
  1418.  inode->i_ino));
  1419. D3(printk (KERN_NOTICE "read_inode(): up biglockn"));
  1420. up(&c->fmc->biglock);
  1421. return;
  1422. }
  1423. inode->u.generic_ip = (void *)f;
  1424. inode->i_mode = f->mode;
  1425. inode->i_nlink = f->nlink;
  1426. inode->i_uid = f->uid;
  1427. inode->i_gid = f->gid;
  1428. inode->i_size = f->size;
  1429. inode->i_atime = f->atime;
  1430. inode->i_mtime = f->mtime;
  1431. inode->i_ctime = f->ctime;
  1432. inode->i_blksize = PAGE_SIZE;
  1433. inode->i_blocks = (inode->i_size + 511) >> 9;
  1434. if (S_ISREG(inode->i_mode)) {
  1435. inode->i_op = &jffs_file_inode_operations;
  1436. inode->i_fop = &jffs_file_operations;
  1437. inode->i_mapping->a_ops = &jffs_address_operations;
  1438. }
  1439. else if (S_ISDIR(inode->i_mode)) {
  1440. inode->i_op = &jffs_dir_inode_operations;
  1441. inode->i_fop = &jffs_dir_operations;
  1442. }
  1443. else if (S_ISLNK(inode->i_mode)) {
  1444. inode->i_op = &page_symlink_inode_operations;
  1445. inode->i_mapping->a_ops = &jffs_address_operations;
  1446. }
  1447. else {
  1448. /* If the node is a device of some sort, then the number of
  1449.    the device should be read from the flash memory and then
  1450.    added to the inode's i_rdev member.  */
  1451. kdev_t rdev;
  1452. jffs_read_data(f, (char *)&rdev, 0, sizeof(kdev_t));
  1453. init_special_inode(inode, inode->i_mode, kdev_t_to_nr(rdev));
  1454. }
  1455. D3(printk (KERN_NOTICE "read_inode(): up biglockn"));
  1456. up(&c->fmc->biglock);
  1457. }
  1458. void
  1459. jffs_delete_inode(struct inode *inode)
  1460. {
  1461. struct jffs_file *f;
  1462. struct jffs_control *c;
  1463. D3(printk("jffs_delete_inode(): inode->i_ino == %lun",
  1464.   inode->i_ino));
  1465. lock_kernel();
  1466. inode->i_size = 0;
  1467. inode->i_blocks = 0;
  1468. inode->u.generic_ip = 0;
  1469. clear_inode(inode);
  1470. if (inode->i_nlink == 0) {
  1471. c = (struct jffs_control *) inode->i_sb->u.generic_sbp;
  1472. f = (struct jffs_file *) jffs_find_file (c, inode->i_ino);
  1473. jffs_possibly_delete_file(f);
  1474. }
  1475. unlock_kernel();
  1476. }
  1477. void
  1478. jffs_write_super(struct super_block *sb)
  1479. {
  1480. struct jffs_control *c = (struct jffs_control *)sb->u.generic_sbp;
  1481. jffs_garbage_collect_trigger(c);
  1482. }
  1483. static struct super_operations jffs_ops =
  1484. {
  1485. read_inode:   jffs_read_inode,
  1486. delete_inode: jffs_delete_inode,
  1487. put_super:    jffs_put_super,
  1488. write_super:  jffs_write_super,
  1489. statfs:       jffs_statfs,
  1490. };
  1491. static DECLARE_FSTYPE_DEV(jffs_fs_type, "jffs", jffs_read_super);
  1492. static int __init
  1493. init_jffs_fs(void)
  1494. {
  1495. printk(KERN_INFO "JFFS version " JFFS_VERSION_STRING
  1496. ", (C) 1999, 2000  Axis Communications ABn");
  1497. #ifdef CONFIG_JFFS_PROC_FS
  1498. jffs_proc_root = proc_mkdir("jffs", proc_root_fs);
  1499. #endif
  1500. fm_cache = kmem_cache_create("jffs_fm", sizeof(struct jffs_fm),
  1501.      0, SLAB_HWCACHE_ALIGN, NULL, NULL);
  1502. node_cache = kmem_cache_create("jffs_node",sizeof(struct jffs_node),
  1503.        0, SLAB_HWCACHE_ALIGN, NULL, NULL);
  1504. return register_filesystem(&jffs_fs_type);
  1505. }
  1506. static void __exit
  1507. exit_jffs_fs(void)
  1508. {
  1509. unregister_filesystem(&jffs_fs_type);
  1510. kmem_cache_destroy(fm_cache);
  1511. kmem_cache_destroy(node_cache);
  1512. }
  1513. EXPORT_NO_SYMBOLS;
  1514. module_init(init_jffs_fs)
  1515. module_exit(exit_jffs_fs)
  1516. MODULE_DESCRIPTION("The Journalling Flash File System");
  1517. MODULE_AUTHOR("Axis Communications AB.");
  1518. MODULE_LICENSE("GPL");