Search  

---

C:/temp/src/j2k/nto/bakJuly/Semaphore.cpp

Go to the documentation of this file.

#ifndef  __J2K__Semaphore_CPP__
#define  __J2K__Semaphore_CPP__

#define DEADLOCK_SEM 1000

static int cnt = 0;

#include <j2k/nto/Semaphore.hpp>

  Semaphore::Semaphore( SCHAR init, const char* sem_name, int c ) 
    : state( init ), color( c ), fg( 0 )
  { 
    name = (char*)sem_name;
    if ( c > 15 ) { color = c - 16; fg++; }
    if ( sem_name[0] == 's' ) { fg = 1; }
  }

  void Semaphore::P() 
  {
    m.lock();
    while ( state < 1 ) 
    {
      m.unlock();
        if ( ++cnt > DEADLOCK_SEM ) { 
          printf( "Deadlock(%s=%d|%d)", name, cnt, state ); fflush( stdout );
          exit( 1 );
        }
        sched_yield();
      m.lock();
    }
    --state;  
    m.unlock();
  }

  void Semaphore::V() {
    m.lock();
      ++state;
    m.unlock();
  }     

  SCHAR Semaphore::get() {
    register SCHAR s = 0;
    m.lock();
      s = state;
    m.unlock();

    return s;
  }     

  void Semaphore::set( SCHAR value ) 
  {
    m.lock();
      state = value;
    m.unlock();
  }     

#endif

---