iolist_size/1
This commit is contained in:
parent
49ebed5b0b
commit
7abc667f7d
|
@ -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,
|
||||||
|
|
Loading…
Reference in New Issue