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

Remove RPC configurations

This commit is contained in:
Feng Lee 2017-11-22 16:44:00 +08:00
parent 38c33e9c8b
commit 223f3d4da5
3 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
Makefile
View File

@ -2,13 +2,12 @@ PROJECT = emqx
PROJECT_DESCRIPTION = EMQ X Broker PROJECT_DESCRIPTION = EMQ X Broker
PROJECT_VERSION = 2.3.0 PROJECT_VERSION = 2.3.0
NO_AUTOPATCH = gen_rpc cuttlefish NO_AUTOPATCH = cuttlefish
DEPS = goldrush gproc gen_rpc lager esockd ekka mochiweb pbkdf2 lager_syslog bcrypt clique jsx DEPS = goldrush gproc lager esockd ekka mochiweb pbkdf2 lager_syslog bcrypt clique jsx
dep_goldrush = git https://github.com/basho/goldrush 0.1.9 dep_goldrush = git https://github.com/basho/goldrush 0.1.9
dep_gproc = git https://github.com/uwiger/gproc dep_gproc = git https://github.com/uwiger/gproc
dep_gen_rpc = git https://github.com/priestjim/gen_rpc
dep_getopt = git https://github.com/jcomellas/getopt v0.8.2 dep_getopt = git https://github.com/jcomellas/getopt v0.8.2
dep_lager = git https://github.com/basho/lager master dep_lager = git https://github.com/basho/lager master
dep_lager_syslog = git https://github.com/basho/lager_syslog dep_lager_syslog = git https://github.com/basho/lager_syslog

3
src/emqx_rpc.erl
View File

@ -26,6 +26,5 @@
%% @doc Wraps gen_rpc first. %% @doc Wraps gen_rpc first.
cast(Node, Mod, Fun, Args) -> cast(Node, Mod, Fun, Args) ->
emqx_metrics:inc('messages/forward'), emqx_metrics:inc('messages/forward'), rpc:cast(Node, Mod, Fun, Args).
gen_rpc:cast({Node, erlang:system_info(scheduler_id)}, Mod, Fun, Args).

2
src/emqx_server.erl
View File

@ -137,7 +137,7 @@ with_subpid(SubId) when is_binary(SubId) ->
with_subpid({SubId, SubPid}) when is_binary(SubId), is_pid(SubPid) -> with_subpid({SubId, SubPid}) when is_binary(SubId), is_pid(SubPid) ->
{SubId, SubPid}. {SubId, SubPid}.
-spec(subscriptions(subscriber()) -> [{subscriber(), binary(), list(suboption())}]). -spec(subscriptions(emqx:subscriber()) -> [{emqx:subscriber(), binary(), list(emqx:suboption())}]).
subscriptions(SubPid) when is_pid(SubPid) -> subscriptions(SubPid) when is_pid(SubPid) ->
with_subproperty(ets:lookup(mqtt_subscription, SubPid)); with_subproperty(ets:lookup(mqtt_subscription, SubPid));