be_process_mclistener.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_MESSAGECENTERLISTENER__
#define __BE_PROCESS_MESSAGECENTERLISTENER__
 
#include <cstdint>
#include <memory>
 
#include <be_process_forkmanager.h>
#include <be_process_worker.h>
 
namespace BiometricEvaluation
{
        namespace Process
        {
                class MessageCenterListener : public Worker
                {
                public:
                        static const std::string PARAM_PORT;
 
                        int32_t
                        workerMain();
 
                        /* Default constructor. */
                        MessageCenterListener() = default;
                        /* Default destructor. */
                        ~MessageCenterListener() = default;
 
                private:
                        uint16_t _port;
                        int _socket;
                        struct addrinfo *_addr;
                        std::shared_ptr<Process::ForkManager> _manager;
                        std::map<uint32_t, std::shared_ptr<WorkerController>>
                            _clientMap;
 
                        void
                        parseArgs();
 
                        void
                        spawnReceiver(
                            int clientSocket);
 
                        void
                        setupSocket();
 
                        void
                        listen();
 
                        int
                        accept();
 
                        void
                        tearDown();
                };
        }
}
 
#endif /* __BE_PROCESS_MESSAGECENTERLISTENER__ */