TCPPacketMerger.h

Go to the documentation of this file.

// this is for emacs file handling -*- mode: c++; indent-tabs-mode: nil -*-

// -- BEGIN LICENSE BLOCK ----------------------------------------------

// -- END LICENSE BLOCK ------------------------------------------------

//----------------------------------------------------------------------
//----------------------------------------------------------------------

#ifndef SICK_SAFETYSCANNERS_DATA_PROCESSING_TCPPACKETMERGER_H
#define SICK_SAFETYSCANNERS_DATA_PROCESSING_TCPPACKETMERGER_H

#include <sick_safetyscanners/datastructure/PacketBuffer.h>

#include <sick_safetyscanners/data_processing/ParseDatagramHeader.h>

#include <mutex>
#include <vector>

namespace sick {
namespace data_processing {

class TCPPacketMerger
{
public:
  TCPPacketMerger();

  bool isComplete() const;

  bool isEmpty() const;

  bool addTCPPacket(const sick::datastructure::PacketBuffer& buffer);

  sick::datastructure::PacketBuffer getDeployedPacketBuffer();

  uint32_t getTargetSize() const;

  void setTargetSize(const uint32_t& targetSize);

private:
  bool m_is_complete;
  sick::datastructure::PacketBuffer m_deployed_packet_buffer;

  std::vector<sick::datastructure::PacketBuffer> m_buffer_vector;
  std::mutex m_buffer_mutex;
  uint32_t m_targetSize;

  bool addToMap(const sick::datastructure::PacketBuffer& new_packet);
  bool deployPacketIfComplete();

  uint32_t getCurrentSize();
  bool deployPacket();
};

} // namespace data_processing
} // namespace sick

#endif // SICK_SAFETYSCANNERS_DATA_PROCESSING_TCPPACKETMERGER_H