SocketReadTask.hpp

Go to the documentation of this file.

// ======================================================================
// \title  SocketReadTask.hpp
// \author mstarch
// \brief  hpp file for SocketReadTask implementation class
//
// \copyright
// Copyright 2009-2020, by the California Institute of Technology.
// ALL RIGHTS RESERVED.  United States Government Sponsorship
// acknowledged.
//
// ======================================================================
#ifndef DRV_SOCKETREADTASK_HPP
#define DRV_SOCKETREADTASK_HPP
 
#include <Fw/Buffer/Buffer.hpp>
#include <Drv/Ip/IpSocket.hpp>
#include <Os/Task.hpp>
 
namespace Drv {
class SocketReadTask {
  public:
    SocketReadTask();
 
    virtual ~SocketReadTask();
 
    void startSocketTask(const Fw::StringBase &name,
                         const NATIVE_INT_TYPE priority,
                         const NATIVE_INT_TYPE stack,
                         const bool reconnect = true,
                         const NATIVE_INT_TYPE cpuAffinity = -1);
 
    SocketIpStatus open();
 
    void close();
 
    void stopSocketTask(void);
 
    Os::Task::TaskStatus joinSocketTask(void** value_ptr);
 
 
  PROTECTED:
    virtual IpSocket& getSocketHandler() = 0;
 
    virtual Fw::Buffer getBuffer() = 0;
 
    virtual void sendBuffer(Fw::Buffer buffer, SocketIpStatus status) = 0;
 
    static void readTask(void* pointer);
 
    Os::Task m_task;
    bool m_reconnect; 
    bool m_stop; 
 
};
};
#endif  // DRV_SOCKETREADTASK_HPP