be_process_worker.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_PROCESS_WORKER_H__
#define __BE_PROCESS_WORKER_H__
 
#include <cstdint>
 
#include <be_error_exception.h>
#include <be_memory_autoarray.h>
#include <be_process.h>
 
namespace BiometricEvaluation
{
        namespace Process
        {
                class Worker
                {
                public:
                        virtual int32_t
                        workerMain() = 0;
                        
                        std::shared_ptr<void>
                        getParameter(
                            const std::string &name);
                            
                        double
                        getParameterAsDouble(
                            const std::string &name);
                            
                        int64_t
                        getParameterAsInteger(
                            const std::string &name);
                            
                        std::string
                        getParameterAsString(
                            const std::string &name);
                            
                        void
                        setParameter(
                            const std::string &name, 
                            std::shared_ptr<void> argument);
                        
                        virtual void
                        stop()
                            final;
                        
                        void
                        closeWorkerPipeEnds();
 
                        void
                        closeManagerPipeEnds();
 
                        int
                        getSendingPipe() const;
 
                        int
                        getReceivingPipe() const;
 
                        void
                        sendMessageToManager(
                            const Memory::uint8Array &message);
 
                        void
                        receiveMessageFromManager(
                            Memory::uint8Array &message);
 
                        void
                        _initCommunication();
 
                        virtual ~Worker();
 
                protected:
                        Worker();
                
                        virtual bool
                        stopRequested()
                            const
                            final;
                        
                        bool
                        waitForMessage(
                            int numSeconds = -1)
                            const;
 
                private:                
                        volatile bool _stopRequested;
                        
                        ParameterList _parameters;
                        
                        bool _communicationEnabled;
                        int _pipeToChild[2];
                        int _pipeFromChild[2];
                };
        }
}
 
#endif /* __BE_PROCESS_WORKER_H__ */