TGo4WatchRunnable.cxx

Go to the documentation of this file.

//-------------------------------------------------------------
//        Go4 Release Package v3.04-01 (build 30401)
//                      28-November-2008
//---------------------------------------------------------------
//   The GSI Online Offline Object Oriented (Go4) Project
//   Experiment Data Processing at EE 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 "TGo4WatchRunnable.h"

#include "TGo4Log.h"
#include "TGo4Thread.h"
#include "TGo4ClientStatus.h"

const UInt_t TGo4WatchRunnable::fguWATCHINTERVAL=5000;

TGo4WatchRunnable::TGo4WatchRunnable(const char* name, TGo4ExampleClient* cli)
: TGo4Runnable(name,cli)
{
   TRACE((15,"TGo4WatchRunnable::TGo4WatchRunnable(Text_t*,TGo4ExampleClient*) constructor",__LINE__, __FILE__));
   fxApplication=cli->GetApplication();
}

TGo4WatchRunnable::~TGo4WatchRunnable()
{
  TRACE((15,"TGo4WatchRunnable::~TGo4WatchRunnable() destructor",__LINE__, __FILE__));

}

Int_t TGo4WatchRunnable::Run(void*)
{
   TRACE((12,"TGo4WatchRunnable::Run()",__LINE__, __FILE__));
   TGo4ClientTask* cli= dynamic_cast<TGo4ClientTask*> (fxManager);
   if(cli)
   {
      cli->UpdateStatusBuffer(); // will create status object and stream it into TBuffer
      cli->SendStatusBuffer();   // send TBuffer with most recent client status
       // note: updating and sending of status buffer may be separated
       // into different threads. Updating aquires main mutex, sending usually
       // works without main mutex.
   if(fxApplication)
      {
         cli->SendStatusMessage(1,kTRUE,"Application %s of client %s has been watched",
                              fxApplication->GetName(),
                              cli->GetName());
         // method to pass text messages of priorities 0,1,2
         // (info, warning, error) to the server. kTRUE means additional local printout
      }
   }
   TGo4Thread::Sleep(fguWATCHINTERVAL); // wait for the next update
   return 0;
}

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

---