Merge pull request #802 from emqtt/emq20

iolist_size/1
This commit is contained in:
Feng Lee 2016-12-07 19:13:53 +08:00 committed by GitHub
commit 4399a5d641
1 changed files with 1 additions and 1 deletions

View File

@ -69,7 +69,7 @@ init([MqttEnv, WsPid, Req, ReplyChannel]) ->
%% SendFun = fun(Payload) -> ReplyChannel({binary, Payload}) end, %% SendFun = fun(Payload) -> ReplyChannel({binary, Payload}) end,
SendFun = fun(Packet) -> SendFun = fun(Packet) ->
Data = emqttd_serializer:serialize(Packet), Data = emqttd_serializer:serialize(Packet),
emqttd_metrics:inc('bytes/sent', size(Data)), emqttd_metrics:inc('bytes/sent', iolist_size(Data)),
ReplyChannel({binary, Data}) ReplyChannel({binary, Data})
end, end,
ProtoState = emqttd_protocol:init(Peername, SendFun, ProtoState = emqttd_protocol:init(Peername, SendFun,