2 * Copyright (C) Sistina Software, Inc. 1997-2003 All rights reserved.
3 * Copyright (C) 2004-2005 Red Hat, Inc. All rights reserved.
5 * This copyrighted material is made available to anyone wishing to use,
6 * modify, copy, or redistribute it subject to the terms and conditions
7 * of the GNU General Public License v.2.
10 #include <linux/sched.h>
11 #include <linux/slab.h>
12 #include <linux/spinlock.h>
13 #include <linux/completion.h>
14 #include <linux/buffer_head.h>
15 #include <linux/delay.h>
16 #include <asm/semaphore.h>
24 * gfs2_lm_mount - mount a locking protocol
25 * @sdp: the filesystem
26 * @args: mount arguements
27 * @silent: if 1, don't complain if the FS isn't a GFS2 fs
32 int gfs2_lm_mount(struct gfs2_sbd *sdp, int silent)
34 char *proto = sdp->sd_proto_name;
35 char *table = sdp->sd_table_name;
39 if (sdp->sd_args.ar_spectator)
40 flags |= LM_MFLAG_SPECTATOR;
42 fs_info(sdp, "Trying to join cluster \"%s\", \"%s\"\n", proto, table);
44 error = gfs2_mount_lockproto(proto, table, sdp->sd_args.ar_hostdata,
46 GFS2_MIN_LVB_SIZE, flags,
47 &sdp->sd_lockstruct, &sdp->sd_kobj);
49 fs_info(sdp, "can't mount proto=%s, table=%s, hostdata=%s\n",
50 proto, table, sdp->sd_args.ar_hostdata);
54 if (gfs2_assert_warn(sdp, sdp->sd_lockstruct.ls_lockspace) ||
55 gfs2_assert_warn(sdp, sdp->sd_lockstruct.ls_ops) ||
56 gfs2_assert_warn(sdp, sdp->sd_lockstruct.ls_lvb_size >=
58 gfs2_unmount_lockproto(&sdp->sd_lockstruct);
62 if (sdp->sd_args.ar_spectator)
63 snprintf(sdp->sd_fsname, GFS2_FSNAME_LEN, "%s.s", table);
65 snprintf(sdp->sd_fsname, GFS2_FSNAME_LEN, "%s.%u", table,
66 sdp->sd_lockstruct.ls_jid);
68 fs_info(sdp, "Joined cluster. Now mounting FS...\n");
70 if ((sdp->sd_lockstruct.ls_flags & LM_LSFLAG_LOCAL) &&
71 !sdp->sd_args.ar_ignore_local_fs) {
72 sdp->sd_args.ar_localflocks = 1;
73 sdp->sd_args.ar_localcaching = 1;
80 void gfs2_lm_others_may_mount(struct gfs2_sbd *sdp)
82 if (likely(!test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
83 sdp->sd_lockstruct.ls_ops->lm_others_may_mount(
84 sdp->sd_lockstruct.ls_lockspace);
87 void gfs2_lm_unmount(struct gfs2_sbd *sdp)
89 if (likely(!test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
90 gfs2_unmount_lockproto(&sdp->sd_lockstruct);
93 int gfs2_lm_withdraw(struct gfs2_sbd *sdp, char *fmt, ...)
97 if (test_and_set_bit(SDF_SHUTDOWN, &sdp->sd_flags))
104 fs_err(sdp, "about to withdraw from the cluster\n");
105 BUG_ON(sdp->sd_args.ar_debug);
108 fs_err(sdp, "waiting for outstanding I/O\n");
110 /* FIXME: suspend dm device so oustanding bio's complete
111 and all further io requests fail */
113 fs_err(sdp, "telling LM to withdraw\n");
114 gfs2_withdraw_lockproto(&sdp->sd_lockstruct);
115 fs_err(sdp, "withdrawn\n");
121 int gfs2_lm_get_lock(struct gfs2_sbd *sdp, struct lm_lockname *name,
125 if (unlikely(test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
128 error = sdp->sd_lockstruct.ls_ops->lm_get_lock(
129 sdp->sd_lockstruct.ls_lockspace, name, lockp);
133 void gfs2_lm_put_lock(struct gfs2_sbd *sdp, lm_lock_t *lock)
135 if (likely(!test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
136 sdp->sd_lockstruct.ls_ops->lm_put_lock(lock);
139 unsigned int gfs2_lm_lock(struct gfs2_sbd *sdp, lm_lock_t *lock,
140 unsigned int cur_state, unsigned int req_state,
144 if (unlikely(test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
147 ret = sdp->sd_lockstruct.ls_ops->lm_lock(lock,
153 unsigned int gfs2_lm_unlock(struct gfs2_sbd *sdp, lm_lock_t *lock,
154 unsigned int cur_state)
157 if (unlikely(test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
160 ret = sdp->sd_lockstruct.ls_ops->lm_unlock(lock, cur_state);
164 void gfs2_lm_cancel(struct gfs2_sbd *sdp, lm_lock_t *lock)
166 if (likely(!test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
167 sdp->sd_lockstruct.ls_ops->lm_cancel(lock);
170 int gfs2_lm_hold_lvb(struct gfs2_sbd *sdp, lm_lock_t *lock, char **lvbp)
173 if (unlikely(test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
176 error = sdp->sd_lockstruct.ls_ops->lm_hold_lvb(lock, lvbp);
180 void gfs2_lm_unhold_lvb(struct gfs2_sbd *sdp, lm_lock_t *lock, char *lvb)
182 if (likely(!test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
183 sdp->sd_lockstruct.ls_ops->lm_unhold_lvb(lock, lvb);
186 void gfs2_lm_sync_lvb(struct gfs2_sbd *sdp, lm_lock_t *lock, char *lvb)
188 if (likely(!test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
189 sdp->sd_lockstruct.ls_ops->lm_sync_lvb(lock, lvb);
192 int gfs2_lm_plock_get(struct gfs2_sbd *sdp, struct lm_lockname *name,
193 struct file *file, struct file_lock *fl)
196 if (unlikely(test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
199 error = sdp->sd_lockstruct.ls_ops->lm_plock_get(
200 sdp->sd_lockstruct.ls_lockspace,
205 int gfs2_lm_plock(struct gfs2_sbd *sdp, struct lm_lockname *name,
206 struct file *file, int cmd, struct file_lock *fl)
209 if (unlikely(test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
212 error = sdp->sd_lockstruct.ls_ops->lm_plock(
213 sdp->sd_lockstruct.ls_lockspace,
214 name, file, cmd, fl);
218 int gfs2_lm_punlock(struct gfs2_sbd *sdp, struct lm_lockname *name,
219 struct file *file, struct file_lock *fl)
222 if (unlikely(test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
225 error = sdp->sd_lockstruct.ls_ops->lm_punlock(
226 sdp->sd_lockstruct.ls_lockspace,
231 void gfs2_lm_recovery_done(struct gfs2_sbd *sdp, unsigned int jid,
232 unsigned int message)
234 if (likely(!test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
235 sdp->sd_lockstruct.ls_ops->lm_recovery_done(
236 sdp->sd_lockstruct.ls_lockspace, jid, message);