Commit 2731f526 authored by Tomasz Zawadzki's avatar Tomasz Zawadzki
Browse files

lib/blob: add md page parameter to _spdk_bs_load_replay_md_parse_page() 



Further part of the series will hold array of md pages
in the ctx. Callers of _spdk_bs_load_replay_md_parse_page()
will make select which page to parse.

Signed-off-by: default avatarTomasz Zawadzki <tomasz.zawadzki@intel.com>
Change-Id: I3fb70660672ba74bdb338eb1233409103903b215
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/983


Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarJim Harris <james.r.harris@intel.com>
Reviewed-by: default avatarShuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
parent 2a51c755

lib/blob/blobstore.c

+3 −4
Original line number Diff line number Diff line
@@ -3608,10 +3608,9 @@ _spdk_bs_load_read_used_pages(struct spdk_bs_load_ctx *ctx) 
}



static int

_spdk_bs_load_replay_md_parse_page(struct spdk_bs_load_ctx *ctx)

_spdk_bs_load_replay_md_parse_page(struct spdk_bs_load_ctx *ctx, struct spdk_blob_md_page *page)

{

	struct spdk_blob_store *bs = ctx->bs;

	struct spdk_blob_md_page *page = ctx->page;

	struct spdk_blob_md_descriptor *desc;

	size_t	cur_desc = 0;
@@ -3907,7 +3906,7 @@ _spdk_bs_load_replay_extent_page_cpl(spdk_bs_sequence_t *seq, void *cb_arg, int 


	page_num = ctx->extent_pages[ctx->num_extent_pages - 1];

	spdk_bit_array_set(ctx->bs->used_md_pages, page_num);

	if (_spdk_bs_load_replay_md_parse_page(ctx)) {

	if (_spdk_bs_load_replay_md_parse_page(ctx, ctx->page)) {

		_spdk_bs_load_ctx_fail(ctx, -EILSEQ);

		return;

	}
@@ -3957,7 +3956,7 @@ _spdk_bs_load_replay_md_cpl(spdk_bs_sequence_t *seq, void *cb_arg, int bserrno) 
			if (page->sequence_num == 0) {

				spdk_bit_array_set(ctx->bs->used_blobids, page_num);

			}

			if (_spdk_bs_load_replay_md_parse_page(ctx)) {

			if (_spdk_bs_load_replay_md_parse_page(ctx, page)) {

				_spdk_bs_load_ctx_fail(ctx, -EILSEQ);

				return;

			}