Diff: WizziCom.h

Revision:

0:95b73d0b37b7

Child:

1:ca1c9bfb1cf4

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/WizziCom.h	Wed Apr 26 12:29:35 2017 +0000
@@ -0,0 +1,190 @@
+#ifndef _D7A_COM_H_
+#define _D7A_COM_H_
+
+#include "mbed.h"
+#include "rtos.h"
+#include "CBuffer.h"
+#include "WizziDebug.h"
+
+
+typedef enum
+{
+    HAL_ERROR_NONE                      =    0,
+    HAL_ERROR_DEFAULT                   =   -1,
+    HAL_ERROR_MEM_FULL                  =   -2,
+    HAL_ERROR_MEM_EMPTY                 =   -3,
+    HAL_ERROR_MODULE_BUSY               =   -4,
+    HAL_ERROR_MODULE_OFF                =   -5,
+    HAL_ERROR_SERIAL_BAD_SYNC           = -100,
+    HAL_ERROR_SERIAL_BAD_SEQ            = -101,
+    HAL_ERROR_I2C_BAD_DEVID             = -200,
+    HAL_ERROR_I2C_NACK                  = -201,
+    HAL_ERROR_I2C_ARB_LOST              = -202,
+
+} hal_error_t;
+
+
+typedef enum {
+    // Default printf type
+    WizziComPacketPrintf,
+    // Substitute the string by a codeword
+    // interpreted by the PC com tool
+    WizziComPacketPrintfCompressed,
+    // Display the payload as hex data
+    WizziComPacketPrintHex,
+
+    // AT command
+    WizziComPacketAlpCmd,
+    // AT command response
+    WizziComPacketAlpResp,
+    // AT unsolicited message
+    WizziComPacketAlpUns,
+    // AT unsolicited error
+    WizziComPacketAlpErr,
+
+    // Remote Commands
+    WizziComPacketCmd,
+    
+    // Remote System reset
+    WizziComPacketSysReset,
+    // Button Emulator
+    WizziComPacketSysButton,
+    // Dump Debug parameters
+    WizziComPacketSysInfo,
+    // CUP signalisation
+    WizziComPacketSysCup,
+    // Ping distant COM
+    WizziComPacketSysPing,
+    // Pong from distant COM
+    WizziComPacketSysPong,
+    // Enable system config from distant COM
+    WizziComPacketSysConfig,
+    // Configure Output Trace level from distant COM
+    WizziComPacketSysTlev,
+    // Configure COM port redirection
+    WizziComPacketSysRedir,
+    // Flow control signalling
+    WizziComPacketSysXon,
+    WizziComPacketSysXoff,
+    WizziComPacketSysXack,
+
+    // File System Command/Response
+    WizziComPacketFsCmd,
+    WizziComPacketFsResp,
+    
+    WIZZICOM_PKT_QTY,
+    
+    // Special flag to redirect all undirected packets to this callback
+    WizziComPacketOther = WIZZICOM_PKT_QTY,
+} WizziComPacketType;
+
+typedef struct {
+    uint8_t type;
+    uint8_t length;
+    uint8_t data[1];
+} WizziComPacket_t;
+
+//======================================================================
+// wizzi_com_tx_msg_t
+//----------------------------------------------------------------------
+// Transmit message structure
+//======================================================================
+typedef struct
+{
+    // identifier wizzi_com_flow_t
+    uint8_t  id;
+    // length of the string buffer defined by a pointer
+    uint8_t  plen;
+    // length of the allocated buffer
+    uint8_t  alen;
+    // pointer to a string buffer that does not need to be freed
+    uint8_t* pbuf;
+    // pointer to argument that does not need to be freed
+    uint8_t* abuf;
+
+} wizzi_com_tx_msg_t;
+
+//======================================================================
+// wizzi_com_rx_msg_t
+//----------------------------------------------------------------------
+// Receive message structure
+//======================================================================
+typedef struct
+{
+    // error message
+    hal_error_t err;
+    // length of the log (string) buffer
+    uint8_t  blen;
+    // identifier wizzi_com_flow_t
+    uint8_t  id;
+    // Com port where the message came from
+    uint8_t com_id;
+    // pointer to the log buffer
+    uint8_t  buffer[1];
+
+} wizzi_com_rx_msg_t;
+
+typedef struct {
+    uint32_t len;
+    uint8_t buf[1];
+} wizzi_com_tx_buf_t;
+
+
+class WizziCom {
+    typedef void (*WizziComCallback)(WizziCom* com, WizziComPacket_t* packet);
+
+private:
+    uint8_t                         _state;
+    wizzi_com_rx_msg_t              _msg;
+    uint16_t                        _skipped_bytes;
+    uint8_t                         _tx_seq;
+    uint8_t                         _rx_seq;
+    
+    DigitalOut*                     _irq_out;
+    InterruptIn*                    _irq_in;
+    RawSerial*                      _serial;
+    
+    CBuffer<uint8_t, 512>           _rx_buf;
+    
+    Semaphore                       _data_parsing;
+    Semaphore                       _irq_in_int;
+    Thread                          _rx_thread;
+    Thread                          _tx_thread;
+    Thread                          _callback_thread;
+    Queue<wizzi_com_tx_buf_t, 8>    _tx_queue;
+    Queue<WizziComPacket_t, 8>      _rx_queue;
+    
+    Callback<void(WizziCom*, WizziComPacket_t*)>      _callback[WIZZICOM_PKT_QTY+1];
+    
+    void                            _rx_isr();
+    void                            _irq_in_isr();
+    void                            _send_raw(wizzi_com_tx_buf_t* tx_buf);
+    void                            _sys_xack(void);
+    wizzi_com_tx_buf_t*             _new_msg(wizzi_com_tx_msg_t* msg);
+    void                            _post_msg(wizzi_com_tx_msg_t* msg);
+    void                            _new_pkt(WizziComPacket_t* pkt);
+    uint8_t                         _flow_to_type(uint8_t flow_id);
+    void                            _parse_packet_header(void);
+    void                            _parse_packet_body(void);
+    void                            _thread_rx(void);
+    void                            _thread_tx(void);
+    void                            _thread_callback(void);
+    
+public:
+    WizziCom(PinName tx, PinName rx, PinName irq_out = NC, PinName irq_in = NC);
+    ~WizziCom();
+    
+    void attach(WizziComCallback function, WizziComPacketType packet_type);
+    
+    template<class T>
+    void attach(T* object, void (T::*member)(WizziCom*, WizziComPacket_t*), WizziComPacketType packet_type)
+    {
+        _callback[packet_type] = callback(object, member);
+    }
+    
+    void reset(void);
+    void send(WizziComPacketType type, uint8_t length, uint8_t* data);
+    void send(WizziComPacket_t* packet);
+};
+
+#endif // _D7A_COM_H_
\ No newline at end of file