fix dets
This commit is contained in:
parent
f51756e4b5
commit
fc96042cae
@ -14,7 +14,6 @@
|
|||||||
|
|
||||||
%% API
|
%% API
|
||||||
-export([start_link/0]).
|
-export([start_link/0]).
|
||||||
-export([start_service/1, stop_service/1]).
|
|
||||||
|
|
||||||
%% Supervisor callbacks
|
%% Supervisor callbacks
|
||||||
-export([init/1]).
|
-export([init/1]).
|
||||||
|
|||||||
@ -56,7 +56,7 @@ get_service(ServiceId) when is_binary(ServiceId) ->
|
|||||||
get_all_services() ->
|
get_all_services() ->
|
||||||
gen_server:call(?SERVER, get_all_services).
|
gen_server:call(?SERVER, get_all_services).
|
||||||
|
|
||||||
-spec get_running_services() -> {ok, [#service{}]} | {error, Reason :: term()}.
|
-spec get_running_services() -> {ok, [#service{}]}.
|
||||||
get_running_services() ->
|
get_running_services() ->
|
||||||
gen_server:call(?SERVER, get_running_services).
|
gen_server:call(?SERVER, get_running_services).
|
||||||
|
|
||||||
@ -138,7 +138,7 @@ handle_call(get_all_services, _From, State = #state{}) ->
|
|||||||
handle_call(get_running_services, _From, State = #state{}) ->
|
handle_call(get_running_services, _From, State = #state{}) ->
|
||||||
Items = dets:foldl(fun(Record, Acc) -> [Record|Acc] end, [], ?TAB),
|
Items = dets:foldl(fun(Record, Acc) -> [Record|Acc] end, [], ?TAB),
|
||||||
RunningItems = lists:filter(fun(#service{status = Status}) -> Status =:= 1 end, lists:reverse(Items)),
|
RunningItems = lists:filter(fun(#service{status = Status}) -> Status =:= 1 end, lists:reverse(Items)),
|
||||||
{reply, RunningItems, State};
|
{reply, {ok, RunningItems}, State};
|
||||||
|
|
||||||
handle_call(_Request, _From, State = #state{}) ->
|
handle_call(_Request, _From, State = #state{}) ->
|
||||||
{reply, ok, State}.
|
{reply, ok, State}.
|
||||||
|
|||||||
@ -2,7 +2,7 @@
|
|||||||
{efka, [
|
{efka, [
|
||||||
{root_dir, "/usr/local/code/efka"},
|
{root_dir, "/usr/local/code/efka"},
|
||||||
|
|
||||||
{dets_dir, "/tmp/db/"},
|
{dets_dir, "/usr/local/code/tmp/dets/"},
|
||||||
|
|
||||||
{tcp_server, [
|
{tcp_server, [
|
||||||
{port, 18088}
|
{port, 18088}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user