lsst::afw::table::io::InputArchive::Impl Class Reference

Public Member Functions
std::shared_ptr< Persistable >	get (int id, InputArchive const &self)
Map const &	getAll (InputArchive const &self)
	Impl ()
	Impl (BaseCatalog const &index, CatalogVector const &catalogs)
	Impl (const Impl &)=delete
Impl &	operator= (const Impl &)=delete
	Impl (Impl &&)=delete
Impl &	operator= (Impl &&)=delete

Public Attributes
Map	_map
BaseCatalog	_index
CatalogVector	_catalogs

Detailed Description

Definition at line 38 of file InputArchive.cc.

Constructor & Destructor Documentation

Impl() [1/4]

lsst::afw::table::io::InputArchive::Impl::Impl ( )

inline

Definition at line 137 of file InputArchive.cc.

: _index(ArchiveIndexSchema::get().schema) {}

Impl() [2/4]

lsst::afw::table::io::InputArchive::Impl::Impl ( BaseCatalog const &  index, CatalogVector const &  catalogs  )

inline

Definition at line 139 of file InputArchive.cc.

                                                                  : _index(index), _catalogs(catalogs) {
        if (index.getSchema() != indexKeys.schema) {
            throw LSST_EXCEPT(pex::exceptions::RuntimeError, "Incorrect schema for index catalog");
        }
        _map.insert(std::make_pair(0, std::shared_ptr<Persistable>()));
        _index.sort(IndexSortCompare());
    }

Impl() [3/4]

lsst::afw::table::io::InputArchive::Impl::Impl ( const Impl &  )

delete

Impl() [4/4]

lsst::afw::table::io::InputArchive::Impl::Impl ( Impl &&  )

delete

Member Function Documentation

get()

std::shared_ptr<Persistable> lsst::afw::table::io::InputArchive::Impl::get ( int  id, InputArchive const &  self  )

inline

Definition at line 40 of file InputArchive.cc.

                                                                     {
        std::shared_ptr<Persistable> empty;
        if (id == 0) return empty;
        std::pair<Map::iterator, bool> r = _map.insert(std::make_pair(id, empty));
        if (r.second) {
            // insertion successful means we haven't reassembled this object yet; do that now.
            CatalogVector factoryArgs;
            // iterate over records in index with this ID; we know they're sorted by ID and then
            // by catPersistable, so we can just append to factoryArgs.
            std::string name;
            std::string module;
            for (BaseCatalog::iterator indexIter = _index.find(id, indexKeys.id);
                 indexIter != _index.end() && indexIter->get(indexKeys.id) == id; ++indexIter) {
                if (name.empty()) {
                    name = indexIter->get(indexKeys.name);
                } else if (name != indexIter->get(indexKeys.name)) {
                    throw LSST_EXCEPT(
                            MalformedArchiveError,
                            (boost::format("Inconsistent name in index for ID %d; got '%s', expected '%s'") %
                             indexIter->get(indexKeys.id) % indexIter->get(indexKeys.name) % name)
                                    .str());
                }
                if (module.empty()) {
                    module = indexIter->get(indexKeys.module);
                } else if (module != indexIter->get(indexKeys.module)) {
                    throw LSST_EXCEPT(
                            MalformedArchiveError,
                            (boost::format(
                                     "Inconsistent module in index for ID %d; got '%s', expected '%s'") %
                             indexIter->get(indexKeys.id) % indexIter->get(indexKeys.module) % module)
                                    .str());
                }
                int catArchive = indexIter->get(indexKeys.catArchive);
                if (catArchive == ArchiveIndexSchema::NO_CATALOGS_SAVED) {
                    break;  // object was written with saveEmpty, and hence no catalogs.
                }
                std::size_t catN = catArchive - 1;
                if (catN >= _catalogs.size()) {
                    throw LSST_EXCEPT(
                            MalformedArchiveError,
                            (boost::format(
                                     "Invalid catalog number in index for ID %d; got '%d', max is '%d'") %
                             indexIter->get(indexKeys.id) % catN % _catalogs.size())
                                    .str());
                }
                BaseCatalog& fullCatalog = _catalogs[catN];
                std::size_t i1 = indexIter->get(indexKeys.row0);
                std::size_t i2 = i1 + indexIter->get(indexKeys.nRows);
                if (i2 > fullCatalog.size()) {
                    throw LSST_EXCEPT(MalformedArchiveError,
                                      (boost::format("Index and data catalogs do not agree for ID %d; "
                                                     "catalog %d has %d rows, not %d") %
                                       indexIter->get(indexKeys.id) % indexIter->get(indexKeys.catArchive) %
                                       fullCatalog.size() % i2)
                                              .str());
                }
                factoryArgs.push_back(BaseCatalog(fullCatalog.getTable(), fullCatalog.begin() + i1,
                                                  fullCatalog.begin() + i2));
            }
            try {
                PersistableFactory const& factory = PersistableFactory::lookup(name, module);
                r.first->second = factory.read(self, factoryArgs);
            } catch (pex::exceptions::Exception& err) {
                LSST_EXCEPT_ADD(err,
                                (boost::format("loading object with id=%d, name='%s'") % id % name).str());
                throw;
            }
            // If we're loading the object for the first time, and we've failed, we should have already
            // thrown an exception, and we assert that here.
            assert(r.first->second);
        } else if (!r.first->second) {
            // If we'd already tried and failed to load this object before - but we'd caught the exception
            // previously (because the calling code didn't consider that to be a fatal error) - we'll
            // just throw an exception again.  While we can't know exactly what was thrown before,
            // it's most likely it was a NotFoundError because a needed extension package was not setup.
            // And conveniently it's appropriate to throw that here too, since now the problem is that
            // the object should have been loaded into the cache and it wasn't found there.
            throw LSST_EXCEPT(pex::exceptions::NotFoundError,
                              (boost::format("Not trying to reload object with id=%d; a previous attempt to "
                                             "load it already failed.") %
                               id)
                                      .str());
        }
        return r.first->second;
    }

getAll()

Map const& lsst::afw::table::io::InputArchive::Impl::getAll ( InputArchive const &  self )

inline

Definition at line 126 of file InputArchive.cc.

                                                {
        int id = 0;
        for (BaseCatalog::iterator indexIter = _index.begin(); indexIter != _index.end(); ++indexIter) {
            if (indexIter->get(indexKeys.id) != id) {
                id = indexIter->get(indexKeys.id);
                get(id, self);
            }
        }
        return _map;
    }

operator=() [1/2]

Impl& lsst::afw::table::io::InputArchive::Impl::operator= ( const Impl &  )

delete

operator=() [2/2]

Impl& lsst::afw::table::io::InputArchive::Impl::operator= ( Impl &&  )

delete

Member Data Documentation

_catalogs

CatalogVector lsst::afw::table::io::InputArchive::Impl::_catalogs

Definition at line 157 of file InputArchive.cc.

_index

BaseCatalog lsst::afw::table::io::InputArchive::Impl::_index

Definition at line 156 of file InputArchive.cc.

_map

Map lsst::afw::table::io::InputArchive::Impl::_map

Definition at line 155 of file InputArchive.cc.

---

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

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-0.7.0/Linux64/afw/22.0.1-32-g5ddfab5d3+60ce4897b0/src/table/io/InputArchive.cc