| /drivers/staging/lustre/lustre/mdc/ |
| D | mdc_locks.c | 118 int mdc_set_lock_data(struct obd_export *exp, __u64 *lockh, void *data, in mdc_set_lock_data() argument
127 if (!*lockh) in mdc_set_lock_data()
130 lock = ldlm_handle2lock((struct lustre_handle *)lockh); in mdc_set_lock_data()
157 struct lustre_handle *lockh) in mdc_lock_match() argument
166 &res_id, type, policy, mode, lockh, 0); in mdc_lock_match()
551 struct lustre_handle *lockh, in mdc_finish_enqueue() argument
572 memset(lockh, 0, sizeof(*lockh)); in mdc_finish_enqueue()
575 lock = ldlm_handle2lock(lockh); in mdc_finish_enqueue()
581 ldlm_lock_addref(lockh, lock->l_req_mode); in mdc_finish_enqueue()
582 ldlm_lock_decref(lockh, einfo->ei_mode); in mdc_finish_enqueue()
[all …]
|
| D | mdc_internal.h | 75 __u64 *lockh, void *data, __u64 *bits);
91 struct lustre_handle *lockh, void *lmm, int lmmsize,
150 struct lustre_handle *lockh);
|
| /drivers/staging/lustre/lustre/ldlm/ |
| D | ldlm_lock.c | 530 void ldlm_lock2handle(const struct ldlm_lock *lock, struct lustre_handle *lockh) in ldlm_lock2handle() argument
532 lockh->cookie = lock->l_handle.h_cookie; in ldlm_lock2handle()
669 void ldlm_lock_addref(struct lustre_handle *lockh, __u32 mode) in ldlm_lock_addref() argument
673 lock = ldlm_handle2lock(lockh); in ldlm_lock_addref()
711 int ldlm_lock_addref_try(struct lustre_handle *lockh, __u32 mode) in ldlm_lock_addref_try() argument
717 lock = ldlm_handle2lock(lockh); in ldlm_lock_addref_try()
841 void ldlm_lock_decref(struct lustre_handle *lockh, __u32 mode) in ldlm_lock_decref() argument
843 struct ldlm_lock *lock = __ldlm_handle2lock(lockh, 0); in ldlm_lock_decref()
845 LASSERTF(lock != NULL, "Non-existing lock: %#llx\n", lockh->cookie); in ldlm_lock_decref()
858 void ldlm_lock_decref_and_cancel(struct lustre_handle *lockh, __u32 mode) in ldlm_lock_decref_and_cancel() argument
[all …]
|
| D | ldlm_request.c | 336 struct lustre_handle *lockh, int rc) in ldlm_cli_enqueue_fini() argument
345 lock = ldlm_handle2lock(lockh); in ldlm_cli_enqueue_fini()
658 struct lustre_handle *lockh, int async) in ldlm_cli_enqueue() argument
675 lock = ldlm_handle2lock_long(lockh, 0); in ldlm_cli_enqueue()
692 ldlm_lock2handle(lock, lockh); in ldlm_cli_enqueue()
736 body->lock_handle[0] = *lockh; in ldlm_cli_enqueue()
767 lockh, rc); in ldlm_cli_enqueue()
1007 int ldlm_cli_cancel(struct lustre_handle *lockh, in ldlm_cli_cancel() argument
1018 lock = ldlm_handle2lock_long(lockh, LDLM_FL_CANCELING); in ldlm_cli_cancel()
|
| D | ldlm_resource.c | 749 struct lustre_handle lockh; in cleanup_resource() local
795 ldlm_lock2handle(lock, &lockh); in cleanup_resource()
796 rc = ldlm_cli_cancel(&lockh, LCF_ASYNC); in cleanup_resource()
|
| /drivers/staging/lustre/lustre/include/ |
| D | lustre_dlm.h | 1073 struct lustre_handle *lockh);
1166 void ldlm_lock_addref(struct lustre_handle *lockh, __u32 mode);
1167 int ldlm_lock_addref_try(struct lustre_handle *lockh, __u32 mode);
1168 void ldlm_lock_decref(struct lustre_handle *lockh, __u32 mode);
1169 void ldlm_lock_decref_and_cancel(struct lustre_handle *lockh, __u32 mode);
1177 ldlm_mode_t ldlm_revalidate_lock_handle(struct lustre_handle *lockh,
1238 struct lustre_handle *lockh, int async);
1251 struct lustre_handle *lockh, int rc);
1253 int ldlm_cli_cancel(struct lustre_handle *lockh,
|
| D | obd_class.h | 1459 struct lustre_handle *lockh, in md_enqueue() argument
1468 rc = MDP(exp->exp_obd, enqueue)(exp, einfo, it, op_data, lockh, in md_enqueue()
1650 __u64 *lockh, void *data, __u64 *bits) in md_set_lock_data() argument
1654 return MDP(exp->exp_obd, set_lock_data)(exp, lockh, data, bits); in md_set_lock_data()
1679 struct lustre_handle *lockh) in md_lock_match() argument
1684 policy, mode, lockh); in md_lock_match()
|
| /drivers/staging/lustre/lustre/osc/ |
| D | osc_internal.h | 113 struct lustre_handle *lockh,
115 int osc_cancel_base(struct lustre_handle *lockh, __u32 mode);
119 __u64 *flags, void *data, struct lustre_handle *lockh,
|
| D | osc_request.c | 2048 static int osc_set_data_with_check(struct lustre_handle *lockh, in osc_set_data_with_check() argument
2051 struct ldlm_lock *lock = ldlm_handle2lock(lockh); in osc_set_data_with_check()
2059 lockh, einfo->ei_cbdata); in osc_set_data_with_check()
2193 struct lustre_handle *lockh, in osc_enqueue_base() argument
2233 einfo->ei_type, policy, mode, lockh, 0); in osc_enqueue_base()
2235 struct ldlm_lock *matched = ldlm_handle2lock(lockh); in osc_enqueue_base()
2241 ldlm_lock_decref(lockh, mode); in osc_enqueue_base()
2251 ldlm_lock_addref(lockh, LCK_PR); in osc_enqueue_base()
2265 ldlm_lock_decref(lockh, LCK_PW); in osc_enqueue_base()
2268 ldlm_lock_decref(lockh, einfo->ei_mode); in osc_enqueue_base()
[all …]
|
| D | osc_page.c | 70 struct lustre_handle *lockh;
80 lockh = &info->oti_handle;
92 dlmmode, &flags, NULL, lockh, unref);
|
| D | osc_lock.c | 680 struct lustre_handle *lockh; in osc_dlm_blocking_ast0() local
682 lockh = &osc_env_info(env)->oti_handle; in osc_dlm_blocking_ast0()
683 ldlm_lock2handle(dlmlock, lockh); in osc_dlm_blocking_ast0()
684 result = ldlm_cli_cancel(lockh, LCF_ASYNC); in osc_dlm_blocking_ast0()
|
| /drivers/staging/lustre/lustre/llite/ |
| D | xattr_cache.c | 272 struct lustre_handle lockh = { 0 }; in ll_xattr_find_get_lock() local
288 mode = ll_take_md_lock(inode, MDS_INODELOCK_XATTR, &lockh, 0, in ll_xattr_find_get_lock()
292 oit->d.lustre.it_lock_handle = lockh.cookie; in ll_xattr_find_get_lock()
308 rc = md_enqueue(exp, &einfo, oit, op_data, &lockh, NULL, 0, NULL, 0); in ll_xattr_find_get_lock()
|
| D | file.c | 271 struct lustre_handle lockh; in ll_md_close() local
317 LDLM_IBITS, &policy, lockmode, &lockh)) in ll_md_close()
718 struct lustre_handle lockh; in ll_md_blocking_lease_ast() local
722 ldlm_lock2handle(lock, &lockh); in ll_md_blocking_lease_ast()
723 rc = ldlm_cli_cancel(&lockh, LCF_ASYNC); in ll_md_blocking_lease_ast()
2659 struct lustre_handle lockh = {0}; in ll_file_flock() local
2751 op_data, &lockh, &flock, 0, NULL /* req */, flags); in ll_file_flock()
2760 op_data, &lockh, &flock, 0, NULL /* req */, flags); in ll_file_flock()
2787 struct lustre_handle lockh; in ll_have_md_lock() local
2809 &policy, mode, &lockh)) { in ll_have_md_lock()
[all …]
|
| D | dir.c | 339 struct lustre_handle lockh; in ll_get_dir_page() local
352 ll_inode2fid(dir), LDLM_IBITS, &policy, mode, &lockh); in ll_get_dir_page()
370 op_data, &lockh, NULL, 0, NULL, 0); in ll_get_dir_page()
390 md_set_lock_data(ll_i2sbi(dir)->ll_md_exp, &lockh.cookie, in ll_get_dir_page()
393 ldlm_lock_dump_handle(D_OTHER, &lockh); in ll_get_dir_page()
468 ldlm_lock_decref(&lockh, mode); in ll_get_dir_page()
|
| D | llite_lib.c | 1601 struct lustre_handle lockh; in ll_update_inode() local
1609 &lockh, LDLM_FL_CBPENDING, in ll_update_inode()
1626 ldlm_lock_decref(&lockh, mode); in ll_update_inode()
1991 struct lustre_handle lockh; in ll_prep_inode() local
1994 lockh.cookie = it->d.lustre.it_lock_handle; in ll_prep_inode()
1995 lock = ldlm_handle2lock(&lockh); in ll_prep_inode()
|
| D | namei.c | 168 struct lustre_handle lockh; in ll_md_blocking_ast() local
173 ldlm_lock2handle(lock, &lockh); in ll_md_blocking_ast()
174 rc = ldlm_cli_cancel(&lockh, LCF_ASYNC); in ll_md_blocking_ast()
|
| D | llite_internal.h | 710 struct lustre_handle *lockh, __u64 flags,
|
| /drivers/staging/lustre/lustre/mgc/ |
| D | mgc_request.c | 762 struct lustre_handle lockh; in mgc_blocking_ast() local
770 ldlm_lock2handle(lock, &lockh); in mgc_blocking_ast()
771 rc = ldlm_cli_cancel(&lockh, LCF_ASYNC); in mgc_blocking_ast()
865 struct lustre_handle *lockh) in mgc_enqueue() argument
895 NULL, 0, LVB_T_NONE, lockh, 0); in mgc_enqueue()
1525 struct lustre_handle lockh = { 0 }; in mgc_process_log() local
1549 cld, 0, NULL, &lockh); in mgc_process_log()
1553 rc = ldlm_lock_set_data(&lockh, (void *)cld); in mgc_process_log()
1580 ldlm_lock_decref(&lockh, LCK_CR); in mgc_process_log()
|
| /drivers/staging/lustre/lustre/lmv/ |
| D | lmv_obd.c | 1689 struct lustre_handle *lockh, void *lmm, int lmmsize, in lmv_enqueue_remote() argument
1717 memcpy(&plock, lockh, sizeof(plock)); in lmv_enqueue_remote()
1739 rc = md_enqueue(tgt->ltd_exp, einfo, it, rdata, lockh, in lmv_enqueue_remote()
1750 struct lustre_handle *lockh, void *lmm, int lmmsize, in lmv_enqueue() argument
1772 rc = md_enqueue(tgt->ltd_exp, einfo, it, op_data, lockh, in lmv_enqueue()
1776 rc = lmv_enqueue_remote(exp, einfo, it, op_data, lockh, in lmv_enqueue()
2512 static int lmv_set_lock_data(struct obd_export *exp, __u64 *lockh, void *data, in lmv_set_lock_data() argument
2518 rc = md_set_lock_data(lmv->tgts[0]->ltd_exp, lockh, data, bits); in lmv_set_lock_data()
2525 struct lustre_handle *lockh) in lmv_lock_match() argument
2547 type, policy, mode, lockh); in lmv_lock_match()
|