In This Package:

RegistrationSequence.cc

Go to the documentation of this file.

#include "Event/RegistrationSequence.h"

using namespace DayaBay;

DayaBay::RegistrationSequence::RegistrationSequence() 
{
    setEarliest(TimeStamp::GetBOT());
    setLatest(TimeStamp::GetBOT());
    m_registrations = new Registrations();
}

DayaBay::RegistrationSequence::~RegistrationSequence() 
{
    if (m_registrations) {
        m_registrations->clear();
        delete m_registrations;
        m_registrations = 0;
    }
}

const std::string& defLoc() { return RegistrationSequenceLocation::Default; }

void DayaBay::RegistrationSequence::setRegistrations(Registrations* value)
{
    delete m_registrations;
    m_registrations = value;
}

bool RegistrationSequence::empty() const 
{
  return m_registrations->empty();
}

RegistrationSequence::size_type RegistrationSequence::size() const 
{
  return m_registrations->size();
}

const RegistrationSequence::Registrations& RegistrationSequence::registrations() const {
  return *m_registrations;
}

void RegistrationSequence::insert(IRegistry* registry,
                                  DataObject* object,
                                  bool marked) {
  if ( 0 == object) {
    return;
  }

  TemporalDataObject* temporal = dynamic_cast<TemporalDataObject*>(object);
  if (0 != temporal) {
      // only do something when the object has a meaningful time
      if(temporal->earliest() != TimeStamp::GetBOT() &&
         temporal->latest()   != TimeStamp::GetBOT() ) {

          if (TimeStamp::GetBOT() == earliest() || earliest() > temporal->earliest()) {
              setEarliest(temporal->earliest());
          }
      
          if (TimeStamp::GetBOT() == latest() || latest() < temporal->latest()) {
              setLatest(temporal->latest());
          }
      }
  }

  m_registrations->push_back(Registration(registry,
                                          object,
                                          marked));

}

RegistrationSequence::Registrations
RegistrationSequence::registration(const std::string& path) const
{
    Registrations ret;

    IRegistrationSequence::Registrations::iterator it, 
        done = m_registrations->end();
    for (it = m_registrations->begin(); it != done; ++it) {
        if (it->path() == path) ret.push_back(*it);
    }
    return ret;
}

RegistrationSequence::Registration* 
RegistrationSequence::registration(const DataObject* dobj) const
{
    IRegistrationSequence::Registrations::iterator it, 
        done = m_registrations->end();
    for (it = m_registrations->begin(); it != done; ++it) {
        if (it->object() == dobj) return &(*it);
    }
    return 0;    
}

std::ostream& RegistrationSequence::fillStream(std::ostream& s) const 
{
    TemporalDataObject::fillStream(s);
    s << "{ " << m_registrations->size() << " registrations :\n";
    IRegistrationSequence::Registrations::iterator it, 
        done = m_registrations->end();
    int count = 0;
    for (it = m_registrations->begin(); it != done; ++it) {
        DataObject* dobj = it->object();

        s << "\n[" << count++ << "] " << dobj->name() 
          << " (entry=" << it->entry() 
          << ",store=" << it->store() << ")"
          << ": "; dobj->fillStream(s);
    }
    s << "\n}\n";
    return s;
}

---