Search  

---

C:/temp/src/j2k/nto/bak2/Basic_PThread.cpp

Go to the documentation of this file.

#ifndef __J2K__Basic_PThread_CPP__
#define __J2K__Basic_PThread_CPP__

/*************************************************************************
 **  FILE NAME   : Basic_PThread.cpp                                    **
 **  CLASS NAME  : Basic_PThread                                        **
 **  DESCRIPTION : This class allows the creation of Generic Thread     **
 **                which takes care of the internals                    **
 **                of the PThread features. Any other subsequent        **
 **                classes can use this thread, or can appear as thread **
 **                just by inheriting from this basic class.            **
 **                just by inheriting from this basic class.            **
 **                just by inheriting from this basic class.            **
 *************************************************************************/

#include <j2k/nto/Basic_PThread.hpp>

/**************************************************************
***************************************************************
***  Attribute         Default Value                        ***
***  =========         =============                        *** 
***   detachstate       PTHREAD_CREATE_JOINABLE             *** 
***   schedpolicy       PTHREAD_INHERIT_SCHED               ***
***   schedparam        Inherited from parent PThread       *** 
***   contentionscope   PTHREAD_SCOPE_SYSTEM                *** 
***   stacksize         4096                                *** 
***   stackaddr         NULL                                ***
***************************************************************
**************************************************************/

 // INVALID arg attr !

 void Basic_PThread::start( int start_prio )
 {
   if ( pid >= 0 && (signed long)pid != INVALID_PID ) return;

   memset( &attr,  0, sizeof( attr  ) );
   memset( &param, 0, sizeof( param ) );

   register int rc = EOK;

   rc = pthread_attr_init(            &attr );
   MC_OnError( rc, Error, "while initializing a basic pthread attribute." )

   rc = pthread_attr_setdetachstate(  &attr, PTHREAD_CREATE_DETACHED );
   MC_OnError( rc, Error, "while setting a basic pthread attribute to detached." )

   rc = pthread_attr_setscope(        &attr, PTHREAD_SCOPE_SYSTEM );
   MC_OnError( rc, Error, "while setting a basic pthread attribute to system scope." )

   rc = pthread_attr_setinheritsched( &attr, PTHREAD_EXPLICIT_SCHED );   
   MC_OnError( rc, Error, "while setting a basic pthread attribute to explicit scheduling." )

   priority = start_prio;
   attr.param.sched_priority = start_prio;

   rc = pthread_attr_setschedpolicy( &attr, SCHED_RR );
   MC_OnError( rc, Error, "while setting a this pthread parameter to Round-Robin." )

   // Call the static Wrapper() which will call the dynamic run()
   rc = pthread_create( &pid, &attr, Wrapper, (void*)this );

   if ( rc == -1 ) {
     printf( "Forgot to include libraries:" 
             "g++ -lpthread -lrt -lsocket -lnsl -g Basic_PThread.cpp" );
   }

   MC_OnError( rc, Error, "while starting a basic pthread." )

   pthread_detach( pid );

   // pthread_exit( NULL );
 }

#endif

---