---

/Go4CommandsBase/TGo4CommandInvoker.cxx

Go to the documentation of this file.

//---------------------------------------------------------------
//        Go4 Release Package v2.10-5 (build 21005) 
//                      03-Nov-2005
//---------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//       Experiment Data Processing at DVEE department, GSI
//---------------------------------------------------------------
//
//Copyright (C) 2000- Gesellschaft f. Schwerionenforschung, GSI
//                    Planckstr. 1, 64291 Darmstadt, Germany
//Contact:            http://go4.gsi.de
//----------------------------------------------------------------
//This software can be used under the license agreements as stated
//in Go4License.txt file which is part of the distribution.
//----------------------------------------------------------------
#include "TGo4CommandInvoker.h"

#include "Go4Log/TGo4Log.h"
#include "Go4LockGuard/TGo4LockGuard.h"

class TGo4Pair : public TObject {
  public:
     TGo4Pair(const char* name, TGo4CommandReceiver* p) : 
        TObject(),
        fxName(name), 
        fxReceiver(p) 
     {
     }
     
     virtual ~TGo4Pair() {}
     
     virtual const char* GetName() const { return fxName.Data(); }
     
     TGo4CommandReceiver* GetReceiver() const { return fxReceiver; }

  private:
     TString fxName;         
     TGo4CommandReceiver* fxReceiver; 
};

// ***************************************************************

ClassImp(TGo4CommandInvoker)

TMutex * TGo4CommandInvoker::fxMutex = 0;
TGo4CommandInvoker * TGo4CommandInvoker::fxInstance = 0;
TObjArray * TGo4CommandInvoker::fxArray = 0;

TGo4CommandInvoker * TGo4CommandInvoker::Instance()
{
    TRACE((10,"TGo4CommandInvoker * TGo4CommandInvoker::Instance()", __LINE__, __FILE__));
    if (fxInstance == 0)
      fxInstance = new TGo4CommandInvoker();
    return fxInstance;
}

void TGo4CommandInvoker::Register(const char* name, TGo4CommandReceiver *p)
{
    TRACE((12,"static void TGo4CommandInvoker::Register(Text_t * name, TGo4CommandReceiver *p)", __LINE__, __FILE__));
    TGo4LockGuard lockguard(fxMutex);
    fxArray->Add(new TGo4Pair(name, p));
}

TGo4CommandReceiver* TGo4CommandInvoker::Lookup(const char* name)
{
  TRACE((10,"static TGo4CommandReceiver * TGo4CommandInvoker::Lookup(Text_t * name)", __LINE__, __FILE__));
  TGo4Pair* pair = (TGo4Pair*) fxArray->FindObject(name);
  
  return pair!=0 ? pair->GetReceiver() : 0;
}

TGo4CommandInvoker::~TGo4CommandInvoker()
   {
     TRACE((12,"TGo4CommandInvoker::~TGo4CommandInvoker()", __LINE__, __FILE__));
     if(fxCommand)
       delete fxCommand;
     fxCommand = 0;
     fxArray->Delete();
     delete fxArray;
   }

TGo4CommandInvoker::TGo4CommandInvoker()
   {
     TRACE((12,"TGo4CommandInvoker::TGo4CommandInvoker()", __LINE__, __FILE__));
     fxCommand = 0;
     fxArray = new TObjArray(10);
     fxMutex = new TMutex(kTRUE);
   }

void TGo4CommandInvoker::Invoke(TGo4Command * com)
{
   if(com==0) return;
   TGo4LockGuard lockguard(fxMutex);
   TGo4CommandReceiver *rec = Lookup(com->GetReceiverName());
   if(rec!=0) {
       com->SetReceiver(rec);  
       if(com->GetMode()>=com->GetProtection())
           com->ExeCom();
       else
           com->RefuseCom();
    } else
      TGo4Log::Debug(" CommandInvoker: UNKNOWN receiver");
}

void TGo4CommandInvoker::Invoke()
{
     TRACE((12,"void TGo4CommandInvoker::Invoke()", __LINE__, __FILE__));
     TGo4LockGuard lockguard(fxMutex);
     if(fxCommand==0) return;
     
     TGo4CommandReceiver* rcv = Lookup(fxCommand->GetReceiverName());
     
     if(rcv!=0) {
          fxCommand->SetReceiver(rcv);
          fxCommand->ExeCom();
     }
     delete fxCommand;
     fxCommand = 0;
}

//----------------------------END OF GO4 SOURCE FILE ---------------------

---