From 1428223a2b1cfbbd85d3e2a1f02dce7c71b6603a Mon Sep 17 00:00:00 2001 From: Ery Lee Date: Wed, 25 Mar 2015 23:23:25 +0800 Subject: [PATCH] trace --- apps/emqttd/src/emqttd.erl | 8 +++++ apps/emqttd/src/emqttd_trace.erl | 51 ++++++++++++++++++++++++++++++++ 2 files changed, 59 insertions(+) create mode 100644 apps/emqttd/src/emqttd_trace.erl diff --git a/apps/emqttd/src/emqttd.erl b/apps/emqttd/src/emqttd.erl index f9d70fc04..578280c42 100644 --- a/apps/emqttd/src/emqttd.erl +++ b/apps/emqttd/src/emqttd.erl @@ -79,4 +79,12 @@ is_running(Node) -> Pid when is_pid(Pid) -> true end. +%% TODO: publish chain... +publish(FromClient, Topic, Message) -> + emqttd_router:route(Message). + +%% TODO: subscribe: subscribe chain... +subscribe(FromClient, Topic) -> + emqttd_pubsub:subscribe(Topic). + diff --git a/apps/emqttd/src/emqttd_trace.erl b/apps/emqttd/src/emqttd_trace.erl new file mode 100644 index 000000000..3c25a2e3c --- /dev/null +++ b/apps/emqttd/src/emqttd_trace.erl @@ -0,0 +1,51 @@ +%%%----------------------------------------------------------------------------- +%%% @Copyright (C) 2012-2015, Feng Lee +%%% +%%% Permission is hereby granted, free of charge, to any person obtaining a copy +%%% of this software and associated documentation files (the "Software"), to deal +%%% in the Software without restriction, including without limitation the rights +%%% to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +%%% copies of the Software, and to permit persons to whom the Software is +%%% furnished to do so, subject to the following conditions: +%%% +%%% The above copyright notice and this permission notice shall be included in all +%%% copies or substantial portions of the Software. +%%% +%%% THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +%%% IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +%%% FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +%%% AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +%%% LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +%%% OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE +%%% SOFTWARE. +%%%----------------------------------------------------------------------------- +%%% @doc +%%% emqttd trace. +%%% +%%% @end +%%%----------------------------------------------------------------------------- +-module(emqttd_trace). + +%% Trace publish messages and write to file.. +%%------------------------------------------------------------------------------ +%% @doc +%% Start to trace client or topic. +%% +%% @end +%%------------------------------------------------------------------------------ +start_trace(client, ClientId) -> + ok; +start_trace(topic, Topic) -> + ok. + +%%------------------------------------------------------------------------------ +%% @doc +%% Stop tracing client or topic. +%% +%% @end +%%------------------------------------------------------------------------------ +stop_trace(client, ClientId) -> + ok; +stop_trace(topic, Topic) -> + ok. +