filesystem freeze: add error handling of write_super_lockfs/unlockfs
[linux-2.6-block.git] / fs / gfs2 / glops.c
CommitLineData
b3b94faa
DT
1/*
2 * Copyright (C) Sistina Software, Inc. 1997-2003 All rights reserved.
cf45b752 3 * Copyright (C) 2004-2008 Red Hat, Inc. All rights reserved.
b3b94faa
DT
4 *
5 * This copyrighted material is made available to anyone wishing to use,
6 * modify, copy, or redistribute it subject to the terms and conditions
e9fc2aa0 7 * of the GNU General Public License version 2.
b3b94faa
DT
8 */
9
b3b94faa
DT
10#include <linux/slab.h>
11#include <linux/spinlock.h>
12#include <linux/completion.h>
13#include <linux/buffer_head.h>
5c676f6d 14#include <linux/gfs2_ondisk.h>
7d308590 15#include <linux/lm_interface.h>
6802e340 16#include <linux/bio.h>
b3b94faa
DT
17
18#include "gfs2.h"
5c676f6d 19#include "incore.h"
b3b94faa
DT
20#include "bmap.h"
21#include "glock.h"
22#include "glops.h"
23#include "inode.h"
24#include "log.h"
25#include "meta_io.h"
b3b94faa
DT
26#include "recovery.h"
27#include "rgrp.h"
5c676f6d 28#include "util.h"
ddacfaf7 29#include "trans.h"
b3b94faa 30
ddacfaf7
SW
31/**
32 * ail_empty_gl - remove all buffers for a given lock from the AIL
33 * @gl: the glock
34 *
35 * None of the buffers should be dirty, locked, or pinned.
36 */
37
38static void gfs2_ail_empty_gl(struct gfs2_glock *gl)
39{
40 struct gfs2_sbd *sdp = gl->gl_sbd;
41 unsigned int blocks;
42 struct list_head *head = &gl->gl_ail_list;
43 struct gfs2_bufdata *bd;
44 struct buffer_head *bh;
ddacfaf7
SW
45 int error;
46
47 blocks = atomic_read(&gl->gl_ail_count);
48 if (!blocks)
49 return;
50
51 error = gfs2_trans_begin(sdp, 0, blocks);
52 if (gfs2_assert_withdraw(sdp, !error))
53 return;
54
55 gfs2_log_lock(sdp);
56 while (!list_empty(head)) {
57 bd = list_entry(head->next, struct gfs2_bufdata,
58 bd_ail_gl_list);
59 bh = bd->bd_bh;
f91a0d3e 60 gfs2_remove_from_ail(bd);
1ad38c43
SW
61 bd->bd_bh = NULL;
62 bh->b_private = NULL;
63 bd->bd_blkno = bh->b_blocknr;
64 gfs2_assert_withdraw(sdp, !buffer_busy(bh));
65 gfs2_trans_add_revoke(sdp, bd);
ddacfaf7
SW
66 }
67 gfs2_assert_withdraw(sdp, !atomic_read(&gl->gl_ail_count));
68 gfs2_log_unlock(sdp);
69
70 gfs2_trans_end(sdp);
71 gfs2_log_flush(sdp, NULL);
72}
ba7f7290
SW
73
74/**
75 * gfs2_pte_inval - Sync and invalidate all PTEs associated with a glock
76 * @gl: the glock
77 *
78 */
79
80static void gfs2_pte_inval(struct gfs2_glock *gl)
81{
82 struct gfs2_inode *ip;
83 struct inode *inode;
84
85 ip = gl->gl_object;
86 inode = &ip->i_inode;
b60623c2 87 if (!ip || !S_ISREG(inode->i_mode))
ba7f7290
SW
88 return;
89
ba7f7290 90 unmap_shared_mapping_range(inode->i_mapping, 0, 0);
ba7f7290
SW
91 if (test_bit(GIF_SW_PAGED, &ip->i_flags))
92 set_bit(GLF_DIRTY, &gl->gl_flags);
93
ba7f7290
SW
94}
95
b3b94faa
DT
96/**
97 * meta_go_sync - sync out the metadata for this glock
98 * @gl: the glock
b3b94faa
DT
99 *
100 * Called when demoting or unlocking an EX glock. We must flush
101 * to disk all dirty buffers/pages relating to this glock, and must not
102 * not return to caller to demote/unlock the glock until I/O is complete.
103 */
104
1a14d3a6 105static void meta_go_sync(struct gfs2_glock *gl)
b3b94faa 106{
b5d32bea
SW
107 if (gl->gl_state != LM_ST_EXCLUSIVE)
108 return;
109
b3b94faa 110 if (test_and_clear_bit(GLF_DIRTY, &gl->gl_flags)) {
b09e593d 111 gfs2_log_flush(gl->gl_sbd, gl);
7276b3b0 112 gfs2_meta_sync(gl);
1a14d3a6 113 gfs2_ail_empty_gl(gl);
b3b94faa 114 }
b3b94faa
DT
115}
116
117/**
118 * meta_go_inval - invalidate the metadata for this glock
119 * @gl: the glock
120 * @flags:
121 *
122 */
123
124static void meta_go_inval(struct gfs2_glock *gl, int flags)
125{
126 if (!(flags & DIO_METADATA))
127 return;
128
129 gfs2_meta_inval(gl);
cf45b752
BP
130 if (gl->gl_object == GFS2_I(gl->gl_sbd->sd_rindex))
131 gl->gl_sbd->sd_rindex_uptodate = 0;
132 else if (gl->gl_ops == &gfs2_rgrp_glops && gl->gl_object) {
133 struct gfs2_rgrpd *rgd = (struct gfs2_rgrpd *)gl->gl_object;
134
135 rgd->rd_flags &= ~GFS2_RDF_UPTODATE;
136 }
b3b94faa
DT
137}
138
b5d32bea
SW
139/**
140 * inode_go_sync - Sync the dirty data and/or metadata for an inode glock
141 * @gl: the glock protecting the inode
142 *
143 */
144
145static void inode_go_sync(struct gfs2_glock *gl)
146{
147 struct gfs2_inode *ip = gl->gl_object;
3042a2cc
SW
148 struct address_space *metamapping = gl->gl_aspace->i_mapping;
149 int error;
150
151 if (gl->gl_state != LM_ST_UNLOCKED)
152 gfs2_pte_inval(gl);
153 if (gl->gl_state != LM_ST_EXCLUSIVE)
154 return;
b5d32bea
SW
155
156 if (ip && !S_ISREG(ip->i_inode.i_mode))
157 ip = NULL;
158
159 if (test_bit(GLF_DIRTY, &gl->gl_flags)) {
b524fe64 160 gfs2_log_flush(gl->gl_sbd, gl);
3042a2cc 161 filemap_fdatawrite(metamapping);
b5d32bea
SW
162 if (ip) {
163 struct address_space *mapping = ip->i_inode.i_mapping;
3042a2cc
SW
164 filemap_fdatawrite(mapping);
165 error = filemap_fdatawait(mapping);
3e9f45bd 166 mapping_set_error(mapping, error);
b5d32bea 167 }
3042a2cc
SW
168 error = filemap_fdatawait(metamapping);
169 mapping_set_error(metamapping, error);
b5d32bea
SW
170 clear_bit(GLF_DIRTY, &gl->gl_flags);
171 gfs2_ail_empty_gl(gl);
172 }
173}
174
b3b94faa
DT
175/**
176 * inode_go_inval - prepare a inode glock to be released
177 * @gl: the glock
178 * @flags:
179 *
180 */
181
182static void inode_go_inval(struct gfs2_glock *gl, int flags)
183{
b004157a 184 struct gfs2_inode *ip = gl->gl_object;
b3b94faa 185 int meta = (flags & DIO_METADATA);
b3b94faa
DT
186
187 if (meta) {
188 gfs2_meta_inval(gl);
b004157a
SW
189 if (ip)
190 set_bit(GIF_INVALID, &ip->i_flags);
191 }
192
3cc3f710 193 if (ip && S_ISREG(ip->i_inode.i_mode))
b004157a 194 truncate_inode_pages(ip->i_inode.i_mapping, 0);
b3b94faa
DT
195}
196
197/**
198 * inode_go_demote_ok - Check to see if it's ok to unlock an inode glock
199 * @gl: the glock
200 *
201 * Returns: 1 if it's ok
202 */
203
97cc1025 204static int inode_go_demote_ok(const struct gfs2_glock *gl)
b3b94faa
DT
205{
206 struct gfs2_sbd *sdp = gl->gl_sbd;
97cc1025
SW
207 if (sdp->sd_jindex == gl->gl_object || sdp->sd_rindex == gl->gl_object)
208 return 0;
209 return 1;
b3b94faa
DT
210}
211
212/**
213 * inode_go_lock - operation done after an inode lock is locked by a process
214 * @gl: the glock
215 * @flags:
216 *
217 * Returns: errno
218 */
219
220static int inode_go_lock(struct gfs2_holder *gh)
221{
222 struct gfs2_glock *gl = gh->gh_gl;
813e0c46 223 struct gfs2_sbd *sdp = gl->gl_sbd;
5c676f6d 224 struct gfs2_inode *ip = gl->gl_object;
b3b94faa
DT
225 int error = 0;
226
091806ed 227 if (!ip || (gh->gh_flags & GL_SKIP))
b3b94faa
DT
228 return 0;
229
bfded27b 230 if (test_bit(GIF_INVALID, &ip->i_flags)) {
b3b94faa
DT
231 error = gfs2_inode_refresh(ip);
232 if (error)
233 return error;
b3b94faa
DT
234 }
235
383f01fb 236 if ((ip->i_diskflags & GFS2_DIF_TRUNC_IN_PROG) &&
b3b94faa 237 (gl->gl_state == LM_ST_EXCLUSIVE) &&
813e0c46
SW
238 (gh->gh_state == LM_ST_EXCLUSIVE)) {
239 spin_lock(&sdp->sd_trunc_lock);
240 if (list_empty(&ip->i_trunc_list))
241 list_add(&sdp->sd_trunc_list, &ip->i_trunc_list);
242 spin_unlock(&sdp->sd_trunc_lock);
243 wake_up(&sdp->sd_quota_wait);
244 return 1;
245 }
b3b94faa
DT
246
247 return error;
248}
249
6802e340
SW
250/**
251 * inode_go_dump - print information about an inode
252 * @seq: The iterator
253 * @ip: the inode
254 *
255 * Returns: 0 on success, -ENOBUFS when we run out of space
256 */
257
258static int inode_go_dump(struct seq_file *seq, const struct gfs2_glock *gl)
259{
260 const struct gfs2_inode *ip = gl->gl_object;
261 if (ip == NULL)
262 return 0;
fa75cedc 263 gfs2_print_dbg(seq, " I: n:%llu/%llu t:%u f:0x%02lx d:0x%08x s:%llu/%llu\n",
6802e340
SW
264 (unsigned long long)ip->i_no_formal_ino,
265 (unsigned long long)ip->i_no_addr,
fa75cedc
SW
266 IF2DT(ip->i_inode.i_mode), ip->i_flags,
267 (unsigned int)ip->i_diskflags,
268 (unsigned long long)ip->i_inode.i_size,
269 (unsigned long long)ip->i_disksize);
6802e340
SW
270 return 0;
271}
272
b3b94faa
DT
273/**
274 * rgrp_go_demote_ok - Check to see if it's ok to unlock a RG's glock
275 * @gl: the glock
276 *
277 * Returns: 1 if it's ok
278 */
279
97cc1025 280static int rgrp_go_demote_ok(const struct gfs2_glock *gl)
b3b94faa
DT
281{
282 return !gl->gl_aspace->i_mapping->nrpages;
283}
284
285/**
286 * rgrp_go_lock - operation done after an rgrp lock is locked by
287 * a first holder on this node.
288 * @gl: the glock
289 * @flags:
290 *
291 * Returns: errno
292 */
293
294static int rgrp_go_lock(struct gfs2_holder *gh)
295{
5c676f6d 296 return gfs2_rgrp_bh_get(gh->gh_gl->gl_object);
b3b94faa
DT
297}
298
299/**
300 * rgrp_go_unlock - operation done before an rgrp lock is unlocked by
301 * a last holder on this node.
302 * @gl: the glock
303 * @flags:
304 *
305 */
306
307static void rgrp_go_unlock(struct gfs2_holder *gh)
308{
5c676f6d 309 gfs2_rgrp_bh_put(gh->gh_gl->gl_object);
b3b94faa
DT
310}
311
6802e340
SW
312/**
313 * rgrp_go_dump - print out an rgrp
314 * @seq: The iterator
315 * @gl: The glock in question
316 *
317 */
318
319static int rgrp_go_dump(struct seq_file *seq, const struct gfs2_glock *gl)
320{
321 const struct gfs2_rgrpd *rgd = gl->gl_object;
322 if (rgd == NULL)
323 return 0;
fa75cedc
SW
324 gfs2_print_dbg(seq, " R: n:%llu f:%02x b:%u/%u i:%u\n",
325 (unsigned long long)rgd->rd_addr, rgd->rd_flags,
326 rgd->rd_free, rgd->rd_free_clone, rgd->rd_dinodes);
6802e340
SW
327 return 0;
328}
329
b3b94faa 330/**
3042a2cc 331 * trans_go_sync - promote/demote the transaction glock
b3b94faa
DT
332 * @gl: the glock
333 * @state: the requested state
334 * @flags:
335 *
336 */
337
3042a2cc 338static void trans_go_sync(struct gfs2_glock *gl)
b3b94faa
DT
339{
340 struct gfs2_sbd *sdp = gl->gl_sbd;
341
342 if (gl->gl_state != LM_ST_UNLOCKED &&
343 test_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags)) {
344 gfs2_meta_syncfs(sdp);
345 gfs2_log_shutdown(sdp);
346 }
b3b94faa
DT
347}
348
349/**
350 * trans_go_xmote_bh - After promoting/demoting the transaction glock
351 * @gl: the glock
352 *
353 */
354
6802e340 355static int trans_go_xmote_bh(struct gfs2_glock *gl, struct gfs2_holder *gh)
b3b94faa
DT
356{
357 struct gfs2_sbd *sdp = gl->gl_sbd;
feaa7bba 358 struct gfs2_inode *ip = GFS2_I(sdp->sd_jdesc->jd_inode);
5c676f6d 359 struct gfs2_glock *j_gl = ip->i_gl;
55167622 360 struct gfs2_log_header_host head;
b3b94faa
DT
361 int error;
362
6802e340 363 if (test_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags)) {
1a14d3a6 364 j_gl->gl_ops->go_inval(j_gl, DIO_METADATA);
b3b94faa
DT
365
366 error = gfs2_find_jhead(sdp->sd_jdesc, &head);
367 if (error)
368 gfs2_consist(sdp);
369 if (!(head.lh_flags & GFS2_LOG_HEAD_UNMOUNT))
370 gfs2_consist(sdp);
371
372 /* Initialize some head of the log stuff */
373 if (!test_bit(SDF_SHUTDOWN, &sdp->sd_flags)) {
374 sdp->sd_log_sequence = head.lh_sequence + 1;
375 gfs2_log_pointers_init(sdp, head.lh_blkno);
376 }
377 }
6802e340 378 return 0;
b3b94faa
DT
379}
380
97cc1025
SW
381/**
382 * trans_go_demote_ok
383 * @gl: the glock
384 *
385 * Always returns 0
386 */
387
388static int trans_go_demote_ok(const struct gfs2_glock *gl)
389{
390 return 0;
391}
392
b3b94faa
DT
393/**
394 * quota_go_demote_ok - Check to see if it's ok to unlock a quota glock
395 * @gl: the glock
396 *
397 * Returns: 1 if it's ok
398 */
399
97cc1025 400static int quota_go_demote_ok(const struct gfs2_glock *gl)
b3b94faa
DT
401{
402 return !atomic_read(&gl->gl_lvb_count);
403}
404
8fb4b536 405const struct gfs2_glock_operations gfs2_meta_glops = {
b5d32bea 406 .go_xmote_th = meta_go_sync,
ea67eedb 407 .go_type = LM_TYPE_META,
b3b94faa
DT
408};
409
8fb4b536 410const struct gfs2_glock_operations gfs2_inode_glops = {
3042a2cc 411 .go_xmote_th = inode_go_sync,
b3b94faa
DT
412 .go_inval = inode_go_inval,
413 .go_demote_ok = inode_go_demote_ok,
414 .go_lock = inode_go_lock,
6802e340 415 .go_dump = inode_go_dump,
ea67eedb 416 .go_type = LM_TYPE_INODE,
6802e340 417 .go_min_hold_time = HZ / 5,
b3b94faa
DT
418};
419
8fb4b536 420const struct gfs2_glock_operations gfs2_rgrp_glops = {
cad5b939 421 .go_xmote_th = meta_go_sync,
b3b94faa
DT
422 .go_inval = meta_go_inval,
423 .go_demote_ok = rgrp_go_demote_ok,
424 .go_lock = rgrp_go_lock,
425 .go_unlock = rgrp_go_unlock,
6802e340 426 .go_dump = rgrp_go_dump,
ea67eedb 427 .go_type = LM_TYPE_RGRP,
6802e340 428 .go_min_hold_time = HZ / 5,
b3b94faa
DT
429};
430
8fb4b536 431const struct gfs2_glock_operations gfs2_trans_glops = {
3042a2cc 432 .go_xmote_th = trans_go_sync,
b3b94faa 433 .go_xmote_bh = trans_go_xmote_bh,
97cc1025 434 .go_demote_ok = trans_go_demote_ok,
ea67eedb 435 .go_type = LM_TYPE_NONDISK,
b3b94faa
DT
436};
437
8fb4b536 438const struct gfs2_glock_operations gfs2_iopen_glops = {
ea67eedb 439 .go_type = LM_TYPE_IOPEN,
b3b94faa
DT
440};
441
8fb4b536 442const struct gfs2_glock_operations gfs2_flock_glops = {
ea67eedb 443 .go_type = LM_TYPE_FLOCK,
b3b94faa
DT
444};
445
8fb4b536 446const struct gfs2_glock_operations gfs2_nondisk_glops = {
ea67eedb 447 .go_type = LM_TYPE_NONDISK,
b3b94faa
DT
448};
449
8fb4b536 450const struct gfs2_glock_operations gfs2_quota_glops = {
b3b94faa 451 .go_demote_ok = quota_go_demote_ok,
ea67eedb 452 .go_type = LM_TYPE_QUOTA,
b3b94faa
DT
453};
454
8fb4b536 455const struct gfs2_glock_operations gfs2_journal_glops = {
ea67eedb 456 .go_type = LM_TYPE_JOURNAL,
b3b94faa
DT
457};
458