Search  

---

C:/temp/src/j2k/Deprecated/old_18mar_diff/nto/Semaphore.cpp

Go to the documentation of this file.

#ifndef  Semaphore_CPP
#define  Semaphore_CPP

#define DEADLOCK_SEM 1000

static int cnt = 0;

#include "Semaphore.hpp"
#include <iostream.h>

  Semaphore::Semaphore( int 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;
  }     

#endif

---