]>
git.proxmox.com Git - mirror_ubuntu-jammy-kernel.git/blob - fs/gfs2/lock_dlm.c
2 * Copyright (C) Sistina Software, Inc. 1997-2003 All rights reserved.
3 * Copyright (C) 2004-2009 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 version 2.
11 #include <linux/dlm.h>
12 #include <linux/slab.h>
13 #include <linux/types.h>
14 #include <linux/gfs2_ondisk.h>
21 static void gdlm_ast(void *arg
)
23 struct gfs2_glock
*gl
= arg
;
24 unsigned ret
= gl
->gl_state
;
25 struct gfs2_sbd
*sdp
= gl
->gl_sbd
;
27 BUG_ON(gl
->gl_lksb
.sb_flags
& DLM_SBF_DEMOTED
);
29 if (gl
->gl_lksb
.sb_flags
& DLM_SBF_VALNOTVALID
)
30 memset(gl
->gl_lvb
, 0, GDLM_LVB_SIZE
);
32 switch (gl
->gl_lksb
.sb_status
) {
33 case -DLM_EUNLOCK
: /* Unlocked, so glock can be freed */
34 if (gl
->gl_ops
->go_flags
& GLOF_ASPACE
)
35 kmem_cache_free(gfs2_glock_aspace_cachep
, gl
);
37 kmem_cache_free(gfs2_glock_cachep
, gl
);
38 if (atomic_dec_and_test(&sdp
->sd_glock_disposal
))
39 wake_up(&sdp
->sd_glock_wait
);
41 case -DLM_ECANCEL
: /* Cancel while getting lock */
42 ret
|= LM_OUT_CANCELED
;
44 case -EAGAIN
: /* Try lock fails */
45 case -EDEADLK
: /* Deadlock detected */
47 case -ETIMEDOUT
: /* Canceled due to timeout */
52 default: /* Something unexpected */
57 if (gl
->gl_lksb
.sb_flags
& DLM_SBF_ALTMODE
) {
58 if (gl
->gl_req
== LM_ST_SHARED
)
60 else if (gl
->gl_req
== LM_ST_DEFERRED
)
66 set_bit(GLF_INITIAL
, &gl
->gl_flags
);
67 gfs2_glock_complete(gl
, ret
);
70 if (!test_bit(GLF_INITIAL
, &gl
->gl_flags
))
71 gl
->gl_lksb
.sb_lkid
= 0;
72 gfs2_glock_complete(gl
, ret
);
75 static void gdlm_bast(void *arg
, int mode
)
77 struct gfs2_glock
*gl
= arg
;
81 gfs2_glock_cb(gl
, LM_ST_UNLOCKED
);
84 gfs2_glock_cb(gl
, LM_ST_DEFERRED
);
87 gfs2_glock_cb(gl
, LM_ST_SHARED
);
90 printk(KERN_ERR
"unknown bast mode %d", mode
);
95 /* convert gfs lock-state to dlm lock-mode */
97 static int make_mode(const unsigned int lmstate
)
102 case LM_ST_EXCLUSIVE
:
109 printk(KERN_ERR
"unknown LM state %d", lmstate
);
114 static u32
make_flags(const u32 lkid
, const unsigned int gfs_flags
,
119 if (gfs_flags
& LM_FLAG_TRY
)
120 lkf
|= DLM_LKF_NOQUEUE
;
122 if (gfs_flags
& LM_FLAG_TRY_1CB
) {
123 lkf
|= DLM_LKF_NOQUEUE
;
124 lkf
|= DLM_LKF_NOQUEUEBAST
;
127 if (gfs_flags
& LM_FLAG_PRIORITY
) {
128 lkf
|= DLM_LKF_NOORDER
;
129 lkf
|= DLM_LKF_HEADQUE
;
132 if (gfs_flags
& LM_FLAG_ANY
) {
133 if (req
== DLM_LOCK_PR
)
134 lkf
|= DLM_LKF_ALTCW
;
135 else if (req
== DLM_LOCK_CW
)
136 lkf
|= DLM_LKF_ALTPR
;
142 lkf
|= DLM_LKF_CONVERT
;
144 lkf
|= DLM_LKF_VALBLK
;
149 static unsigned int gdlm_lock(struct gfs2_glock
*gl
,
150 unsigned int req_state
, unsigned int flags
)
152 struct lm_lockstruct
*ls
= &gl
->gl_sbd
->sd_lockstruct
;
157 gl
->gl_req
= req_state
;
158 req
= make_mode(req_state
);
159 lkf
= make_flags(gl
->gl_lksb
.sb_lkid
, flags
, req
);
162 * Submit the actual lock request.
165 error
= dlm_lock(ls
->ls_dlm
, req
, &gl
->gl_lksb
, lkf
, gl
->gl_strname
,
166 GDLM_STRNAME_BYTES
- 1, 0, gdlm_ast
, gl
, gdlm_bast
);
167 if (error
== -EAGAIN
)
174 static void gdlm_put_lock(struct kmem_cache
*cachep
, struct gfs2_glock
*gl
)
176 struct gfs2_sbd
*sdp
= gl
->gl_sbd
;
177 struct lm_lockstruct
*ls
= &sdp
->sd_lockstruct
;
180 if (gl
->gl_lksb
.sb_lkid
== 0) {
181 kmem_cache_free(cachep
, gl
);
182 if (atomic_dec_and_test(&sdp
->sd_glock_disposal
))
183 wake_up(&sdp
->sd_glock_wait
);
187 error
= dlm_unlock(ls
->ls_dlm
, gl
->gl_lksb
.sb_lkid
, DLM_LKF_VALBLK
,
190 printk(KERN_ERR
"gdlm_unlock %x,%llx err=%d\n",
192 (unsigned long long)gl
->gl_name
.ln_number
, error
);
197 static void gdlm_cancel(struct gfs2_glock
*gl
)
199 struct lm_lockstruct
*ls
= &gl
->gl_sbd
->sd_lockstruct
;
200 dlm_unlock(ls
->ls_dlm
, gl
->gl_lksb
.sb_lkid
, DLM_LKF_CANCEL
, NULL
, gl
);
203 static int gdlm_mount(struct gfs2_sbd
*sdp
, const char *fsname
)
205 struct lm_lockstruct
*ls
= &sdp
->sd_lockstruct
;
208 if (fsname
== NULL
) {
209 fs_info(sdp
, "no fsname found\n");
213 error
= dlm_new_lockspace(fsname
, strlen(fsname
), &ls
->ls_dlm
,
214 DLM_LSFL_FS
| DLM_LSFL_NEWEXCL
|
215 (ls
->ls_nodir
? DLM_LSFL_NODIR
: 0),
218 printk(KERN_ERR
"dlm_new_lockspace error %d", error
);
223 static void gdlm_unmount(struct gfs2_sbd
*sdp
)
225 struct lm_lockstruct
*ls
= &sdp
->sd_lockstruct
;
228 dlm_release_lockspace(ls
->ls_dlm
, 2);
233 static const match_table_t dlm_tokens
= {
234 { Opt_jid
, "jid=%d"},
236 { Opt_first
, "first=%d"},
237 { Opt_nodir
, "nodir=%d"},
241 const struct lm_lockops gfs2_dlm_ops
= {
242 .lm_proto_name
= "lock_dlm",
243 .lm_mount
= gdlm_mount
,
244 .lm_unmount
= gdlm_unmount
,
245 .lm_put_lock
= gdlm_put_lock
,
246 .lm_lock
= gdlm_lock
,
247 .lm_cancel
= gdlm_cancel
,
248 .lm_tokens
= &dlm_tokens
,