18f4e91deSSage Weil #include <linux/in.h> 28f4e91deSSage Weil 38f4e91deSSage Weil #include "super.h" 43d14c5d2SYehuda Sadeh #include "mds_client.h" 53d14c5d2SYehuda Sadeh #include <linux/ceph/ceph_debug.h> 63d14c5d2SYehuda Sadeh 73d14c5d2SYehuda Sadeh #include "ioctl.h" 88f4e91deSSage Weil 98f4e91deSSage Weil 108f4e91deSSage Weil /* 118f4e91deSSage Weil * ioctls 128f4e91deSSage Weil */ 138f4e91deSSage Weil 148f4e91deSSage Weil /* 158f4e91deSSage Weil * get and set the file layout 168f4e91deSSage Weil */ 178f4e91deSSage Weil static long ceph_ioctl_get_layout(struct file *file, void __user *arg) 188f4e91deSSage Weil { 19496ad9aaSAl Viro struct ceph_inode_info *ci = ceph_inode(file_inode(file)); 208f4e91deSSage Weil struct ceph_ioctl_layout l; 218f4e91deSSage Weil int err; 228f4e91deSSage Weil 23496ad9aaSAl Viro err = ceph_do_getattr(file_inode(file), CEPH_STAT_CAP_LAYOUT); 248f4e91deSSage Weil if (!err) { 258f4e91deSSage Weil l.stripe_unit = ceph_file_layout_su(ci->i_layout); 268f4e91deSSage Weil l.stripe_count = ceph_file_layout_stripe_count(ci->i_layout); 278f4e91deSSage Weil l.object_size = ceph_file_layout_object_size(ci->i_layout); 288f4e91deSSage Weil l.data_pool = le32_to_cpu(ci->i_layout.fl_pg_pool); 293469ac1aSSage Weil l.preferred_osd = (s32)-1; 308f4e91deSSage Weil if (copy_to_user(arg, &l, sizeof(l))) 318f4e91deSSage Weil return -EFAULT; 328f4e91deSSage Weil } 338f4e91deSSage Weil 348f4e91deSSage Weil return err; 358f4e91deSSage Weil } 368f4e91deSSage Weil 37e49bf4c5SSage Weil static long __validate_layout(struct ceph_mds_client *mdsc, 38e49bf4c5SSage Weil struct ceph_ioctl_layout *l) 39e49bf4c5SSage Weil { 40e49bf4c5SSage Weil int i, err; 41e49bf4c5SSage Weil 42e49bf4c5SSage Weil /* validate striping parameters */ 43e49bf4c5SSage Weil if ((l->object_size & ~PAGE_MASK) || 44e49bf4c5SSage Weil (l->stripe_unit & ~PAGE_MASK) || 4545f2e081SSage Weil (l->stripe_unit != 0 && 4645f2e081SSage Weil ((unsigned)l->object_size % (unsigned)l->stripe_unit))) 47e49bf4c5SSage Weil return -EINVAL; 48e49bf4c5SSage Weil 49e49bf4c5SSage Weil /* make sure it's a valid data pool */ 50e49bf4c5SSage Weil mutex_lock(&mdsc->mutex); 51e49bf4c5SSage Weil err = -EINVAL; 52e49bf4c5SSage Weil for (i = 0; i < mdsc->mdsmap->m_num_data_pg_pools; i++) 53e49bf4c5SSage Weil if (mdsc->mdsmap->m_data_pg_pools[i] == l->data_pool) { 54e49bf4c5SSage Weil err = 0; 55e49bf4c5SSage Weil break; 56e49bf4c5SSage Weil } 57e49bf4c5SSage Weil mutex_unlock(&mdsc->mutex); 58e49bf4c5SSage Weil if (err) 59e49bf4c5SSage Weil return err; 60e49bf4c5SSage Weil 61e49bf4c5SSage Weil return 0; 62e49bf4c5SSage Weil } 63e49bf4c5SSage Weil 648f4e91deSSage Weil static long ceph_ioctl_set_layout(struct file *file, void __user *arg) 658f4e91deSSage Weil { 66496ad9aaSAl Viro struct inode *inode = file_inode(file); 675f21c96dSSage Weil struct inode *parent_inode; 683d14c5d2SYehuda Sadeh struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; 698f4e91deSSage Weil struct ceph_mds_request *req; 708f4e91deSSage Weil struct ceph_ioctl_layout l; 71496ad9aaSAl Viro struct ceph_inode_info *ci = ceph_inode(file_inode(file)); 72a35eca95SGreg Farnum struct ceph_ioctl_layout nl; 73e49bf4c5SSage Weil int err; 748f4e91deSSage Weil 758f4e91deSSage Weil if (copy_from_user(&l, arg, sizeof(l))) 768f4e91deSSage Weil return -EFAULT; 778f4e91deSSage Weil 78a35eca95SGreg Farnum /* validate changed params against current layout */ 79496ad9aaSAl Viro err = ceph_do_getattr(file_inode(file), CEPH_STAT_CAP_LAYOUT); 80702aeb1fSSage Weil if (err) 81a35eca95SGreg Farnum return err; 82a35eca95SGreg Farnum 83702aeb1fSSage Weil memset(&nl, 0, sizeof(nl)); 84a35eca95SGreg Farnum if (l.stripe_count) 85a35eca95SGreg Farnum nl.stripe_count = l.stripe_count; 86702aeb1fSSage Weil else 87702aeb1fSSage Weil nl.stripe_count = ceph_file_layout_stripe_count(ci->i_layout); 88a35eca95SGreg Farnum if (l.stripe_unit) 89a35eca95SGreg Farnum nl.stripe_unit = l.stripe_unit; 90702aeb1fSSage Weil else 91702aeb1fSSage Weil nl.stripe_unit = ceph_file_layout_su(ci->i_layout); 92a35eca95SGreg Farnum if (l.object_size) 93a35eca95SGreg Farnum nl.object_size = l.object_size; 94702aeb1fSSage Weil else 95702aeb1fSSage Weil nl.object_size = ceph_file_layout_object_size(ci->i_layout); 96a35eca95SGreg Farnum if (l.data_pool) 97a35eca95SGreg Farnum nl.data_pool = l.data_pool; 98702aeb1fSSage Weil else 99702aeb1fSSage Weil nl.data_pool = ceph_file_layout_pg_pool(ci->i_layout); 100702aeb1fSSage Weil 101702aeb1fSSage Weil /* this is obsolete, and always -1 */ 102702aeb1fSSage Weil nl.preferred_osd = le64_to_cpu(-1); 103a35eca95SGreg Farnum 104e49bf4c5SSage Weil err = __validate_layout(mdsc, &nl); 1058f4e91deSSage Weil if (err) 1068f4e91deSSage Weil return err; 1078f4e91deSSage Weil 1088f4e91deSSage Weil req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SETLAYOUT, 1098f4e91deSSage Weil USE_AUTH_MDS); 1108f4e91deSSage Weil if (IS_ERR(req)) 1118f4e91deSSage Weil return PTR_ERR(req); 11270b666c3SSage Weil req->r_inode = inode; 11370b666c3SSage Weil ihold(inode); 1148f4e91deSSage Weil req->r_inode_drop = CEPH_CAP_FILE_SHARED | CEPH_CAP_FILE_EXCL; 1158f4e91deSSage Weil 1168f4e91deSSage Weil req->r_args.setlayout.layout.fl_stripe_unit = 1178f4e91deSSage Weil cpu_to_le32(l.stripe_unit); 1188f4e91deSSage Weil req->r_args.setlayout.layout.fl_stripe_count = 1198f4e91deSSage Weil cpu_to_le32(l.stripe_count); 1208f4e91deSSage Weil req->r_args.setlayout.layout.fl_object_size = 1218f4e91deSSage Weil cpu_to_le32(l.object_size); 1228f4e91deSSage Weil req->r_args.setlayout.layout.fl_pg_pool = cpu_to_le32(l.data_pool); 1238f4e91deSSage Weil 1245f21c96dSSage Weil parent_inode = ceph_get_dentry_parent_inode(file->f_dentry); 1258f4e91deSSage Weil err = ceph_mdsc_do_request(mdsc, parent_inode, req); 1265f21c96dSSage Weil iput(parent_inode); 1278f4e91deSSage Weil ceph_mdsc_put_request(req); 1288f4e91deSSage Weil return err; 1298f4e91deSSage Weil } 1308f4e91deSSage Weil 1318f4e91deSSage Weil /* 132571dba52SGreg Farnum * Set a layout policy on a directory inode. All items in the tree 133571dba52SGreg Farnum * rooted at this inode will inherit this layout on creation, 134571dba52SGreg Farnum * (It doesn't apply retroactively ) 135571dba52SGreg Farnum * unless a subdirectory has its own layout policy. 136571dba52SGreg Farnum */ 137571dba52SGreg Farnum static long ceph_ioctl_set_layout_policy (struct file *file, void __user *arg) 138571dba52SGreg Farnum { 139496ad9aaSAl Viro struct inode *inode = file_inode(file); 140571dba52SGreg Farnum struct ceph_mds_request *req; 141571dba52SGreg Farnum struct ceph_ioctl_layout l; 142e49bf4c5SSage Weil int err; 143571dba52SGreg Farnum struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; 144571dba52SGreg Farnum 145571dba52SGreg Farnum /* copy and validate */ 146571dba52SGreg Farnum if (copy_from_user(&l, arg, sizeof(l))) 147571dba52SGreg Farnum return -EFAULT; 148571dba52SGreg Farnum 149e49bf4c5SSage Weil err = __validate_layout(mdsc, &l); 150571dba52SGreg Farnum if (err) 151571dba52SGreg Farnum return err; 152571dba52SGreg Farnum 153571dba52SGreg Farnum req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SETDIRLAYOUT, 154571dba52SGreg Farnum USE_AUTH_MDS); 155571dba52SGreg Farnum 156571dba52SGreg Farnum if (IS_ERR(req)) 157571dba52SGreg Farnum return PTR_ERR(req); 15870b666c3SSage Weil req->r_inode = inode; 15970b666c3SSage Weil ihold(inode); 160571dba52SGreg Farnum 161571dba52SGreg Farnum req->r_args.setlayout.layout.fl_stripe_unit = 162571dba52SGreg Farnum cpu_to_le32(l.stripe_unit); 163571dba52SGreg Farnum req->r_args.setlayout.layout.fl_stripe_count = 164571dba52SGreg Farnum cpu_to_le32(l.stripe_count); 165571dba52SGreg Farnum req->r_args.setlayout.layout.fl_object_size = 166571dba52SGreg Farnum cpu_to_le32(l.object_size); 167571dba52SGreg Farnum req->r_args.setlayout.layout.fl_pg_pool = 168571dba52SGreg Farnum cpu_to_le32(l.data_pool); 169571dba52SGreg Farnum 170571dba52SGreg Farnum err = ceph_mdsc_do_request(mdsc, inode, req); 171571dba52SGreg Farnum ceph_mdsc_put_request(req); 172571dba52SGreg Farnum return err; 173571dba52SGreg Farnum } 174571dba52SGreg Farnum 175571dba52SGreg Farnum /* 1768f4e91deSSage Weil * Return object name, size/offset information, and location (OSD 1778f4e91deSSage Weil * number, network address) for a given file offset. 1788f4e91deSSage Weil */ 1798f4e91deSSage Weil static long ceph_ioctl_get_dataloc(struct file *file, void __user *arg) 1808f4e91deSSage Weil { 1818f4e91deSSage Weil struct ceph_ioctl_dataloc dl; 182496ad9aaSAl Viro struct inode *inode = file_inode(file); 1838f4e91deSSage Weil struct ceph_inode_info *ci = ceph_inode(inode); 1843d14c5d2SYehuda Sadeh struct ceph_osd_client *osdc = 1853d14c5d2SYehuda Sadeh &ceph_sb_to_client(inode->i_sb)->client->osdc; 1868f4e91deSSage Weil u64 len = 1, olen; 1878f4e91deSSage Weil u64 tmp; 18851042122SSage Weil struct ceph_pg pgid; 189457712a0SSage Weil int r; 1908f4e91deSSage Weil 1918f4e91deSSage Weil /* copy and validate */ 1928f4e91deSSage Weil if (copy_from_user(&dl, arg, sizeof(dl))) 1938f4e91deSSage Weil return -EFAULT; 1948f4e91deSSage Weil 1958f4e91deSSage Weil down_read(&osdc->map_sem); 196e8afad65SAlex Elder r = ceph_calc_file_object_mapping(&ci->i_layout, dl.file_offset, len, 197457712a0SSage Weil &dl.object_no, &dl.object_offset, 198457712a0SSage Weil &olen); 199457712a0SSage Weil if (r < 0) 200457712a0SSage Weil return -EIO; 2018f4e91deSSage Weil dl.file_offset -= dl.object_offset; 2028f4e91deSSage Weil dl.object_size = ceph_file_layout_object_size(ci->i_layout); 2038f4e91deSSage Weil dl.block_size = ceph_file_layout_su(ci->i_layout); 2048f4e91deSSage Weil 2058f4e91deSSage Weil /* block_offset = object_offset % block_size */ 2068f4e91deSSage Weil tmp = dl.object_offset; 2078f4e91deSSage Weil dl.block_offset = do_div(tmp, dl.block_size); 2088f4e91deSSage Weil 2098f4e91deSSage Weil snprintf(dl.object_name, sizeof(dl.object_name), "%llx.%08llx", 2108f4e91deSSage Weil ceph_ino(inode), dl.object_no); 211*41766f87SAlex Elder 212*41766f87SAlex Elder ceph_calc_ceph_pg(&pgid, dl.object_name, osdc->osdmap, 213*41766f87SAlex Elder ceph_file_layout_pg_pool(ci->i_layout)); 2148f4e91deSSage Weil 2158f4e91deSSage Weil dl.osd = ceph_calc_pg_primary(osdc->osdmap, pgid); 2168f4e91deSSage Weil if (dl.osd >= 0) { 2178f4e91deSSage Weil struct ceph_entity_addr *a = 2188f4e91deSSage Weil ceph_osd_addr(osdc->osdmap, dl.osd); 2198f4e91deSSage Weil if (a) 2208f4e91deSSage Weil memcpy(&dl.osd_addr, &a->in_addr, sizeof(dl.osd_addr)); 2218f4e91deSSage Weil } else { 2228f4e91deSSage Weil memset(&dl.osd_addr, 0, sizeof(dl.osd_addr)); 2238f4e91deSSage Weil } 2248f4e91deSSage Weil up_read(&osdc->map_sem); 2258f4e91deSSage Weil 2268f4e91deSSage Weil /* send result back to user */ 2278f4e91deSSage Weil if (copy_to_user(arg, &dl, sizeof(dl))) 2288f4e91deSSage Weil return -EFAULT; 2298f4e91deSSage Weil 2308f4e91deSSage Weil return 0; 2318f4e91deSSage Weil } 2328f4e91deSSage Weil 2338c6e9229SSage Weil static long ceph_ioctl_lazyio(struct file *file) 2348c6e9229SSage Weil { 2358c6e9229SSage Weil struct ceph_file_info *fi = file->private_data; 236496ad9aaSAl Viro struct inode *inode = file_inode(file); 2378c6e9229SSage Weil struct ceph_inode_info *ci = ceph_inode(inode); 2388c6e9229SSage Weil 2398c6e9229SSage Weil if ((fi->fmode & CEPH_FILE_MODE_LAZY) == 0) { 240be655596SSage Weil spin_lock(&ci->i_ceph_lock); 2418c6e9229SSage Weil ci->i_nr_by_mode[fi->fmode]--; 2428c6e9229SSage Weil fi->fmode |= CEPH_FILE_MODE_LAZY; 2438c6e9229SSage Weil ci->i_nr_by_mode[fi->fmode]++; 244be655596SSage Weil spin_unlock(&ci->i_ceph_lock); 2458c6e9229SSage Weil dout("ioctl_layzio: file %p marked lazy\n", file); 2468c6e9229SSage Weil 2478c6e9229SSage Weil ceph_check_caps(ci, 0, NULL); 2488c6e9229SSage Weil } else { 2498c6e9229SSage Weil dout("ioctl_layzio: file %p already lazy\n", file); 2508c6e9229SSage Weil } 2518c6e9229SSage Weil return 0; 2528c6e9229SSage Weil } 2538c6e9229SSage Weil 2544918b6d1SSage Weil static long ceph_ioctl_syncio(struct file *file) 2554918b6d1SSage Weil { 2564918b6d1SSage Weil struct ceph_file_info *fi = file->private_data; 2574918b6d1SSage Weil 2584918b6d1SSage Weil fi->flags |= CEPH_F_SYNC; 2594918b6d1SSage Weil return 0; 2604918b6d1SSage Weil } 2614918b6d1SSage Weil 2628f4e91deSSage Weil long ceph_ioctl(struct file *file, unsigned int cmd, unsigned long arg) 2638f4e91deSSage Weil { 2648f4e91deSSage Weil dout("ioctl file %p cmd %u arg %lu\n", file, cmd, arg); 2658f4e91deSSage Weil switch (cmd) { 2668f4e91deSSage Weil case CEPH_IOC_GET_LAYOUT: 2678f4e91deSSage Weil return ceph_ioctl_get_layout(file, (void __user *)arg); 2688f4e91deSSage Weil 2698f4e91deSSage Weil case CEPH_IOC_SET_LAYOUT: 2708f4e91deSSage Weil return ceph_ioctl_set_layout(file, (void __user *)arg); 2718f4e91deSSage Weil 272571dba52SGreg Farnum case CEPH_IOC_SET_LAYOUT_POLICY: 273571dba52SGreg Farnum return ceph_ioctl_set_layout_policy(file, (void __user *)arg); 274571dba52SGreg Farnum 2758f4e91deSSage Weil case CEPH_IOC_GET_DATALOC: 2768f4e91deSSage Weil return ceph_ioctl_get_dataloc(file, (void __user *)arg); 2778c6e9229SSage Weil 2788c6e9229SSage Weil case CEPH_IOC_LAZYIO: 2798c6e9229SSage Weil return ceph_ioctl_lazyio(file); 2804918b6d1SSage Weil 2814918b6d1SSage Weil case CEPH_IOC_SYNCIO: 2824918b6d1SSage Weil return ceph_ioctl_syncio(file); 2838f4e91deSSage Weil } 284571dba52SGreg Farnum 2858f4e91deSSage Weil return -ENOTTY; 2868f4e91deSSage Weil } 287