---

/ps/src/dsc/co/mw/mwfwk/cmwfwDoorKeeper.cc

Go to the documentation of this file.

#include "cmwfwDoorKeeper.h"


#define FILE "source file:cmwfwDoorKeeper.cc"
#define ID "Contact Steen JENSEN, PS/CO"
#define PROGRAM "Middleware server framework"
#define T(a,b,c,d,e) TRACE(a,"%s(%s): %s %s %s %s\n",myname,FILE,b,c,d,e)
#define E(a,b,c,d) ERROR("%s:%s(%s):ERROR: %s %s %s %s - %s\n",PROGRAM,myname,FILE,a,b,c,d,ID)




cmwfwDoorKeeper::cmwfwDoorKeeper(){
  char* myname = "cmwfwDoorKeeper::cmwfwDoorKeeper";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  POSSIBLE_JTC_ADOPT_CURRENT_THREAD();
  theLockObject = 0;

  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
};

cmwfwDoorKeeper::~cmwfwDoorKeeper(){
  char* myname = "cmwfwDoorKeeper::~cmwfwDoorKeeper";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  if(theLockObject != 0){
#ifdef CMWFW_WINDOWSNT
  cout << "!!! Error: DoorKeeper destroyed without unlocking!" << endl;
//#else
//  E("DoorKeeper destroyed without unlocking","","","");
#endif
        releaseLock();
  };

  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
};

void cmwfwDoorKeeper::getLock(){
  char* myname = "cmwfwDoorKeeper::getLock";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  POSSIBLE_JTC_ADOPT_CURRENT_THREAD();
  theLockObject = new JTCSynchronized(theMonitor);
  if(!theLockObject)heaperr(47);

  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
};

void cmwfwDoorKeeper::releaseLock(){
  char* myname = "cmwfwDoorKeeper::releaseLock";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  POSSIBLE_JTC_ADOPT_CURRENT_THREAD();
  if (theLockObject == 0) {
#ifdef CMWFW_WINDOWSNT
    cout<<"!!! Error: Release attempted when theLockObject == 0!"<<endl;
#else
    E("Release attempted when theLockObject == 0!","","","");
#endif
  return;
  };
  JTCSynchronized* copyOfTheLockObject = theLockObject;
  theLockObject = 0;
  delete copyOfTheLockObject;

  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
};

void cmwfwDoorKeeper::wait() {
  char* myname = "cmwfwDoorKeeper::wait";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  POSSIBLE_JTC_ADOPT_CURRENT_THREAD();
  JTCSynchronized* theOldLock = theLockObject;
  theLockObject = 0;
  theMonitor.wait();            
  theLockObject = theOldLock;

  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
};

void cmwfwDoorKeeper::wait(int timeout) {
  char* myname = "cmwfwDoorKeeper::wait";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  POSSIBLE_JTC_ADOPT_CURRENT_THREAD();
  JTCSynchronized* theOldLock = theLockObject;
  theLockObject = 0;
  theMonitor.wait(timeout);
  theLockObject = theOldLock;

  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
};


void cmwfwDoorKeeper::notify() {
  char* myname = "cmwfwDoorKeeper::notify";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  POSSIBLE_JTC_ADOPT_CURRENT_THREAD();
  if (theLockObject == 0)
#ifdef CMWFW_WINDOWSNT
    cout << "Argh: notify attempted when theLockObject == 0!" << endl;
#else
    E("Argh: notify attempted when theLockObject == 0!","","","");
#endif
  JTCSynchronized* theOldLock = theLockObject;
  theLockObject = 0;
  theMonitor.notify();
  theLockObject = theOldLock;

  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
};

void cmwfwDoorKeeper::notifyAll() {
  char* myname = "cmwfwDoorKeeper::notifyAll";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  POSSIBLE_JTC_ADOPT_CURRENT_THREAD();
  if (theLockObject == 0)
#ifdef CMWFW_WINDOWSNT
    cout<<"Argh: notifyAll attempted when theLockObject == 0!"<<endl;
#else
    E("Argh: notifyAll attempted when theLockObject == 0!","","","");
#endif
  JTCSynchronized* theOldLock = theLockObject;
  theLockObject = 0;
  theMonitor.notifyAll();
  theLockObject = theOldLock;

  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
};



void cmwfwDoorKeeper::heaperr(int line){
  char* myname = "cmwfwDoorKeeper";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  char l[30];
  itoa(line,l);
  E("Out of heap in line ",l,"","");
  throw cmwfwInternalError(FILE,line,"Out of heap memory");
  T(CMWFW_TRACE_CALLS,"Exiting due to heap allocation error","","","");
  exit(-1);
};






cmwfwDoorKeeperLock::cmwfwDoorKeeperLock(cmwfwDoorKeeper& theDoorKeeper){
  char* myname = "cmwfwDoorKeeperLock::cmwfwDoorKeeperLock";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  mTheDoorKeeper = &theDoorKeeper;
  isActivated = false;
};

void cmwfwDoorKeeperLock::activate(){
  char* myname = "cmwfwDoorKeeperLock::activate";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  mTheDoorKeeper->getLock();
  isActivated = true;
};

cmwfwDoorKeeperLock::~cmwfwDoorKeeperLock() {
  char* myname = "cmwfwDoorKeeperLock::~cmwfwDoorKeeperLock";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  if(isActivated == true){
    mTheDoorKeeper->notify();
    mTheDoorKeeper->releaseLock();
    isActivated = false;
  };
};

---