X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fdu_app%2Fdu_mgr_main.c;h=2f7e12873330f00a25139898c7ee4585cd698a5d;hb=0a26c487f1b6bbb5217e47b15fa8273b2e749283;hp=f4791d29ed44998cb65daf0bb8a4fd460073065d;hpb=4d45b914f9e94203603d3b9fdbcb1aad361301dd;p=o-du%2Fl2.git diff --git a/src/du_app/du_mgr_main.c b/src/du_app/du_mgr_main.c index f4791d29e..2f7e12873 100644 --- a/src/du_app/du_mgr_main.c +++ b/src/du_app/du_mgr_main.c @@ -166,25 +166,25 @@ uint8_t sctpInit(SSTskId sysTskId) uint8_t rlcDlInit(SSTskId sysTskId) { /* Register RLC DL TAPA Task */ - if(ODU_REG_TTSK((Ent)ENTKW, (Inst)1, (Ttype)TTNORM, (Prior)PRIOR0, + if(ODU_REG_TTSK((Ent)ENTRLC, (Inst)1, (Ttype)TTNORM, (Prior)PRIOR0, rlcDlActvInit, (ActvTsk)rlcDlActvTsk) != ROK) { return RFAILED; } /* Attach RLC DL Task */ - if (ODU_ATTACH_TTSK((Ent)ENTKW, (Inst)1, sysTskId)!= ROK) + if (ODU_ATTACH_TTSK((Ent)ENTRLC, (Inst)1, sysTskId)!= ROK) { return RFAILED; } /* Register MAC TAPA Task */ - if(ODU_REG_TTSK((Ent)ENTRG, (Inst)0, (Ttype)TTNORM, (Prior)PRIOR0, + if(ODU_REG_TTSK((Ent)ENTMAC, (Inst)0, (Ttype)TTNORM, (Prior)PRIOR0, rgActvInit, (ActvTsk)rgActvTsk) != ROK) { return RFAILED; } /* Attach MAC Task */ - if (ODU_ATTACH_TTSK((Ent)ENTRG, (Inst)0, sysTskId)!= ROK) + if (ODU_ATTACH_TTSK((Ent)ENTMAC, (Inst)0, sysTskId)!= ROK) { return RFAILED; } @@ -213,13 +213,13 @@ uint8_t rlcDlInit(SSTskId sysTskId) uint8_t rlcUlInit(SSTskId sysTskId) { /* Register RLC UL TAPA Task */ - if(ODU_REG_TTSK((Ent)ENTKW, (Inst)0, (Ttype)TTNORM, (Prior)PRIOR0, + if(ODU_REG_TTSK((Ent)ENTRLC, (Inst)0, (Ttype)TTNORM, (Prior)PRIOR0, rlcUlActvInit, (ActvTsk)rlcUlActvTsk) != ROK) { return RFAILED; } /* Attach RLC DL Task */ - if (ODU_ATTACH_TTSK((Ent)ENTKW, (Inst)0, sysTskId)!= ROK) + if (ODU_ATTACH_TTSK((Ent)ENTRLC, (Inst)0, sysTskId)!= ROK) { return RFAILED; } @@ -254,18 +254,34 @@ uint8_t commonInit() ODU_SET_PROC_ID(DU_PROC); /* system task for DU APP */ - SCreateSTsk(PRIOR0, &du_app_stsk); + if(SCreateSTsk(PRIOR0, &du_app_stsk) != ROK) + { + DU_LOG("\nDU_APP : System Task creation for DU APP failed"); + return RFAILED; + } /* system task for RLC_DL and MAC */ - SCreateSTsk(PRIOR0, &rlc_mac_cl_stsk); + if(SCreateSTsk(PRIOR0, &rlc_mac_cl_stsk) != ROK) + { + DU_LOG("\nDU_APP : System Task creation for RLC DL/MAC failed"); + return RFAILED; + } pthread_attr_init(&attr); pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); /* system task for RLC UL */ - SCreateSTsk(PRIOR1, &rlc_ul_stsk); + if(SCreateSTsk(PRIOR1, &rlc_ul_stsk) != ROK) + { + DU_LOG("\nDU_APP : System Task creation for RLC UL failed"); + return RFAILED; + } /* system task for SCTP receiver thread */ - SCreateSTsk(PRIOR0, &sctp_stsk); + if(SCreateSTsk(PRIOR0, &sctp_stsk) != ROK) + { + DU_LOG("\nDU_APP : System Task creation for SCTP failed"); + return RFAILED; + } /* Create TAPA tasks */ if(duAppInit(du_app_stsk) != ROK)