Search  

---

C:/temp/src/j2k/QNX4/Thread.hpp

Go to the documentation of this file.

// For QNX425

#ifndef __J2K__Thread_HPP__
#define __J2K__Thread_HPP__

/**********************************************************************
 **  FILE NAME   : <j2k/Fred/QNX/Thread.hpp>                         **
 **  CLASS NAME  : Thread                                            **
 **  DESCRIPTION : This class allows the creation of                 **
 **                Generic Thread which takes care of the internals  **
 **                of the QNX OS. Any other subsequent classes can   **
 **                use this thread, or can appear as thread just     **
 **                by inheriting from this basic class.              **
 **********************************************************************/

#include <j2k/Fred/QNX/System.hpp>

// Default Arguments
#define  DEFAULT_STACK  4096
#define  DEFAULT_ALGO   SCHED_RR
#define  DEFAULT_PRIO   12
#define  DEFAULT_NODE   0

// Alias for Scheduling Schemes
#define  S_FIFO         SCHED_FIFO
#define  S_ROUND_ROBIN  SCHED_RR
#define  S_ADAPTIVE     SCHED_OTHER

// Message Passing Values
#define  MSG_NONE       0
#define  MSG_STOP       1
#define  MSG_REFRESH    2
#define  MSG_YIELD      3
#define  MSG_PRINT      4
#define  MSG_FUNCTION   5

class Thread {
// MC_SerializeHeader()

private:
  // Not Implemented yet.
  Thread( const Thread& thread );  
  inline int  yield();  

public:
  // Optimized Default Constructor
  inline Thread(); 


  inline virtual ~Thread();

  static void FAR Thread::Wrapper( void* ptrThis );

  void start( size_t stack_size = DEFAULT_STACK, 
                 int       alg  = DEFAULT_ALGO, 
                 int       prio = DEFAULT_PRIO  );

  inline void refresh();
  inline void stop();

  // Return the Process ID value 
  inline pid_t getPID();
  inline int isStarted();
   
  // Should be overriden by it's children...
  virtual void run() = 0;

  // Get Initial Starting values
  inline size_t  getStack() {          return start_stack; }
  inline int     getStartAlgo() {      return start_algo;  }
  inline int     getStartPriority() {  return start_prio;  }

  // Get, Set, Reset Priority and Scheduling Schemes
  inline int     getPriority();
  inline void    setPriority( int prio );
  inline void  resetPriority();

  inline int     getScheduler();
  inline void    setScheduler( int sched );
  inline void  resetScheduler();

  inline struct sched_param*  getSchedulerParam();
  inline void                 setSchedulerParam( struct sched_param* param );
  inline void               resetSchedulerParam();

// So, children can access easily the PID
protected: 
  pid_t  pid;

  // Not used yet.
  pid_t  rpid;
  Msg_t  msg;
  Msg_t  rmsg;
  Msg_t  smsg;

// Private, since only used by Reset and Restart functions
private:
  size_t                start_stack;
  int                   start_algo;
  int                   start_prio;
  struct sched_param*   start_param;
};

#endif

---