Commit adadfe48 authored by Linus Torvalds's avatar Linus Torvalds

Merge branch 'for-linus' of git://git.infradead.org/ubifs-2.6

* 'for-linus' of git://git.infradead.org/ubifs-2.6:
  UBIFS: seek journal heads to the latest bud in replay
  UBIFS: do not free write-buffers when in R/O mode
parents 625a3b60 52c6e6f9
...@@ -174,26 +174,6 @@ void ubifs_add_bud(struct ubifs_info *c, struct ubifs_bud *bud) ...@@ -174,26 +174,6 @@ void ubifs_add_bud(struct ubifs_info *c, struct ubifs_bud *bud)
spin_unlock(&c->buds_lock); spin_unlock(&c->buds_lock);
} }
/**
* ubifs_create_buds_lists - create journal head buds lists for remount rw.
* @c: UBIFS file-system description object
*/
void ubifs_create_buds_lists(struct ubifs_info *c)
{
struct rb_node *p;
spin_lock(&c->buds_lock);
p = rb_first(&c->buds);
while (p) {
struct ubifs_bud *bud = rb_entry(p, struct ubifs_bud, rb);
struct ubifs_jhead *jhead = &c->jheads[bud->jhead];
list_add_tail(&bud->list, &jhead->buds_list);
p = rb_next(p);
}
spin_unlock(&c->buds_lock);
}
/** /**
* ubifs_add_bud_to_log - add a new bud to the log. * ubifs_add_bud_to_log - add a new bud to the log.
* @c: UBIFS file-system description object * @c: UBIFS file-system description object
......
...@@ -59,6 +59,7 @@ enum { ...@@ -59,6 +59,7 @@ enum {
* @new_size: truncation new size * @new_size: truncation new size
* @free: amount of free space in a bud * @free: amount of free space in a bud
* @dirty: amount of dirty space in a bud from padding and deletion nodes * @dirty: amount of dirty space in a bud from padding and deletion nodes
* @jhead: journal head number of the bud
* *
* UBIFS journal replay must compare node sequence numbers, which means it must * UBIFS journal replay must compare node sequence numbers, which means it must
* build a tree of node information to insert into the TNC. * build a tree of node information to insert into the TNC.
...@@ -80,6 +81,7 @@ struct replay_entry { ...@@ -80,6 +81,7 @@ struct replay_entry {
struct { struct {
int free; int free;
int dirty; int dirty;
int jhead;
}; };
}; };
}; };
...@@ -159,6 +161,11 @@ static int set_bud_lprops(struct ubifs_info *c, struct replay_entry *r) ...@@ -159,6 +161,11 @@ static int set_bud_lprops(struct ubifs_info *c, struct replay_entry *r)
err = PTR_ERR(lp); err = PTR_ERR(lp);
goto out; goto out;
} }
/* Make sure the journal head points to the latest bud */
err = ubifs_wbuf_seek_nolock(&c->jheads[r->jhead].wbuf, r->lnum,
c->leb_size - r->free, UBI_SHORTTERM);
out: out:
ubifs_release_lprops(c); ubifs_release_lprops(c);
return err; return err;
...@@ -627,10 +634,6 @@ static int replay_bud(struct ubifs_info *c, int lnum, int offs, int jhead, ...@@ -627,10 +634,6 @@ static int replay_bud(struct ubifs_info *c, int lnum, int offs, int jhead,
ubifs_assert(sleb->endpt - offs >= used); ubifs_assert(sleb->endpt - offs >= used);
ubifs_assert(sleb->endpt % c->min_io_size == 0); ubifs_assert(sleb->endpt % c->min_io_size == 0);
if (sleb->endpt + c->min_io_size <= c->leb_size && !c->ro_mount)
err = ubifs_wbuf_seek_nolock(&c->jheads[jhead].wbuf, lnum,
sleb->endpt, UBI_SHORTTERM);
*dirty = sleb->endpt - offs - used; *dirty = sleb->endpt - offs - used;
*free = c->leb_size - sleb->endpt; *free = c->leb_size - sleb->endpt;
...@@ -653,12 +656,14 @@ static int replay_bud(struct ubifs_info *c, int lnum, int offs, int jhead, ...@@ -653,12 +656,14 @@ static int replay_bud(struct ubifs_info *c, int lnum, int offs, int jhead,
* @sqnum: sequence number * @sqnum: sequence number
* @free: amount of free space in bud * @free: amount of free space in bud
* @dirty: amount of dirty space from padding and deletion nodes * @dirty: amount of dirty space from padding and deletion nodes
* @jhead: journal head number for the bud
* *
* This function inserts a reference node to the replay tree and returns zero * This function inserts a reference node to the replay tree and returns zero
* in case of success or a negative error code in case of failure. * in case of success or a negative error code in case of failure.
*/ */
static int insert_ref_node(struct ubifs_info *c, int lnum, int offs, static int insert_ref_node(struct ubifs_info *c, int lnum, int offs,
unsigned long long sqnum, int free, int dirty) unsigned long long sqnum, int free, int dirty,
int jhead)
{ {
struct rb_node **p = &c->replay_tree.rb_node, *parent = NULL; struct rb_node **p = &c->replay_tree.rb_node, *parent = NULL;
struct replay_entry *r; struct replay_entry *r;
...@@ -688,6 +693,7 @@ static int insert_ref_node(struct ubifs_info *c, int lnum, int offs, ...@@ -688,6 +693,7 @@ static int insert_ref_node(struct ubifs_info *c, int lnum, int offs,
r->flags = REPLAY_REF; r->flags = REPLAY_REF;
r->free = free; r->free = free;
r->dirty = dirty; r->dirty = dirty;
r->jhead = jhead;
rb_link_node(&r->rb, parent, p); rb_link_node(&r->rb, parent, p);
rb_insert_color(&r->rb, &c->replay_tree); rb_insert_color(&r->rb, &c->replay_tree);
...@@ -712,7 +718,7 @@ static int replay_buds(struct ubifs_info *c) ...@@ -712,7 +718,7 @@ static int replay_buds(struct ubifs_info *c)
if (err) if (err)
return err; return err;
err = insert_ref_node(c, b->bud->lnum, b->bud->start, b->sqnum, err = insert_ref_node(c, b->bud->lnum, b->bud->start, b->sqnum,
free, dirty); free, dirty, b->bud->jhead);
if (err) if (err)
return err; return err;
} }
......
...@@ -1257,12 +1257,12 @@ static int mount_ubifs(struct ubifs_info *c) ...@@ -1257,12 +1257,12 @@ static int mount_ubifs(struct ubifs_info *c)
goto out_free; goto out_free;
} }
sprintf(c->bgt_name, BGT_NAME_PATTERN, c->vi.ubi_num, c->vi.vol_id);
if (!c->ro_mount) {
err = alloc_wbufs(c); err = alloc_wbufs(c);
if (err) if (err)
goto out_cbuf; goto out_cbuf;
sprintf(c->bgt_name, BGT_NAME_PATTERN, c->vi.ubi_num, c->vi.vol_id);
if (!c->ro_mount) {
/* Create background thread */ /* Create background thread */
c->bgt = kthread_create(ubifs_bg_thread, c, "%s", c->bgt_name); c->bgt = kthread_create(ubifs_bg_thread, c, "%s", c->bgt_name);
if (IS_ERR(c->bgt)) { if (IS_ERR(c->bgt)) {
...@@ -1631,12 +1631,6 @@ static int ubifs_remount_rw(struct ubifs_info *c) ...@@ -1631,12 +1631,6 @@ static int ubifs_remount_rw(struct ubifs_info *c)
if (err) if (err)
goto out; goto out;
err = alloc_wbufs(c);
if (err)
goto out;
ubifs_create_buds_lists(c);
/* Create background thread */ /* Create background thread */
c->bgt = kthread_create(ubifs_bg_thread, c, "%s", c->bgt_name); c->bgt = kthread_create(ubifs_bg_thread, c, "%s", c->bgt_name);
if (IS_ERR(c->bgt)) { if (IS_ERR(c->bgt)) {
...@@ -1744,7 +1738,6 @@ static void ubifs_remount_ro(struct ubifs_info *c) ...@@ -1744,7 +1738,6 @@ static void ubifs_remount_ro(struct ubifs_info *c)
if (err) if (err)
ubifs_ro_mode(c, err); ubifs_ro_mode(c, err);
free_wbufs(c);
vfree(c->orph_buf); vfree(c->orph_buf);
c->orph_buf = NULL; c->orph_buf = NULL;
kfree(c->write_reserve_buf); kfree(c->write_reserve_buf);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment