From 36943e07aac0e54a1b10579640fc970cd3f2f60f Mon Sep 17 00:00:00 2001 From: wzd Date: Sat, 28 Dec 2024 17:55:30 +0800 Subject: [PATCH] =?UTF-8?q?seq=20ack=E6=B6=88=E6=81=AF=E4=B8=BA=E9=9B=B6?= =?UTF-8?q?=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/dcs/dcs_page.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/dcs/dcs_page.c b/src/dcs/dcs_page.c index 22d1973..f7ff032 100644 --- a/src/dcs/dcs_page.c +++ b/src/dcs/dcs_page.c @@ -628,9 +628,9 @@ void dcs_proc_try_ask_master_for_page_owner_id(dms_process_context_t *ctx, dms_m if (result.type == DRC_REQ_OWNER_GRANTED) { // this page_req not in memory of other instance, notify requester to load from disk dms_ask_res_ack_ld_t ack; - ack.head.seq = result.seq; dms_init_ack_head(&page_req.head, &ack.head, MSG_ACK_GRANT_OWNER, sizeof(dms_ask_res_ack_ld_t), ctx->sess_id); + ack.head.seq = result.seq; #ifndef OPENGAUSS ack.scn = g_dms.callback.get_global_scn(ctx->db_handle); ack.master_lsn = g_dms.callback.get_global_lsn(ctx->db_handle); @@ -642,9 +642,9 @@ void dcs_proc_try_ask_master_for_page_owner_id(dms_process_context_t *ctx, dms_m } else if (result.type == DRC_REQ_OWNER_ALREADY_OWNER) { // asker is already owner, just notify requester(owner) page_req is ready dms_already_owner_ack_t ack; - ack.head.seq = result.seq; dms_init_ack_head(&page_req.head, &ack.head, MSG_ACK_ALREADY_OWNER, sizeof(dms_already_owner_ack_t), ctx->sess_id); + ack.head.seq = result.seq; #ifndef OPENGAUSS ack.scn = g_dms.callback.get_global_scn(ctx->db_handle); #endif -- Gitee