Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Adapt emqx_sn to emqx30 #90

Merged
merged 15 commits into from Nov 9, 2018

Conversation

@gilbertwong96
Copy link
Contributor

gilbertwong96 commented Nov 5, 2018

  • Adapt emqx_sn to emqx30
  • Support rebar3 to build project
shutdown(frame_error, StateData)
{keep_state, StateData1#state{sock_stats = SockStats1}}
catch
error : Error ->

This comment has been minimized.

Copy link
@turtleDeng

turtleDeng Nov 7, 2018

Collaborator

error : Error: Stacktrace ->

@@ -488,15 +509,13 @@ transform(?PUBLISH_PACKET(Qos, Topic, PacketId, Payload), _FuncMsgIdToTopicId) -
undefined ->
{?SN_SHORT_TOPIC, Topic}
end,
Flags = #mqtt_sn_flags{qos = Qos, topic_id_type = TopicIdType},
Flags = #mqtt_sn_flags{qos = QoS, topic_id_type = TopicIdType},
io:format("~n Topic type: ~p Topic Content: ~p ~n", [TopicIdType, TopicContent]),

This comment has been minimized.

Copy link
@turtleDeng

turtleDeng Nov 7, 2018

Collaborator

io:format -> lager:debug


send_message(Msg, StateData = #state{sockpid = SockPid, peer = Peer}) ->
?LOG(debug, "SEND ~s~n", [emqx_sn_frame:format(Msg)], StateData),
SockPid ! {datagram, Peer, emqx_sn_frame:serialize(Msg)}.
io:format("~n Msg: ~p ~n", [Msg]),

This comment has been minimized.

Copy link
@turtleDeng

turtleDeng Nov 7, 2018

Collaborator

io:format -> lager:debug

@turtleDeng turtleDeng merged commit 99d9c82 into emqx30 Nov 9, 2018
@gilbertwong96 gilbertwong96 deleted the Test-Realize-MqttSN branch Nov 10, 2018
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
2 participants
You can’t perform that action at this time.