posix_thread_manager.hpp

Go to the documentation of this file.

#ifndef POSIXTHREADMANAGER_H
#define POSIXTHREADMANAGER_H

#include "dji_thread_manager.hpp"
#include "pthread.h"

namespace DJI
{
namespace OSDK
{

class PosixThreadManager : public ThreadAbstract
{
public:
  PosixThreadManager()
  {
  }
  ~PosixThreadManager();

  void init();

public:
  void lockRecvContainer();
  void freeRecvContainer();

  void lockMSG();
  void freeMSG();

  void lockACK();
  void freeACK();

  void lockProtocolHeader();
  void freeProtocolHeader();

  void lockNonBlockCBAck();
  void freeNonBlockCBAck();

  void lockStopCond();
  void freeStopCond();

  void lockFrame();
  void freeFrame();

  void notify();
  void notifyNonBlockCBAckRecv();
  void wait(int timeoutInSeconds);
  void nonBlockWait();

private:
  pthread_mutex_t m_memLock;
  pthread_mutex_t m_msgLock;
  pthread_mutex_t m_ackLock;
  pthread_cond_t  m_ackRecvCv;

  pthread_mutex_t m_headerLock;
  pthread_mutex_t m_nbAckLock;
  pthread_cond_t  m_nbAckRecv;

  pthread_mutex_t m_stopCondLock;

  pthread_mutex_t m_frameLock;
};

} // namespace OSDK
} // namespace DJI

#endif // POSIXTHREADMANAGER_H