1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586 |
- -module(syn).
- -export([start/0, stop/0]).
- -export([register/2, unregister/1]).
- -export([find_by_key/1, find_by_pid/1]).
- -export([options/1]).
- -export([count/0, count/1]).
- -spec start() -> ok.
- start() ->
- {ok, _} = application:ensure_all_started(mnesia),
- {ok, _} = application:ensure_all_started(syn),
- ok.
- -spec stop() -> ok.
- stop() ->
- ok = application:stop(syn).
- -spec register(Key :: any(), Pid :: pid()) -> ok | {error, taken}.
- register(Key, Pid) ->
- syn_backbone:register(Key, Pid).
- -spec unregister(Key :: any()) -> ok | {error, undefined}.
- unregister(Key) ->
- syn_backbone:unregister(Key).
- -spec find_by_key(Key :: any()) -> pid() | undefined.
- find_by_key(Key) ->
- syn_backbone:find_by_key(Key).
- -spec find_by_pid(Pid :: pid()) -> Key :: any() | undefined.
- find_by_pid(Pid) ->
- syn_backbone:find_by_pid(Pid).
- -spec options(list()) -> ok.
- options(Options) ->
-
- case proplists:get_value(netsplit_conflicting_mode, Options) of
- undefined ->
- ok;
- kill ->
- syn_netsplits:conflicting_mode(kill);
- {send_message, Message} ->
- syn_netsplits:conflicting_mode({send_message, Message})
- end.
- -spec count() -> non_neg_integer().
- count() ->
- syn_backbone:count().
- -spec count(Node :: atom()) -> non_neg_integer().
- count(Node) ->
- syn_backbone:count(Node).
|