| /fs/ocfs2/dlm/ |
| D | dlmthread.c | 46 void __dlm_wait_on_lockres_flags(struct dlm_lock_resource *res, int flags) in __dlm_wait_on_lockres_flags() argument
50 assert_spin_locked(&res->spinlock); in __dlm_wait_on_lockres_flags()
52 add_wait_queue(&res->wq, &wait); in __dlm_wait_on_lockres_flags()
55 if (res->state & flags) { in __dlm_wait_on_lockres_flags()
56 spin_unlock(&res->spinlock); in __dlm_wait_on_lockres_flags()
58 spin_lock(&res->spinlock); in __dlm_wait_on_lockres_flags()
61 remove_wait_queue(&res->wq, &wait); in __dlm_wait_on_lockres_flags()
65 int __dlm_lockres_has_locks(struct dlm_lock_resource *res) in __dlm_lockres_has_locks() argument
67 if (list_empty(&res->granted) && in __dlm_lockres_has_locks()
68 list_empty(&res->converting) && in __dlm_lockres_has_locks()
[all …]
|
| D | dlmmaster.c | 51 struct dlm_lock_resource *res,
78 struct dlm_lock_resource *res,
87 static int dlm_do_master_request(struct dlm_lock_resource *res,
92 struct dlm_lock_resource *res,
96 struct dlm_lock_resource *res,
100 struct dlm_lock_resource *res,
107 struct dlm_lock_resource *res);
109 struct dlm_lock_resource *res);
111 struct dlm_lock_resource *res,
114 struct dlm_lock_resource *res);
[all …]
|
| D | dlmconvert.c | 44 struct dlm_lock_resource *res,
49 struct dlm_lock_resource *res,
62 struct dlm_lock_resource *res, in dlmconvert_master() argument
68 spin_lock(&res->spinlock); in dlmconvert_master()
70 __dlm_wait_on_lockres(res); in dlmconvert_master()
71 __dlm_lockres_reserve_ast(res); in dlmconvert_master()
72 res->state |= DLM_LOCK_RES_IN_PROGRESS; in dlmconvert_master()
74 status = __dlmconvert_master(dlm, res, lock, flags, type, in dlmconvert_master()
77 res->state &= ~DLM_LOCK_RES_IN_PROGRESS; in dlmconvert_master()
78 spin_unlock(&res->spinlock); in dlmconvert_master()
[all …]
|
| D | dlmlock.c | 46 struct dlm_lock_resource *res,
75 static int dlm_can_grant_new_lock(struct dlm_lock_resource *res, in dlm_can_grant_new_lock() argument
80 list_for_each_entry(tmplock, &res->granted, list) { in dlm_can_grant_new_lock()
85 list_for_each_entry(tmplock, &res->converting, list) { in dlm_can_grant_new_lock()
104 struct dlm_lock_resource *res, in dlmlock_master() argument
112 spin_lock(&res->spinlock); in dlmlock_master()
115 status = __dlm_lockres_state_to_status(res); in dlmlock_master()
119 spin_unlock(&res->spinlock); in dlmlock_master()
123 __dlm_wait_on_lockres(res); in dlmlock_master()
124 __dlm_lockres_reserve_ast(res); in dlmlock_master()
[all …]
|
| D | dlmunlock.c | 44 struct dlm_lock_resource *res,
49 struct dlm_lock_resource *res,
55 struct dlm_lock_resource *res,
84 struct dlm_lock_resource *res, in dlmunlock_common() argument
100 BUG_ON(res->owner != dlm->node_num); in dlmunlock_common()
102 BUG_ON(res->owner == dlm->node_num); in dlmunlock_common()
111 "while waiting for an ast!", res->lockname.len, in dlmunlock_common()
112 res->lockname.name); in dlmunlock_common()
116 spin_lock(&res->spinlock); in dlmunlock_common()
117 if (res->state & DLM_LOCK_RES_IN_PROGRESS) { in dlmunlock_common()
[all …]
|
| D | dlmrecovery.c | 52 static inline int dlm_num_locks_in_lockres(struct dlm_lock_resource *res);
60 struct dlm_lock_resource *res,
63 struct dlm_lock_resource *res,
80 struct dlm_lock_resource *res,
240 struct dlm_lock_resource *res; in dlm_print_reco_node_status() local
278 list_for_each_entry(res, &dlm->reco.resources, recovering) { in dlm_print_reco_node_status()
280 dlm->name, res->lockname.len, res->lockname.name); in dlm_print_reco_node_status()
875 struct dlm_lock_resource *res; in dlm_request_all_locks_worker() local
921 list_for_each_entry(res, &resources, recovering) { in dlm_request_all_locks_worker()
922 ret = dlm_send_one_lockres(dlm, res, mres, reco_master, in dlm_request_all_locks_worker()
[all …]
|
| D | dlmast.c | 36 static void dlm_update_lvb(struct dlm_ctxt *dlm, struct dlm_lock_resource *res,
78 struct dlm_lock_resource *res; in __dlm_queue_ast() local
83 res = lock->lockres; in __dlm_queue_ast()
90 dlm->name, res->lockname.len, res->lockname.name, in __dlm_queue_ast()
98 dlm->name, res->lockname.len, res->lockname.name, in __dlm_queue_ast()
109 dlm->name, res->lockname.len, res->lockname.name, in __dlm_queue_ast()
124 dlm_lockres_release_ast(dlm, res); in __dlm_queue_ast()
144 struct dlm_lock_resource *res; in __dlm_queue_bast() local
151 res = lock->lockres; in __dlm_queue_bast()
156 dlm->name, res->lockname.len, res->lockname.name, in __dlm_queue_bast()
[all …]
|
| D | dlmcommon.h | 393 dlm_list_idx_to_ptr(struct dlm_lock_resource *res, enum dlm_lockres_list idx) in dlm_list_idx_to_ptr() argument
397 ret = &res->granted; in dlm_list_idx_to_ptr()
399 ret = &res->converting; in dlm_list_idx_to_ptr()
401 ret = &res->blocked; in dlm_list_idx_to_ptr()
787 __dlm_lockres_state_to_status(struct dlm_lock_resource *res) in __dlm_lockres_state_to_status() argument
791 assert_spin_locked(&res->spinlock); in __dlm_lockres_state_to_status()
793 if (res->state & (DLM_LOCK_RES_RECOVERING| in __dlm_lockres_state_to_status()
796 else if (res->state & DLM_LOCK_RES_MIGRATING) in __dlm_lockres_state_to_status()
798 else if (res->state & DLM_LOCK_RES_IN_PROGRESS) in __dlm_lockres_state_to_status()
825 struct dlm_lock_resource *res);
[all …]
|
| D | dlmdebug.c | 35 void dlm_print_one_lock_resource(struct dlm_lock_resource *res) in dlm_print_one_lock_resource() argument
37 spin_lock(&res->spinlock); in dlm_print_one_lock_resource()
38 __dlm_print_one_lock_resource(res); in dlm_print_one_lock_resource()
39 spin_unlock(&res->spinlock); in dlm_print_one_lock_resource()
42 static void dlm_print_lockres_refmap(struct dlm_lock_resource *res) in dlm_print_lockres_refmap() argument
45 assert_spin_locked(&res->spinlock); in dlm_print_lockres_refmap()
50 bit = find_next_bit(res->refmap, O2NM_MAX_NODES, bit); in dlm_print_lockres_refmap()
56 printk("], inflight=%u\n", res->inflight_locks); in dlm_print_lockres_refmap()
82 void __dlm_print_one_lock_resource(struct dlm_lock_resource *res) in __dlm_print_one_lock_resource() argument
87 assert_spin_locked(&res->spinlock); in __dlm_print_one_lock_resource()
[all …]
|
| /fs/hfs/ |
| D | extent.c | 112 int res; in __hfs_ext_write_extent() local
116 res = hfs_brec_find(fd); in __hfs_ext_write_extent()
118 if (res != -ENOENT) in __hfs_ext_write_extent()
119 return res; in __hfs_ext_write_extent()
121 res = hfs_bmap_reserve(fd->tree, fd->tree->depth + 1); in __hfs_ext_write_extent()
122 if (res) in __hfs_ext_write_extent()
123 return res; in __hfs_ext_write_extent()
127 if (res) in __hfs_ext_write_extent()
128 return res; in __hfs_ext_write_extent()
138 int res = 0; in hfs_ext_write_extent() local
[all …]
|
| D | attr.c | 28 int res; in __hfs_setxattr() local
33 res = hfs_find_init(HFS_SB(inode->i_sb)->cat_tree, &fd); in __hfs_setxattr()
34 if (res) in __hfs_setxattr()
35 return res; in __hfs_setxattr()
37 res = hfs_brec_find(&fd); in __hfs_setxattr()
38 if (res) in __hfs_setxattr()
49 res = -ERANGE; in __hfs_setxattr()
56 res = -ERANGE; in __hfs_setxattr()
60 if (!res) in __hfs_setxattr()
65 return res; in __hfs_setxattr()
[all …]
|
| D | bfind.c | 49 int res; in __hfs_brec_find() local
53 res = -ENOENT; in __hfs_brec_find()
59 res = -EINVAL; in __hfs_brec_find()
66 res = 0; in __hfs_brec_find()
78 res = -EINVAL; in __hfs_brec_find()
90 return res; in __hfs_brec_find()
101 int height, res; in hfs_brec_find() local
111 res = 0; in hfs_brec_find()
116 res = PTR_ERR(bnode); in hfs_brec_find()
126 res = __hfs_brec_find(bnode, fd); in hfs_brec_find()
[all …]
|
| D | dir.c | 26 int res; in hfs_lookup() local
28 res = hfs_find_init(HFS_SB(dir->i_sb)->cat_tree, &fd); in hfs_lookup()
29 if (res) in hfs_lookup()
30 return ERR_PTR(res); in hfs_lookup()
32 res = hfs_brec_read(&fd, &rec, sizeof(rec)); in hfs_lookup()
33 if (res) { in hfs_lookup()
34 if (res != -ENOENT) in hfs_lookup()
35 inode = ERR_PTR(res); in hfs_lookup()
196 int res; in hfs_create() local
202 res = hfs_cat_create(inode->i_ino, dir, &dentry->d_name, inode); in hfs_create()
[all …]
|
| /fs/hfsplus/ |
| D | extents.c | 91 int res; in __hfsplus_ext_write_extent() local
99 res = hfs_brec_find(fd, hfs_find_rec_by_key); in __hfsplus_ext_write_extent()
101 if (res != -ENOENT) in __hfsplus_ext_write_extent()
102 return res; in __hfsplus_ext_write_extent()
104 res = hfs_bmap_reserve(fd->tree, fd->tree->depth + 1); in __hfsplus_ext_write_extent()
105 if (res) in __hfsplus_ext_write_extent()
106 return res; in __hfsplus_ext_write_extent()
111 if (res) in __hfsplus_ext_write_extent()
112 return res; in __hfsplus_ext_write_extent()
131 int res = 0; in hfsplus_ext_write_extent_locked() local
[all …]
|
| D | dir.c | 309 int res; in hfsplus_link() local
323 res = hfsplus_rename_cat(inode->i_ino, in hfsplus_link()
326 if (!res) in hfsplus_link()
328 if (res != -EEXIST) in hfsplus_link()
334 res = hfsplus_create_cat(cnid, src_dir, in hfsplus_link()
336 if (res) in hfsplus_link()
342 res = hfsplus_create_cat(cnid, dst_dir, &dst_dentry->d_name, inode); in hfsplus_link()
343 if (res) in hfsplus_link()
355 return res; in hfsplus_link()
365 int res; in hfsplus_unlink() local
[all …]
|
| D | xattr.c | 427 int res; in hfsplus_setxattr() local
435 res = __hfsplus_setxattr(inode, xattr_name, value, size, flags); in hfsplus_setxattr()
437 return res; in hfsplus_setxattr()
443 ssize_t res = 0; in hfsplus_getxattr_finder_info() local
453 res = hfs_find_init(HFSPLUS_SB(inode->i_sb)->cat_tree, &fd); in hfsplus_getxattr_finder_info()
454 if (res) { in hfsplus_getxattr_finder_info()
456 return res; in hfsplus_getxattr_finder_info()
458 res = hfsplus_find_cat(inode->i_sb, inode->i_ino, &fd); in hfsplus_getxattr_finder_info()
459 if (res) in hfsplus_getxattr_finder_info()
469 res = folder_rec_len; in hfsplus_getxattr_finder_info()
[all …]
|
| D | bfind.c | 120 int res; in __hfs_brec_find() local
125 res = -ENOENT; in __hfs_brec_find()
131 res = -EINVAL; in __hfs_brec_find()
136 res = 0; in __hfs_brec_find()
145 res = -EINVAL; in __hfs_brec_find()
159 return res; in __hfs_brec_find()
170 int height, res; in hfs_brec_find() local
180 res = 0; in hfs_brec_find()
185 res = PTR_ERR(bnode); in hfs_brec_find()
195 res = __hfs_brec_find(bnode, fd, do_key_compare); in hfs_brec_find()
[all …]
|
| /fs/nfs/ |
| D | nfs4xdr.c | 75 struct nfs4_layoutget_res *res);
994 __u32 *res, size_t len) in mask_bitmap4() argument
1003 res[i] = tmp; in mask_bitmap4()
3362 static int decode_attr_link_support(struct xdr_stream *xdr, uint32_t *bitmap, uint32_t *res) in decode_attr_link_support() argument
3366 *res = 0; in decode_attr_link_support()
3373 *res = be32_to_cpup(p); in decode_attr_link_support()
3376 dprintk("%s: link support=%s\n", __func__, *res == 0 ? "false" : "true"); in decode_attr_link_support()
3380 static int decode_attr_symlink_support(struct xdr_stream *xdr, uint32_t *bitmap, uint32_t *res) in decode_attr_symlink_support() argument
3384 *res = 0; in decode_attr_symlink_support()
3391 *res = be32_to_cpup(p); in decode_attr_symlink_support()
[all …]
|
| D | nfs42xdr.c | 462 static int decode_allocate(struct xdr_stream *xdr, struct nfs42_falloc_res *res) in decode_allocate() argument
468 struct nfs42_write_res *res) in decode_write_response() argument
480 status = decode_opaque_fixed(xdr, &res->stateid, in decode_write_response()
488 p = xdr_decode_hyper(p, &res->count); in decode_write_response()
489 res->verifier.committed = be32_to_cpup(p); in decode_write_response()
490 return decode_verifier(xdr, &res->verifier.verifier); in decode_write_response()
494 struct nfs42_copy_res *res) { in decode_copy_requirements() argument
501 res->consecutive = be32_to_cpup(p++); in decode_copy_requirements()
502 res->synchronous = be32_to_cpup(p++); in decode_copy_requirements()
506 static int decode_copy(struct xdr_stream *xdr, struct nfs42_copy_res *res) in decode_copy() argument
[all …]
|
| D | nfs3proc.c | 34 int res; in nfs3_rpc_wrapper() local
36 res = rpc_call_sync(clnt, msg, flags); in nfs3_rpc_wrapper()
37 if (res != -EJUKEBOX) in nfs3_rpc_wrapper()
40 res = -ERESTARTSYS; in nfs3_rpc_wrapper()
42 return res; in nfs3_rpc_wrapper()
161 struct nfs3_diropres res = { in nfs3_proc_lookup() local
168 .rpc_resp = &res, in nfs3_proc_lookup()
173 res.dir_attr = nfs_alloc_fattr(); in nfs3_proc_lookup()
174 if (res.dir_attr == NULL) in nfs3_proc_lookup()
179 nfs_refresh_inode(dir, res.dir_attr); in nfs3_proc_lookup()
[all …]
|
| D | callback_proc.c | 27 struct cb_getattrres *res = resp; in nfs4_callback_getattr() local
32 res->status = htonl(NFS4ERR_OP_NOT_IN_SESSION); in nfs4_callback_getattr()
36 res->bitmap[0] = res->bitmap[1] = 0; in nfs4_callback_getattr()
37 res->status = htonl(NFS4ERR_BADHANDLE); in nfs4_callback_getattr()
45 res->status = htonl(NFS4ERR_DELAY); in nfs4_callback_getattr()
47 -ntohl(res->status)); in nfs4_callback_getattr()
55 res->size = i_size_read(inode); in nfs4_callback_getattr()
56 res->change_attr = delegation->change_attr; in nfs4_callback_getattr()
58 res->change_attr++; in nfs4_callback_getattr()
59 res->ctime = timespec64_to_timespec(inode->i_ctime); in nfs4_callback_getattr()
[all …]
|
| D | nfs4proc.c | 685 struct nfs4_sequence_res *res, int cache_reply, in nfs4_init_sequence() argument
692 res->sr_slot = NULL; in nfs4_init_sequence()
695 static void nfs40_sequence_free_slot(struct nfs4_sequence_res *res) in nfs40_sequence_free_slot() argument
697 struct nfs4_slot *slot = res->sr_slot; in nfs40_sequence_free_slot()
706 res->sr_slot = NULL; in nfs40_sequence_free_slot()
710 struct nfs4_sequence_res *res) in nfs40_sequence_done() argument
712 if (res->sr_slot != NULL) in nfs40_sequence_done()
713 nfs40_sequence_free_slot(res); in nfs40_sequence_done()
758 static void nfs41_sequence_free_slot(struct nfs4_sequence_res *res) in nfs41_sequence_free_slot() argument
760 nfs41_release_slot(res->sr_slot); in nfs41_sequence_free_slot()
[all …]
|
| D | nfs42proc.c | 33 struct nfs42_falloc_res res = { in _nfs42_proc_fallocate() local
39 msg->rpc_resp = &res; in _nfs42_proc_fallocate()
46 res.falloc_fattr = nfs_alloc_fattr(); in _nfs42_proc_fallocate()
47 if (!res.falloc_fattr) in _nfs42_proc_fallocate()
51 &args.seq_args, &res.seq_res, 0); in _nfs42_proc_fallocate()
53 status = nfs_post_op_update_inode(inode, res.falloc_fattr); in _nfs42_proc_fallocate()
55 kfree(res.falloc_fattr); in _nfs42_proc_fallocate()
134 static int handle_async_copy(struct nfs42_copy_res *res, in handle_async_copy() argument
152 if (memcmp(&res->write_res.stateid, &tmp_copy->stateid, in handle_async_copy()
166 memcpy(©->stateid, &res->write_res.stateid, NFS4_STATEID_SIZE); in handle_async_copy()
[all …]
|
| D | nfs3acl.c | 56 struct nfs3_getaclres res = { in nfs3_get_acl() local
61 .rpc_resp = &res, in nfs3_get_acl()
87 res.fattr = nfs_alloc_fattr(); in nfs3_get_acl()
88 if (res.fattr == NULL) in nfs3_get_acl()
105 status = nfs_refresh_inode(inode, res.fattr); in nfs3_get_acl()
117 if ((args.mask & res.mask) != args.mask) { in nfs3_get_acl()
122 if (res.acl_access != NULL) { in nfs3_get_acl()
123 if ((posix_acl_equiv_mode(res.acl_access, NULL) == 0) || in nfs3_get_acl()
124 res.acl_access->a_count == 0) { in nfs3_get_acl()
125 posix_acl_release(res.acl_access); in nfs3_get_acl()
[all …]
|
| /fs/ocfs2/ |
| D | suballoc.c | 57 static u64 ocfs2_group_from_res(struct ocfs2_suballoc_result *res) in ocfs2_group_from_res() argument
59 if (res->sr_blkno == 0) in ocfs2_group_from_res()
62 if (res->sr_bg_blkno) in ocfs2_group_from_res()
63 return res->sr_bg_blkno; in ocfs2_group_from_res()
65 return ocfs2_which_suballoc_group(res->sr_blkno, res->sr_bit_offset); in ocfs2_group_from_res()
87 struct ocfs2_suballoc_result *res);
92 struct ocfs2_suballoc_result *res);
97 struct ocfs2_suballoc_result *res);
1278 struct ocfs2_suballoc_result *res) in ocfs2_block_group_find_clear_bits() argument
1323 res->sr_bit_offset = best_offset; in ocfs2_block_group_find_clear_bits()
[all …]
|