In This Package:

TrimmingAgent.cpp

Go to the documentation of this file.

#include "TrimmingAgent.h"

#include "GaudiKernel/DataObject.h"
#include "GaudiKernel/GaudiException.h"
#include "GaudiKernel/IRegistry.h"
#include "GaudiKernel/MsgStream.h"
#include "DataUtilities/DybArchiveList.h"

TrimmingAgent::TrimmingAgent(MsgStream* msgStream) :
  m_window(0),
  m_msgStream(msgStream){
}

TrimmingAgent::~TrimmingAgent() {
  if (0 != m_msgStream) {
    delete m_msgStream;
  }
}

bool TrimmingAgent::analyse(IRegistry* pRegistry,
                            int /* level */) {
  DataObject* object = pRegistry->object();
  if (0 == object) {
    return true;
  }
  
  DybArchiveList* list = dynamic_cast<DybArchiveList*>(object);
  if (0 == list) {
    return true;
  }

  std::string path = pRegistry->identifier();
  TimeStamp earliest = m_latest;
  earliest.Add(-1.0 * window(path));

  unsigned int dataCount = 0; 
  unsigned int temporalCount = 0; 
  DybArchiveList::iterator entry = list->begin();
  while (list->end() != entry) {
    (*m_msgStream)<< MSG::VERBOSE<< "not end" <<endreq;
    DataObject* dataObject = (*entry);

    // Protect against zero object.
    if ( 0 == dataObject) {
      entry = list->erase(entry);
    } else {
      // wangzhe 
      //ITemporal* temporalObject = dynamic_cast<ITemporal*>(dataObject);
      TemporalDataObject * temporalObject = dynamic_cast<TemporalDataObject*>(dataObject);
      // wz
      
      if (0 == temporalObject) {
        entry = list->erase(entry);
        ++dataCount;
      } else {
        // for debuging
        (*m_msgStream)<< MSG::VERBOSE<< path<<endreq;
        (*m_msgStream)<< MSG::VERBOSE<< "pObj "<<temporalObject<<endreq;
        (*m_msgStream)<< MSG::VERBOSE<< "m_latest "<<m_latest<<endreq;
        (*m_msgStream)<< MSG::VERBOSE<< "earliest "<<earliest<<endreq;
        (*m_msgStream)<< MSG::VERBOSE<< "window "<<double(window(path))<< " seconds"<<endreq;
        (*m_msgStream)<< MSG::VERBOSE<< "obj latest   "<<temporalObject->latest()<<endreq;
        (*m_msgStream)<< MSG::VERBOSE<< "obj earliest "<<temporalObject->earliest()<<endreq;
        (*m_msgStream)<< MSG::VERBOSE<< "obj refCount "<<temporalObject->refCount()<<endreq;
        // only earliest time is always in time order.
        // Some event with long delay coincidence might inverse the sequence.
        if (temporalObject->earliest() <= earliest) {
          (*m_msgStream)
              << MSG::DEBUG<< "Erased from AES " << path
              << " dt = " << double(earliest - temporalObject->earliest()) << " seconds"
              << endreq;
          entry = list->erase(entry);
          ++temporalCount;
        } else {
          ++entry;
        }
        // for debuging
        // (*m_msgStream) << MSG::VERBOSE<<"obj refCount "<<temporalObject->refCount()<<endreq;
      }
    }
  }
  if (0 != m_msgStream) {
    if (0 != dataCount) {
      std::string plural = "";
      if (1 != dataCount) {
        plural == "s";
      }
      (*m_msgStream) << MSG::DEBUG
                     << "Removed "
                     << dataCount
                     << " DataObject"
                     << plural
                     << " from the \""
                     << path
                     << "\" node in the archive."
                     << endreq;    
    }
    if (0 != temporalCount) {
      std::string plural = "";
      if (1 != dataCount) {
        plural == "s";
      }
      (*m_msgStream) << MSG::DEBUG
                     << "Removed "
                     << temporalCount
                     << " ITemporal object"
                     << plural
                     << " from the \""
                     << path
                     << "\" node in the archive."
                     << endreq;
    }
  }
  return true;
}

const TimeStamp TrimmingAgent::earliest() {
  TimeStamp result = m_latest;
  result.Add(m_window);
  return result;
}

const TimeStamp& TrimmingAgent::latest() {
  return m_latest;
}

const TimeStamp& TrimmingAgent::window() {
  return m_window;
}

const TimeStamp& TrimmingAgent::window(const std::string& path) {
    WindowMap_t::iterator wit = m_windows.find(path);
    if (wit == m_windows.end()) {
        return m_window;
    }
    return wit->second;
}

void TrimmingAgent::setLatest(const TimeStamp& latest) {
  m_latest = latest;
}

void TrimmingAgent::setWindow(const TimeStamp& window) {
  m_window = window;
}

void TrimmingAgent::setWindow(const std::string& path,
                              const TimeStamp& window) {
  m_windows[path] = window;
}

---