be_process_messagecenter.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_MESSAGECENTER__
#define __BE_PROCESS_MESSAGECENTER__
 
#include <memory>
 
#include <be_process_mclistener.h>
#include <be_process_manager.h>
#include <be_process_workercontroller.h>
 
namespace BiometricEvaluation
{
        namespace Process
        {
                class MessageCenter
                {
                public:
                        static const int CONNECTION_BACKLOG = 10;
                        static const uint16_t DEFAULT_PORT = 7899;
                        static const int DEFAULT_TIMEOUT = 1;
                        static const uint64_t MAX_MESSAGE_LENGTH = 255;
 
                        MessageCenter(
                            uint32_t port = MessageCenter::DEFAULT_PORT);
 
                        bool
                        hasUnseenMessages()
                            const;
 
                        bool
                        getNextMessage(
                            uint32_t &clientID,
                            Memory::uint8Array &message,
                            int numSeconds = -1);
 
                        void
                        sendResponse(
                            uint32_t clientID,
                            const Memory::uint8Array &message)
                            const;
 
                        void
                        disconnectClient(
                            uint32_t clientID);
 
                private:
                        std::shared_ptr<Process::Manager> _manager;
                        std::shared_ptr<Process::WorkerController> _listener;
                };
        }
}
 
#endif /* __BE_PROCESS_MESSAGECENTER__ */