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 <linux/gfs2_ondisk.h>
17 #include <asm/semaphore.h>
20 #include "lm_interface.h"
29 * gfs2_lm_mount - mount a locking protocol
30 * @sdp: the filesystem
31 * @args: mount arguements
32 * @silent: if 1, don't complain if the FS isn't a GFS2 fs
37 int gfs2_lm_mount(struct gfs2_sbd
*sdp
, int silent
)
39 char *proto
= sdp
->sd_proto_name
;
40 char *table
= sdp
->sd_table_name
;
44 if (sdp
->sd_args
.ar_spectator
)
45 flags
|= LM_MFLAG_SPECTATOR
;
47 fs_info(sdp
, "Trying to join cluster \"%s\", \"%s\"\n", proto
, table
);
49 error
= gfs2_mount_lockproto(proto
, table
, sdp
->sd_args
.ar_hostdata
,
51 GFS2_MIN_LVB_SIZE
, flags
,
52 &sdp
->sd_lockstruct
, &sdp
->sd_kobj
);
54 fs_info(sdp
, "can't mount proto=%s, table=%s, hostdata=%s\n",
55 proto
, table
, sdp
->sd_args
.ar_hostdata
);
59 if (gfs2_assert_warn(sdp
, sdp
->sd_lockstruct
.ls_lockspace
) ||
60 gfs2_assert_warn(sdp
, sdp
->sd_lockstruct
.ls_ops
) ||
61 gfs2_assert_warn(sdp
, sdp
->sd_lockstruct
.ls_lvb_size
>=
63 gfs2_unmount_lockproto(&sdp
->sd_lockstruct
);
67 if (sdp
->sd_args
.ar_spectator
)
68 snprintf(sdp
->sd_fsname
, GFS2_FSNAME_LEN
, "%s.s", table
);
70 snprintf(sdp
->sd_fsname
, GFS2_FSNAME_LEN
, "%s.%u", table
,
71 sdp
->sd_lockstruct
.ls_jid
);
73 fs_info(sdp
, "Joined cluster. Now mounting FS...\n");
75 if ((sdp
->sd_lockstruct
.ls_flags
& LM_LSFLAG_LOCAL
) &&
76 !sdp
->sd_args
.ar_ignore_local_fs
) {
77 sdp
->sd_args
.ar_localflocks
= 1;
78 sdp
->sd_args
.ar_localcaching
= 1;
85 void gfs2_lm_others_may_mount(struct gfs2_sbd
*sdp
)
87 if (likely(!test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
88 sdp
->sd_lockstruct
.ls_ops
->lm_others_may_mount(
89 sdp
->sd_lockstruct
.ls_lockspace
);
92 void gfs2_lm_unmount(struct gfs2_sbd
*sdp
)
94 if (likely(!test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
95 gfs2_unmount_lockproto(&sdp
->sd_lockstruct
);
98 int gfs2_lm_withdraw(struct gfs2_sbd
*sdp
, char *fmt
, ...)
102 if (test_and_set_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
))
109 fs_err(sdp
, "about to withdraw from the cluster\n");
110 BUG_ON(sdp
->sd_args
.ar_debug
);
113 fs_err(sdp
, "waiting for outstanding I/O\n");
115 /* FIXME: suspend dm device so oustanding bio's complete
116 and all further io requests fail */
118 fs_err(sdp
, "telling LM to withdraw\n");
119 gfs2_withdraw_lockproto(&sdp
->sd_lockstruct
);
120 fs_err(sdp
, "withdrawn\n");
126 int gfs2_lm_get_lock(struct gfs2_sbd
*sdp
, struct lm_lockname
*name
,
130 if (unlikely(test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
133 error
= sdp
->sd_lockstruct
.ls_ops
->lm_get_lock(
134 sdp
->sd_lockstruct
.ls_lockspace
, name
, lockp
);
138 void gfs2_lm_put_lock(struct gfs2_sbd
*sdp
, lm_lock_t
*lock
)
140 if (likely(!test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
141 sdp
->sd_lockstruct
.ls_ops
->lm_put_lock(lock
);
144 unsigned int gfs2_lm_lock(struct gfs2_sbd
*sdp
, lm_lock_t
*lock
,
145 unsigned int cur_state
, unsigned int req_state
,
149 if (unlikely(test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
152 ret
= sdp
->sd_lockstruct
.ls_ops
->lm_lock(lock
,
158 unsigned int gfs2_lm_unlock(struct gfs2_sbd
*sdp
, lm_lock_t
*lock
,
159 unsigned int cur_state
)
162 if (unlikely(test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
165 ret
= sdp
->sd_lockstruct
.ls_ops
->lm_unlock(lock
, cur_state
);
169 void gfs2_lm_cancel(struct gfs2_sbd
*sdp
, lm_lock_t
*lock
)
171 if (likely(!test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
172 sdp
->sd_lockstruct
.ls_ops
->lm_cancel(lock
);
175 int gfs2_lm_hold_lvb(struct gfs2_sbd
*sdp
, lm_lock_t
*lock
, char **lvbp
)
178 if (unlikely(test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
181 error
= sdp
->sd_lockstruct
.ls_ops
->lm_hold_lvb(lock
, lvbp
);
185 void gfs2_lm_unhold_lvb(struct gfs2_sbd
*sdp
, lm_lock_t
*lock
, char *lvb
)
187 if (likely(!test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
188 sdp
->sd_lockstruct
.ls_ops
->lm_unhold_lvb(lock
, lvb
);
191 void gfs2_lm_sync_lvb(struct gfs2_sbd
*sdp
, lm_lock_t
*lock
, char *lvb
)
193 if (likely(!test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
194 sdp
->sd_lockstruct
.ls_ops
->lm_sync_lvb(lock
, lvb
);
197 int gfs2_lm_plock_get(struct gfs2_sbd
*sdp
, struct lm_lockname
*name
,
198 struct file
*file
, struct file_lock
*fl
)
201 if (unlikely(test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
204 error
= sdp
->sd_lockstruct
.ls_ops
->lm_plock_get(
205 sdp
->sd_lockstruct
.ls_lockspace
,
210 int gfs2_lm_plock(struct gfs2_sbd
*sdp
, struct lm_lockname
*name
,
211 struct file
*file
, int cmd
, struct file_lock
*fl
)
214 if (unlikely(test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
217 error
= sdp
->sd_lockstruct
.ls_ops
->lm_plock(
218 sdp
->sd_lockstruct
.ls_lockspace
,
219 name
, file
, cmd
, fl
);
223 int gfs2_lm_punlock(struct gfs2_sbd
*sdp
, struct lm_lockname
*name
,
224 struct file
*file
, struct file_lock
*fl
)
227 if (unlikely(test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
230 error
= sdp
->sd_lockstruct
.ls_ops
->lm_punlock(
231 sdp
->sd_lockstruct
.ls_lockspace
,
236 void gfs2_lm_recovery_done(struct gfs2_sbd
*sdp
, unsigned int jid
,
237 unsigned int message
)
239 if (likely(!test_bit(SDF_SHUTDOWN
, &sdp
->sd_flags
)))
240 sdp
->sd_lockstruct
.ls_ops
->lm_recovery_done(
241 sdp
->sd_lockstruct
.ls_lockspace
, jid
, message
);