#include "du_app_rlc_inf.h"
#include "du_mgr.h"
#include "du_utils.h"
+/* Global variable declaration */
+uint8_t socket_type; /* Socket type */
+bool nonblocking; /* Blocking/Non-blocking socket */
+bool connUp; /* Is connection up */
+bool pollingState;
+CmInetNetAddrLst localAddrLst;
+CmInetNetAddrLst remoteAddrLst;
+/* Global variable declaration */
+DuSctpDestCb f1Params; /* SCTP configurations at DU */
+DuSctpDestCb ricParams; /* SCTP configurations at DU */
/**************************************************************************
* @brief Task Initiation callback function.
* RFAILED - failure
*
* ****************************************************************/
-uint8_t sctpNtfyHdlr(CmInetSctpNotification *ntfy, uint8_t *itfState)
+uint8_t sctpNtfyHdlr(CmInetSctpNotification *ntfy, uint8_t *itfState, uint8_t interface)
{
Pst pst;
DU_LOG("\nINFO --> SCTP : Send Failed notification received\n");
break;
case CM_INET_SCTP_SHUTDOWN_EVENT : /* peer socket gracefully closed */
- DU_LOG("\nINFO --> SCTP : Shutdown Event notification received\n");
- *itfState = DU_SCTP_DOWN;
- exit(0);
- break;
+ {
+ DU_LOG("\nINFO --> SCTP : Shutdown Event notification received\n");
+ *itfState = DU_SCTP_DOWN;
+ switch(interface)
+ {
+ case F1_INTERFACE:
+ break;
+ case E2_INTERFACE:
+ removeE2NodeInformation();
+ break;
+ default:
+ exit(0);
+ }
+ break;
+ }
case CM_INET_SCTP_ADAPTATION_INDICATION :
DU_LOG("\nINFO --> SCTP : Adaptation Indication received\n");
break;
{
DU_LOG("\nERROR --> SCTP: Failed to receive sctp msg for sockFd[%d]\n", sockFd->fd);
recvMsgSet = RFAILED;
+
}
else
{
{
f1Params.assocId = pollParams->ntfy.u.assocChange.assocId;
DU_LOG("\nDEBUG --> SCTP : AssocId assigned to F1Params from PollParams [%d]\n", f1Params.assocId);
- ret = sctpNtfyHdlr(&pollParams->ntfy, &f1Params.itfState);
+ ret = sctpNtfyHdlr(&pollParams->ntfy, &f1Params.itfState, F1_INTERFACE);
}
else if(pollParams->port == ricParams.destPort)
{
ricParams.assocId = pollParams->ntfy.u.assocChange.assocId;
DU_LOG("\nDEBUG --> SCTP : AssocId assigned to ricParams from PollParams [%d]\n", ricParams.assocId);
- ret = sctpNtfyHdlr(&pollParams->ntfy, &ricParams.itfState);
+ ret = sctpNtfyHdlr(&pollParams->ntfy, &ricParams.itfState, E2_INTERFACE);
}
else
{