5 #include "ceph_debug.h"
13 * get and set the file layout
15 static long ceph_ioctl_get_layout(struct file
*file
, void __user
*arg
)
17 struct ceph_inode_info
*ci
= ceph_inode(file
->f_dentry
->d_inode
);
18 struct ceph_ioctl_layout l
;
21 err
= ceph_do_getattr(file
->f_dentry
->d_inode
, CEPH_STAT_CAP_LAYOUT
);
23 l
.stripe_unit
= ceph_file_layout_su(ci
->i_layout
);
24 l
.stripe_count
= ceph_file_layout_stripe_count(ci
->i_layout
);
25 l
.object_size
= ceph_file_layout_object_size(ci
->i_layout
);
26 l
.data_pool
= le32_to_cpu(ci
->i_layout
.fl_pg_pool
);
27 if (copy_to_user(arg
, &l
, sizeof(l
)))
34 static long ceph_ioctl_set_layout(struct file
*file
, void __user
*arg
)
36 struct inode
*inode
= file
->f_dentry
->d_inode
;
37 struct inode
*parent_inode
= file
->f_dentry
->d_parent
->d_inode
;
38 struct ceph_mds_client
*mdsc
= &ceph_sb_to_client(inode
->i_sb
)->mdsc
;
39 struct ceph_mds_request
*req
;
40 struct ceph_ioctl_layout l
;
43 /* copy and validate */
44 if (copy_from_user(&l
, arg
, sizeof(l
)))
47 if ((l
.object_size
& ~PAGE_MASK
) ||
48 (l
.stripe_unit
& ~PAGE_MASK
) ||
51 (unsigned)l
.object_size
% (unsigned)l
.stripe_unit
))
54 /* make sure it's a valid data pool */
55 if (l
.data_pool
> 0) {
56 mutex_lock(&mdsc
->mutex
);
58 for (i
= 0; i
< mdsc
->mdsmap
->m_num_data_pg_pools
; i
++)
59 if (mdsc
->mdsmap
->m_data_pg_pools
[i
] == l
.data_pool
) {
63 mutex_unlock(&mdsc
->mutex
);
68 req
= ceph_mdsc_create_request(mdsc
, CEPH_MDS_OP_SETLAYOUT
,
72 req
->r_inode
= igrab(inode
);
73 req
->r_inode_drop
= CEPH_CAP_FILE_SHARED
| CEPH_CAP_FILE_EXCL
;
75 req
->r_args
.setlayout
.layout
.fl_stripe_unit
=
76 cpu_to_le32(l
.stripe_unit
);
77 req
->r_args
.setlayout
.layout
.fl_stripe_count
=
78 cpu_to_le32(l
.stripe_count
);
79 req
->r_args
.setlayout
.layout
.fl_object_size
=
80 cpu_to_le32(l
.object_size
);
81 req
->r_args
.setlayout
.layout
.fl_pg_pool
= cpu_to_le32(l
.data_pool
);
82 req
->r_args
.setlayout
.layout
.fl_pg_preferred
= cpu_to_le32((s32
)-1);
84 err
= ceph_mdsc_do_request(mdsc
, parent_inode
, req
);
85 ceph_mdsc_put_request(req
);
90 * Return object name, size/offset information, and location (OSD
91 * number, network address) for a given file offset.
93 static long ceph_ioctl_get_dataloc(struct file
*file
, void __user
*arg
)
95 struct ceph_ioctl_dataloc dl
;
96 struct inode
*inode
= file
->f_dentry
->d_inode
;
97 struct ceph_inode_info
*ci
= ceph_inode(inode
);
98 struct ceph_osd_client
*osdc
= &ceph_client(inode
->i_sb
)->osdc
;
101 struct ceph_object_layout ol
;
104 /* copy and validate */
105 if (copy_from_user(&dl
, arg
, sizeof(dl
)))
108 down_read(&osdc
->map_sem
);
109 ceph_calc_file_object_mapping(&ci
->i_layout
, dl
.file_offset
, &len
,
110 &dl
.object_no
, &dl
.object_offset
, &olen
);
111 dl
.file_offset
-= dl
.object_offset
;
112 dl
.object_size
= ceph_file_layout_object_size(ci
->i_layout
);
113 dl
.block_size
= ceph_file_layout_su(ci
->i_layout
);
115 /* block_offset = object_offset % block_size */
116 tmp
= dl
.object_offset
;
117 dl
.block_offset
= do_div(tmp
, dl
.block_size
);
119 snprintf(dl
.object_name
, sizeof(dl
.object_name
), "%llx.%08llx",
120 ceph_ino(inode
), dl
.object_no
);
121 ceph_calc_object_layout(&ol
, dl
.object_name
, &ci
->i_layout
,
125 dl
.osd
= ceph_calc_pg_primary(osdc
->osdmap
, pgid
);
127 struct ceph_entity_addr
*a
=
128 ceph_osd_addr(osdc
->osdmap
, dl
.osd
);
130 memcpy(&dl
.osd_addr
, &a
->in_addr
, sizeof(dl
.osd_addr
));
132 memset(&dl
.osd_addr
, 0, sizeof(dl
.osd_addr
));
134 up_read(&osdc
->map_sem
);
136 /* send result back to user */
137 if (copy_to_user(arg
, &dl
, sizeof(dl
)))
143 long ceph_ioctl(struct file
*file
, unsigned int cmd
, unsigned long arg
)
145 dout("ioctl file %p cmd %u arg %lu\n", file
, cmd
, arg
);
147 case CEPH_IOC_GET_LAYOUT
:
148 return ceph_ioctl_get_layout(file
, (void __user
*)arg
);
150 case CEPH_IOC_SET_LAYOUT
:
151 return ceph_ioctl_set_layout(file
, (void __user
*)arg
);
153 case CEPH_IOC_GET_DATALOC
:
154 return ceph_ioctl_get_dataloc(file
, (void __user
*)arg
);
This page took 0.09134 seconds and 5 git commands to generate.