Core.h

Go to the documentation of this file.

 
#ifndef __ROGUE_PROTOCOLS_UDP_CORE_H__
#define __ROGUE_PROTOCOLS_UDP_CORE_H__
#include "rogue/Directives.h"
 
#include <netdb.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <stdint.h>
#include <sys/socket.h>
 
#include <atomic>
#include <memory>
#include <mutex>
#include <thread>
 
#include "rogue/Logging.h"
 
namespace rogue {
namespace protocols {
namespace udp {
 
const uint32_t JumboMTU = 9000;
const uint32_t StdMTU   = 1500;
 
// IPv4 Header = 20B, UDP Header = 8B
const uint32_t HdrSize = 20 + 8;
 
const uint32_t MaxJumboPayload = JumboMTU - HdrSize;
const uint32_t MaxStdPayload   = StdMTU - HdrSize;
 
class Core {
  protected:
    std::shared_ptr<rogue::Logging> udpLog_;
 
    // Jumbo-frame enable state.
    bool jumbo_;
 
    // Socket descriptor.
    int32_t fd_;
 
    // Peer socket address.
    struct sockaddr_in remAddr_;
 
    // Transmit select()/send timeout.
    struct timeval timeout_;
 
    std::thread* thread_ = nullptr;
    std::atomic<bool> threadEn_{false};
 
    // Synchronizes shared socket/address updates in derived classes.
    std::mutex udpMtx_;
 
  public:
    static void setup_python();
 
    explicit Core(bool jumbo);
 
    ~Core();
 
    void stop();
 
    uint32_t maxPayload();
 
    bool setRxBufferCount(uint32_t count);
 
    void setTimeout(uint32_t timeout);
};
 
// Convenience
typedef std::shared_ptr<rogue::protocols::udp::Core> CorePtr;
}  // namespace udp
}  // namespace protocols
};  // namespace rogue
 
#endif