Index: firmware/App/Services/SystemCommMessages.c =================================================================== diff -u -r5070f8552a200e15dcc2ca0532db10fba9dc8c6b -r8f4112033e1c247f629202cdc97389ffd5cb0170 --- firmware/App/Services/SystemCommMessages.c (.../SystemCommMessages.c) (revision 5070f8552a200e15dcc2ca0532db10fba9dc8c6b) +++ firmware/App/Services/SystemCommMessages.c (.../SystemCommMessages.c) (revision 8f4112033e1c247f629202cdc97389ffd5cb0170) @@ -2278,6 +2278,26 @@ memcpy( &payload, message->payload, sizeof(DG_RO_PUMP_DATA_PAYLOAD_T) ); setDGROPumpData( payload.setPtPSI, payload.measFlowRateMlMin ); } +} + +/*********************************************************************//** + * @brief + * The handleDialysateFlowData function handles dialysate flow data broadcast + * message from the DG. + * @details Inputs: none + * @details Outputs: message handled + * @param message a pointer to the message to handle + * @return none + *************************************************************************/ +void handleDialysateFlowData( MESSAGE_T *message ) +{ + if ( message->hdr.payloadLen == sizeof(DIALYSATE_FLOW_METER_DATA_T) ) + { + DIALYSATE_FLOW_METER_DATA_T payload; + + memcpy( &payload, message->payload, sizeof(DIALYSATE_FLOW_METER_DATA_T) ); + setDialysateFlowData( payload.measuredDialysateFlowRate ); + } } /*********************************************************************//**