be_mpi_recordstoredistributor.h

Go to the documentation of this file.

 
#ifndef _BE_MPI_RECORDSTOREDISTRIBUTOR_H
#define _BE_MPI_RECORDSTOREDISTRIBUTOR_H
 
#include <be_mpi_distributor.h>
#include <be_mpi_recordstoreresources.h>
 
namespace BiometricEvaluation {
        namespace MPI {
                
                class RecordStoreDistributor : public Distributor {
                public:
                        static const std::string CHECKPOINTLASTKEY;
 
                        static const std::string CHECKPOINTNUMKEYS;
 
                        RecordStoreDistributor(
                            const std::string &propertiesFileName,
                            const bool includeValues);
 
                        ~RecordStoreDistributor();
 
                protected:
                        void
                        createWorkPackage(MPI::WorkPackage &workPackage);
                        void checkpointSave(const std::string &reason);
                        void checkpointRestore();
 
                private:
                        std::unique_ptr<MPI::RecordStoreResources>
                            _resources;
                        uint64_t _recordsRemaining;
                        bool _includeValues;
                        std::string _lastDistributedKey{};
                };
        }
}
 
#endif /* _BE_MPI_RECORDSTOREDISTRIBUTOR_H */