/**************************************************************************
 * This file is property of and copyright by the ALICE HLT Project        * 
 * ALICE Experiment at CERN, All rights reserved.                         *
 *                                                                        *
 * Primary Authors: Jochen Thaeder <thaeder@kip.uni-heidelberg.de>        *
 *                  Sorina Popescu <sorina.popescu@cern.ch                *
 *                  for The ALICE HLT Project.                            *
 *                                                                        *
 * Permission to use, copy, modify and distribute this software and its   *
 * documentation strictly for non-commercial purposes is hereby granted   *
 * without fee, provided that the above copyright notice appears in all   *
 * copies and that both the copyright notice and this permission notice   *
 * appear in the supporting documentation. The authors make no claims     *
 * about the suitability of this software for any purpose. It is          *
 * provided "as is" without express or implied warranty.                  *
 **************************************************************************/

/** @file   AliHLTTPCCalibSignalComponent.cxx
    @author Jochen Thaeder, Sorina Popescu
    @date   8 may 2007
    @brief  HLT pulser calibration component for the TPC.
*/

#if __GNUC__>= 3
using namespace std;
#endif

#include "AliHLTTPCLogging.h"
#include "AliHLTTPCTransform.h"

#include "AliHLTTPCCalibSignalComponent.h"

#include "AliRawDataHeader.h"
#include "AliRawReaderMemory.h"
#include "AliTPCRawStream.h"

#include "AliTPCCalibSignal.h"

#include <stdlib.h>
#include <errno.h>
#include "TString.h"

// this is a global object used for automatic component registration, do not use this
AliHLTTPCCalibSignalComponent gAliHLTTPCCalibSignalComponent;

ClassImp(AliHLTTPCCalibSignalComponent)

AliHLTTPCCalibSignalComponent::AliHLTTPCCalibSignalComponent()
  :
  fRawReader(NULL),
  fRawStream(NULL),
  fCalibSignal(NULL),
  fRCUFormat(kFALSE)
{
  // see header file for class documentation
  // or
  // refer to README to build package
  // or
  // visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
}

AliHLTTPCCalibSignalComponent::AliHLTTPCCalibSignalComponent(const AliHLTTPCCalibSignalComponent&)
  :
  fRawReader(NULL),
  fRawStream(NULL),
  fCalibSignal(NULL),
  fRCUFormat(kFALSE)
{
  // see header file for class documentation
  HLTFatal("copy constructor to be tested");
}

AliHLTTPCCalibSignalComponent& AliHLTTPCCalibSignalComponent::operator=(const AliHLTTPCCalibSignalComponent&)
{ 
  // see header file for class documentation
  HLTFatal("assignment operator to be tested");
  return *this;
}	

AliHLTTPCCalibSignalComponent::~AliHLTTPCCalibSignalComponent()
{
  // see header file for class documentation
}

// Public functions to implement AliHLTComponent's interface.
// These functions are required for the registration process

const char* AliHLTTPCCalibSignalComponent::GetComponentID()
{
  // see header file for class documentation
  return "TPCCalibSignal";
}

void AliHLTTPCCalibSignalComponent::GetInputDataTypes( vector<AliHLTComponentDataType>& list)
{
  // see header file for class documentation
  list.clear(); 
  list.push_back( AliHLTTPCDefinitions::fgkDDLPackedRawDataType );
}

AliHLTComponentDataType AliHLTTPCCalibSignalComponent::GetOutputDataType()
{
  // see header file for class documentation
  return AliHLTTPCDefinitions::fgkCalibSignalDataType;
}

void AliHLTTPCCalibSignalComponent::GetOutputDataSize( unsigned long& constBase, double& inputMultiplier )
{
  // see header file for class documentation
  // XXX TODO: Find more realistic values.  
  constBase = 0;
  inputMultiplier = (2.0);
}

AliHLTComponent* AliHLTTPCCalibSignalComponent::Spawn()
{
  // see header file for class documentation
  return new AliHLTTPCCalibSignalComponent();
}  

Int_t AliHLTTPCCalibSignalComponent::DoInit( int argc, const char** argv )
{
  // see header file for class documentation
  
  // ** Interprete commandline arguments
  Int_t i = 0;
  Char_t* cpErr;

  while ( i < argc ) {      
    
    // -- rcu format option-- default in constructor: kFALSE => use new data format
    if ( !strcmp( argv[i], "rcuformat" ) ) {
      if ( argc <= i+1 ) {
	HLTError( "Missing RCU format - RCU format not specified" );
	return ENOTSUP;
      }
      
      // Decodes the rcu format --  options: "old" or "new"
      if ( !strcmp( argv[i+1], "old" ) ) {
	fRCUFormat = kTRUE;
      }
      else if ( !strcmp( argv[i+1], "new" ) ) {
	fRCUFormat = kFALSE;
      }
      else {
	HLTError( "Missing RCU format - Cannot convert rcu format  specifier '%s'.", argv[i+1] );
	return EINVAL;
      }
      
      i += 2;
      continue;
    }

    HLTError( "Unknown Option - Unknown option '%s'", argv[i] );
    return EINVAL;
    
  }
  
  // ** Create Signal calibration
  if ( fCalibSignal )
    return EINPROGRESS;
  
  fCalibSignal = new AliTPCCalibSignal();

  // **  Create AliRoot Memory Reader
  if (fRawReader)
    return EINPROGRESS;

#if defined(HAVE_ALIRAWDATA) && defined(HAVE_ALITPCRAWSTREAM_H) 
  fRawReader = new AliRawReaderMemory();
#else
  HLTFatal("AliRawReader  not available - check your build");
  return -ENODEV;
#endif

  return 0;
}

Int_t AliHLTTPCCalibSignalComponent::DoDeinit()
{
  // see header file for class documentation

  if ( fRawReader )
    delete fRawReader;
  fRawReader = NULL;

  if ( fCalibSignal )
    delete fCalibSignal;
  fCalibSignal = NULL;

  return 0;
}

/*
 * --- will be changing with the Calibration Processor, -> Split DoEvent into 2 functions:
 *    --- > Process event
 *    --- > Ship Data to FXS
 * --- setter for rcuformat need in AliTPCCalibSignal class
 */
Int_t AliHLTTPCCalibSignalComponent::DoEvent( const AliHLTComponentEventData& evtData, AliHLTComponentTriggerData& trigData ) {
  // see header file for class documentation

  const AliHLTComponentBlockData* iter = NULL;
  AliHLTUInt32_t spec = 0;

  Int_t slice, patch;
  Int_t minPatch = 5;
  Int_t maxPatch = 0;
  Int_t DDLid = 0;
 
  //--------same as for pedestal

  // ** Loop over all input blocks and specify which data format should be read
  iter = GetFirstInputBlock( AliHLTTPCDefinitions::fgkDDLPackedRawDataType );
  
  while ( iter != NULL ) {
    
    // ** Print Debug output which data format was received
    char tmp1[14], tmp2[14];
    DataType2Text( iter->fDataType, tmp1 );
    DataType2Text( AliHLTTPCDefinitions::fgkDDLPackedRawDataType, tmp2 );

    HLTDebug ( "Event received - Event 0x%08LX (%Lu) received datatype: %s - required datatype: %s", evtData.fEventID, evtData.fEventID, tmp1, tmp2 );

    // ** Get DDL ID in order to tell the memory reader which slice/patch to use
    slice = AliHLTTPCDefinitions::GetMinSliceNr( *iter );
    patch = AliHLTTPCDefinitions::GetMinPatchNr( *iter );

    if (patch < 2) DDLid = 768 + (2 * slice) + patch;
    else DDLid = 838 + (4*slice) + patch;

    // ---------
    
    HLTDebug ( "Input Raw Data - Slice/Patch: %d/%d - EquipmentID : %d.", slice, patch, DDLid );
    
    // ** Get the  min and max patch, used in the output specfication
    if ( patch < minPatch ) minPatch =  patch;
    if ( patch > maxPatch ) maxPatch =  patch;

    // ** Init TPCRawStream
    fRawReader->SetMemory( reinterpret_cast<UChar_t*>( iter->fPtr ), iter->fSize );
    fRawReader->SetEquipmentID(DDLid);

    fRawStream = new AliTPCRawStream( fRawReader );
    fRawStream->SetOldRCUFormat( fRCUFormat );

    fCalibSignal->ProcessEvent( fRawStream );
  
    if ( fRawStream )
      delete fRawStream;
    fRawStream = NULL;    

    //-----------
    // ** Get next input block, with the same specification as defined in GetFirstInputBlock()
    iter = GetNextInputBlock();

  } //  while ( iter != NULL ) {
  
  // !!! HIGHLY DEBUG !!!
  // fCalibSignal->DumpToFile("Signal.root");
  // !!! HIGHLY DEBUG !!!

  // ** Call only at END of RUN event
  //  fCalibSignal->Analyse();
  
  // ** PushBack data to shared memory ... 

  spec = AliHLTTPCDefinitions::EncodeDataSpecification( slice, slice, minPatch, maxPatch );
  PushBack( (TObject*) fCalibSignal, AliHLTTPCDefinitions::fgkCalibSignalDataType, spec);
  
  return 0;
} // Int_t AliHLTTPCCalibSignalComponent::DoEvent( const AliHLTComponentEventData& evtData, AliHLTComponentTriggerData& trigData ) {
//-------------