UdpConnection.h

Go to the documentation of this file.

/****
 * Sming Framework Project - Open Source framework for high efficiency native ESP8266 development.
 * Created 2015 by Skurydin Alexey
 * http://github.com/SmingHub/Sming
 * All files of the Sming Core are provided under the LGPL v3 license.
 *
 * UdpConnection.h
 *
 ****/
 
#pragma once
 
#include <Network/IpConnection.h>
#include <lwip/udp.h>
 
class UdpConnection;
 
using UdpConnectionDataDelegate =
    Delegate<void(UdpConnection& connection, char* data, int size, IpAddress remoteIP, uint16_t remotePort)>;
 
class UdpConnection : public IpConnection
{
public:
    UdpConnection()
    {
        initialize();
    }
 
    UdpConnection(UdpConnectionDataDelegate dataHandler) : onDataCallback(dataHandler)
    {
        initialize();
    }
 
    virtual ~UdpConnection()
    {
        close();
    }
 
    virtual bool listen(int port);
    virtual bool connect(IpAddress ip, uint16_t port);
    virtual void close();
 
    // After connect(..)
    virtual bool send(const char* data, int length);
 
    bool sendString(const char* data)
    {
        return send(data, strlen(data));
    }
 
    bool sendString(const String& data)
    {
        return send(data.c_str(), data.length());
    }
 
    virtual bool sendTo(IpAddress remoteIP, uint16_t remotePort, const char* data, int length);
 
    bool sendStringTo(IpAddress remoteIP, uint16_t remotePort, const char* data)
    {
        return sendTo(remoteIP, remotePort, data, strlen(data));
    }
 
    bool sendStringTo(IpAddress remoteIP, uint16_t remotePort, const String& data)
    {
        return sendTo(remoteIP, remotePort, data.c_str(), data.length());
    }
 
    bool setMulticast(IpAddress ip);
 
    bool setMulticastTtl(size_t ttl);
 
protected:
    virtual void onReceive(pbuf* buf, IpAddress remoteIP, uint16_t remotePort);
 
protected:
    bool initialize(udp_pcb* pcb = nullptr);
    static void staticOnReceive(void* arg, struct udp_pcb* pcb, struct pbuf* p, LWIP_IP_ADDR_T* addr, u16_t port);
 
protected:
    udp_pcb* udp = nullptr;
    UdpConnectionDataDelegate onDataCallback = nullptr;
};