JDATABASE::JDetectorIntegration_t Struct Reference

Detector integration. More...

#include <JDetectorIntegration_t.hh>

Inheritance diagram for JDATABASE::JDetectorIntegration_t:

Public Types
typedef std::multimap< JUPI_t, int >	map_type
typedef std::pair< map_type::const_iterator, map_type::const_iterator >	range_type
typedef map_type::const_iterator	range_const_iterator
typedef map_type::const_iterator	range_iterator

Public Member Functions
	JDetectorIntegration_t ()
	Default constructor.
void	configure (const std::string &detid, const bool option=false)
	Configure detector integration for given detector identifier.
const JProductIntegration_t &	trace (const JUPI_t &upi, const JPBS_t &pbs=PBS::DETECTOR) const
	Trace product up to given integration level.
void	print (std::ostream &out, const JUPI_t &upi) const
	Print product trace.
void	print (std::ostream &out, const JProductIntegration_t &product) const
	Print product trace.
void	load (const char *const file_name, const std::string &separator=";")
	Load detector integration from CSV formatted input file.
range_type	find (const JUPI_t &upi) const
	Find range of products with given UPI.
range_type	find (const JPBS_t &pbs) const
	Find range of products with given PBS.
range_type	get (const JUPI_t &upi) const
	Get components of product with given UPI.

Static Public Member Functions
static const char *const	getName ()
	Table name.
static bool	compare (const JProductIntegration_t &first, const JProductIntegration_t &second)
	Compare two product integrations.

Protected Member Functions
void	configure (JProductIntegration_t &product, const JPeriod_t &period)
	Configure detector integration for given detector identifier.

Protected Attributes
map_type	up
	up link UPI to integration data
map_type	down
	down link UPI to integration data
map_type	out
	link UPI to disintegrated data

Friends
bool	operator>> (ResultSet &rs, JDetectorIntegration_t &detector)
	Read detector integration from result set.
std::istream &	operator>> (std::istream &in, JDetectorIntegration_t &object)
	Read detector integration from input stream.
std::ostream &	operator<< (std::ostream &out, const JDetectorIntegration_t &object)
	Write detector integration to output stream.

Detailed Description

Detector integration.

This class is used

• to read product integration data from the data base;
  
• to organise detector specific integration data in memory;
• to efficiently trace a product;
• to efficiently find product(s);

Note that the method JDetectorIntegration_t::configure should be used to set up the integration data for a specific detector.

Definition at line 187 of file JDetectorIntegration_t.hh.

Member Typedef Documentation

map_type

std::multimap<JUPI_t, int> JDATABASE::JDetectorIntegration_t::map_type

Definition at line 192 of file JDetectorIntegration_t.hh.

range_type

std::pair<map_type::const_iterator, map_type::const_iterator> JDATABASE::JDetectorIntegration_t::range_type

Definition at line 194 of file JDetectorIntegration_t.hh.

range_const_iterator

map_type::const_iterator JDATABASE::JDetectorIntegration_t::range_const_iterator

Definition at line 195 of file JDetectorIntegration_t.hh.

range_iterator

map_type::const_iterator JDATABASE::JDetectorIntegration_t::range_iterator

Definition at line 196 of file JDetectorIntegration_t.hh.

Constructor & Destructor Documentation

JDetectorIntegration_t()

JDATABASE::JDetectorIntegration_t::JDetectorIntegration_t ( )

inline

Default constructor.

Definition at line 202 of file JDetectorIntegration_t.hh.

    {}

Member Function Documentation

getName()

static const char *const JDATABASE::JDetectorIntegration_t::getName ( )

inlinestatic

Table name.

Definition at line 190 of file JDetectorIntegration_t.hh.

configure() [1/2]

void JDATABASE::JDetectorIntegration_t::configure ( const std::string & detid, const bool option = false )

inline

Configure detector integration for given detector identifier.

The components of the given detector are selected based on the following rules:

1. the component should have a start date before that of the given detector;
2. if multiple components appear at the same place in the same container, the one with the latest start date is taken.

The option can be used to retain only those products that are part of the given detector.

Parameters

detid	detector identifier
option	option

Definition at line 219 of file JDetectorIntegration_t.hh.

    {
      using namespace std;
      using namespace JPP;
 
      up  .clear();
      down.clear();
      out .clear();
 
      for (size_t index = 0; index != this->size(); ++index) {
 
        JProductIntegration_t& product = (*this)[index];
 
        product.unset();
 
        if (product.content != JUPI_t()) {
 
          up  .insert(make_pair(product.content  .getUPI(), index));
          down.insert(make_pair(product.container.getUPI(), index));
 
        } else {
 
          out .insert(make_pair(product.container.getUPI(), index));
        }
      }
 
      for (iterator product = this->begin(); product != this->end(); ++product) {
        if (product->operation == detid) {
          configure(*product, JPeriod_t(product->start_date, product->end_date));
        }
      }
 
      if (option) {     
        this->erase(partition(this->begin(), this->end(), make_predicate(&JProductIntegration_t::is_set, true)), this->end());
      }
 
      up  .clear();
      down.clear();
 
      for (size_t index = 0; index != this->size(); ++index) {
 
        const JProductIntegration_t& product = (*this)[index];
 
        if (product.is_set()) {
          up  .insert(make_pair(product.content  .getUPI(), index));
          down.insert(make_pair(product.container.getUPI(), index));
        }
      }
    }

trace()

const JProductIntegration_t & JDATABASE::JDetectorIntegration_t::trace ( const JUPI_t & upi, const JPBS_t & pbs = PBS::DETECTOR ) const

inline

Trace product up to given integration level.

Parameters

upi	UPI
pbs	PBS

Returns

product

Definition at line 277 of file JDetectorIntegration_t.hh.

    {
      using namespace std;
      
      if (upi.getPBS() >= pbs) {
 
        const range_type range = find(upi);
 
        switch (distance(range.first, range.second)) {
 
        case 1:
          {
            const JProductIntegration_t& product = (*this)[range.first->second];
 
            if (product.container.getPBS() == pbs) 
              return product;
            else
              return trace(product.container.getUPI(), pbs);
          }
          
        case 0:
          THROW(JDatabaseException, "Invalid UPI " << upi);
 
        default:
          THROW(JDatabaseException, "Ambiguous integration of UPI " << upi);
        }
 
      } else {
 
        THROW(JDatabaseException, "Invalid PBS " << upi.getPBS() << " < " << pbs);
      }
    }

print() [1/2]

void JDATABASE::JDetectorIntegration_t::print ( std::ostream & out, const JUPI_t & upi ) const

inline

Print product trace.

Parameters

out	output stream
upi	UPI

Definition at line 318 of file JDetectorIntegration_t.hh.

    {
      using namespace std;
      
      range_type range;
 
      range = find(upi);
 
      for (map_type::const_iterator i = range.first; i != range.second; ++i) {
 
        out << upi << " -> ";
 
        print(out, (*this)[i->second]);
      }
 
      range = down.equal_range(upi);
 
      for (range_iterator i = range.first; i != range.second; ++i) {
        out << "<- " << (*this)[i->second] << endl; 
      }
    }

print() [2/2]

void JDATABASE::JDetectorIntegration_t::print ( std::ostream & out, const JProductIntegration_t & product ) const

inline

Print product trace.

Parameters

out	output stream
product	product

Definition at line 347 of file JDetectorIntegration_t.hh.

    {
      using namespace std;
      
      out << product.container.getUPI()                      << ' '
        //<< JPeriod_t(product.start_date, product.end_date) << ' '
          << "-> ";
 
      const range_type range = find(product.container.getUPI());
 
      for (map_type::const_iterator i = range.first; i != range.second; ++i) {
        print(out, (*this)[i->second]);
      }
 
      if (distance(range.first, range.second) != 1) {
        out << product.operation << std::endl;
      }
    }

load()

void JDATABASE::JDetectorIntegration_t::load ( const char *const file_name, const std::string & separator = ";" )

inline

Load detector integration from CSV formatted input file.

The input should be conform output of JPrintDB -q "integration" -c ";" -W1.

Parameters

file_name	file name
separator	separator

Definition at line 402 of file JDetectorIntegration_t.hh.

    {
      using namespace std;
      using namespace JPP;
 
      ifstream in(file_name);
 
      in.ignore(numeric_limits<streamsize>::max(), '\n');
 
      for (string buffer; getline(in, buffer); ) {
 
        istringstream is(buffer);
 
        const locale loc(is.getloc(), new JWhiteSpacesFacet(is.getloc(), separator));
 
        is.imbue(loc);
 
        JProductIntegration parameters;
 
        is >> buffer;  istringstream(trim(buffer)) >> parameters.OPERATIONID;
        is >> buffer;  istringstream(trim(buffer)) >> parameters.CITY;
        is >> buffer;  istringstream(trim(buffer)) >> parameters.LOCATIONID;
        is >> buffer;  istringstream(trim(buffer)) >> parameters.LOGIN;
        is >> buffer;  istringstream(trim(buffer)) >> parameters.USERID;
        is >> buffer;  istringstream(trim(buffer)) >> parameters.STARTD;
        is >> buffer;  istringstream(trim(buffer)) >> parameters.ENDD;
        is >> buffer;  istringstream(trim(buffer)) >> parameters.CONTAINER_UPI;
        is >> buffer;  istringstream(trim(buffer)) >> parameters.POSITION;
        is >> buffer;  istringstream(trim(buffer)) >> parameters.CONTENT_UPI;
 
        const JProductIntegration_t product(parameters);
 
        this->up  .insert(make_pair(product.content  .getUPI(), this->size()));
        this->down.insert(make_pair(product.container.getUPI(), this->size()));
 
        this->push_back(product);
      }
 
      in.close();
    }

find() [1/2]

range_type JDATABASE::JDetectorIntegration_t::find ( const JUPI_t & upi ) const

inline

Find range of products with given UPI.

The returned range corresponds to the usual begin and end iterators, each pointing to an STL pair consisting of a UPI and index.

Parameters

upi

UPI

Returns

index

Definition at line 492 of file JDetectorIntegration_t.hh.

    {
      return up.equal_range(upi);
    }

find() [2/2]

range_type JDATABASE::JDetectorIntegration_t::find ( const JPBS_t & pbs ) const

inline

Find range of products with given PBS.

The returned range corresponds to the usual begin and end iterators, each pointing to an STL pair consisting of a UPI and index.

Parameters

pbs

PBS

Returns

range

Definition at line 506 of file JDetectorIntegration_t.hh.

    {
      range_const_iterator p = up.lower_bound(JUPI_t(pbs));
      range_const_iterator q = p;
 
      while (q != up.end() && (*this)[q->second].content.getPBS() <= pbs) {
        ++q;
      }
 
      return range_type(p,q);
    }

get()

range_type JDATABASE::JDetectorIntegration_t::get ( const JUPI_t & upi ) const

inline

Get components of product with given UPI.

The returned range corresponds to the usual begin and end iterators, each pointing to an STL pair consisting of a UPI and index.

Parameters

upi

UPI

Returns

index

Definition at line 527 of file JDetectorIntegration_t.hh.

    {
      return down.equal_range(upi);
    }

compare()

static bool JDATABASE::JDetectorIntegration_t::compare ( const JProductIntegration_t & first, const JProductIntegration_t & second )

inlinestatic

Compare two product integrations.

Parameters

first	first product integration
second	second product integration

Returns

true if first integrated before second; else false

Definition at line 540 of file JDetectorIntegration_t.hh.

    {
      if (first.start_date == second.start_date)
        return first.operation  < second.operation;
      else
        return first.start_date < second.start_date;
    }

configure() [2/2]

void JDATABASE::JDetectorIntegration_t::configure ( JProductIntegration_t & product, const JPeriod_t & period )

inlineprotected

Configure detector integration for given detector identifier.

This method recursively sets the status all related products.

Parameters

product	product
period	validity period

Definition at line 557 of file JDetectorIntegration_t.hh.

    {
      using namespace std;
 
      range_type range;
 
      range = out.equal_range(product.container);
 
      for (range_iterator i = range.first; i != range.second; ++i) {
 
        const JProductIntegration_t& object = (*this)[i->second];
            
        if (object.position   == product.position        &&
            object.start_date <= period.getLowerLimit()  &&
            object.start_date >  product.start_date) {
          return;
        }
      }
 
      product.set();
 
      map<int, int>    zmap;    // position -> index
      
      range = down.equal_range(product.content);
 
      for (range_iterator i = range.first; i != range.second; ++i) {
 
        const JProductIntegration_t& object = (*this)[i->second];
 
        if (object.start_date <= period.getLowerLimit()) {
          if (zmap.count(object.position) == 0 || compare((*this)[zmap[object.position]], object)) {
            zmap[object.position] = i->second;
          }
        }
      }
 
      for (map<int, int>::iterator i = zmap.begin(); i != zmap.end(); ++i) {
        configure((*this)[i->second], period);
      }
    }

Friends And Related Symbol Documentation

operator>> [1/2]

bool operator>> ( ResultSet & rs, JDetectorIntegration_t & detector )

friend

Read detector integration from result set.

Parameters

rs	result set
detector	detector

Returns

true if read; else false

Definition at line 374 of file JDetectorIntegration_t.hh.

    {
      using namespace std;
 
      for (JProductIntegration parameters; rs >> parameters; ) {
 
        const JProductIntegration_t product(parameters);
 
        detector.up  .insert(make_pair(product.content  .getUPI(), detector.size()));
        detector.down.insert(make_pair(product.container.getUPI(), detector.size()));
 
        detector.push_back(product);
      }
 
      rs.Close();
 
      return true;
    }

operator>> [2/2]

std::istream & operator>> ( std::istream & in, JDetectorIntegration_t & object )

friend

Read detector integration from input stream.

Parameters

in	input stream
object	detector integration

Returns

input stream

Definition at line 451 of file JDetectorIntegration_t.hh.

    {
      using namespace std;
 
      for (JProductIntegration_t product; in >> product; ) {
 
        object.up  .insert(make_pair(product.content  .getUPI(), object.size()));
        object.down.insert(make_pair(product.container.getUPI(), object.size()));
 
        object.push_back(product);
      }
 
      return in;
    }

operator<<

std::ostream & operator<< ( std::ostream & out, const JDetectorIntegration_t & object )

friend

Write detector integration to output stream.

Parameters

out	output stream
object	detector integration

Returns

output stream

Definition at line 474 of file JDetectorIntegration_t.hh.

    {
      for (const_iterator i = object.begin(); i != object.end(); ++i) {
        out << *i << std::endl;
      }
 
      return out;
    }

Member Data Documentation

up

map_type JDATABASE::JDetectorIntegration_t::up

protected

up link UPI to integration data

Definition at line 599 of file JDetectorIntegration_t.hh.

down

map_type JDATABASE::JDetectorIntegration_t::down

protected

down link UPI to integration data

Definition at line 600 of file JDetectorIntegration_t.hh.

out

map_type JDATABASE::JDetectorIntegration_t::out

protected

link UPI to disintegrated data

Definition at line 601 of file JDetectorIntegration_t.hh.

---

The documentation for this struct was generated from the following file:

• JDetectorIntegration_t.hh