Go4CommandsBase/TGo4CommandInvoker.cxx

Go to the documentation of this file.

// $Id: TGo4CommandInvoker.cxx 999 2013-07-25 11:58:59Z linev $
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum für Schwerionenforschung GmbH
//                     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 "TMutex.h"
#include "TString.h"
#include "TObjArray.h"

#include "TGo4Log.h"
#include "TGo4LockGuard.h"
#include "TGo4Command.h"
#include "TGo4CommandProtoList.h"
#include "TGo4RemoteCommand.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; 
};

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

TGo4CommandInvoker::TGo4CommandInvoker() :
   TObject(),
   TGo4CommandReceiver()
{
   GO4TRACE((12,"TGo4CommandInvoker::TGo4CommandInvoker()", __LINE__, __FILE__));
   fxCommand = 0;
   fxArray = new TObjArray(10);
   fxMutex = new TMutex(kTRUE);
   fxCommandList=new TGo4CommandProtoList("Go4 base commandlist");
   Register("CommandInvoker",this); // we are ourselves receiver for remote commands
}

TGo4CommandInvoker::~TGo4CommandInvoker()
{
   GO4TRACE((12,"TGo4CommandInvoker::~TGo4CommandInvoker()", __LINE__, __FILE__));
   delete fxCommand;
   delete fxCommandList;
   delete fxMutex;
   fxArray->Delete();
   delete fxArray;
}


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

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

void TGo4CommandInvoker::UnRegister(TGo4CommandReceiver *p)
{
    GO4TRACE((12,"static void TGo4CommandInvoker::UnRegister(TGo4CommandReceiver *p)", __LINE__, __FILE__));
    if (fxArray==0) return;
    TGo4LockGuard lockguard(fxMutex);
    TIter riter(fxArray);
    TObject* ob=0;
    while((ob=riter())!=0) {
       TGo4Pair* pair = dynamic_cast<TGo4Pair*>(ob);
       if(pair==0) {
          TGo4Log::Error("NEVER COME HERE: TGo4CommandInvoker::UnRegister - receiver list with no receiver");
          break;
       }
       if(pair->GetReceiver()==p) {
          //std::cout <<"TGo4CommandInvoker::UnRegister removed receiver "<<pair->ReceiverName()<< std::endl;
          fxArray->Remove(pair);
          delete pair;
          break;
       }
   }
   fxArray->Compress();
}


TGo4CommandReceiver* TGo4CommandInvoker::Lookup(const char* name)
{
  GO4TRACE((10,"static TGo4CommandReceiver * TGo4CommandInvoker::Lookup(const char* name)", __LINE__, __FILE__));
  TGo4Pair* pair = (TGo4Pair*) fxArray->FindObject(name);

  return pair!=0 ? pair->GetReceiver() : 0;
}

void TGo4CommandInvoker::Invoke(TGo4Command * com)
{
    GO4TRACE((12,"void TGo4CommandInvoker::Invoke(TGo4Command * com)", __LINE__, __FILE__));
    if(com==0) return;
    TGo4LockGuard lockguard(fxMutex);
     //std::cout <<"Invoker has command "<<com->GetName() << std::endl;
    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()
{
   GO4TRACE((12,"void TGo4CommandInvoker::Invoke()", __LINE__, __FILE__));
   if(fxCommand==0) return;
   //std::cout <<"TGo4CommandInvoker::Invoke() PLAIN NEVER COME HERE" << std::endl;
   TGo4LockGuard lockguard(fxMutex);

   TGo4CommandReceiver* rcv = Lookup(fxCommand->GetReceiverName());

   if(rcv!=0) {
      fxCommand->SetReceiver(rcv);
      fxCommand->ExeCom();
   }
   delete fxCommand;
   fxCommand = 0;
}

void TGo4CommandInvoker::SetCommandList(TGo4CommandProtoList* list)
{
   delete fxCommandList;
   fxCommandList=list;
}

Int_t TGo4CommandInvoker::ExecuteFromRemote(TGo4RemoteCommand* remcom)
{
   if(fxCommandList==0) return -1;
   TGo4Command* realcommand=fxCommandList->MakeCommand(remcom);
   realcommand->SetTaskName(remcom->GetTaskName());
   realcommand->SetMode(remcom->GetMode());
   Invoke(realcommand);
   delete realcommand;
   return 0;
}