URL
https://opencores.org/ocsvn/w11/w11/trunk
Subversion Repositories w11
[/] [w11/] [tags/] [w11a_V0.74/] [tools/] [src/] [librlink/] [RlinkPacketBufRcv.hpp] - Rev 27
Go to most recent revision | Compare with Previous | Blame | View Log
// $Id: RlinkPacketBufRcv.hpp 607 2014-11-30 20:02:48Z mueller $ // // Copyright 2014- by Walter F.J. Mueller <W.F.J.Mueller@gsi.de> // // This program is free software; you may redistribute and/or modify it under // the terms of the GNU General Public License as published by the Free // Software Foundation, either version 2, or at your option any later version. // // This program is distributed in the hope that it will be useful, but // WITHOUT ANY WARRANTY, without even the implied warranty of MERCHANTABILITY // or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License // for complete details. // // Revision History: // Date Rev Version Comment // 2014-11-30 607 1.0 Initial version // 2014-11-02 600 0.1 First draft (re-organize PacketBuf for rlink v4) // --------------------------------------------------------------------------- /*! \file \version $Id: RlinkPacketBufRcv.hpp 607 2014-11-30 20:02:48Z mueller $ \brief Declaration of class RlinkPacketBuf. */ #ifndef included_Retro_RlinkPacketBufRcv #define included_Retro_RlinkPacketBufRcv 1 #include "RlinkPacketBuf.hpp" #include "RlinkPort.hpp" namespace Retro { class RlinkPacketBufRcv: public RlinkPacketBuf { public: RlinkPacketBufRcv(); ~RlinkPacketBufRcv(); int ReadData(RlinkPort* port, double timeout, RerrMsg& emsg); bool ProcessData(); void AcceptPacket(); void FlushRaw(); enum pkt_state { kPktPend=0, //<! pending, still being filled kPktResp, //<! response packet (SOP+EOP) kPktAttn, //<! attn notify packet (ATTN+EOP) kPktError //<! errorous packet }; pkt_state PacketState(); bool CheckSize(size_t nbyte) const; void GetWithCrc(uint8_t& data); void GetWithCrc(uint16_t& data); void GetWithCrc(uint16_t* pdata, size_t count); bool CheckCrc(); int NakIndex() const; void Dump(std::ostream& os, int ind=0, const char* text=0) const; // statistics counter indices enum stats { kStatNRxDrop=0, //!< Rx bytes dropped kStatNRxSop, //!< Rx SOP commas seen kStatNRxEop, //!< Rx EOP commas seen kStatNRxNak, //!< Rx NAK commas seen kStatNRxAttn, //!< Rx ATTN commas seen kStatNRxEsc, //!< Rx data escapes kStatNRxClobber //!< Rx clobbered escapes }; protected: void ProcessDataIdle(); void ProcessDataFill(); uint8_t GetEcode(); enum rcv_state { kRcvIdle=0, //!< wait for SOP or ATTN kRcvFill, //!< fill packet till EOP seen kRcvDone, //!< packet ok, EOP seen kRcvError //!< packet framing error }; protected: uint8_t fRawBuf[4096]; //!< raw data buffer size_t fRawBufSize; //!< # of valid bytes in RawBuf size_t fRawBufDone; //!< # of processed bytes in RawBuf enum rcv_state fRcvState; //!< receive FSM state size_t fNDone; //!< number of pkt bytes processed bool fEscSeen; //!< last char was Escape int fNakIndex; //!< index of active nak (-1 if no) std::vector<uint8_t> fDropData; //!< dropped data buffer }; } // end namespace Retro #include "RlinkPacketBufRcv.ipp" #endif
Go to most recent revision | Compare with Previous | Blame | View Log