From b733a3bcfb89fb9b2cfcfbd4922035177d176bfd Mon Sep 17 00:00:00 2001
From: Feng Lee <feng@emqtt.io>
Date: Tue, 12 Jun 2018 12:10:53 +0800
Subject: [PATCH] Throw mqtt_frame_too_large exception if the sent frame is too
 large

---
 src/emqx_frame.erl | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/emqx_frame.erl b/src/emqx_frame.erl
index 61f8f9e50..ae2ab010d 100644
--- a/src/emqx_frame.erl
+++ b/src/emqx_frame.erl
@@ -378,7 +378,7 @@ serialize(#mqtt_packet_header{type   = Type,
                               retain = Retain}, VariableBin, PayloadBin)
     when ?CONNECT =< Type andalso Type =< ?AUTH ->
     Len = iolist_size(VariableBin) + iolist_size(PayloadBin),
-    true = (Len =< ?MAX_PACKET_SIZE),
+    (Len =< ?MAX_PACKET_SIZE) orelse error(mqtt_frame_too_large),
     [<<Type:4, (flag(Dup)):1, (flag(QoS)):2, (flag(Retain)):1>>,
      serialize_remaining_len(Len), VariableBin, PayloadBin].