broke

Author: RobertPendergrast

FprimeZephyrReference/Components/PayloadHandler/PayloadHandler.cpp

@@ -23,6 +23,8 @@ PayloadHandler ::~PayloadHandler() {}
 
 void PayloadHandler ::in_port_handler(FwIndexType portNum, Fw::Buffer& buffer, const Drv::ByteStreamStatus& status) {
 
+    this->log_ACTIVITY_LO_UartReceived();
+
     const U8* data = buffer.getData();
     FwSizeType size = buffer.getSize();
 
@@ -38,7 +40,7 @@ void PayloadHandler ::in_port_handler(FwIndexType portNum, Fw::Buffer& buffer, c
             if (m_lineIndex < sizeof(m_lineBuffer) - 1) {
                 m_lineBuffer[m_lineIndex++] = byte;
             }
-
+            this->log_ACTIVITY_LO_ByteReceived(byte);
             // Have we reached the end of the line? If so that means we have a header
             // Check to see what the header is. 
             if (byte == '\n' || byte == '\r') {
@@ -48,6 +50,7 @@ void PayloadHandler ::in_port_handler(FwIndexType portNum, Fw::Buffer& buffer, c
                 // Check the header.
                 // Right now I'm just checking for an image start tag, but we can expand this to other types later
                 if (strstr((const char*)m_lineBuffer, "<IMG_START>")) {
+                    this->log_ACTIVITY_LO_ImageHeaderReceived();
                     m_receiving = true;
                     m_bytes_received = 0;
                     m_expected_size = 0;
@@ -88,6 +91,7 @@ void PayloadHandler ::in_port_handler(FwIndexType portNum, Fw::Buffer& buffer, c
             // Write a byte to the file
             FwSizeType oneByte = 1;
             m_file.write(&byte, oneByte);
+            this->log_ACTIVITY_LO_ByteReceived(byte);
             m_bytes_received++;
 
             // Check to see if we are done receiving

FprimeZephyrReference/Components/PayloadHandler/PayloadHandler.fpp

@@ -13,6 +13,12 @@ module Components {
 
         event DataReceived( data: U8, path: string) severity activity high format "Stored {} bytes of payload data to {}"
 
+        event ByteReceived( byte: U8) severity activity low format "Received byte: {}"
+
+        event ImageHeaderReceived() severity activity low format "Received image header"
+
+        event UartReceived() severity activity low format "Received UART data"
+
         output port out_port: Drv.ByteStreamSend
 
         sync input port in_port: Drv.ByteStreamData  

FprimeZephyrReference/ReferenceDeployment/Top/topology.fpp

@@ -126,6 +126,7 @@ module ReferenceDeployment {
       rateGroup10Hz.RateGroupMemberOut[0] -> comDriver.schedIn
       rateGroup10Hz.RateGroupMemberOut[1] -> ComCcsdsUart.aggregator.timeout
       rateGroup10Hz.RateGroupMemberOut[2] -> ComCcsds.aggregator.timeout
+      #rateGroup10Hz.RateGroupMemberOut[3] -> peripheralUartDriver.schedIn
 
       # Slow rate (1Hz) rate group
       rateGroupDriver.CycleOut[Ports_RateGroups.rateGroup1Hz] -> rateGroup1Hz.CycleIn