From 387f2468c0fc509d828545db6f26cf773b5f93c0 Mon Sep 17 00:00:00 2001 From: Gilbert Wong Date: Thu, 18 Oct 2018 15:01:45 +0800 Subject: [PATCH] Add SendFun case for emqx-sn --- src/emqx_protocol.erl | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/emqx_protocol.erl b/src/emqx_protocol.erl index 93a1a8b64..3638e94e2 100644 --- a/src/emqx_protocol.erl +++ b/src/emqx_protocol.erl @@ -562,6 +562,9 @@ send(Packet = ?PACKET(Type), PState = #pstate{proto_ver = Ver, sendfun = SendFun {binary, _Data} -> emqx_metrics:sent(Packet), {ok, inc_stats(send, Type, PState)}; + {datagram, _Peer, _Data} -> + emqx_metrics:sent(Packet), + {ok, inc_stats(send, Type, PState)}; {error, Reason} -> {error, Reason} end.