be_mpi_csvdistributor.h

Go to the documentation of this file.

/*
 * This software was developed at the National Institute of Standards and
 * Technology (NIST) by employees of the Federal Government in the course
 * of their official duties.  Pursuant to title 17 Section 105 of the
 * United States Code, this software is not subject to copyright protection
 * and is in the public domain.  NIST assumes no responsibility whatsoever for
 * its use by other parties, and makes no guarantees, expressed or implied,
 * about its quality, reliability, or any other characteristic.
 */
 
#ifndef BE_MPI_CSVDISTRIBUTOR_H_
#define BE_MPI_CSVDISTRIBUTOR_H_
 
#include <memory>
#include <string>
 
#include <be_mpi_csvresources.h>
#include <be_mpi_distributor.h>
 
namespace BiometricEvaluation
{
        namespace MPI
        {
                class CSVDistributor : public Distributor
                {
                public:
                        static const std::string CHECKPOINTLINECOUNT;
 
                        static const std::string CHECKPOINTRANDOMSEED;
 
                        CSVDistributor(
                            const std::string &propertiesFileName,
                            const std::string &delimiter = "");
                        ~CSVDistributor();
 
                protected:
                        void
                        createWorkPackage(MPI::WorkPackage &workPackage);
                        void
                        checkpointSave(const std::string &reason);
                        void
                        checkpointRestore();
 
                private:
                        std::unique_ptr<MPI::CSVResources> _resources;
                        uint64_t _distributedLineCount{};
                };
        }
}
 
#endif /* BE_MPI_CSVDISTRIBUTOR_H_ */