osaf/libs/agents/saf/cpa/cpa_mds.c | 10 +-
osaf/libs/agents/saf/cpa/cpa_proc.c | 4 +
osaf/libs/common/cpsv/cpsv_evt.c | 838 +++++++++++++++++++++++++++++++
osaf/libs/common/cpsv/include/cpsv_evt.h | 2 +
osaf/services/saf/cpsv/cpd/cpd_db.c | 1 +
osaf/services/saf/cpsv/cpd/cpd_evt.c | 3 +
osaf/services/saf/cpsv/cpd/cpd_mds.c | 24 +-
osaf/services/saf/cpsv/cpd/cpd_proc.c | 3 +-
osaf/services/saf/cpsv/cpnd/cpnd_evt.c | 9 +-
osaf/services/saf/cpsv/cpnd/cpnd_mds.c | 32 +-
10 files changed, 918 insertions(+), 8 deletions(-)
diff --git a/osaf/libs/agents/saf/cpa/cpa_mds.c
b/osaf/libs/agents/saf/cpa/cpa_mds.c
--- a/osaf/libs/agents/saf/cpa/cpa_mds.c
+++ b/osaf/libs/agents/saf/cpa/cpa_mds.c
@@ -763,11 +763,16 @@ uint32_t cpa_mds_msg_sync_send(uint32_t
mds_info.info.svc_send.info.sndrsp.i_time_to_wait = timeout; /*
timeto wait in 10ms */
mds_info.info.svc_send.info.sndrsp.i_to_dest = *destination;
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpa ==>> %s to node 0x%X", cpsv_evt_str(i_evt, evt_str,
MAX_EVT_STR_LEN), m_NCS_NODE_ID_FROM_MDS_DEST(*destination));
+
/* send the message */
rc = ncsmds_api(&mds_info);
- if (rc == NCSCC_RC_SUCCESS)
+ if (rc == NCSCC_RC_SUCCESS) {
*o_evt = mds_info.info.svc_send.info.sndrsp.o_rsp;
+ TRACE("cpa <<== %s from node 0x%X", cpsv_evt_str(*o_evt,
evt_str, MAX_EVT_STR_LEN), m_NCS_NODE_ID_FROM_MDS_DEST(*destination));
+ }
TRACE_LEAVE2("retval = %u",rc);
return rc;
@@ -810,6 +815,9 @@ uint32_t cpa_mds_msg_send(uint32_t cpa_m
/* fill the send rsp strcuture */
mds_info.info.svc_send.info.snd.i_to_dest = *destination;
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpa ==>> %s to node 0x%X", cpsv_evt_str(i_evt, evt_str,
MAX_EVT_STR_LEN), m_NCS_NODE_ID_FROM_MDS_DEST(*destination));
+
/* send the message */
rc = ncsmds_api(&mds_info);
diff --git a/osaf/libs/agents/saf/cpa/cpa_proc.c
b/osaf/libs/agents/saf/cpa/cpa_proc.c
--- a/osaf/libs/agents/saf/cpa/cpa_proc.c
+++ b/osaf/libs/agents/saf/cpa/cpa_proc.c
@@ -732,6 +732,10 @@ static void cpa_proc_active_nd_down_bcas
uint32_t cpa_process_evt(CPA_CB *cb, CPSV_EVT *evt)
{
uint32_t rc = NCSCC_RC_SUCCESS;
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+
+ TRACE("cpa <<== %s from node 0x%X", cpsv_evt_str(evt, evt_str,
MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(evt->sinfo.dest));
TRACE_ENTER();
switch (evt->info.cpa.type) {
diff --git a/osaf/libs/common/cpsv/cpsv_evt.c b/osaf/libs/common/cpsv/cpsv_evt.c
--- a/osaf/libs/common/cpsv/cpsv_evt.c
+++ b/osaf/libs/common/cpsv/cpsv_evt.c
@@ -29,11 +29,849 @@
*/
#include "cpsv.h"
+#include "cpa_tmr.h"
FUNC_DECLARATION(CPSV_CKPT_DATA);
static SaCkptSectionIdT *cpsv_evt_dec_sec_id(NCS_UBAID *i_ub, uint32_t svc_id);
static uint32_t cpsv_evt_enc_sec_id(NCS_UBAID *o_ub, SaCkptSectionIdT *sec_id);
+const char *cpa_evt_str[] = {
+ "STRING_0",
+
+ /* Locally generated events */
+ "CPA_EVT_MDS_INFO", /* CPND UP/DOWN Info */
+ "CPA_EVT_TIME_OUT", /* Time out events at CPA */
+
+ /* Events from CPND */
+
+ "CPA_EVT_ND2A_CKPT_INIT_RSP",
+ "CPA_EVT_ND2A_CKPT_FINALIZE_RSP",
+ "CPA_EVT_ND2A_CKPT_OPEN_RSP",
+ "CPA_EVT_ND2A_CKPT_CLOSE_RSP",
+ "CPA_EVT_ND2A_CKPT_UNLINK_RSP",
+ "CPA_EVT_ND2A_CKPT_RDSET_RSP",
+ "CPA_EVT_ND2A_CKPT_AREP_SET_RSP",
+ "CPA_EVT_ND2A_CKPT_STATUS",
+
+ "CPA_EVT_ND2A_SEC_CREATE_RSP",
+ "CPA_EVT_ND2A_SEC_DELETE_RSP",
+ "CPA_EVT_ND2A_SEC_EXPTIME_RSP",
+ "CPA_EVT_ND2A_SEC_ITER_RSP",
+ "CPA_EVT_ND2A_SEC_ITER_GETNEXT_RSP",
+
+ "CPA_EVT_ND2A_CKPT_ARRIVAL_NTFY",
+
+ "CPA_EVT_ND2A_CKPT_DATA_RSP",
+
+ "CPA_EVT_ND2A_CKPT_SYNC_RSP",
+ "CPA_EVT_D2A_ACT_CKPT_INFO_BCAST_SEND",
+ "CPA_EVT_ND2A_CKPT_READ_ACK_RSP",
+ "CPA_EVT_ND2A_CKPT_BCAST_SEND",
+ "CPA_EVT_D2A_NDRESTART",
+ "CPA_EVT_CB_DUMP",
+ "CPA_EVT_ND2A_CKPT_CLM_NODE_LEFT",
+ "CPA_EVT_ND2A_CKPT_CLM_NODE_JOINED",
+ "CPA_EVT_ND2A_ACT_CKPT_INFO_BCAST_SEND",
+};
+
+const char* cpnd_evt_str[] = {
+ /* events from CPA to CPND */
+ "CPND_EVT_BASE = 1",
+
+ /* Locally generated events */
+ "CPND_EVT_MDS_INFO", /* CPA/CPND/CPD UP/DOWN Info */
+ "CPND_EVT_TIME_OUT", /* Time out event */
+
+ /* Events from CPA */
+
+ "CPND_EVT_A2ND_CKPT_INIT", /* Checkpoint Initialization */
+ "CPND_EVT_A2ND_CKPT_FINALIZE", /* Checkpoint finalization */
+ "CPND_EVT_A2ND_CKPT_OPEN", /* Checkpoint Open Request */
+ "CPND_EVT_A2ND_CKPT_CLOSE", /* Checkpoint Close Call */
+ "CPND_EVT_A2ND_CKPT_UNLINK", /* Checkpoint Unlink Call */
+ "CPND_EVT_A2ND_CKPT_RDSET", /* Checkpoint Retention duration set
call */
+ "CPND_EVT_A2ND_CKPT_AREP_SET", /* Checkpoint Active Replica Set Call */
+ "CPND_EVT_A2ND_CKPT_STATUS_GET", /* Checkpoint Status Get Call */
+
+ "CPND_EVT_A2ND_CKPT_SECT_CREATE", /* Checkpoint Section Create
Call */
+ "CPND_EVT_A2ND_CKPT_SECT_DELETE", /* Checkpoint Section Delete
Call */
+ "CPND_EVT_A2ND_CKPT_SECT_EXP_SET", /* Checkpoint Section Expiry
Time Set Call */
+ "CPND_EVT_A2ND_CKPT_SECT_ITER_REQ", /*Checkpoint Section iteration
initialize */
+
+ "CPND_EVT_A2ND_CKPT_ITER_GETNEXT", /* Checkpoint Section
Iternation Getnext Call */
+
+ "CPND_EVT_A2ND_ARRIVAL_CB_REG", /* Checkpoint Arrival Callback
Register*/
+
+ "CPND_EVT_A2ND_CKPT_WRITE", /* Checkpoint Write And overwrite call
*/
+ "CPND_EVT_A2ND_CKPT_READ", /* Checkpoint Read Call */
+ "CPND_EVT_A2ND_CKPT_SYNC", /* Checkpoint Synchronize call */
+
+ "CPND_EVT_A2ND_CKPT_READ_ACK", /* read ack */
+
+ /* Events from other CPND */
+
+/* ckpt status information from active */
+
+ "CPND_EVT_ND2ND_ACTIVE_STATUS", /* ckpt status info from active */
+ "CPND_EVT_ND2ND_ACTIVE_STATUS_ACK", /* ckpt status ack from active
*/
+
+ "CPND_EVT_ND2ND_CKPT_SYNC_REQ", /* rqst from ND to ND(A) to sync ckpt */
+ "CPND_EVT_ND2ND_CKPT_ACTIVE_SYNC", /* CPND(A) sync updts to All
the Ckpts */
+/* Section Create Stuff.... */
+
+ "CPSV_EVT_ND2ND_CKPT_SECT_CREATE_REQ",
+ "CPSV_EVT_ND2ND_CKPT_SECT_CREATE_RSP",
+ "CPSV_EVT_ND2ND_CKPT_SECT_ACTIVE_CREATE_RSP",
+
+ "CPSV_EVT_ND2ND_CKPT_SECT_DELETE_REQ",
+ "CPSV_EVT_ND2ND_CKPT_SECT_DELETE_RSP",
+
+ "CPSV_EVT_ND2ND_CKPT_SECT_EXPTMR_REQ",
+ "CPSV_EVT_ND2ND_CKPT_SECT_EXPTMR_RSP",
+
+ "CPSV_EVT_ND2ND_CKPT_SECT_DATA_ACCESS_REQ", /* for
write,read,overwrite */
+ "CPSV_EVT_ND2ND_CKPT_SECT_ACTIVE_DATA_ACCESS_REQ",
+ "CPSV_EVT_ND2ND_CKPT_SECT_ACTIVE_DATA_ACCESS_RSP",
+
+ /* Events from CPD to CPND */
+
+ "CPND_EVT_D2ND_CKPT_INFO", /* Rsp to the ckpt open call */
+ "CPND_EVT_D2ND_CKPT_SIZE",
+ "CPND_EVT_D2ND_CKPT_REP_ADD", /* ckpt open is propogated to other NDs
*/
+ "CPND_EVT_D2ND_CKPT_REP_DEL", /* ckpt close is propogated to other
NDs */
+
+ "CPSV_D2ND_RESTART", /* for cpnd redundancy */
+ "CPSV_D2ND_RESTART_DONE", /* for cpnd redundancy */
+
+ "CPND_EVT_D2ND_CKPT_CREATE", /* ckpt create evt for Non-collocated */
+ "CPND_EVT_D2ND_CKPT_DESTROY", /* The ckpt destroy evt for Non-colloc
*/
+ "CPND_EVT_D2ND_CKPT_DESTROY_ACK",
+ "CPND_EVT_D2ND_CKPT_CLOSE_ACK", /* Rsps to ckpt close call */
+ "CPND_EVT_D2ND_CKPT_UNLINK", /* Unlink info */
+ "CPND_EVT_D2ND_CKPT_UNLINK_ACK", /* Rsps to ckpt unlink call */
+ "CPND_EVT_D2ND_CKPT_RDSET", /* Retention duration to set */
+ "CPND_EVT_D2ND_CKPT_RDSET_ACK", /* Retention duration Ack */
+ "CPND_EVT_D2ND_CKPT_ACTIVE_SET", /* for colloc ckpts,mark the
Active */
+ "CPND_EVT_D2ND_CKPT_ACTIVE_SET_ACK", /* Ack for active replica set
rqst */
+
+ "CPND_EVT_ND2ND_CKPT_ITER_NEXT_REQ",
+ "CPND_EVT_ND2ND_CKPT_ACTIVE_ITERNEXT",
+
+ "CPND_EVT_CB_DUMP",
+
+ "CPND_EVT_D2ND_CKPT_NUM_SECTIONS",
+ "CPND_EVT_A2ND_CKPT_REFCNTSET", /* ref cont opener's set call */
+ "CPND_EVT_A2ND_CKPT_LIST_UPDATE", /* Checkpoint ckpt list update Call */
+ "CPND_EVT_A2ND_ARRIVAL_CB_UNREG", /* Checkpoint Arrival Callback
Un-Register*/
+};
+
+const char* cpd_evt_str[] = {
+ "CPD_EVT_BASE = 1",
+
+ /* Locally generated Events */
+ "CPD_EVT_MDS_INFO",
+
+ /* Events from CPND */
+ "CPD_EVT_ND2D_CKPT_CREATE",
+ "CPD_EVT_ND2D_CKPT_UNLINK",
+ "CPD_EVT_ND2D_CKPT_RDSET",
+ "CPD_EVT_ND2D_ACTIVE_SET",
+ "CPD_EVT_ND2D_CKPT_CLOSE",
+ "CPD_EVT_ND2D_CKPT_DESTROY",
+ "CPD_EVT_ND2D_CKPT_USR_INFO",
+ "CPD_EVT_ND2D_CKPT_SYNC_INFO",
+ "CPD_EVT_ND2D_CKPT_SEC_INFO_UPD",
+ "CPD_EVT_ND2D_CKPT_MEM_USED",
+ "CPD_EVT_CB_DUMP",
+ "CPD_EVT_MDS_QUIESCED_ACK_RSP",
+ "CPD_EVT_ND2D_CKPT_DESTROY_BYNAME",
+ "CPD_EVT_ND2D_CKPT_CREATED_SECTIONS",
+ "CPD_EVT_TIME_OUT",
+};
+
+/****************************************************************************\
+ PROCEDURE NAME : cpsv_evt_str
+
+ DESCRIPTION : This routine will return the event string from the event
+
+ ARGUMENTS : evt : event .
+
+ RETURNS : None
+
+ NOTES :
+\*****************************************************************************/
+char* cpsv_evt_str(CPSV_EVT *evt, char *o_evt_str, size_t len)
+{
+ if (evt == NULL)
+ return "Invalid evt";
+
+ if (o_evt_str == NULL)
+ return "Invalid o_evt_str";
+
+ switch (evt->type) {
+ case CPSV_EVT_TYPE_CPND:
+ switch (evt->info.cpnd.type) {
+ case CPND_EVT_MDS_INFO:
+ {
+ CPSV_MDS_INFO *info = &evt->info.cpnd.info.mds_info;
+ snprintf(o_evt_str, len,
"CPND_EVT_MDS_INFO(node_id=0x%X, svc=%s(%u) - %s(%u))",
+ info->node_id,
+ info->svc_id == NCSMDS_SVC_ID_CPA ? "CPA" :
+ info->svc_id == NCSMDS_SVC_ID_CPND ? "CPND" :
+ info->svc_id == NCSMDS_SVC_ID_CPD ? "CPD" :
"OTHER",
+ info->svc_id,
+ info->change == NCSMDS_NO_ACTIVE ? "NO_ACT" :
+ info->change == NCSMDS_NEW_ACTIVE ? "NEW_ACT" :
+ info->change == NCSMDS_UP ? "UP" :
+ info->change == NCSMDS_DOWN ? "DOWN" :
+ info->change == NCSMDS_RED_UP ? "RED_UP" :
+ info->change == NCSMDS_RED_DOWN ? "RED_DOWN" :
+ info->change == NCSMDS_CHG_ROLE ? "CHG_ROLE" :
"OTHER",
+ info->change);
+ break;
+ }
+ case CPND_EVT_TIME_OUT:
+ {
+ CPND_TMR_INFO *info = &evt->info.cpnd.info.tmr_info;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_TIME_OUT(type=%s(%u))", info->ckpt_id,
+ info->type == CPND_TMR_TYPE_RETENTION ?
"RETENTION" :
+ info->type == CPND_TMR_TYPE_SEC_EXPI ?
"SEC_EXPI" :
+ info->type == CPND_ALL_REPL_RSP_EXPI ?
"REPL_RSP_EXPI" :
+ info->type == CPND_TMR_OPEN_ACTIVE_SYNC ?
"OPEN_ACTIVE_SYNC" :
+ info->type ==
CPND_TMR_TYPE_NON_COLLOC_RETENTION ? "NON_COL_RETENTION" : "INVALID",
+ info->type);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_INIT:
+ snprintf(o_evt_str, len, "CPND_EVT_A2ND_CKPT_INIT");
+ break;
+ case CPND_EVT_A2ND_CKPT_FINALIZE:
+ {
+ snprintf(o_evt_str, len,
"CPND_EVT_A2ND_CKPT_FINALIZE(hdl=%llu)", evt->info.cpnd.info.finReq.client_hdl);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_OPEN:
+ {
+ CPSV_A2ND_OPEN_REQ *info = &evt->info.cpnd.info.openReq;
+ snprintf(o_evt_str, len,
"CPND_EVT_A2ND_CKPT_OPEN(hdl=%llu, %s)",
+ info->client_hdl, info->ckpt_name.value);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_CLOSE:
+ {
+ CPSV_A2ND_CKPT_CLOSE *info =
&evt->info.cpnd.info.closeReq;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_CLOSE(hdl=%llu, flags=0x%X)",
+ info->ckpt_id, info->client_hdl,
info->ckpt_flags);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_UNLINK:
+ {
+ CPSV_A2ND_CKPT_UNLINK *info =
&evt->info.cpnd.info.ulinkReq;
+ snprintf(o_evt_str, len,
"CPND_EVT_A2ND_CKPT_UNLINK(%s)", info->ckpt_name.value);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_RDSET:
+ {
+ CPSV_A2ND_RDSET *info = &evt->info.cpnd.info.rdsetReq;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_RDSET(reten_time=%llu)", info->ckpt_id, info->reten_time);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_AREP_SET:
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_AREP_SET", evt->info.cpnd.info.arsetReq.ckpt_id);
+ break;
+ case CPND_EVT_A2ND_CKPT_STATUS_GET:
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_STATUS_GET", evt->info.cpnd.info.statReq.ckpt_id);
+ break;
+ case CPND_EVT_A2ND_CKPT_SECT_CREATE:
+ {
+ CPSV_CKPT_SECT_CREATE *info =
&evt->info.cpnd.info.sec_creatReq;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_SECT_CREATE(sec_id=%s, mdest=%lX)",
+ info->ckpt_id, info->sec_attri.sectionId->id,
info->agent_mdest);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_SECT_DELETE:
+ {
+ CPSV_A2ND_SECT_DELETE *info =
&evt->info.cpnd.info.sec_delReq;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_SECT_DELETE(sec_id=%s)",
+ info->ckpt_id, info->sec_id.id);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_SECT_EXP_SET:
+ {
+ CPSV_A2ND_SECT_EXP_TIME *info =
&evt->info.cpnd.info.sec_expset;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_SECT_EXP_SET(sec_id=%s, exp_time=%llu)",
+ info->ckpt_id, info->sec_id.id, info->exp_time);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_SECT_ITER_REQ:
+ {
+ CPSV_CKPT_STATUS_GET *info =
&evt->info.cpnd.info.sec_iter_req;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_SECT_ITER_REQ", info->ckpt_id );
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_ITER_GETNEXT:
+ {
+ CPSV_A2ND_SECT_ITER_GETNEXT *info =
&evt->info.cpnd.info.iter_getnext;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_ITER_GETNEXT(sec_id=%s, filter=%s, n_secs_trav=%u,
exp_tmr=%llu)",
+ info->ckpt_id, info->section_id.id,
+ info->filter == SA_CKPT_SECTIONS_FOREVER ?
"FOREVER" :
+ info->filter ==
SA_CKPT_SECTIONS_LEQ_EXPIRATION_TIME ? "LEQ_EX_TIME" :
+ info->filter ==
SA_CKPT_SECTIONS_GEQ_EXPIRATION_TIME ? "GEQ_EX_TIME" :
+ info->filter == SA_CKPT_SECTIONS_CORRUPTED ?
"CORRUPTED" :
+ info->filter == SA_CKPT_SECTIONS_ANY ? "ANY" :
"INVALID",
+ info->n_secs_trav, info->exp_tmr);
+ break;
+ }
+ case CPND_EVT_A2ND_ARRIVAL_CB_REG:
+ snprintf(o_evt_str, len,
"CPND_EVT_A2ND_ARRIVAL_CB_REG(hdl=%llu)",
evt->info.cpnd.info.arr_ntfy.client_hdl);
+ break;
+ case CPND_EVT_A2ND_CKPT_WRITE:
+ {
+ CPSV_CKPT_ACCESS *info =
&evt->info.cpnd.info.ckpt_write;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_WRITE(type=%s(%d))", info->ckpt_id,
+ info->type == CPSV_CKPT_ACCESS_WRITE ? "WRITE" :
+ info->type == CPSV_CKPT_ACCESS_OVWRITE ?
"OVWRITE" : "INVALID",
+ info->type);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_READ:
+ {
+ CPSV_CKPT_ACCESS *info = &evt->info.cpnd.info.ckpt_read;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_READ()", info->ckpt_id);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_SYNC:
+ {
+ CPSV_A2ND_CKPT_SYNC *info =
&evt->info.cpnd.info.ckpt_sync;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_A2ND_CKPT_SYNC(hdl=%llu, open=%s)",
+ info->ckpt_id, info->client_hdl,
info->is_ckpt_open ? "true" : "false");
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_READ_ACK:
+ /* This message is not used */
+ snprintf(o_evt_str, len, "CPND_EVT_A2ND_CKPT_READ_ACK");
+ break;
+ case CPND_EVT_ND2ND_ACTIVE_STATUS:
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_ND2ND_ACTIVE_STATUS", evt->info.cpnd.info.stat_get.ckpt_id);
+ break;
+ case CPND_EVT_ND2ND_ACTIVE_STATUS_ACK:
+ {
+ CPSV_CKPT_STATUS *info = &evt->info.cpnd.info.status;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_ND2ND_ACTIVE_STATUS_ACK(err=%u, mem_used=%llu, "
+ "n_secs=%u, ckpt_size=%llu, reten=%llu,
max_sec=%u)", info->ckpt_id, info->error,
+ info->status.memoryUsed,
info->status.numberOfSections,
+
info->status.checkpointCreationAttributes.checkpointSize,
+
info->status.checkpointCreationAttributes.retentionDuration,
+
info->status.checkpointCreationAttributes.maxSections);
+ break;
+ }
+ case CPND_EVT_ND2ND_CKPT_SYNC_REQ:
+ {
+ CPSV_A2ND_CKPT_SYNC *info =
&evt->info.cpnd.info.sync_req;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_ND2ND_CKPT_SYNC_REQ(hdl=%llu, open=%s)",
+ info->ckpt_id, info->client_hdl,
info->is_ckpt_open ? "true" : "false");
+ break;
+ }
+ case CPND_EVT_ND2ND_CKPT_ACTIVE_SYNC:
+ {
+ CPSV_CKPT_ACCESS *info =
&evt->info.cpnd.info.ckpt_nd2nd_sync;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_ND2ND_CKPT_ACTIVE_SYNC(seq_no=%u, last_seq=%u, is_open=%s)",
+ info->ckpt_id, info->seqno, info->last_seq,
info->ckpt_sync.is_ckpt_open == true ? "true" : "false");
+ break;
+ }
+ case CPSV_EVT_ND2ND_CKPT_SECT_CREATE_REQ:
+ {
+ CPSV_CKPT_SECT_CREATE *info =
&evt->info.cpnd.info.active_sec_creat;
+ snprintf(o_evt_str, len, "[%llu]
CPSV_EVT_ND2ND_CKPT_SECT_CREATE_REQ(sec_id=%s)",
+ info->ckpt_id, info->sec_attri.sectionId->id);
+ break;
+ }
+ case CPSV_EVT_ND2ND_CKPT_SECT_CREATE_RSP:
+ {
+ CPSV_CKPT_SECT_INFO *info =
&evt->info.cpnd.info.active_sec_creat_rsp;
+ snprintf(o_evt_str, len, "[%llu]
CPSV_EVT_ND2ND_CKPT_SECT_CREATE_RSP(err=%u, sec_id=%s)",
+ info->ckpt_id, info->error, info->sec_id.id);
+ break;
+ }
+ case CPSV_EVT_ND2ND_CKPT_SECT_ACTIVE_CREATE_RSP:
+ {
+ CPSV_CKPT_SECT_INFO *info =
&evt->info.cpnd.info.active_sec_creat_rsp;
+ snprintf(o_evt_str, len, "[%llu]
CPSV_EVT_ND2ND_CKPT_SECT_ACTIVE_CREATE_RSP(err=%u)",
+ info->ckpt_id, info->error);
+ break;
+ }
+ case CPSV_EVT_ND2ND_CKPT_SECT_DELETE_REQ:
+ {
+ CPSV_CKPT_SECT_INFO *info =
&evt->info.cpnd.info.sec_delete_req;
+ snprintf(o_evt_str, len, "[%llu]
CPSV_EVT_ND2ND_CKPT_SECT_DELETE_REQ(sec_id=%s)",
+ info->ckpt_id, info->sec_id.id);
+ break;
+ }
+ case CPSV_EVT_ND2ND_CKPT_SECT_DELETE_RSP:
+ snprintf(o_evt_str, len,
"CPSV_EVT_ND2ND_CKPT_SECT_DELETE_RSP(err=%u)",
evt->info.cpnd.info.sec_delete_rsp.error);
+ break;
+ case CPSV_EVT_ND2ND_CKPT_SECT_EXPTMR_REQ:
+ {
+ CPSV_A2ND_SECT_EXP_TIME *info =
&evt->info.cpnd.info.sec_exp_set;
+ snprintf(o_evt_str, len, "[%llu]
CPSV_EVT_ND2ND_CKPT_SECT_EXPTMR_REQ(sec_id=%s, exp_tmr=%llu)",
+ info->ckpt_id, info->sec_id.id, info->exp_time);
+ break;
+ }
+ case CPSV_EVT_ND2ND_CKPT_SECT_EXPTMR_RSP:
+ snprintf(o_evt_str, len,
"CPSV_EVT_ND2ND_CKPT_SECT_EXPTMR_RSP(err=%u)",
+ evt->info.cpnd.info.sec_exp_rsp.error);
+ break;
+ case CPSV_EVT_ND2ND_CKPT_SECT_DATA_ACCESS_REQ:
+ /* This message is not used */
+ snprintf(o_evt_str, len,
"CPSV_EVT_ND2ND_CKPT_SECT_DATA_ACCESS_REQ");
+ break;
+ case CPSV_EVT_ND2ND_CKPT_SECT_ACTIVE_DATA_ACCESS_REQ:
+ {
+ CPSV_CKPT_ACCESS *info =
&evt->info.cpnd.info.ckpt_nd2nd_data;
+ snprintf(o_evt_str, len, "[%llu]
CPSV_EVT_ND2ND_CKPT_SECT_ACTIVE_DATA_ACCESS_REQ(type=%s(%d), seqno=%u,
last_seq=%u)",
+ info->ckpt_id,
+ info->type == CPSV_CKPT_ACCESS_WRITE ? "WRITE" :
+ info->type == CPSV_CKPT_ACCESS_OVWRITE ?
"OVWRITE" : "INVALID",
+ info->type, info->seqno, info->last_seq);
+ break;
+ }
+ case CPSV_EVT_ND2ND_CKPT_SECT_ACTIVE_DATA_ACCESS_RSP:
+ {
+ CPSV_ND2A_DATA_ACCESS_RSP *info =
&evt->info.cpnd.info.ckpt_nd2nd_data_rsp;
+ snprintf(o_evt_str, len, "[%llu]
CPSV_EVT_ND2ND_CKPT_SECT_ACTIVE_DATA_ACCESS_RSP(err=%u, type=%s(%u))",
+ info->ckpt_id,
+ info->type == CPSV_DATA_ACCESS_WRITE_RSP ?
info->error : info->info.ovwrite_error.error,
+ info->type == CPSV_DATA_ACCESS_WRITE_RSP?
"WRITE_RSP" : "OVWRITE_RSP", info->type);
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_INFO:
+ {
+ CPSV_D2ND_CKPT_INFO *info =
&evt->info.cpnd.info.ckpt_info;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_D2ND_CKPT_INFO(err=%u, active=0x%X, create_rep=%s)",
+ info->ckpt_id, info->error,
m_NCS_NODE_ID_FROM_MDS_DEST(info->active_dest),
+ info->ckpt_rep_create == true ? "true" :
"false");
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_SIZE:
+ {
+ CPSV_CKPT_USED_SIZE *info =
&evt->info.cpnd.info.ckpt_mem_size;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_D2ND_CKPT_SIZE(err=%u, used_mem=%u)",
+ info->ckpt_id, info->error,
info->ckpt_used_size);
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_REP_ADD:
+ {
+ CPSV_CKPT_DESTLIST_INFO *info =
&evt->info.cpnd.info.ckpt_add;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_D2ND_CKPT_REP_ADD(dest=0x%X, active=0x%X, restart=%s, dest_cnt=%u)",
+ info->ckpt_id,
m_NCS_NODE_ID_FROM_MDS_DEST(info->mds_dest),
+ m_NCS_NODE_ID_FROM_MDS_DEST(info->active_dest),
+ info->is_cpnd_restart == true ? "true" :
"false", info->dest_cnt);
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_REP_DEL:
+ {
+ CPSV_CKPT_DEST_INFO *info =
&evt->info.cpnd.info.ckpt_del;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_D2ND_CKPT_REP_DEL(node_id=0x%X)",
+ info->ckpt_id,
m_NCS_NODE_ID_FROM_MDS_DEST(info->mds_dest));
+ break;
+ }
+ case CPSV_D2ND_RESTART:
+ snprintf(o_evt_str, len, "[%llu] CPSV_D2ND_RESTART",
evt->info.cpnd.info.cpnd_restart.ckpt_id);
+ break;
+ case CPSV_D2ND_RESTART_DONE:
+ {
+ CPSV_CKPT_DESTLIST_INFO *info =
&evt->info.cpnd.info.cpnd_restart_done;
+ snprintf(o_evt_str, len, "[%llu]
CPSV_D2ND_RESTART_DONE(active=0x%X, dest_cnt=%u)", info->ckpt_id,
+ m_NCS_NODE_ID_FROM_MDS_DEST(info->active_dest),
info->dest_cnt);
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_CREATE:
+ {
+ CPSV_D2ND_CKPT_CREATE *info =
&evt->info.cpnd.info.ckpt_create;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_D2ND_CKPT_CREATE(%s, create_rep=%s, active=0x%X)",
+ info->ckpt_info.ckpt_id, info->ckpt_name.value,
+ info->ckpt_info.ckpt_rep_create ? "true" :
"false",
+
m_NCS_NODE_ID_FROM_MDS_DEST(info->ckpt_info.active_dest));
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_DESTROY:
+ {
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_D2ND_CKPT_DESTROY", evt->info.cpnd.info.ckpt_destroy.ckpt_id);
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_DESTROY_ACK:
+ {
+ snprintf(o_evt_str, len,
"CPND_EVT_D2ND_CKPT_DESTROY_ACK(err=%u)",
evt->info.cpnd.info.destroy_ack.error);
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_CLOSE_ACK:
+ /* This message is not used */
+ snprintf(o_evt_str, len,
"CPND_EVT_D2ND_CKPT_CLOSE_ACK");
+ break;
+ case CPND_EVT_D2ND_CKPT_UNLINK:
+ {
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_D2ND_CKPT_UNLINK", evt->info.cpnd.info.ckpt_ulink.ckpt_id);
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_UNLINK_ACK:
+ {
+ CPSV_SAERR_INFO *info = &evt->info.cpnd.info.ulink_ack;
+ snprintf(o_evt_str, len,
"CPND_EVT_D2ND_CKPT_UNLINK_ACK(err=%u)", info->error);
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_RDSET:
+ {
+ CPSV_CKPT_RDSET *info = &evt->info.cpnd.info.rdset;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_D2ND_CKPT_RDSET(%s(%u), time=%llu)",
+ info->ckpt_id,
+ info->type == CPSV_CKPT_RDSET_INFO ? "INFO" :
+ info->type == CPSV_CKPT_RDSET_START ? "START" :
+ info->type == CPSV_CKPT_RDSET_STOP ? "STOP" :
"OTHER",
+ info->type, info->reten_time);
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_RDSET_ACK:
+ snprintf(o_evt_str, len,
"CPND_EVT_D2ND_CKPT_RDSET_ACK(err=%u)", evt->info.cpnd.info.rdset_ack.error);
+ break;
+ case CPND_EVT_D2ND_CKPT_ACTIVE_SET:
+ {
+ CPSV_CKPT_DEST_INFO *info =
&evt->info.cpnd.info.active_set;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_D2ND_CKPT_ACTIVE_SET(active_node = 0x%X)",
+ info->ckpt_id,
m_NCS_NODE_ID_FROM_MDS_DEST(info->mds_dest));
+ break;
+ }
+ case CPND_EVT_D2ND_CKPT_ACTIVE_SET_ACK:
+ /* This message is not used */
+ snprintf(o_evt_str, len,
"CPND_EVT_D2ND_CKPT_ACTIVE_SET_ACK(err=%u)",
+ evt->info.cpnd.info.arep_ack.error);
+ break;
+ case CPND_EVT_ND2ND_CKPT_ITER_NEXT_REQ:
+ {
+ CPSV_A2ND_SECT_ITER_GETNEXT *info =
&evt->info.cpnd.info.iter_getnext;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_ND2ND_CKPT_ITER_NEXT_REQ(sec_id=%s, filter=%s, n_secs_trav=%u,
exp_tmr=%llu)",
+ info->ckpt_id, info->section_id.id,
+ info->filter == SA_CKPT_SECTIONS_FOREVER ?
"FOREVER" :
+ info->filter ==
SA_CKPT_SECTIONS_LEQ_EXPIRATION_TIME ? "LEQ_EX_TIME" :
+ info->filter ==
SA_CKPT_SECTIONS_GEQ_EXPIRATION_TIME ? "GEQ_EX_TIME" :
+ info->filter == SA_CKPT_SECTIONS_CORRUPTED ?
"CORRUPTED" :
+ info->filter == SA_CKPT_SECTIONS_ANY ? "ANY" :
"INVALID",
+ info->n_secs_trav, info->exp_tmr);
+
+ break;
+ }
+ case CPND_EVT_ND2ND_CKPT_ACTIVE_ITERNEXT:
+ snprintf(o_evt_str, len,
"CPND_EVT_ND2ND_CKPT_ACTIVE_ITERNEXT");
+ break;
+ case CPND_EVT_CB_DUMP:
+ snprintf(o_evt_str, len, "CPND_EVT_CB_DUMP");
+ break;
+ case CPND_EVT_D2ND_CKPT_NUM_SECTIONS:
+ {
+ CPSV_CKPT_NUM_SECTIONS *info =
&evt->info.cpnd.info.ckpt_sections;
+ snprintf(o_evt_str, len, "[%llu]
CPND_EVT_D2ND_CKPT_NUM_SECTIONS", info->ckpt_id);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_REFCNTSET:
+ {
+ CPSV_A2ND_REFCNTSET *info =
&evt->info.cpnd.info.refCntsetReq;
+ snprintf(o_evt_str, len, "
CPND_EVT_A2ND_CKPT_REFCNTSET(no_of_nodes=%u)", info->no_of_nodes);
+ break;
+ }
+ case CPND_EVT_A2ND_CKPT_LIST_UPDATE:
+ {
+ CPSV_A2ND_CKPT_LIST_UPDATE *info =
&evt->info.cpnd.info.ckptListUpdate;
+ snprintf(o_evt_str, len,
"CPND_EVT_A2ND_CKPT_LIST_UPDATE(hdl=%llu, %s)",
+ info->client_hdl, info->ckpt_name.value);
+ break;
+ }
+ case CPND_EVT_A2ND_ARRIVAL_CB_UNREG:
+ snprintf(o_evt_str, len,
"CPND_EVT_A2ND_ARRIVAL_CB_UNREG(hdl=%llu)",
+ evt->info.cpnd.info.arr_ntfy.client_hdl);
+ break;
+ default:
+ snprintf(o_evt_str, len, "INVALID_CPND_TYPE(type =
%d)", evt->info.cpnd.type);
+ break;
+ }
+ break;
+
+ case CPSV_EVT_TYPE_CPA:
+ switch (evt->info.cpa.type) {
+ case CPA_EVT_MDS_INFO:
+ /* This message type is not used */
+ snprintf(o_evt_str, len, "CPA_EVT_MDS_INFO");
+ break;
+ case CPA_EVT_TIME_OUT:
+ {
+ CPA_TMR_INFO *info = &evt->info.cpa.info.tmr_info;
+ snprintf(o_evt_str, len, "CPA_EVT_TIME_OUT(hdl=%llu,
type=%s(%u))",
+ info->client_hdl,
+ info->type == CPA_TMR_TYPE_CPND_RETENTION ?
"RETENTION" :
+ info->type == CPA_TMR_TYPE_OPEN ? "OPEN" :
+ info->type == CPA_TMR_TYPE_SYNC ? "SYNC" :
"INVALID",
+ info->type);
+ break;
+ }
+ case CPA_EVT_ND2A_CKPT_INIT_RSP:
+ {
+ CPSV_ND2A_INIT_RSP *info = &evt->info.cpa.info.initRsp;
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_INIT_RSP(hdl=%llu, err=%u)", info->ckptHandle, info->error);
+ break;
+ }
+ case CPA_EVT_ND2A_CKPT_FINALIZE_RSP:
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_FINALIZE_RSP(err=%u)", evt->info.cpa.info.finRsp.error);
+ break;
+ case CPA_EVT_ND2A_CKPT_OPEN_RSP:
+ {
+ CPSV_ND2A_OPEN_RSP *info = &evt->info.cpa.info.openRsp;
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_OPEN_RSP(err=%u, active=0x%X, gbl_hdl=%llu, lcl_hdl=0X%llX)",
+ info->error,
m_NCS_NODE_ID_FROM_MDS_DEST(info->active_dest), info->gbl_ckpt_hdl,
info->lcl_ckpt_hdl);
+ break;
+ }
+ case CPA_EVT_ND2A_CKPT_CLOSE_RSP:
+ {
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_CLOSE_RSP(err=%u)", evt->info.cpa.info.closeRsp.error);
+ break;
+ }
+ case CPA_EVT_ND2A_CKPT_UNLINK_RSP:
+ {
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_UNLINK_RSP(err=%u)", evt->info.cpa.info.ulinkRsp.error);
+ break;
+ }
+ case CPA_EVT_ND2A_CKPT_RDSET_RSP:
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_RDSET_RSP(err=%u)", evt->info.cpa.info.rdsetRsp.error);
+ break;
+ case CPA_EVT_ND2A_CKPT_AREP_SET_RSP:
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_AREP_SET_RSP(err=%u)", evt->info.cpa.info.arsetRsp.error);
+ break;
+ case CPA_EVT_ND2A_CKPT_STATUS:
+ {
+ CPSV_CKPT_STATUS *info = &evt->info.cpa.info.status;
+ snprintf(o_evt_str, len, "[%llu]
CPA_EVT_ND2A_CKPT_STATUS(err=%u, mem_used=%llu, "
+ "n_secs=%u, ckpt_size=%llu, reten=%llu,
max_sec=%u)", info->ckpt_id, info->error,
+ info->status.memoryUsed,
info->status.numberOfSections,
+
info->status.checkpointCreationAttributes.checkpointSize,
+
info->status.checkpointCreationAttributes.retentionDuration,
+
info->status.checkpointCreationAttributes.maxSections);
+
+ break;
+ }
+ case CPA_EVT_ND2A_SEC_CREATE_RSP:
+ {
+ CPSV_CKPT_SECT_INFO *info =
&evt->info.cpa.info.sec_creat_rsp;
+ snprintf(o_evt_str, len, "[%llu]
CPA_EVT_ND2A_SEC_CREATE_RSP(err=%u, sec_id=%s, mdest=%lX)",
+ info->ckpt_id, info->error, info->sec_id.id,
info->agent_mdest);
+ break;
+ }
+ case CPA_EVT_ND2A_SEC_DELETE_RSP:
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_SEC_DELETE_RSP(err=%u)", evt->info.cpa.info.sec_delete_rsp.error);
+ break;
+ case CPA_EVT_ND2A_SEC_EXPTIME_RSP:
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_SEC_EXPTIME_RSP(err=%u)",
evt->info.cpa.info.sec_exptmr_rsp.error);
+ break;
+ case CPA_EVT_ND2A_SEC_ITER_RSP:
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_SEC_ITER_RSP(err=%u)", evt->info.cpa.info.sec_iter_rsp.error);
+ break;
+ case CPA_EVT_ND2A_SEC_ITER_GETNEXT_RSP:
+ {
+ CPSV_ND2A_SECT_ITER_GETNEXT_RSP *info =
&evt->info.cpa.info.iter_next_rsp;
+ snprintf(o_evt_str, len, "[%llu]
CPA_EVT_ND2A_SEC_ITER_GETNEXT_RSP(err=%u, iter_id=%llu, sec_id=%s,
n_secs_trav=%u)",
+ info->ckpt_id, info->error, info->iter_id,
info->sect_desc.sectionId.id, info->n_secs_trav);
+ break;
+ }
+ case CPA_EVT_ND2A_CKPT_ARRIVAL_NTFY:
+ {
+ CPSV_ND2A_ARRIVAL_MSG *info =
&evt->info.cpa.info.arr_msg;
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_ARRIVAL_NTFY(hdl=%llu)", info->client_hdl);
+ break;
+ }
+ case CPA_EVT_ND2A_CKPT_DATA_RSP:
+ {
+ CPSV_ND2A_DATA_ACCESS_RSP *info =
&evt->info.cpa.info.sec_data_rsp;
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_DATA_RSP(err=%u, type=%s(%u))",
+ info->type == CPSV_DATA_ACCESS_OVWRITE_RSP ?
info->info.ovwrite_error.error : info->error,
+ info->type == CPSV_DATA_ACCESS_LCL_READ_RSP ?
"LCL_READ" :
+ info->type == CPSV_DATA_ACCESS_RMT_READ_RSP ?
"RMT_READ" :
+ info->type == CPSV_DATA_ACCESS_WRITE_RSP ?
"WRITE" :
+ info->type == CPSV_DATA_ACCESS_OVWRITE_RSP ?
"OVWRITE" : "INVALID", info->type);
+ break;
+ }
+ case CPA_EVT_ND2A_CKPT_SYNC_RSP:
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_SYNC_RSP(err=%u)",
+ evt->info.cpa.info.sync_rsp.error);
+ break;
+ case CPA_EVT_D2A_ACT_CKPT_INFO_BCAST_SEND:
+ {
+ CPSV_CKPT_DEST_INFO *info =
&evt->info.cpa.info.ackpt_info;
+ snprintf(o_evt_str, len, "[%llu]
CPA_EVT_D2A_ACT_CKPT_INFO_BCAST_SEND(active_node=0x%X)",
+ info->ckpt_id,
m_NCS_NODE_ID_FROM_MDS_DEST(info->mds_dest));
+ break;
+ }
+ case CPA_EVT_ND2A_CKPT_READ_ACK_RSP:
+ /* This message type is not used */
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_READ_ACK_RSP");
+ break;
+ case CPA_EVT_ND2A_CKPT_BCAST_SEND:
+ {
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_BCAST_SEND");
+ break;
+ }
+ case CPA_EVT_D2A_NDRESTART:
+ {
+ CPSV_CKPT_DEST_INFO *info =
&evt->info.cpa.info.ackpt_info;
+ snprintf(o_evt_str, len, "[%llu]
CPA_EVT_D2A_NDRESTART(node=0x%X)",
+ info->ckpt_id,
m_NCS_NODE_ID_FROM_MDS_DEST(info->mds_dest));
+ break;
+ }
+ case CPA_EVT_CB_DUMP:
+ snprintf(o_evt_str, len, "CPA_EVT_CB_DUMP");
+ break;
+ case CPA_EVT_ND2A_CKPT_CLM_NODE_LEFT:
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_CLM_NODE_LEFT");
+ break;
+ case CPA_EVT_ND2A_CKPT_CLM_NODE_JOINED:
+ snprintf(o_evt_str, len,
"CPA_EVT_ND2A_CKPT_CLM_NODE_JOINED");
+ break;
+ case CPA_EVT_ND2A_ACT_CKPT_INFO_BCAST_SEND:
+ {
+ CPSV_CKPT_DEST_INFO *info =
&evt->info.cpa.info.ackpt_info;
+ snprintf(o_evt_str, len, "[%llu]
CPA_EVT_ND2A_ACT_CKPT_INFO_BCAST_SEND(active_node=0x%X)",
+ info->ckpt_id,
m_NCS_NODE_ID_FROM_MDS_DEST(info->mds_dest));
+ break;
+ }
+ default:
+ snprintf(o_evt_str, len, "INVALID_CPA_TYPE(type = %d)",
evt->info.cpa.type);
+ break;
+ }
+ break;
+
+ case CPSV_EVT_TYPE_CPD:
+ switch (evt->info.cpd.type) {
+ case CPD_EVT_MDS_INFO:
+ {
+ CPSV_MDS_INFO *info = &evt->info.cpd.info.mds_info;
+ snprintf(o_evt_str, len,
"CPD_EVT_MDS_INFO(node_id=0x%X, svc=%s(%u) - %s(%u))",
+ info->node_id,
+ info->svc_id == NCSMDS_SVC_ID_CPA ? "CPA" :
+ info->svc_id == NCSMDS_SVC_ID_CPND ? "CPND" :
+ info->svc_id == NCSMDS_SVC_ID_CPD ? "CPD" :
"OTHER",
+ info->svc_id,
+ info->change == NCSMDS_NO_ACTIVE ? "NO_ACT" :
+ info->change == NCSMDS_NEW_ACTIVE ? "NEW_ACT" :
+ info->change == NCSMDS_UP ? "UP" :
+ info->change == NCSMDS_DOWN ? "DOWN" :
+ info->change == NCSMDS_RED_UP ? "RED_UP" :
+ info->change == NCSMDS_RED_DOWN ? "RED_DOWN" :
+ info->change == NCSMDS_CHG_ROLE ? "CHG_ROLE" :
"OTHERS",
+ info->change);
+ break;
+
+ }
+ case CPD_EVT_ND2D_CKPT_CREATE:
+ {
+ CPSV_ND2D_CKPT_CREATE *info =
&evt->info.cpd.info.ckpt_create;
+ snprintf(o_evt_str, len, "CPD_EVT_ND2D_CKPT_CREATE(%s,
creationFlags=0x%X)",
+ info->ckpt_name.value,
info->attributes.creationFlags);
+ break;
+ }
+ case CPD_EVT_ND2D_CKPT_UNLINK:
+ {
+ snprintf(o_evt_str, len,
"CPD_EVT_ND2D_CKPT_UNLINK(%s)", evt->info.cpd.info.ckpt_ulink.ckpt_name.value);
+ break;
+ }
+ case CPD_EVT_ND2D_CKPT_RDSET:
+ {
+ CPSV_CKPT_RDSET *info = &evt->info.cpd.info.rd_set;
+ snprintf(o_evt_str, len, "[%llu]
CPD_EVT_ND2D_CKPT_RDSET(reten_time=%llu)", info->ckpt_id, info->reten_time);
+ break;
+ }
+ case CPD_EVT_ND2D_ACTIVE_SET:
+ {
+ CPSV_CKPT_DEST_INFO *info =
&evt->info.cpd.info.arep_set;
+ snprintf(o_evt_str, len, "[%llu]
CPD_EVT_ND2D_ACTIVE_SET(node=0x%X)", info->ckpt_id,
+ m_NCS_NODE_ID_FROM_MDS_DEST(info->mds_dest));
+ break;
+ }
+ case CPD_EVT_ND2D_CKPT_CLOSE:
+ {
+ CPSV_CKPT_ID_INFO *info =
&evt->info.cpd.info.ckpt_close;
+ snprintf(o_evt_str, len, "[%llu]
CPD_EVT_ND2D_CKPT_CLOSE", info->ckpt_id);
+ break;
+ }
+ case CPD_EVT_ND2D_CKPT_DESTROY:
+ {
+ CPSV_CKPT_ID_INFO *info =
&evt->info.cpd.info.ckpt_destroy;
+ snprintf(o_evt_str, len, "[%llu]
CPD_EVT_ND2D_CKPT_DESTROY", info->ckpt_id);
+ break;
+ }
+ case CPD_EVT_ND2D_CKPT_USR_INFO:
+ {
+ CPSV_ND2D_USR_INFO *info =
&evt->info.cpd.info.ckpt_usr_info;
+ snprintf(o_evt_str, len, "[%llu]
CPD_EVT_ND2D_CKPT_USR_INFO(open_flags=0x%X, %s(%u), ckpt_flags=%u)",
+ info->ckpt_id, info->ckpt_flags,
+ info->info_type == CPSV_USR_INFO_CKPT_OPEN ?
"OPEN" :
+ info->info_type == CPSV_USR_INFO_CKPT_CLOSE ?
"CLOSE" :
+ info->info_type ==
CPSV_USR_INFO_CKPT_OPEN_FIRST ? "OPEN_FIRST" :
+ info->info_type ==
CPSV_USR_INFO_CKPT_CLOSE_LAST ? "CLOSE_LAST" : "OTHER",
+ info->info_type, info->ckpt_flags);
+ break;
+ }
+ case CPD_EVT_ND2D_CKPT_SYNC_INFO:
+ /* This message type is not used */
+ snprintf(o_evt_str, len, "CPD_EVT_ND2D_CKPT_SYNC_INFO");
+ break;
+ case CPD_EVT_ND2D_CKPT_SEC_INFO_UPD:
+ {
+ CPSV_CKPT_SEC_INFO_UPD *info =
&evt->info.cpd.info.ckpt_sec_info;
+ snprintf(o_evt_str, len, "[%llu]
CPD_EVT_ND2D_CKPT_SEC_INFO_UPD(type=%s(%u))", info->ckpt_id,
+ info->info_type == CPSV_CKPT_SEC_INFO_CREATE ?
"CREATE" :
+ info->info_type == CPSV_CKPT_SEC_INFO_DELETE ?
"DELETE" : "OTHER",
+ info->info_type);
+ break;
+ }
+ case CPD_EVT_ND2D_CKPT_MEM_USED:
+ {
+ CPSV_CKPT_USED_SIZE *info =
&evt->info.cpd.info.ckpt_mem_used;
+ snprintf(o_evt_str, len, "[%llu]
CPD_EVT_ND2D_CKPT_MEM_USED(err=%u, used_size=%u)",
+ info->ckpt_id, info->error,
info->ckpt_used_size);
+ break;
+ }
+ case CPD_EVT_CB_DUMP:
+ snprintf(o_evt_str, len, "CPD_EVT_CB_DUMP");
+ break;
+ case CPD_EVT_MDS_QUIESCED_ACK_RSP:
+ snprintf(o_evt_str, len,
"CPD_EVT_MDS_QUIESCED_ACK_RSP");
+ break;
+ case CPD_EVT_ND2D_CKPT_DESTROY_BYNAME:
+ {
+ CPSV_CKPT_NAME_INFO *info =
&evt->info.cpd.info.ckpt_destroy_byname;
+ snprintf(o_evt_str, len,
"CPD_EVT_ND2D_CKPT_DESTROY_BYNAME(ckpt=%s)", info->ckpt_name.value);
+ break;
+ }
+ case CPD_EVT_ND2D_CKPT_CREATED_SECTIONS:
+ {
+ CPSV_CKPT_NUM_SECTIONS *info =
&evt->info.cpd.info.ckpt_created_sections;
+ snprintf(o_evt_str, len, "[%llu]
CPD_EVT_ND2D_CKPT_CREATED_SECTIONS(err=%u, num_secs=%u)",
+ info->ckpt_id, info->error,
info->ckpt_num_sections);
+ break;
+ }
+ case CPD_EVT_TIME_OUT:
+ {
+ CPD_TMR_INFO *info = &evt->info.cpd.info.tmr_info;
+ snprintf(o_evt_str, len, "CPD_EVT_TIME_OUT(type=%u,
node=0x%X)", info->type,
+
m_NCS_NODE_ID_FROM_MDS_DEST(info->info.cpnd_dest));
+ break;
+ }
+ default:
+ snprintf(o_evt_str, len, "INVALID_CPD_TYPE(type = %d)",
evt->info.cpd.type);
+ break;
+ }
+ break;
+ default:
+ snprintf(o_evt_str, len, "INVALID_EVENT_TYPE(type = %d)",
evt->type);
+ }
+ return o_evt_str;
+}
+
/****************************************************************************\
PROCEDURE NAME : cpsv_evt_cpy
diff --git a/osaf/libs/common/cpsv/include/cpsv_evt.h
b/osaf/libs/common/cpsv/include/cpsv_evt.h
--- a/osaf/libs/common/cpsv/include/cpsv_evt.h
+++ b/osaf/libs/common/cpsv/include/cpsv_evt.h
@@ -431,6 +431,7 @@ typedef struct cpsv_a2nd_ckpt_list_updat
#define CPSV_CKPT_ACCESS_SYNC 0x3
#define MAX_SYNC_TRANSFER_SIZE (30 * 1024 * 1024)
+#define MAX_EVT_STR_LEN 512
typedef struct cpsv_ckpt_access {
SaUint32T type; /* --- 0-write/1-overwrite/2-read/3-sync -----
*/
@@ -850,6 +851,7 @@ typedef struct cpsv_evt {
} CPSV_EVT;
/* Event Declerations */
+char* cpsv_evt_str(CPSV_EVT *evt, char *o_evt_str, size_t len);
uint32_t cpsv_evt_cpy(CPSV_EVT *src, CPSV_EVT *dest, uint32_t svc_id);
uint32_t cpsv_evt_enc_flat(EDU_HDL *edu_hdl, CPSV_EVT *i_evt, NCS_UBAID *o_ub);
uint32_t cpsv_evt_dec_flat(EDU_HDL *edu_hdl, NCS_UBAID *i_ub, CPSV_EVT *o_evt);
diff --git a/osaf/services/saf/cpsv/cpd/cpd_db.c
b/osaf/services/saf/cpsv/cpd/cpd_db.c
--- a/osaf/services/saf/cpsv/cpd/cpd_db.c
+++ b/osaf/services/saf/cpsv/cpd/cpd_db.c
@@ -403,6 +403,7 @@ uint32_t cpd_ckpt_reploc_node_add(NCS_PA
return NCSCC_RC_FAILURE;
}
}
+
TRACE_LEAVE();
return NCSCC_RC_SUCCESS;
}
diff --git a/osaf/services/saf/cpsv/cpd/cpd_evt.c
b/osaf/services/saf/cpsv/cpd/cpd_evt.c
--- a/osaf/services/saf/cpsv/cpd/cpd_evt.c
+++ b/osaf/services/saf/cpsv/cpd/cpd_evt.c
@@ -99,6 +99,9 @@ void cpd_process_evt(CPSV_EVT *evt)
#if ( CPSV_DEBUG == 1)
TRACE("%s", cpd_evt_str[evt->info.cpd.type]);
#endif
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpd <<== %s from node 0x%X", cpsv_evt_str(evt, evt_str,
MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(evt->sinfo.dest));
switch (evt->info.cpd.type) {
case CPD_EVT_MDS_INFO:
diff --git a/osaf/services/saf/cpsv/cpd/cpd_mds.c
b/osaf/services/saf/cpsv/cpd/cpd_mds.c
--- a/osaf/services/saf/cpsv/cpd/cpd_mds.c
+++ b/osaf/services/saf/cpsv/cpd/cpd_mds.c
@@ -658,6 +658,11 @@ uint32_t cpd_mds_send_rsp(CPD_CB *cb, CP
mds_info.info.svc_send.info.rsp.i_sender_dest = s_info->dest;
/* send the message */
+
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpd ==>> %s to node 0x%X", cpsv_evt_str(evt, evt_str,
MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(s_info->dest));
+
rc = ncsmds_api(&mds_info);
if (rc != NCSCC_RC_SUCCESS) {
LOG_ER("cpd mds send failed for dest %"PRIu64,s_info->dest);
@@ -707,12 +712,21 @@ uint32_t cpd_mds_msg_sync_send(CPD_CB *c
mds_info.info.svc_send.info.sndrsp.i_to_dest = to_dest;
/* send the message */
+
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpd ==>> %s to node 0x%X", cpsv_evt_str(i_evt, evt_str,
MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(to_dest));
+
rc = ncsmds_api(&mds_info);
- if (rc == NCSCC_RC_SUCCESS)
+ if (rc == NCSCC_RC_SUCCESS) {
*o_evt = mds_info.info.svc_send.info.sndrsp.o_rsp;
+ TRACE("cpd <<== %s from node 0x%X", cpsv_evt_str(*o_evt,
evt_str, MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(to_dest));
+ }
else {
LOG_ER("cpd mds send failed for dest %"PRIu64,to_dest);
}
+
TRACE_LEAVE();
return rc;
}
@@ -753,6 +767,11 @@ uint32_t cpd_mds_msg_send(CPD_CB *cb, ui
mds_info.info.svc_send.info.snd.i_to_dest = to_dest;
/* send the message */
+
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpd ==>> %s to node 0x%X", cpsv_evt_str(evt, evt_str,
MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(to_dest));
+
rc = ncsmds_api(&mds_info);
if (rc != NCSCC_RC_SUCCESS) {
@@ -797,6 +816,9 @@ uint32_t cpd_mds_bcast_send(CPD_CB *cb,
info.info.svc_send.i_to_svc = to_svc;
info.info.svc_send.info.bcast.i_bcast_scope = NCSMDS_SCOPE_NONE;
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpd ==>> %s (broadcast)", cpsv_evt_str(evt, evt_str,
MAX_EVT_STR_LEN));
+
res = ncsmds_api(&info);
if (res != NCSCC_RC_SUCCESS) {
LOG_ER("cpd mds bcast send failed");
diff --git a/osaf/services/saf/cpsv/cpd/cpd_proc.c
b/osaf/services/saf/cpsv/cpd/cpd_proc.c
--- a/osaf/services/saf/cpsv/cpd/cpd_proc.c
+++ b/osaf/services/saf/cpsv/cpd/cpd_proc.c
@@ -342,7 +342,8 @@ uint32_t cpd_ckpt_db_entry_update(CPD_CB
goto ckpt_node_add_fail;
}
if (reploc_info && create_reploc_node) {
- proc_rc = cpd_ckpt_reploc_node_add(&cb->ckpt_reploc_tree,
reploc_info, cb->ha_state, cb->immOiHandle);
+ TRACE_4("reploc node add for non-collocated on node
0x%X - ckpt_id:%llx", m_NCS_NODE_ID_FROM_MDS_DEST(cpnd_dest), ckpt_id);
+ proc_rc =
cpd_ckpt_reploc_node_add(&cb->ckpt_reploc_tree, reploc_info, cb->ha_state,
cb->immOiHandle);
if (proc_rc != NCSCC_RC_SUCCESS) {
/* goto reploc_node_add_fail; */
TRACE_4("cpd db add failed ");
diff --git a/osaf/services/saf/cpsv/cpnd/cpnd_evt.c
b/osaf/services/saf/cpsv/cpnd/cpnd_evt.c
--- a/osaf/services/saf/cpsv/cpnd/cpnd_evt.c
+++ b/osaf/services/saf/cpsv/cpnd/cpnd_evt.c
@@ -179,6 +179,9 @@ void cpnd_process_evt(CPSV_EVT *evt)
#if (CPSV_DEBUG == 1)
TRACE("%s", cpnd_evt_str[evt->info.cpnd.type]);
#endif
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpnd <<== %s from node 0x%X", cpsv_evt_str(evt, evt_str,
MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(evt->sinfo.dest));
switch (evt->info.cpnd.type) {
case CPND_EVT_MDS_INFO:
@@ -3412,8 +3415,8 @@ static uint32_t cpnd_evt_proc_nd2nd_ckpt
}
if (cp_node->create_attrib.creationFlags &
SA_CKPT_CHECKPOINT_COLLOCATED) {
- send_evt.info.cpnd.info.ckpt_nd2nd_sync.num_of_elmts =
cp_node->replica_info.n_secs;
- rc = cpnd_mds_send_rsp(cb, sinfo, &send_evt);
+ send_evt.info.cpnd.info.ckpt_nd2nd_sync.num_of_elmts =
cp_node->replica_info.n_secs;
+ rc = cpnd_mds_send_rsp(cb, sinfo, &send_evt);
}
if ((cp_node->replica_info.n_secs > 0) &&
!cpnd_ckpt_sec_empty(&cp_node->replica_info)) {
@@ -3428,7 +3431,7 @@ static uint32_t cpnd_evt_proc_nd2nd_ckpt
}
if (evt->info.sync_req.is_ckpt_open) {
- /* Add the new replica's MDS_DEST to the dest liot of this
replica */
+ /* Add the new replica's MDS_DEST to the dest list of this
replica */
rc = cpnd_ckpt_remote_cpnd_add(cp_node, sinfo->dest);
}
diff --git a/osaf/services/saf/cpsv/cpnd/cpnd_mds.c
b/osaf/services/saf/cpsv/cpnd/cpnd_mds.c
--- a/osaf/services/saf/cpsv/cpnd/cpnd_mds.c
+++ b/osaf/services/saf/cpsv/cpnd/cpnd_mds.c
@@ -804,6 +804,10 @@ static uint32_t cpnd_mds_send_try_again_
break;
}
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpnd ==>> %s to node 0x%X - ERR_TRY_AGAIN", cpsv_evt_str(pEvt,
evt_str, MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(pEvt->sinfo.dest));
+
rc = cpnd_mds_send_rsp(cb, &pEvt->sinfo, &send_evt);
if (rc != NCSCC_RC_SUCCESS) {
@@ -846,6 +850,9 @@ uint32_t cpnd_mds_bcast_send(CPND_CB *cb
info.info.svc_send.i_to_svc = to_svc;
info.info.svc_send.info.bcast.i_bcast_scope = NCSMDS_SCOPE_INTRANODE;
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpnd ==>> %s (broadcast)", cpsv_evt_str(evt, evt_str,
MAX_EVT_STR_LEN));
+
res = ncsmds_api(&info);
return (res);
}
@@ -1001,6 +1008,10 @@ uint32_t cpnd_mds_send_rsp(CPND_CB *cb,
mds_info.info.svc_send.info.rsp.i_sender_dest = s_info->dest;
/* send the message */
+
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpnd ==>> %s to node 0x%X", cpsv_evt_str(evt, evt_str,
MAX_EVT_STR_LEN), m_NCS_NODE_ID_FROM_MDS_DEST(s_info->dest));
+
rc = ncsmds_api(&mds_info);
if (rc != NCSCC_RC_SUCCESS)
TRACE_4("cpnd mds send fail for dest:%"PRIu64,s_info->dest);
@@ -1083,11 +1094,18 @@ uint32_t cpnd_mds_msg_sync_send(CPND_CB
mds_info.info.svc_send.info.sndrsp.i_to_dest = to_dest;
/* send the message */
+
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpnd ==>> %s to node 0x%X", cpsv_evt_str(i_evt, evt_str,
MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(to_dest));
+
rc = ncsmds_api(&mds_info);
- if (rc == NCSCC_RC_SUCCESS)
+ if (rc == NCSCC_RC_SUCCESS) {
*o_evt = mds_info.info.svc_send.info.sndrsp.o_rsp;
- else {
+ TRACE("cpnd <<== %s from node 0x%X", cpsv_evt_str(*o_evt,
evt_str, MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(to_dest));
+ } else {
TRACE_4("cpnd mds send fail for to_dest:%"PRIu64",return
value:%d",to_dest, rc);
}
@@ -1152,6 +1170,11 @@ uint32_t cpnd_mds_msg_send(CPND_CB *cb,
mds_info.info.svc_send.info.snd.i_to_dest = to_dest;
/* send the message */
+
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpnd ==>> %s to node 0x%X", cpsv_evt_str(evt, evt_str,
MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(to_dest));
+
rc = ncsmds_api(&mds_info);
if (rc != NCSCC_RC_SUCCESS) {
@@ -1215,6 +1238,11 @@ uint32_t cpnd_mds_msg_sync_ack_send(CPND
mds_info.info.svc_send.info.sndack.i_to_dest = to_dest;
/* send the message */
+
+ char evt_str[MAX_EVT_STR_LEN] = {0};
+ TRACE("cpnd ==>> %s to node 0x%X", cpsv_evt_str(i_evt, evt_str,
MAX_EVT_STR_LEN),
+ m_NCS_NODE_ID_FROM_MDS_DEST(to_dest));
+
rc = ncsmds_api(&mds_info);
if (rc != NCSCC_RC_SUCCESS) {
TRACE_4("cpnd mds send failed for dest:%"PRIu64,to_dest);
------------------------------------------------------------------------------
_______________________________________________
Opensaf-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/opensaf-devel
