WIP nasa#62 - alignment updates started

Author: skliper

fsw/src/ci_lab_app.c

@@ -43,26 +43,25 @@
 /*
  * Declaring the CI_LAB_IngestBuffer as a union
  * ensures it is aligned appropriately to
- * store a CFE_MSG_Message_t type.
+ * store a CFE_SB_Msg_t type.
  */
 typedef union
 {
-    CFE_MSG_Message_t MsgHdr;
-    uint8             bytes[CI_LAB_MAX_INGEST];
-    uint16            hwords[2];
+    CFE_SB_Msg_t SBMsg;
+    uint8        bytes[CI_LAB_MAX_INGEST];
+    uint16       hwords[2];
 } CI_LAB_IngestBuffer_t;
 
 typedef union
 {
-    CFE_MSG_Message_t MsgHdr;
-    CI_LAB_HkTlm_t    HkTlm;
+    CFE_SB_Msg_t   SBMsg;
+    CI_LAB_HkTlm_t HkTlm;
 } CI_LAB_HkTlm_Buffer_t;
 
 typedef struct
 {
     bool               SocketConnected;
     CFE_SB_PipeId_t    CommandPipe;
-    CFE_MSG_Message_t *MsgPtr;
     osal_id_t          SocketID;
     OS_SockAddr_t      SocketAddress;
 
@@ -87,7 +86,9 @@ static CFE_EVS_BinFilter_t CI_LAB_EventFilters[] =
  */
 int32 CI_LAB_Noop(const CI_LAB_Noop_t *data);
 int32 CI_LAB_ResetCounters(const CI_LAB_ResetCounters_t *data);
-int32 CI_LAB_ReportHousekeeping(const CFE_SB_CmdHdr_t *data);
+
+/* Housekeeping message handler */
+int32 CI_LAB_ReportHousekeeping(const CFE_MSG_CommandHeader_t *data);
 
 /** * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
 /* CI_Lab_AppMain() -- Application entry point and main process loop          */
@@ -101,8 +102,9 @@ int32 CI_LAB_ReportHousekeeping(const CFE_SB_CmdHdr_t *data);
 /* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *  * *  * * * * **/
 void CI_Lab_AppMain(void)
 {
-    int32  status;
-    uint32 RunStatus = CFE_ES_RunStatus_APP_RUN;
+    int32         status;
+    uint32        RunStatus = CFE_ES_RunStatus_APP_RUN;
+    CFE_SB_Msg_t *SBMsgPtr;
 
     CFE_ES_PerfLogEntry(CI_LAB_MAIN_TASK_PERF_ID);
 
@@ -116,13 +118,13 @@ void CI_Lab_AppMain(void)
         CFE_ES_PerfLogExit(CI_LAB_MAIN_TASK_PERF_ID);
 
         /* Pend on receipt of command packet -- timeout set to 500 millisecs */
-        status = CFE_SB_RcvMsg(&CI_LAB_Global.MsgPtr, CI_LAB_Global.CommandPipe, 500);
+        status = CFE_SB_RcvMsg(&SBMsgPtr, CI_LAB_Global.CommandPipe, 500);
 
         CFE_ES_PerfLogEntry(CI_LAB_MAIN_TASK_PERF_ID);
 
         if (status == CFE_SUCCESS)
         {
-            CI_LAB_ProcessCommandPacket();
+            CI_LAB_ProcessCommandPacket(SBMsgPtr);
         }
 
         /* Regardless of packet vs timeout, always process uplink queue      */
@@ -201,7 +203,7 @@ void CI_LAB_TaskInit(void)
     */
     OS_TaskInstallDeleteHandler(&CI_LAB_delete_callback);
 
-    CFE_MSG_Init(&CI_LAB_Global.HkBuffer.HkTlm.TlmHeader.BaseMsg, CI_LAB_HK_TLM_MID, CI_LAB_HK_TLM_LNGTH);
+    CFE_MSG_Init(&CI_LAB_Global.HkBuffer.SBMsg.Msg, CI_LAB_HK_TLM_MID, CI_LAB_HK_TLM_LNGTH);
 
     CFE_EVS_SendEvent(CI_LAB_STARTUP_INF_EID, CFE_EVS_EventType_INFORMATION, "CI Lab Initialized.%s",
                       CI_LAB_VERSION_STRING);
@@ -220,20 +222,20 @@ void CI_LAB_TaskInit(void)
 /*        3. Request for housekeeping telemetry packet (from HS task)         */
 /*                                                                            */
 /* * * * * * * * * * * * * * * * * * * * * * * *  * * * * * * *  * *  * * * * */
-void CI_LAB_ProcessCommandPacket(void)
+void CI_LAB_ProcessCommandPacket(CFE_SB_Msg_t *SBMsgPtr)
 {
     CFE_SB_MsgId_t MsgId = CFE_SB_INVALID_MSG_ID;
 
-    CFE_MSG_GetMsgId(CI_LAB_Global.MsgPtr, &MsgId);
+    CFE_MSG_GetMsgId(&SBMsgPtr->Msg, &MsgId);
 
     switch (CFE_SB_MsgIdToValue(MsgId))
     {
         case CI_LAB_CMD_MID:
-            CI_LAB_ProcessGroundCommand();
+            CI_LAB_ProcessGroundCommand(SBMsgPtr);
             break;
 
         case CI_LAB_SEND_HK_MID:
-            CI_LAB_ReportHousekeeping((const CFE_SB_CmdHdr_t *)CI_LAB_Global.MsgPtr);
+            CI_LAB_ReportHousekeeping((const CFE_MSG_CommandHeader_t *)SBMsgPtr);
             break;
 
         default:
@@ -253,21 +255,27 @@ void CI_LAB_ProcessCommandPacket(void)
 /*                                                                            */
 /* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * **/
 
-void CI_LAB_ProcessGroundCommand(void)
+void CI_LAB_ProcessGroundCommand(CFE_SB_Msg_t *SBMsgPtr)
 {
     CFE_MSG_FcnCode_t CommandCode = 0;
 
-    CFE_MSG_GetFcnCode(CI_LAB_Global.MsgPtr, &CommandCode);
+    CFE_MSG_GetFcnCode(&SBMsgPtr->Msg, &CommandCode);
 
     /* Process "known" CI task ground commands */
     switch (CommandCode)
     {
         case CI_LAB_NOOP_CC:
-            CI_LAB_Noop((const CI_LAB_Noop_t *)CI_LAB_Global.MsgPtr);
+            if (CI_LAB_VerifyCmdLength(&SBMsgPtr->Msg, sizeof(CI_LAB_Noop_t)))
+            {
+                CI_LAB_Noop((const CI_LAB_Noop_t *)SBMsgPtr);
+            }
             break;
 
         case CI_LAB_RESET_COUNTERS_CC:
-            CI_LAB_ResetCounters((const CI_LAB_ResetCounters_t *)CI_LAB_Global.MsgPtr);
+            if (CI_LAB_VerifyCmdLength(&SBMsgPtr->Msg, sizeof(CI_LAB_ResetCounters_t)))
+            {
+                CI_LAB_ResetCounters((const CI_LAB_ResetCounters_t *)SBMsgPtr);
+            }
             break;
 
         /* default case already found during FC vs length test */
@@ -319,11 +327,11 @@ int32 CI_LAB_ResetCounters(const CI_LAB_ResetCounters_t *data)
 /*         telemetry, packetize it and send it to the housekeeping task via   */
 /*         the software bus                                                   */
 /* * * * * * * * * * * * * * * * * * * * * * * *  * * * * * * *  * *  * * * * */
-int32 CI_LAB_ReportHousekeeping(const CFE_SB_CmdHdr_t *data)
+int32 CI_LAB_ReportHousekeeping(const CFE_MSG_CommandHeader_t *data)
 {
     CI_LAB_Global.HkBuffer.HkTlm.Payload.SocketConnected = CI_LAB_Global.SocketConnected;
-    CFE_SB_TimeStampMsg(&CI_LAB_Global.HkBuffer.MsgHdr);
-    CFE_SB_SendMsg(&CI_LAB_Global.HkBuffer.MsgHdr);
+    CFE_SB_TimeStampMsg(&CI_LAB_Global.HkBuffer.HkTlm.TlmHeader);
+    CFE_SB_SendMsg(&CI_LAB_Global.HkBuffer.SBMsg);
     return CFE_SUCCESS;
 
 } /* End of CI_LAB_ReportHousekeeping() */

fsw/src/ci_lab_app.h

@@ -63,8 +63,8 @@
 */
 void CI_Lab_AppMain(void);
 void CI_LAB_TaskInit(void);
-void CI_LAB_ProcessCommandPacket(void);
-void CI_LAB_ProcessGroundCommand(void);
+void CI_LAB_ProcessCommandPacket(CFE_SB_Msg_t *SBMsgPtr);
+void CI_LAB_ProcessGroundCommand(CFE_SB_Msg_T *SBMsgPtr);
 void CI_LAB_ResetCounters_Internal(void);
 void CI_LAB_ReadUpLink(void);
 

fsw/src/ci_lab_msg.h

@@ -41,7 +41,7 @@
 */
 typedef struct
 {
-    uint8 CmdHeader[CFE_SB_CMD_HDR_SIZE];
+    CFE_MSG_CommandHeader_t CmdHeader;
 
 } CI_LAB_NoArgsCmd_t;
 
@@ -74,8 +74,8 @@ typedef struct
 
 typedef struct
 {
-    CFE_SB_TlmHdr_t        TlmHeader;
-    CI_LAB_HkTlm_Payload_t Payload;
+    CFE_MSG_TelemetryHeader_t TlmHeader;
+    CI_LAB_HkTlm_Payload_t    Payload;
 } OS_PACK CI_LAB_HkTlm_t;
 
 #define CI_LAB_HK_TLM_LNGTH sizeof(CI_LAB_HkTlm_t)