fs/ceph/dir.c

42 	struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dentry->d_sb);
54 	atomic64_inc(&mdsc->metric.total_dentries);
322 	struct ceph_mds_client *mdsc = fsc->mdsc;
365 	__ceph_touch_fmode(ci, mdsc, CEPH_FILE_MODE_WR);
408 		req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS);
456 		err = ceph_mdsc_do_request(mdsc, NULL, req);
800 	struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb);
840 			__ceph_touch_fmode(ci, mdsc, CEPH_FILE_MODE_RD);
853 	req = ceph_mdsc_create_request(mdsc, op, USE_ANY_MDS);
867 	err = ceph_mdsc_do_request(mdsc, NULL, req);
915 	struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb);
916 	struct ceph_client *cl = mdsc->fsc->client;
935 	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_MKNOD, USE_AUTH_MDS);
965 	err = ceph_mdsc_do_request(mdsc, dir, req);
1025 	struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb);
1026 	struct ceph_client *cl = mdsc->fsc->client;
1046 	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SYMLINK, USE_AUTH_MDS);
1084 	err = ceph_mdsc_do_request(mdsc, dir, req);
1099 	struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb);
1100 	struct ceph_client *cl = mdsc->fsc->client;
1136 	req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS);
1164 	err = ceph_mdsc_do_request(mdsc, dir, req);
1183 	struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb);
1184 	struct ceph_client *cl = mdsc->fsc->client;
1204 	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LINK, USE_AUTH_MDS);
1225 	err = ceph_mdsc_do_request(mdsc, dir, req);
1236 static void ceph_async_unlink_cb(struct ceph_mds_client *mdsc,
1269 		char *path = ceph_mdsc_build_path(mdsc, dentry, &pathlen,
1335 	struct ceph_mds_client *mdsc = fsc->mdsc;
1355 	req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS);
1389 		err = ceph_mdsc_submit_request(mdsc, dir, req);
1414 		err = ceph_mdsc_do_request(mdsc, dir, req);
1428 	struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(old_dir->i_sb);
1429 	struct ceph_client *cl = mdsc->fsc->client;
1462 	req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS);
1483 	err = ceph_mdsc_do_request(mdsc, old_dir, req);
1497  * Move dentry to tail of mdsc->dentry_leases list when lease is updated.
1506 	struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dn->d_sb)->mdsc;
1507 	struct ceph_client *cl = mdsc->fsc->client;
1517 	spin_lock(&mdsc->dentry_list_lock);
1518 	list_move_tail(&di->lease_list, &mdsc->dentry_leases);
1519 	spin_unlock(&mdsc->dentry_list_lock);
1522 static void __dentry_dir_lease_touch(struct ceph_mds_client* mdsc,
1528 	list_move_tail(&di->lease_list, &mdsc->dentry_dir_leases);
1532  * When dir lease is used, add dentry to tail of mdsc->dentry_dir_leases
1540 	struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dn->d_sb)->mdsc;
1541 	struct ceph_client *cl = mdsc->fsc->client;
1563 	spin_lock(&mdsc->dentry_list_lock);
1564 	__dentry_dir_lease_touch(mdsc, di),
1565 	spin_unlock(&mdsc->dentry_list_lock);
1570 	struct ceph_mds_client *mdsc;
1576 	mdsc = ceph_sb_to_fs_client(di->dentry->d_sb)->mdsc;
1577 	spin_lock(&mdsc->dentry_list_lock);
1579 	spin_unlock(&mdsc->dentry_list_lock);
1600 __dentry_leases_walk(struct ceph_mds_client *mdsc,
1610 	list = lwc->dir_lease ? &mdsc->dentry_dir_leases : &mdsc->dentry_leases;
1611 	spin_lock(&mdsc->dentry_list_lock);
1635 			__dentry_dir_lease_touch(mdsc, di);
1659 	spin_unlock(&mdsc->dentry_list_lock);
1670 			spin_lock(&mdsc->dentry_list_lock);
1673 					      &mdsc->dentry_leases);
1675 				__dentry_dir_lease_touch(mdsc, di);
1677 			spin_unlock(&mdsc->dentry_list_lock);
1729 int ceph_trim_dentries(struct ceph_mds_client *mdsc)
1735 	spin_lock(&mdsc->caps_list_lock);
1736         if (mdsc->caps_use_max > 0 &&
1737             mdsc->caps_use_count > mdsc->caps_use_max)
1738 		count = mdsc->caps_use_count - mdsc->caps_use_max;
1741         spin_unlock(&mdsc->caps_list_lock);
1745 	freed = __dentry_leases_walk(mdsc, &lwc);
1754 	lwc.dir_lease_ttl = mdsc->fsc->mount_options->caps_wanted_delay_max * HZ;
1755 	freed +=__dentry_leases_walk(mdsc, &lwc);
1808 	struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dentry->d_sb)->mdsc;
1809 	struct ceph_client *cl = mdsc->fsc->client;
1882 			      struct ceph_mds_client *mdsc)
1885 	struct ceph_client *cl = mdsc->fsc->client;
1892 		__ceph_touch_fmode(ci, mdsc, CEPH_FILE_MODE_RD);
1918 	struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dentry->d_sb)->mdsc;
1919 	struct ceph_client *cl = mdsc->fsc->client;
1944 	mdsc = ceph_sb_to_fs_client(dir->i_sb)->mdsc;
1957 		if (valid || dir_lease_is_valid(dir, dentry, mdsc)) {
1973 		percpu_counter_inc(&mdsc->metric.d_lease_mis);
1977 		req = ceph_mdsc_create_request(mdsc, op, USE_ANY_MDS);
1989 			err = ceph_mdsc_do_request(mdsc, NULL, req);
2008 		percpu_counter_inc(&mdsc->metric.d_lease_hit);
2055 	atomic64_dec(&fsc->mdsc->metric.total_dentries);
2074 	struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dentry->d_sb);
2075 	struct ceph_client *cl = mdsc->fsc->client;