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 { 198f4e91deSSage Weil struct ceph_inode_info *ci = ceph_inode(file->f_dentry->d_inode); 208f4e91deSSage Weil struct ceph_ioctl_layout l; 218f4e91deSSage Weil int err; 228f4e91deSSage Weil 238f4e91deSSage Weil err = ceph_do_getattr(file->f_dentry->d_inode, 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 /* preferred_osd is no longer supported */ 43e49bf4c5SSage Weil if (l->preferred_osd != -1) 44e49bf4c5SSage Weil return -EINVAL; 45e49bf4c5SSage Weil 46e49bf4c5SSage Weil /* validate striping parameters */ 47e49bf4c5SSage Weil if ((l->object_size & ~PAGE_MASK) || 48e49bf4c5SSage Weil (l->stripe_unit & ~PAGE_MASK) || 49e49bf4c5SSage Weil ((unsigned)l->object_size % (unsigned)l->stripe_unit)) 50e49bf4c5SSage Weil return -EINVAL; 51e49bf4c5SSage Weil 52e49bf4c5SSage Weil /* make sure it's a valid data pool */ 53e49bf4c5SSage Weil mutex_lock(&mdsc->mutex); 54e49bf4c5SSage Weil err = -EINVAL; 55e49bf4c5SSage Weil for (i = 0; i < mdsc->mdsmap->m_num_data_pg_pools; i++) 56e49bf4c5SSage Weil if (mdsc->mdsmap->m_data_pg_pools[i] == l->data_pool) { 57e49bf4c5SSage Weil err = 0; 58e49bf4c5SSage Weil break; 59e49bf4c5SSage Weil } 60e49bf4c5SSage Weil mutex_unlock(&mdsc->mutex); 61e49bf4c5SSage Weil if (err) 62e49bf4c5SSage Weil return err; 63e49bf4c5SSage Weil 64e49bf4c5SSage Weil return 0; 65e49bf4c5SSage Weil } 66e49bf4c5SSage Weil 678f4e91deSSage Weil static long ceph_ioctl_set_layout(struct file *file, void __user *arg) 688f4e91deSSage Weil { 698f4e91deSSage Weil struct inode *inode = file->f_dentry->d_inode; 705f21c96dSSage Weil struct inode *parent_inode; 713d14c5d2SYehuda Sadeh struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; 728f4e91deSSage Weil struct ceph_mds_request *req; 738f4e91deSSage Weil struct ceph_ioctl_layout l; 74a35eca95SGreg Farnum struct ceph_inode_info *ci = ceph_inode(file->f_dentry->d_inode); 75a35eca95SGreg Farnum struct ceph_ioctl_layout nl; 76e49bf4c5SSage Weil int err; 778f4e91deSSage Weil 788f4e91deSSage Weil if (copy_from_user(&l, arg, sizeof(l))) 798f4e91deSSage Weil return -EFAULT; 808f4e91deSSage Weil 81a35eca95SGreg Farnum /* validate changed params against current layout */ 82a35eca95SGreg Farnum err = ceph_do_getattr(file->f_dentry->d_inode, CEPH_STAT_CAP_LAYOUT); 83*702aeb1fSSage Weil if (err) 84a35eca95SGreg Farnum return err; 85a35eca95SGreg Farnum 86*702aeb1fSSage Weil memset(&nl, 0, sizeof(nl)); 87a35eca95SGreg Farnum if (l.stripe_count) 88a35eca95SGreg Farnum nl.stripe_count = l.stripe_count; 89*702aeb1fSSage Weil else 90*702aeb1fSSage Weil nl.stripe_count = ceph_file_layout_stripe_count(ci->i_layout); 91a35eca95SGreg Farnum if (l.stripe_unit) 92a35eca95SGreg Farnum nl.stripe_unit = l.stripe_unit; 93*702aeb1fSSage Weil else 94*702aeb1fSSage Weil nl.stripe_unit = ceph_file_layout_su(ci->i_layout); 95a35eca95SGreg Farnum if (l.object_size) 96a35eca95SGreg Farnum nl.object_size = l.object_size; 97*702aeb1fSSage Weil else 98*702aeb1fSSage Weil nl.object_size = ceph_file_layout_object_size(ci->i_layout); 99a35eca95SGreg Farnum if (l.data_pool) 100a35eca95SGreg Farnum nl.data_pool = l.data_pool; 101*702aeb1fSSage Weil else 102*702aeb1fSSage Weil nl.data_pool = ceph_file_layout_pg_pool(ci->i_layout); 103*702aeb1fSSage Weil 104*702aeb1fSSage Weil /* this is obsolete, and always -1 */ 105*702aeb1fSSage Weil nl.preferred_osd = le64_to_cpu(-1); 106a35eca95SGreg Farnum 107e49bf4c5SSage Weil err = __validate_layout(mdsc, &nl); 1088f4e91deSSage Weil if (err) 1098f4e91deSSage Weil return err; 1108f4e91deSSage Weil 1118f4e91deSSage Weil req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SETLAYOUT, 1128f4e91deSSage Weil USE_AUTH_MDS); 1138f4e91deSSage Weil if (IS_ERR(req)) 1148f4e91deSSage Weil return PTR_ERR(req); 11570b666c3SSage Weil req->r_inode = inode; 11670b666c3SSage Weil ihold(inode); 1178f4e91deSSage Weil req->r_inode_drop = CEPH_CAP_FILE_SHARED | CEPH_CAP_FILE_EXCL; 1188f4e91deSSage Weil 1198f4e91deSSage Weil req->r_args.setlayout.layout.fl_stripe_unit = 1208f4e91deSSage Weil cpu_to_le32(l.stripe_unit); 1218f4e91deSSage Weil req->r_args.setlayout.layout.fl_stripe_count = 1228f4e91deSSage Weil cpu_to_le32(l.stripe_count); 1238f4e91deSSage Weil req->r_args.setlayout.layout.fl_object_size = 1248f4e91deSSage Weil cpu_to_le32(l.object_size); 1258f4e91deSSage Weil req->r_args.setlayout.layout.fl_pg_pool = cpu_to_le32(l.data_pool); 1268f4e91deSSage Weil 1275f21c96dSSage Weil parent_inode = ceph_get_dentry_parent_inode(file->f_dentry); 1288f4e91deSSage Weil err = ceph_mdsc_do_request(mdsc, parent_inode, req); 1295f21c96dSSage Weil iput(parent_inode); 1308f4e91deSSage Weil ceph_mdsc_put_request(req); 1318f4e91deSSage Weil return err; 1328f4e91deSSage Weil } 1338f4e91deSSage Weil 1348f4e91deSSage Weil /* 135571dba52SGreg Farnum * Set a layout policy on a directory inode. All items in the tree 136571dba52SGreg Farnum * rooted at this inode will inherit this layout on creation, 137571dba52SGreg Farnum * (It doesn't apply retroactively ) 138571dba52SGreg Farnum * unless a subdirectory has its own layout policy. 139571dba52SGreg Farnum */ 140571dba52SGreg Farnum static long ceph_ioctl_set_layout_policy (struct file *file, void __user *arg) 141571dba52SGreg Farnum { 142571dba52SGreg Farnum struct inode *inode = file->f_dentry->d_inode; 143571dba52SGreg Farnum struct ceph_mds_request *req; 144571dba52SGreg Farnum struct ceph_ioctl_layout l; 145e49bf4c5SSage Weil int err; 146571dba52SGreg Farnum struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; 147571dba52SGreg Farnum 148571dba52SGreg Farnum /* copy and validate */ 149571dba52SGreg Farnum if (copy_from_user(&l, arg, sizeof(l))) 150571dba52SGreg Farnum return -EFAULT; 151571dba52SGreg Farnum 152e49bf4c5SSage Weil err = __validate_layout(mdsc, &l); 153571dba52SGreg Farnum if (err) 154571dba52SGreg Farnum return err; 155571dba52SGreg Farnum 156571dba52SGreg Farnum req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SETDIRLAYOUT, 157571dba52SGreg Farnum USE_AUTH_MDS); 158571dba52SGreg Farnum 159571dba52SGreg Farnum if (IS_ERR(req)) 160571dba52SGreg Farnum return PTR_ERR(req); 16170b666c3SSage Weil req->r_inode = inode; 16270b666c3SSage Weil ihold(inode); 163571dba52SGreg Farnum 164571dba52SGreg Farnum req->r_args.setlayout.layout.fl_stripe_unit = 165571dba52SGreg Farnum cpu_to_le32(l.stripe_unit); 166571dba52SGreg Farnum req->r_args.setlayout.layout.fl_stripe_count = 167571dba52SGreg Farnum cpu_to_le32(l.stripe_count); 168571dba52SGreg Farnum req->r_args.setlayout.layout.fl_object_size = 169571dba52SGreg Farnum cpu_to_le32(l.object_size); 170571dba52SGreg Farnum req->r_args.setlayout.layout.fl_pg_pool = 171571dba52SGreg Farnum cpu_to_le32(l.data_pool); 172571dba52SGreg Farnum 173571dba52SGreg Farnum err = ceph_mdsc_do_request(mdsc, inode, req); 174571dba52SGreg Farnum ceph_mdsc_put_request(req); 175571dba52SGreg Farnum return err; 176571dba52SGreg Farnum } 177571dba52SGreg Farnum 178571dba52SGreg Farnum /* 1798f4e91deSSage Weil * Return object name, size/offset information, and location (OSD 1808f4e91deSSage Weil * number, network address) for a given file offset. 1818f4e91deSSage Weil */ 1828f4e91deSSage Weil static long ceph_ioctl_get_dataloc(struct file *file, void __user *arg) 1838f4e91deSSage Weil { 1848f4e91deSSage Weil struct ceph_ioctl_dataloc dl; 1858f4e91deSSage Weil struct inode *inode = file->f_dentry->d_inode; 1868f4e91deSSage Weil struct ceph_inode_info *ci = ceph_inode(inode); 1873d14c5d2SYehuda Sadeh struct ceph_osd_client *osdc = 1883d14c5d2SYehuda Sadeh &ceph_sb_to_client(inode->i_sb)->client->osdc; 1898f4e91deSSage Weil u64 len = 1, olen; 1908f4e91deSSage Weil u64 tmp; 1918f4e91deSSage Weil struct ceph_object_layout ol; 19251042122SSage Weil struct ceph_pg pgid; 1938f4e91deSSage Weil 1948f4e91deSSage Weil /* copy and validate */ 1958f4e91deSSage Weil if (copy_from_user(&dl, arg, sizeof(dl))) 1968f4e91deSSage Weil return -EFAULT; 1978f4e91deSSage Weil 1988f4e91deSSage Weil down_read(&osdc->map_sem); 1998f4e91deSSage Weil ceph_calc_file_object_mapping(&ci->i_layout, dl.file_offset, &len, 2008f4e91deSSage Weil &dl.object_no, &dl.object_offset, &olen); 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); 2118f4e91deSSage Weil ceph_calc_object_layout(&ol, dl.object_name, &ci->i_layout, 2128f4e91deSSage Weil osdc->osdmap); 2138f4e91deSSage Weil 21451042122SSage Weil pgid = ol.ol_pgid; 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; 2368c6e9229SSage Weil struct inode *inode = file->f_dentry->d_inode; 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