// $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 "TGo4EventSource.h"

#include <stdarg.h>

#include "TClass.h"

#include "TGo4EventElement.h"
#include "TGo4EventErrorException.h"
#include "TGo4EventEndException.h"
#include "TGo4Log.h"

const Int_t TGo4EventSource::fgiTIMEOUTDEFAULT=1; // source timeout default in seconds

TGo4EventSource::TGo4EventSource() :
   TNamed("default eventsource","This is a Go4 EventSource")
{
}

TGo4EventSource::TGo4EventSource(const char *name) :
   TNamed(name, "This is a Go4 Event Source")
{
   GO4TRACE((15,"TGo4EventSource::TGo4EventSource()",__LINE__, __FILE__));
}


TGo4EventSource::~TGo4EventSource()
{
   GO4TRACE((15,"TGo4EventSource::~TGo4EventSource()",__LINE__, __FILE__));
}

void TGo4EventSource::ThrowError(Int_t crestat, Int_t errstat, const char *message,...)
{
   //
   UInt_t lbuflen = TGo4EventSource::fguTXTLEN;
   char *txtbuf = new char[lbuflen];
   va_list args;
   va_start(args, message);
   vsnprintf(txtbuf, lbuflen, message, args);
   va_end(args);
   if(crestat != 0)
      SetCreateStatus(crestat);
   if(errstat != 0)
      SetEventStatus(errstat);
   SetErrMess(txtbuf);
   delete[] txtbuf;
   throw TGo4EventErrorException(this);
}

void TGo4EventSource::ThrowEOF(Int_t crestat, Int_t errstat, const char *message,...)
{
   UInt_t lbuflen = TGo4EventSource::fguTXTLEN;
   char *txtbuf = new char[lbuflen];
   va_list args;
   va_start(args, message);
   vsnprintf(txtbuf, lbuflen, message, args);
   va_end(args);
   if(crestat != 0)
      SetCreateStatus(crestat);
   if(errstat != 0)
      SetEventStatus(errstat);
   SetErrMess(txtbuf);
   delete[] txtbuf;
   throw TGo4EventEndException(this);
}

void TGo4EventSource::Clear(Option_t *)
{
   // dummy clear, may be implemented by user
   TGo4Log::Info("Default clear of eventsource %s", GetName());
}

const char *TGo4EventSource::GetActiveName() const
{
   return GetName();
}

Bool_t TGo4EventSource::CheckEventClass(TClass *cl)
{
   return cl->InheritsFrom(TGo4EventElement::Class());
}