"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "src/imm/agent/imma_proc.cc" 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.

imma_proc.cc  (opensaf-5.21.06):imma_proc.cc  (opensaf-5.21.09)
skipping to change at line 1407 skipping to change at line 1407
break; break;
case IMMA_EVT_ND2A_OI_CCB_COMPLETED_UC: case IMMA_EVT_ND2A_OI_CCB_COMPLETED_UC:
case IMMA_EVT_ND2A_OI_CCB_APPLY_UC: case IMMA_EVT_ND2A_OI_CCB_APPLY_UC:
case IMMA_EVT_ND2A_OI_CCB_ABORT_UC: case IMMA_EVT_ND2A_OI_CCB_ABORT_UC:
break; break;
case IMMA_EVT_ND2A_PROC_STALE_CLIENTS: case IMMA_EVT_ND2A_PROC_STALE_CLIENTS:
break; break;
case IMMA_EVT_ND2A_IMM_SYNCR_TIMEOUT:
break;
default: default:
TRACE_4("Unknown event type %u", evt->type); TRACE_4("Unknown event type %u", evt->type);
break; break;
} }
TRACE_LEAVE(); TRACE_LEAVE();
} }
/**************************************************************************** /****************************************************************************
Name : imma_proc_clm_status_changed Name : imma_proc_clm_status_changed
Description : This function will process the clm state changes. Description : This function will process the clm state changes.
skipping to change at line 1438 skipping to change at line 1441
cb->clmMemberNode = false; cb->clmMemberNode = false;
LOG_NO("CLM node left the cluster"); LOG_NO("CLM node left the cluster");
imma_client_tree_mark_clmexposed(cb); imma_client_tree_mark_clmexposed(cb);
} else if (evt->type == IMMA_EVT_ND2A_IMM_CLM_NODE_JOINED) { } else if (evt->type == IMMA_EVT_ND2A_IMM_CLM_NODE_JOINED) {
cb->clmMemberNode = true; cb->clmMemberNode = true;
TRACE("CLM node join the cluster"); TRACE("CLM node join the cluster");
} }
m_NCS_UNLOCK(&cb->cb_lock, NCS_LOCK_WRITE); m_NCS_UNLOCK(&cb->cb_lock, NCS_LOCK_WRITE);
} }
static void imma_proc_syncr_timeout_update(IMMA_CB *cb, IMMA_EVT *evt) {
TRACE_ENTER();
IMMA_CLIENT_NODE *cl_node = NULL;
SaImmHandleT impl_handle = evt->info.immaTimeoutUpdate.immHandle;
/* get the CB Lock */
if (m_NCS_LOCK(&cb->cb_lock, NCS_LOCK_WRITE) != NCSCC_RC_SUCCESS) {
TRACE_3("Lock failure");
return;
}
/* Get the Client info */
imma_client_node_get(&cb->client_tree, &impl_handle, &cl_node);
if (cl_node == NULL) {
m_NCS_UNLOCK(&cb->cb_lock, NCS_LOCK_WRITE);
TRACE_3("Could not find client node impl_handle: %llx", impl_handle);
return;
}
cl_node->syncr_timeout = evt->info.immaTimeoutUpdate.syncrTimeout;
if (cl_node->syncr_timeout == 0) {
cl_node->syncr_timeout = imma_getSyncrTimeout();
}
TRACE_3("IMMA library syncronous timeout set to:%lld",
cl_node->syncr_timeout);
m_NCS_UNLOCK(&cb->cb_lock, NCS_LOCK_WRITE);
TRACE_LEAVE();
}
/**************************************************************************** /****************************************************************************
Name : imma_process_evt Name : imma_process_evt
Description : This routine will process the callback event received from Description : This routine will process the callback event received from
IMMND. IMMND.
Arguments : cb - IMMA CB. Arguments : cb - IMMA CB.
evt - IMMSV_EVT. evt - IMMSV_EVT.
Return Values : NCSCC_RC_SUCCESS/NCSCC_RC_FAILURE Return Values : NCSCC_RC_SUCCESS/NCSCC_RC_FAILURE
Notes : None Notes : None
******************************************************************************/ ******************************************************************************/
void imma_process_evt(IMMA_CB *cb, IMMSV_EVT *evt) { void imma_process_evt(IMMA_CB *cb, IMMSV_EVT *evt) {
skipping to change at line 1510 skipping to change at line 1541
case IMMA_EVT_ND2A_PROC_STALE_CLIENTS: case IMMA_EVT_ND2A_PROC_STALE_CLIENTS:
LOG_IN("Received PROC_STALE_CLIENTS"); LOG_IN("Received PROC_STALE_CLIENTS");
imma_process_stale_clients(cb); imma_process_stale_clients(cb);
break; break;
case IMMA_EVT_ND2A_IMM_CLM_NODE_LEFT: case IMMA_EVT_ND2A_IMM_CLM_NODE_LEFT:
case IMMA_EVT_ND2A_IMM_CLM_NODE_JOINED: case IMMA_EVT_ND2A_IMM_CLM_NODE_JOINED:
imma_proc_clm_status_changed(cb, &evt->info.imma); imma_proc_clm_status_changed(cb, &evt->info.imma);
break; break;
case IMMA_EVT_ND2A_IMM_SYNCR_TIMEOUT:
imma_proc_syncr_timeout_update(cb, &evt->info.imma);
break;
default: default:
TRACE_4("Unknown event type %u", evt->info.imma.type); TRACE_4("Unknown event type %u", evt->info.imma.type);
break; break;
} }
imma_proc_free_pointers(cb, &evt->info.imma); imma_proc_free_pointers(cb, &evt->info.imma);
return; return;
} }
/**************************************************************************** /****************************************************************************
Name : imma_callback_ipc_rcv Name : imma_callback_ipc_rcv
 End of changes. 3 change blocks. 
0 lines changed or deleted 35 lines changed or added

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