/**************************************************************************
 * This file is property of and copyright by the Experimental Nuclear     *
 * Physics Group, Dep. of Physics                                         *
 * University of Oslo, Norway, 2007                                       *
 *                                                                        *
 * Author: Per Thomas Hille <perthi@fys.uio.no> for the ALICE HLT Project.*
 * Contributors are mentioned in the code where appropriate.              *
 * Please report bugs to perthi@fys.uio.no                                *
 *                                                                        *
 * 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.                  *
 **************************************************************************/



#include "AliHLTPHOSSharedMemoryInterface.h"
#include "AliHLTPHOSRcuCellEnergyDataStruct.h"
#include "AliHLTPHOSValidCellDataStruct.h"
#include <iostream>


AliHLTPHOSSharedMemoryInterface::AliHLTPHOSSharedMemoryInterface(): fCurrentChannel(0),
								    fCellEnergiesPtr(0),
								    fIsSetMemory(false),
								    fHasRawData(false),
								    fMaxCnt(0),
								    fCurrentCnt(0),
								    fCurrentX(0),
								    fCurrentZ(0),
								    fCurrentGain(0),
								    fCharDataOffset(0),
								    fCharPtr(0),
								    fIntPtr(0),
								    fRawDataPtr(0)
{
  fCharDataOffset = sizeof(AliHLTPHOSRcuCellEnergyDataStruct);
}


AliHLTPHOSSharedMemoryInterface::~AliHLTPHOSSharedMemoryInterface()
{

}


AliHLTPHOSValidCellDataStruct*   
AliHLTPHOSSharedMemoryInterface::NextChannel()
{
  // Returns the next channel of the current AliHLTPHOSRcuCellEnergyDataStruct
  // Returns zero when all cannels are read
  /*
  if(fCurrentCnt < fMaxCnt)
    {
     fCurrentChannel = &fCellEnergiesPtr->fValidData[fCurrentCnt];
     fCurrentChannel->fData = fIntPtr; 
     fIntPtr +=  fCurrentChannel->fNSamples;
     fCurrentCnt ++;
     return fCurrentChannel;
    }
  */

  // Changed by OD
  if(fCurrentCnt < fMaxCnt)
    {
      fCurrentChannel = &(fCellEnergiesPtr->fValidData[fCurrentCnt]);
      fCurrentCnt++;
      if(fCellEnergiesPtr->fHasRawData == true)
	{
	  fRawDataPtr = fIntPtr + 1;
	  fIntPtr = fIntPtr + *fIntPtr + 1;
	}
      return fCurrentChannel;
    }
  else
    {
      Reset();
      return 0;
    }

  return 0;
}

Int_t*
AliHLTPHOSSharedMemoryInterface::GetRawData(Int_t& nSamples)
{
  //Added by OD

  if(fHasRawData == true)
    {
      nSamples = *(fRawDataPtr-1);
      return fRawDataPtr;
    }
  else
    {
      return 0;
    }
}

void
AliHLTPHOSSharedMemoryInterface::SetMemory(AliHLTPHOSRcuCellEnergyDataStruct *rcuCellEnergyPtr)
{
  //Shutting up rule checker
  fCellEnergiesPtr =  rcuCellEnergyPtr;
  fMaxCnt =  fCellEnergiesPtr->fCnt;
  if(fCellEnergiesPtr->fHasRawData == true)
    {
      PingPongPointer();
      fHasRawData = true;
    }
  fIsSetMemory = true;
}


void
AliHLTPHOSSharedMemoryInterface::Reset()
{
  //Shutting up rule checker
  fMaxCnt =0;
  fCurrentCnt = 0;
  fCurrentX = 0;
  fCurrentZ = 0;
  fCurrentGain = 0;
  fIsSetMemory = false;
  fHasRawData = false;
}

void 
AliHLTPHOSSharedMemoryInterface::PingPongPointer()
{
  // ping pong ping ping pong ping pong
  
  fCharPtr = (char *)fCellEnergiesPtr ;
  fCharPtr += fCharDataOffset; 
  fIntPtr = (Int_t *)fCharPtr;

}