// $Id$
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum fuer 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 "TGo4ExampleServer.h"

#include "TGo4Log.h"
#include "TGo4Status.h"
#include "TGo4BufferQueue.h"
#include "TGo4ThreadHandler.h"

#include "TGo4LoggingRunnable.h"
#include "TGo4ControllerRunnable.h"
#include "TGo4ExampleCommandList.h"

const char *TGo4ExampleServer::fgcLOGGINGTHREAD="LOGGER-";
const char *TGo4ExampleServer::fgcCONTROLTHREAD="CONTROL-";

TGo4ExampleController* TGo4ExampleServer::GetController()
{
   GO4TRACE((12,"TGo4ExampleServer::GetController()",__LINE__, __FILE__));

   return fxController;
}
TGo4ExampleServer::~TGo4ExampleServer()
{
   GO4TRACE((15,"TGo4ExampleServer::~TGo4ExampleServer()",__LINE__, __FILE__));

   fxWorkHandler->CancelAll(); // make sure threads wont work on controller instance when its deleted
   delete fxController;

}
TGo4ExampleServer::TGo4ExampleServer(const char *name,
                                     UInt_t negotiationport,
                                     Bool_t blockingmode)
: TGo4ServerTask(name, negotiationport, blockingmode,kFALSE)
{
   GO4TRACE((15,"TGo4ExampleServer::TGo4ExampleServer(const char *, Bool_t)",__LINE__, __FILE__));

   TGo4Log::Debug(" ExampleServer ''%s'' started ",GetName());

   fxController = new TGo4ExampleController();

   auto controlrun = new TGo4ControllerRunnable(TString::Format("ControllerRunnable of %s",GetName()).Data(), this);

   auto logrun = new TGo4LoggingRunnable(TString::Format("LoggerRunnable of %s",GetName()).Data(), this);

   // adding runnables to thread handler who takes over the responsibility...:

   fcControlName.Form("%s%s",fgcCONTROLTHREAD,GetName());
   fxWorkHandler->NewThread(fcControlName.Data(), controlrun);

   fcLoggingName.Form("%s%s",fgcLOGGINGTHREAD,GetName());
   fxWorkHandler->NewThread(fcLoggingName.Data(), logrun);

   Launch();
}

TGo4TaskHandlerCommandList* TGo4ExampleServer::CreateCommandList()
{
   return new TGo4ExampleCommandList;
}

Int_t TGo4ExampleServer::StopWorkThreads()
{

   TGo4Log::Debug(" Example Server is stopping work threads ");
   Int_t rev = 0;
   TGo4ThreadHandler* threadhandler = GetWorkHandler();
   TGo4BufferQueue *dataq=GetDataQueue();
   TGo4BufferQueue *statusq=GetStatusQueue();
  // stop my own threads, put dummies into queues to release semaphores
   threadhandler->Stop(fcControlName.Data());
   if(dataq)
      dataq->AddBufferFromObject(new TNamed("StopObject","dummy"));
   threadhandler->Stop(fcLoggingName.Data());
   if(statusq)
      statusq->AddBufferFromObject(new TGo4Status("StopStatus"));
   rev = TGo4ServerTask::StopWorkThreads(); // this will set server task internal flag
   return rev;
}


Int_t TGo4ExampleServer::StartWorkThreads()
{

   TGo4Log::Debug(" Example Server is starting work threads ");
   Int_t rev = 0;
    // start again the  working threads on next current task
   TGo4ThreadHandler* threadhandler = GetWorkHandler();
   threadhandler->Start(fcControlName.Data());
   threadhandler->Start(fcLoggingName.Data());
   rev = TGo4ServerTask::StartWorkThreads(); // this will set server task internal flag
   return rev;

}