StatusReceiver.h

/***************************************************************************
 * \file StatusReceiver.h
 *
 * \brief NDR651 UDP status receiver.
 *
 * \author NH
 * \author JVM
 * \copyright Copyright (c) 2015-2021 CyberRadio Solutions, Inc.
 *
 */

#ifndef INCLUDED_LIBCYBERRADIO_NDR651_STATUSRECEIVER_H_
#define INCLUDED_LIBCYBERRADIO_NDR651_STATUSRECEIVER_H_

#include <boost/thread/mutex.hpp>
#include "LibCyberRadio/Common/Debuggable.h"
#include "LibCyberRadio/Common/Thread.h"

#define MAX_RX_SIZE 8192
#define MAX_RADIO_BUFFSIZE 67108862 // (2^26)-2 samples
#define RADIO_BUFFER_RESERVE 1048576

namespace LibCyberRadio
{
    namespace NDR651
    {

        class StatusReceiver: public LibCyberRadio::Thread, public LibCyberRadio::Debuggable
        {
            public:
                StatusReceiver(std::string ifname, unsigned int port, bool debug, bool updatePE);
                virtual ~StatusReceiver();
                virtual void run();
                bool setStatusInterface(std::string ifname);
                bool setStatusInterface(std::string ifname, bool makeSocketFlag);
                bool setStatusPort(unsigned int port);
                bool setStatusPort(unsigned int port, bool makeSocketFlag);
                bool okToSend(long int pendingSamples, bool lockIfOk);
                long int getFreeSpace(void);
                bool sentNSamples(long int samplesSent);

                bool setUpdatePE(bool updatePE);
                bool getUpdatePE(void) { return _updatePE; };
                int setMaxFreeSpace(float fs, float maxLatency);
                int getMaxFreeSpace(void) { return _freeSpaceMax; };
                //~ bool setUdpPort(unsigned int port);
                int getUdpPort(void) { return _port; };
                void blockUntilAvailable(unsigned int numSamples);

            private:
                int _sockfd;
                char _rxbuff[MAX_RX_SIZE];
                fd_set set;
                bool _sendLock;
                bool _shutdown;
                bool _updatePE;

                std::string _ifname;
                unsigned int _port;
                uint64_t timeoutCount;

                int _651freeSpace;
                int _freeSpaceMax;

                // Synchronization and signal mechanisms
                boost::mutex objectAccessMutex;
                boost::condition_variable waitCondition;

                bool _makeSocket(void);
                bool _setFreeSpace(int, bool, bool, bool);
        };

    } /* namespace NDR651 */

} /* namespace LibCyberRadio */

#endif /* INCLUDED_LIBCYBERRADIO_NDR651_STATUSRECEIVER_H_ */