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
);
28 (s32
)le32_to_cpu(ci
->i_layout
.fl_pg_preferred
);
29 if (copy_to_user(arg
, &l
, sizeof(l
)))
36 static long ceph_ioctl_set_layout(struct file
*file
, void __user
*arg
)
38 struct inode
*inode
= file
->f_dentry
->d_inode
;
39 struct inode
*parent_inode
= file
->f_dentry
->d_parent
->d_inode
;
40 struct ceph_mds_client
*mdsc
= &ceph_sb_to_client(inode
->i_sb
)->mdsc
;
41 struct ceph_mds_request
*req
;
42 struct ceph_ioctl_layout l
;
45 /* copy and validate */
46 if (copy_from_user(&l
, arg
, sizeof(l
)))
49 if ((l
.object_size
& ~PAGE_MASK
) ||
50 (l
.stripe_unit
& ~PAGE_MASK
) ||
53 (unsigned)l
.object_size
% (unsigned)l
.stripe_unit
))
56 /* make sure it's a valid data pool */
57 if (l
.data_pool
> 0) {
58 mutex_lock(&mdsc
->mutex
);
60 for (i
= 0; i
< mdsc
->mdsmap
->m_num_data_pg_pools
; i
++)
61 if (mdsc
->mdsmap
->m_data_pg_pools
[i
] == l
.data_pool
) {
65 mutex_unlock(&mdsc
->mutex
);
70 req
= ceph_mdsc_create_request(mdsc
, CEPH_MDS_OP_SETLAYOUT
,
74 req
->r_inode
= igrab(inode
);
75 req
->r_inode_drop
= CEPH_CAP_FILE_SHARED
| CEPH_CAP_FILE_EXCL
;
77 req
->r_args
.setlayout
.layout
.fl_stripe_unit
=
78 cpu_to_le32(l
.stripe_unit
);
79 req
->r_args
.setlayout
.layout
.fl_stripe_count
=
80 cpu_to_le32(l
.stripe_count
);
81 req
->r_args
.setlayout
.layout
.fl_object_size
=
82 cpu_to_le32(l
.object_size
);
83 req
->r_args
.setlayout
.layout
.fl_pg_pool
= cpu_to_le32(l
.data_pool
);
84 req
->r_args
.setlayout
.layout
.fl_pg_preferred
=
85 cpu_to_le32(l
.preferred_osd
);
87 err
= ceph_mdsc_do_request(mdsc
, parent_inode
, req
);
88 ceph_mdsc_put_request(req
);
93 * Return object name, size/offset information, and location (OSD
94 * number, network address) for a given file offset.
96 static long ceph_ioctl_get_dataloc(struct file
*file
, void __user
*arg
)
98 struct ceph_ioctl_dataloc dl
;
99 struct inode
*inode
= file
->f_dentry
->d_inode
;
100 struct ceph_inode_info
*ci
= ceph_inode(inode
);
101 struct ceph_osd_client
*osdc
= &ceph_client(inode
->i_sb
)->osdc
;
104 struct ceph_object_layout ol
;
107 /* copy and validate */
108 if (copy_from_user(&dl
, arg
, sizeof(dl
)))
111 down_read(&osdc
->map_sem
);
112 ceph_calc_file_object_mapping(&ci
->i_layout
, dl
.file_offset
, &len
,
113 &dl
.object_no
, &dl
.object_offset
, &olen
);
114 dl
.file_offset
-= dl
.object_offset
;
115 dl
.object_size
= ceph_file_layout_object_size(ci
->i_layout
);
116 dl
.block_size
= ceph_file_layout_su(ci
->i_layout
);
118 /* block_offset = object_offset % block_size */
119 tmp
= dl
.object_offset
;
120 dl
.block_offset
= do_div(tmp
, dl
.block_size
);
122 snprintf(dl
.object_name
, sizeof(dl
.object_name
), "%llx.%08llx",
123 ceph_ino(inode
), dl
.object_no
);
124 ceph_calc_object_layout(&ol
, dl
.object_name
, &ci
->i_layout
,
128 dl
.osd
= ceph_calc_pg_primary(osdc
->osdmap
, pgid
);
130 struct ceph_entity_addr
*a
=
131 ceph_osd_addr(osdc
->osdmap
, dl
.osd
);
133 memcpy(&dl
.osd_addr
, &a
->in_addr
, sizeof(dl
.osd_addr
));
135 memset(&dl
.osd_addr
, 0, sizeof(dl
.osd_addr
));
137 up_read(&osdc
->map_sem
);
139 /* send result back to user */
140 if (copy_to_user(arg
, &dl
, sizeof(dl
)))
146 long ceph_ioctl(struct file
*file
, unsigned int cmd
, unsigned long arg
)
148 dout("ioctl file %p cmd %u arg %lu\n", file
, cmd
, arg
);
150 case CEPH_IOC_GET_LAYOUT
:
151 return ceph_ioctl_get_layout(file
, (void __user
*)arg
);
153 case CEPH_IOC_SET_LAYOUT
:
154 return ceph_ioctl_set_layout(file
, (void __user
*)arg
);
156 case CEPH_IOC_GET_DATALOC
:
157 return ceph_ioctl_get_dataloc(file
, (void __user
*)arg
);
This page took 0.033152 seconds and 5 git commands to generate.