Client.h

Go to the documentation of this file.

 
#ifndef __ROGUE_PROTOCOLS_UDP_CLIENT_H__
#define __ROGUE_PROTOCOLS_UDP_CLIENT_H__
#include "rogue/Directives.h"
 
#include <netdb.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <stdint.h>
#include <sys/socket.h>
 
#include <memory>
#include <string>
#include <thread>
 
#include "rogue/Logging.h"
#include "rogue/interfaces/stream/Master.h"
#include "rogue/interfaces/stream/Slave.h"
#include "rogue/protocols/udp/Core.h"
 
namespace rogue {
namespace protocols {
namespace udp {
 
class Client : public rogue::protocols::udp::Core,
               public rogue::interfaces::stream::Master,
               public rogue::interfaces::stream::Slave {
    // Remote hostname or IPv4 address string.
    std::string address_;
 
    // Remote UDP port.
    uint16_t port_;
 
    // Background receive thread entry point.
    void runThread(std::weak_ptr<int>);
 
  public:
    static std::shared_ptr<rogue::protocols::udp::Client> create(std::string host, uint16_t port, bool jumbo);
 
    static void setup_python();
 
    Client(std::string host, uint16_t port, bool jumbo);
 
    ~Client();
 
    void stop();
 
    void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
};
 
// Convenience
typedef std::shared_ptr<rogue::protocols::udp::Client> ClientPtr;
 
}  // namespace udp
}  // namespace protocols
};  // namespace rogue
 
#endif