yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

set_flag

This commit is contained in:
Feng 2015-07-06 15:25:03 +08:00
parent 949b70f277
commit 4f20f9691a
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/emqttd_message.erl
View File

@ -170,7 +170,7 @@ unset_flag(Flag, Msg) when Flag =:= dup orelse Flag =:= retain -> Msg.
%% @doc Format MQTT Message %% @doc Format MQTT Message
%% @end %% @end
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------
format(#mqtt_message{msgid=MsgId, pktid = PktId, qos=Qos, retain=Retain, dup=Dup, topic=Topic}) -> format(#mqtt_message{msgid=MsgId, pktid = PktId, from = From, qos=Qos, retain=Retain, dup=Dup, topic=Topic}) ->
io_lib:format("Message(MsgId=~p, PktId=~p, Qos=~p, Retain=~s, Dup=~s, Topic=~s)", io_lib:format("Message(MsgId=~p, PktId=~p, from=~s, Qos=~p, Retain=~s, Dup=~s, Topic=~s)",
[MsgId, PktId, Qos, Retain, Dup, Topic]). [MsgId, PktId, From, Qos, Retain, Dup, Topic]).

2
src/emqttd_metrics.erl
View File

@ -224,7 +224,7 @@ code_change(_OldVsn, State, _Extra) ->
publish(Metric, Val) -> publish(Metric, Val) ->
Payload = emqttd_util:integer_to_binary(Val), Payload = emqttd_util:integer_to_binary(Val),
Msg = emqttd_message:make(metrics, metric_topic(Metric), Payload), Msg = emqttd_message:make(metrics, metric_topic(Metric), Payload),
emqttd_pubsub:publish(Msg). emqttd_pubsub:publish(emqttd_message:set_flag(sys, Msg)).
create_metric({gauge, Name}) -> create_metric({gauge, Name}) ->
ets:insert(?METRIC_TAB, {{Name, 0}, 0}); ets:insert(?METRIC_TAB, {{Name, 0}, 0});