be_mpi_recordprocessor.h

Go to the documentation of this file.

 
#ifndef _BE_MPI_RECORDPROCESSOR_H
#define _BE_MPI_RECORDPROCESSOR_H
 
#include <be_mpi_recordstoreresources.h>
#include <be_mpi_workpackageprocessor.h>
 
namespace BiometricEvaluation {
        namespace MPI {
                class RecordProcessor : public WorkPackageProcessor {
                public:
                        RecordProcessor(
                            const std::string &propertiesFileName);
 
                        virtual ~RecordProcessor();
 
                        //XXX the thrown exception should be refined into
                        //XXX particular classes
                        virtual void processRecord(const std::string &key) = 0;
 
                        virtual void processRecord(
                            const std::string &key,
                            const Memory::uint8Array &value) = 0;
 
                        /* Implement WorkPackageProcessor interface */
                        virtual std::shared_ptr<WorkPackageProcessor>
                            newProcessor(
                                std::shared_ptr<IO::Logsheet> &logsheet) = 0;
 
                        virtual void performInitialization(
                            std::shared_ptr<IO::Logsheet> &logsheet) = 0;
 
                        void processWorkPackage(
                            MPI::WorkPackage &workPackage);
 
                protected:
                        std::shared_ptr<MPI::RecordStoreResources>
                             getResources();
                private:
                        std::shared_ptr<MPI::RecordStoreResources>
                             _resources;
                };
        }
}
 
#endif /* _BE_MPI_RECORDPROCESSOR_H */