"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "src/imm/immnd/immnd_evt.c" between
opensaf-5.21.06.tar.gz and opensaf-5.21.09.tar.gz

About: OpenSAF is a project focused on Service Availability (SA) that develops middleware based on open and industry standard interfaces for applications requiring uninterrupted 24x7 service.

immnd_evt.c  (opensaf-5.21.06):immnd_evt.c  (opensaf-5.21.09)
skipping to change at line 291 skipping to change at line 291
static void immnd_evt_ccb_abort(IMMND_CB *cb, SaUint32T ccbId, static void immnd_evt_ccb_abort(IMMND_CB *cb, SaUint32T ccbId,
SaUint32T **clientArr, SaUint32T *clArrSize, SaUint32T **clientArr, SaUint32T *clArrSize,
SaUint32T *nodeId); SaUint32T *nodeId);
static uint32_t immnd_evt_proc_reset(IMMND_CB *cb, IMMND_EVT *evt, static uint32_t immnd_evt_proc_reset(IMMND_CB *cb, IMMND_EVT *evt,
IMMSV_SEND_INFO *sinfo); IMMSV_SEND_INFO *sinfo);
static uint32_t immnd_evt_impl_delete(IMMND_CB *cb, IMMND_EVT *evt); static uint32_t immnd_evt_impl_delete(IMMND_CB *cb, IMMND_EVT *evt);
static uint32_t immnd_syncr_timeout_update_all(SaTimeT syncrTimeout);
#if 0 /* Only for debug */ #if 0 /* Only for debug */
static void printImmValue(SaImmValueTypeT t, IMMSV_EDU_ATTR_VAL *v) static void printImmValue(SaImmValueTypeT t, IMMSV_EDU_ATTR_VAL *v)
{ {
switch (t) { switch (t) {
case SA_IMM_ATTR_SAINT32T: case SA_IMM_ATTR_SAINT32T:
TRACE_2("INT32: %i", v->val.saint32); TRACE_2("INT32: %i", v->val.saint32);
break; break;
case SA_IMM_ATTR_SAUINT32T: case SA_IMM_ATTR_SAUINT32T:
TRACE_2("UINT32: %u", v->val.sauint32); TRACE_2("UINT32: %u", v->val.sauint32);
break; break;
skipping to change at line 1033 skipping to change at line 1035
if (sync_pid && (sinfo->pid == sync_pid)) { if (sync_pid && (sinfo->pid == sync_pid)) {
TRACE_2("Sync agent attached, pid: %u", sync_pid); TRACE_2("Sync agent attached, pid: %u", sync_pid);
cl_node->mIsSync = 1; cl_node->mIsSync = 1;
} else if (pbe_pid && (sinfo->pid == pbe_pid) && !isOm && } else if (pbe_pid && (sinfo->pid == pbe_pid) && !isOm &&
!(cl_node->mIsPbe)) { !(cl_node->mIsPbe)) {
LOG_NO("Persistent Back End OI attached, pid: %u", pbe_pid); LOG_NO("Persistent Back End OI attached, pid: %u", pbe_pid);
cl_node->mIsPbe = 1; cl_node->mIsPbe = 1;
} }
send_evt.info.imma.info.initRsp.immHandle = cl_node->imm_app_hdl; send_evt.info.imma.info.initRsp.immHandle = cl_node->imm_app_hdl;
send_evt.info.imma.info.initRsp.syncrTimeout =
immModel_getSyncrTimeout(cb);
error = SA_AIS_OK; error = SA_AIS_OK;
clm_left: clm_left:
agent_rsp: agent_rsp:
send_evt.type = IMMSV_EVT_TYPE_IMMA; send_evt.type = IMMSV_EVT_TYPE_IMMA;
send_evt.info.imma.type = IMMA_EVT_ND2A_IMM_INIT_RSP; send_evt.info.imma.type = IMMA_EVT_ND2A_IMM_INIT_RSP;
send_evt.info.imma.info.initRsp.error = error; send_evt.info.imma.info.initRsp.error = error;
return immnd_mds_send_rsp(cb, sinfo, &send_evt); return immnd_mds_send_rsp(cb, sinfo, &send_evt);
} }
skipping to change at line 4792 skipping to change at line 4796
*/ */
immnd_announceDump(cb); immnd_announceDump(cb);
/* Communicates RIM to IMMD. /* Communicates RIM to IMMD.
Needed to decide if reload Needed to decide if reload
must cause cluster restart. must cause cluster restart.
*/ */
} }
} }
} }
if (cb->mSyncrTimeout) {
cb->mSyncrTimeout = false;
SaTimeT newSyncr = immModel_getSyncrTimeout(cb);
uint32_t rc = immnd_syncr_timeout_update_all(newS
yncr);
if (rc == NCSCC_RC_SUCCESS) {
LOG_NO("Update Syncr timeout(%lld) succes
sful", newSyncr);
}
else {
LOG_NO("Update Syncr timeout(%lld) failur
e. rc:%u",
newSyncr, rc);
}
}
if (arrSize) { if (arrSize) {
int ix; int ix;
memset(&send_evt, '\0', sizeof(IMMSV_EVT)); memset(&send_evt, '\0', sizeof(IMMSV_EVT));
send_evt.type = IMMSV_EVT_TYPE_IMMA; send_evt.type = IMMSV_EVT_TYPE_IMMA;
send_evt.info.imma.type = send_evt.info.imma.type =
IMMA_EVT_ND2A_OI_CCB_APPLY_UC; IMMA_EVT_ND2A_OI_CCB_APPLY_UC;
for (ix = 0; ix < arrSize && err == SA_AIS_OK; for (ix = 0; ix < arrSize && err == SA_AIS_OK;
++ix) { ++ix) {
/* Send apply callbacks for all /* Send apply callbacks for all
skipping to change at line 12524 skipping to change at line 12541
for(uint32_t i=0; i<evt->info.impl_delete.size; ++i) { for(uint32_t i=0; i<evt->info.impl_delete.size; ++i) {
immModel_implementerDelete(cb, immModel_implementerDelete(cb,
evt->info.impl_delete.implNameList[i].buf); evt->info.impl_delete.implNameList[i].buf);
} }
TRACE_LEAVE(); TRACE_LEAVE();
failed: failed:
return rc; return rc;
} }
uint32_t immnd_syncr_timeout_update_all(SaTimeT syncr_timeout)
{
IMMSV_EVT send_evt;
TRACE_ENTER();
uint32_t rc = NCSCC_RC_SUCCESS;
SaImmHandleT client_handle = 0;
IMMND_IMM_CLIENT_NODE *client_node = NULL;
memset(&send_evt, '\0', sizeof(IMMSV_EVT));
send_evt.type = IMMSV_EVT_TYPE_IMMA;
send_evt.info.imma.type = IMMA_EVT_ND2A_IMM_SYNCR_TIMEOUT;
send_evt.info.imma.info.immaTimeoutUpdate.syncrTimeout = syncr_timeout;
immnd_client_node_getnext(immnd_cb, 0, &client_node);
while (client_node) {
client_handle = client_node->imm_app_hdl;
send_evt.info.imma.info.immaTimeoutUpdate.immHandle =
client_handle;
if (immnd_mds_msg_send(immnd_cb, client_node->sv_id,
client_node->agent_mds_dest,
&send_evt) != NCSCC_RC_SUCCESS) {
LOG_ER("Sending syncr timeout update to client id %llx fa
iled",
client_handle);
rc = NCSCC_RC_FAILURE;
}
immnd_client_node_getnext(immnd_cb, client_handle,
&client_node);
}
TRACE_LEAVE();
return rc;
}
 End of changes. 4 change blocks. 
0 lines changed or deleted 20 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)