Receiver.h

Go to the documentation of this file.

#pragma once
#include "BaseComponent.h"
#include "../Common.h"
#include <thread>
#include <mutex>
#include <condition_variable>
#include <atomic>
#include <functional>
#include <string>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
 
namespace RumPi
{
    class Receiver : public BaseComponent
    {
    private:
        std::atomic<bool> myIsConnected;            
        std::atomic<bool> myIsSendMessageReady;     
        std::string mySendMessageBuffer;            
        std::string myReceiveMessageBuffer;         
        unsigned int myPortNumber;                  
        std::atomic<unsigned int> myNumCharactersRead;          
        std::atomic<unsigned int> myNumCharactersWritten;       
        std::atomic<int> mySocketFileDescriptor;                    
        std::atomic<int> myNewSocketFileDescriptor;             
        std::thread myConnectionThread;             
        std::thread mySendThread;                   
        std::thread myReceiveThread;                
        mutable std::mutex mySendLock;              
        mutable std::mutex myReceiveLock;           
        std::condition_variable mySendCondition;    
 
        void ConnectToSocket();
 
        void SendViaThread();
 
        void ReceiveViaThread();
 
    public:
        typedef std::function<void(const char* theReceivedMessage)> OnMessageReceived;
        OnMessageReceived OnMessageReceivedCallback;    
 
        Receiver(unsigned int portNum, OnMessageReceived messageReceivedHandler);
 
        virtual ~Receiver();
 
        virtual void TurnOn() override;
 
        virtual void TurnOff() override;
 
        virtual void ProcessRawValues() override;
 
        virtual std::string ToString() const override;
 
        void ClearSendMessage();
 
        void ClearReceiveMessageBuffer();
 
        void SendMessage(std::string message);
 
        bool GetIsConnected() const;
 
        bool GetIsSendMessageReady() const;
 
        unsigned int GetPortNumber() const;
 
        unsigned int GetNumCharactersRead() const;
 
        unsigned int GetNumCharactersWritten() const;
 
        int GetSocketFileDescriptor() const;
 
        int GetNewSocketFileDescriptor() const;
 
        void SetPortNumber(unsigned int portNum);
    };
} // namespace RumPi