Commit c647b8a8 authored by Ilya Dryomov's avatar Ilya Dryomov Committed by Yan, Zheng
Browse files

libceph: add support for CEPH_OSD_OP_SETALLOCHINT osd op 



This is primarily for rbd's benefit and is supposed to combat
fragmentation:

"... knowing that rbd images have a 4m size, librbd can pass a hint
that will let the osd do the xfs allocation size ioctl on new files so
that they are allocated in 1m or 4m chunks.  We've seen cases where
users with rbd workloads have very high levels of fragmentation in xfs
and this would mitigate that and probably have a pretty nice
performance benefit."

SETALLOCHINT is considered advisory, so our backwards compatibility
mechanism here is to set FAILOK flag for all SETALLOCHINT ops.

Signed-off-by: default avatarIlya Dryomov <ilya.dryomov@inktank.com>
Reviewed-by: default avatarSage Weil <sage@inktank.com>
Reviewed-by: default avatarAlex Elder <elder@linaro.org>
parent 7b25bf5f

include/linux/ceph/osd_client.h

+8 −0
Original line number Diff line number Diff line
@@ -103,6 +103,10 @@ struct ceph_osd_req_op { 
			u32 timeout;

			__u8 flag;

		} watch;

		struct {

			u64 expected_object_size;

			u64 expected_write_size;

		} alloc_hint;

	};

};
@@ -294,6 +298,10 @@ extern void osd_req_op_cls_init(struct ceph_osd_request *osd_req, 
extern void osd_req_op_watch_init(struct ceph_osd_request *osd_req,

					unsigned int which, u16 opcode,

					u64 cookie, u64 version, int flag);

extern void osd_req_op_alloc_hint_init(struct ceph_osd_request *osd_req,

				       unsigned int which,

				       u64 expected_object_size,

				       u64 expected_write_size);



extern struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc,

					       struct ceph_snap_context *snapc,

include/linux/ceph/rados.h

+7 −0
Original line number Diff line number Diff line
@@ -227,6 +227,9 @@ enum { 
	CEPH_OSD_OP_OMAPRMKEYS    = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 24,

	CEPH_OSD_OP_OMAP_CMP      = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 25,



	/* hints */

	CEPH_OSD_OP_SETALLOCHINT = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 35,



	/** multi **/

	CEPH_OSD_OP_CLONERANGE = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_MULTI | 1,

	CEPH_OSD_OP_ASSERT_SRC_VERSION = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_MULTI | 2,
@@ -416,6 +419,10 @@ struct ceph_osd_op { 
			__le64 offset, length;

			__le64 src_offset;

		} __attribute__ ((packed)) clonerange;

		struct {

			__le64 expected_object_size;

			__le64 expected_write_size;

		} __attribute__ ((packed)) alloc_hint;

	};

	__le32 payload_len;

} __attribute__ ((packed));

net/ceph/osd_client.c

+27 −0
Original line number Diff line number Diff line
@@ -436,6 +436,7 @@ static bool osd_req_opcode_valid(u16 opcode) 
	case CEPH_OSD_OP_OMAPCLEAR:

	case CEPH_OSD_OP_OMAPRMKEYS:

	case CEPH_OSD_OP_OMAP_CMP:

	case CEPH_OSD_OP_SETALLOCHINT:

	case CEPH_OSD_OP_CLONERANGE:

	case CEPH_OSD_OP_ASSERT_SRC_VERSION:

	case CEPH_OSD_OP_SRC_CMPXATTR:
@@ -591,6 +592,26 @@ void osd_req_op_watch_init(struct ceph_osd_request *osd_req, 
}

EXPORT_SYMBOL(osd_req_op_watch_init);



void osd_req_op_alloc_hint_init(struct ceph_osd_request *osd_req,

				unsigned int which,

				u64 expected_object_size,

				u64 expected_write_size)

{

	struct ceph_osd_req_op *op = _osd_req_op_init(osd_req, which,

						      CEPH_OSD_OP_SETALLOCHINT);



	op->alloc_hint.expected_object_size = expected_object_size;

	op->alloc_hint.expected_write_size = expected_write_size;



	/*

	 * CEPH_OSD_OP_SETALLOCHINT op is advisory and therefore deemed

	 * not worth a feature bit.  Set FAILOK per-op flag to make

	 * sure older osds don't trip over an unsupported opcode.

	 */

	op->flags |= CEPH_OSD_OP_FLAG_FAILOK;

}

EXPORT_SYMBOL(osd_req_op_alloc_hint_init);



static void ceph_osdc_msg_data_add(struct ceph_msg *msg,

				struct ceph_osd_data *osd_data)

{
@@ -681,6 +702,12 @@ static u64 osd_req_encode_op(struct ceph_osd_request *req, 
		dst->watch.ver = cpu_to_le64(src->watch.ver);

		dst->watch.flag = src->watch.flag;

		break;

	case CEPH_OSD_OP_SETALLOCHINT:

		dst->alloc_hint.expected_object_size =

		    cpu_to_le64(src->alloc_hint.expected_object_size);

		dst->alloc_hint.expected_write_size =

		    cpu_to_le64(src->alloc_hint.expected_write_size);

		break;

	default:

		pr_err("unsupported osd opcode %s\n",

			ceph_osd_op_name(src->op));

CRA Git | Maintained and supported by SUSTech CRA and CCSE