fs/ceph/mds_client.c

24 #include <linux/ceph/pagelist.h>
58 	struct ceph_pagelist *pagelist;
3217 		struct ceph_pagelist *pagelist = req->r_pagelist;
3218 		ceph_msg_data_add_pagelist(msg, pagelist);
3219 		msg->hdr.data_len = cpu_to_le32(pagelist->length);
4373 	/* pre-allocate new pagelist */
4389 		err = ceph_pagelist_encode_32(recon_state->pagelist, 0);
4399 	err = ceph_pagelist_encode_8(recon_state->pagelist, 1);
4403 	page = list_first_entry(&recon_state->pagelist->head, struct page, lru);
4417 	reply->hdr.data_len = cpu_to_le32(recon_state->pagelist->length);
4418 	ceph_msg_data_add_pagelist(reply, recon_state->pagelist);
4421 	ceph_pagelist_release(recon_state->pagelist);
4423 	recon_state->pagelist = _pagelist;
4481 	struct ceph_pagelist *pagelist = recon_state->pagelist;
4604 		 * number of encoded locks is stable, so copy to pagelist
4618 		if (pagelist->length + total_len > RECONNECT_MAX_SIZE) {
4622 			pagelist = recon_state->pagelist;
4625 		err = ceph_pagelist_reserve(pagelist, total_len);
4629 		ceph_pagelist_encode_64(pagelist, ceph_ino(inode));
4631 			ceph_pagelist_encode_8(pagelist, struct_v);
4632 			ceph_pagelist_encode_8(pagelist, 1);
4633 			ceph_pagelist_encode_32(pagelist, struct_len);
4635 		ceph_pagelist_encode_string(pagelist, path, pathlen);
4636 		ceph_pagelist_append(pagelist, &rec, sizeof(rec.v2));
4637 		ceph_locks_to_pagelist(flocks, pagelist,
4640 			ceph_pagelist_encode_64(pagelist, snap_follows);
4644 		err = ceph_pagelist_reserve(pagelist,
4650 		ceph_pagelist_encode_64(pagelist, ceph_ino(inode));
4651 		ceph_pagelist_encode_string(pagelist, path, pathlen);
4652 		ceph_pagelist_append(pagelist, &rec, sizeof(rec.v1));
4666 	struct ceph_pagelist *pagelist = recon_state->pagelist;
4671 		err = ceph_pagelist_encode_32(pagelist, mdsc->num_snap_realms);
4690 			if (pagelist->length + need > RECONNECT_MAX_SIZE) {
4694 				pagelist = recon_state->pagelist;
4697 			err = ceph_pagelist_reserve(pagelist, need);
4701 			ceph_pagelist_encode_8(pagelist, 1);
4702 			ceph_pagelist_encode_8(pagelist, 1);
4703 			ceph_pagelist_encode_32(pagelist, sizeof(sr_rec));
4712 		err = ceph_pagelist_append(pagelist, &sr_rec, sizeof(sr_rec));
4747 	recon_state.pagelist = ceph_pagelist_alloc(GFP_NOFS);
4748 	if (!recon_state.pagelist)
4797 	err = ceph_pagelist_encode_32(recon_state.pagelist, 0);
4822 			recon_state.pagelist->length +
4851 		err = ceph_pagelist_encode_8(recon_state.pagelist, 0);
4858 			list_first_entry(&recon_state.pagelist->head,
4874 	reply->hdr.data_len = cpu_to_le32(recon_state.pagelist->length);
4875 	ceph_msg_data_add_pagelist(reply, recon_state.pagelist);
4886 	ceph_pagelist_release(recon_state.pagelist);
4894 	ceph_pagelist_release(recon_state.pagelist);