oamtask.h

来自「面向对象封装 POSIX timer---------------」· C头文件 代码 · 共 70 行

#ifndef OAMTASK_H_
#define OAMTASK_H_

#include "oamRunner.h"
#include <signal.h>

class CommonData
{
public:
  CommonData();

  CommonData(char * rawData , int length);

  virtual ~CommonData();

  int getLength() const;

  void setLength(int length);

  char * getData() const;

  void setData(char * rawData);

private:
  // the length of the raw data
  int length_m;

  // the pointer of the raw data
  char * rawData_m;  
};

class OamTask:public OamRunner
{
public:
  OamTask();

  virtual ~OamTask();

  int initialize(sigset_t mask);

  int putq(CommonData & commonData);

  int getq(CommonData & commonData);

protected:
  // the logic handler which is implemented by the derived-class
  virtual int handle(CommonData * pData);

private:
  // the definition pf the pipe type.
  enum
  {
    FD_READ = 0,
    FD_WRITE,
    FD_MAX
  };

  // the thread method.
  virtual int run();

  // the FD of the queue.
  int queue_m[FD_MAX];

  // signal set
  sigset_t mask_m;
};


#endif