forkineye
diff --git a/‎ESPAsyncE131.cpp‎
Lines changed: 10 additions & 5 deletions b/‎ESPAsyncE131.cpp‎
Lines changed: 10 additions & 5 deletions
diff --git a/‎ESPAsyncE131.h‎
Lines changed: 5 additions & 1 deletion b/‎ESPAsyncE131.h‎
Lines changed: 5 additions & 1 deletion
@@ -25,10 +25,13 @@ const byte ESPAsyncE131::ACN_ID[12] = { 0x41, 0x53, 0x43, 0x2d, 0x45, 0x31, 0x2e
 
 // Constructor
 ESPAsyncE131::ESPAsyncE131(uint8_t buffers) {
-    pbuff = RingBuf_new(sizeof(e131_packet_t), buffers);
-
-    stats.num_packets = 0;
-    stats.packet_errors = 0;
+    
+    pbuff = nullptr;
+    if (buffers)
+    {
+        pbuff = RingBuf_new (sizeof (e131_packet_t), buffers);
+    }
+    memset ((void*)&stats, 0x00, sizeof (stats));
 }
 
 /////////////////////////////////////////////////////////
@@ -116,7 +119,9 @@ void ESPAsyncE131::parsePacket(AsyncUDPPacket _packet) {
 
 
     if (!error) {
-        pbuff->add(pbuff, sbuff);
+        if (PacketCallback) { (*PacketCallback) (sbuff, UserInfo); }
+        if (pbuff) { pbuff->add (pbuff, sbuff); }
+        
         stats.num_packets++;
         stats.last_clientIP = _packet.remoteIP();
         stats.last_clientPort = _packet.remotePort();
 
@@ -139,6 +139,7 @@ class ESPAsyncE131 {
     e131_packet_t   *sbuff;     // Pointer to scratch packet buffer
     AsyncUDP        udp;        // AsyncUDP
     RingBuf         *pbuff;     // Ring Buffer of universe packet buffers
+    void            * UserInfo = nullptr;
 
     // Internal Initializers
     bool initUnicast();
@@ -147,6 +148,8 @@ class ESPAsyncE131 {
     // Packet parser callback
     void parsePacket(AsyncUDPPacket _packet);
 
+    void (*PacketCallback)(e131_packet_t* ReceivedData, void* UserInfo) = nullptr;
+
  public:
     e131_stats_t  stats;    // Statistics tracker
 
@@ -158,7 +161,8 @@ class ESPAsyncE131 {
     // Ring buffer access
     inline bool isEmpty() { return pbuff->isEmpty(pbuff); }
     inline void *pull(e131_packet_t *packet) { return pbuff->pull(pbuff, packet); }
-    
+    void RegisterCallback (void* _UserInfo, void (*cbFunction)(e131_packet_t*, void*)) { PacketCallback = cbFunction; UserInfo = _UserInfo; }
+
     // Diag functions
     void dumpError(e131_error_t error);
 };