diff options
| -rw-r--r-- | fs/jffs2/erase.c | 1 | ||||
| -rw-r--r-- | fs/jffs2/gc.c | 15 | ||||
| -rw-r--r-- | fs/jffs2/nodemgmt.c | 18 |
3 files changed, 30 insertions, 4 deletions
diff --git a/fs/jffs2/erase.c b/fs/jffs2/erase.c index b2d2b6a6e03e..563c857ca544 100644 --- a/fs/jffs2/erase.c +++ b/fs/jffs2/erase.c | |||
| @@ -172,6 +172,7 @@ static void jffs2_erase_succeeded(struct jffs2_sb_info *c, struct jffs2_eraseblo | |||
| 172 | mutex_unlock(&c->erase_free_sem); | 172 | mutex_unlock(&c->erase_free_sem); |
| 173 | /* Ensure that kupdated calls us again to mark them clean */ | 173 | /* Ensure that kupdated calls us again to mark them clean */ |
| 174 | jffs2_erase_pending_trigger(c); | 174 | jffs2_erase_pending_trigger(c); |
| 175 | wake_up(&c->erase_wait); | ||
| 175 | } | 176 | } |
| 176 | 177 | ||
| 177 | static void jffs2_erase_failed(struct jffs2_sb_info *c, struct jffs2_eraseblock *jeb, uint32_t bad_offset) | 178 | static void jffs2_erase_failed(struct jffs2_sb_info *c, struct jffs2_eraseblock *jeb, uint32_t bad_offset) |
diff --git a/fs/jffs2/gc.c b/fs/jffs2/gc.c index 3b6f2fa12cff..1ea4a843a430 100644 --- a/fs/jffs2/gc.c +++ b/fs/jffs2/gc.c | |||
| @@ -214,6 +214,19 @@ int jffs2_garbage_collect_pass(struct jffs2_sb_info *c) | |||
| 214 | return ret; | 214 | return ret; |
| 215 | } | 215 | } |
| 216 | 216 | ||
| 217 | /* If there are any blocks which need erasing, erase them now */ | ||
| 218 | if (!list_empty(&c->erase_complete_list) || | ||
| 219 | !list_empty(&c->erase_pending_list)) { | ||
| 220 | spin_unlock(&c->erase_completion_lock); | ||
| 221 | D1(printk(KERN_DEBUG "jffs2_garbage_collect_pass() erasing pending blocks\n")); | ||
| 222 | if (jffs2_erase_pending_blocks(c, 1)) { | ||
| 223 | mutex_unlock(&c->alloc_sem); | ||
| 224 | return 0; | ||
| 225 | } | ||
| 226 | D1(printk(KERN_DEBUG "No progress from erasing blocks; doing GC anyway\n")); | ||
| 227 | spin_lock(&c->erase_completion_lock); | ||
| 228 | } | ||
| 229 | |||
| 217 | /* First, work out which block we're garbage-collecting */ | 230 | /* First, work out which block we're garbage-collecting */ |
| 218 | jeb = c->gcblock; | 231 | jeb = c->gcblock; |
| 219 | 232 | ||
| @@ -222,7 +235,7 @@ int jffs2_garbage_collect_pass(struct jffs2_sb_info *c) | |||
| 222 | 235 | ||
| 223 | if (!jeb) { | 236 | if (!jeb) { |
| 224 | /* Couldn't find a free block. But maybe we can just erase one and make 'progress'? */ | 237 | /* Couldn't find a free block. But maybe we can just erase one and make 'progress'? */ |
| 225 | if (!list_empty(&c->erase_pending_list)) { | 238 | if (c->nr_erasing_blocks) { |
| 226 | spin_unlock(&c->erase_completion_lock); | 239 | spin_unlock(&c->erase_completion_lock); |
| 227 | mutex_unlock(&c->alloc_sem); | 240 | mutex_unlock(&c->alloc_sem); |
| 228 | return -EAGAIN; | 241 | return -EAGAIN; |
diff --git a/fs/jffs2/nodemgmt.c b/fs/jffs2/nodemgmt.c index 191359dde4e1..08e2c69fc147 100644 --- a/fs/jffs2/nodemgmt.c +++ b/fs/jffs2/nodemgmt.c | |||
| @@ -116,9 +116,21 @@ int jffs2_reserve_space(struct jffs2_sb_info *c, uint32_t minsize, | |||
| 116 | 116 | ||
| 117 | ret = jffs2_garbage_collect_pass(c); | 117 | ret = jffs2_garbage_collect_pass(c); |
| 118 | 118 | ||
| 119 | if (ret == -EAGAIN) | 119 | if (ret == -EAGAIN) { |
| 120 | jffs2_erase_pending_blocks(c, 1); | 120 | spin_lock(&c->erase_completion_lock); |
| 121 | else if (ret) | 121 | if (c->nr_erasing_blocks && |
| 122 | list_empty(&c->erase_pending_list) && | ||
| 123 | list_empty(&c->erase_complete_list)) { | ||
| 124 | DECLARE_WAITQUEUE(wait, current); | ||
| 125 | set_current_state(TASK_UNINTERRUPTIBLE); | ||
| 126 | add_wait_queue(&c->erase_wait, &wait); | ||
| 127 | D1(printk(KERN_DEBUG "%s waiting for erase to complete\n", __func__)); | ||
| 128 | spin_unlock(&c->erase_completion_lock); | ||
| 129 | |||
| 130 | schedule(); | ||
| 131 | } else | ||
| 132 | spin_unlock(&c->erase_completion_lock); | ||
| 133 | } else if (ret) | ||
| 122 | return ret; | 134 | return ret; |
| 123 | 135 | ||
| 124 | cond_resched(); | 136 | cond_resched(); |
