Current section
11 Versions
Jump to
Current section
11 Versions
Compare versions
4
files changed
+6
additions
-7
deletions
| @@ -37,4 +37,4 @@ | |
| 37 37 | [{<<"app">>,<<"telemetry">>}, |
| 38 38 | {<<"optional">>,false}, |
| 39 39 | {<<"requirement">>,<<"1.2.1">>}]}]}. |
| 40 | - {<<"version">>,<<"3.2.0">>}. |
| 40 | + {<<"version">>,<<"3.3.0">>}. |
| @@ -1,6 +1,6 @@ | |
| 1 1 | {application,amoc, |
| 2 2 | [{description,"A Murder of Crows"}, |
| 3 | - {vsn,"3.2.0"}, |
| 3 | + {vsn,"3.3.0"}, |
| 4 4 | {registered,[]}, |
| 5 5 | {applications,[kernel,stdlib,compiler,telemetry]}, |
| 6 6 | {mod,{amoc_app,[]}}, |
| @@ -19,7 +19,7 @@ | |
| 19 19 | -define(IS_N_OF_USERS(N), (?IS_POS_INT(N) orelse N =:= all)). |
| 20 20 | -define(IS_TIMEOUT(Timeout), (?IS_POS_INT(Timeout) orelse Timeout =:= infinity)). |
| 21 21 | |
| 22 | - -type name() :: atom(). |
| 22 | + -type name() :: term(). |
| 23 23 | |
| 24 24 | -type data() :: {pid(), Data :: any()}. |
| 25 25 | |
| @@ -102,11 +102,11 @@ reset(Name) -> | |
| 102 102 | notify(Name, reset_coordinator). |
| 103 103 | |
| 104 104 | -spec notify(name(), coordinator_timeout | reset_coordinator | {coordinate, {pid(), term()}}) -> ok. |
| 105 | - notify(Name, coordinator_timeout) when is_atom(Name) -> |
| 105 | + notify(Name, coordinator_timeout) -> |
| 106 106 | do_notify(Name, coordinator_timeout); |
| 107 | - notify(Name, reset_coordinator) when is_atom(Name) -> |
| 107 | + notify(Name, reset_coordinator) -> |
| 108 108 | do_notify(Name, reset_coordinator); |
| 109 | - notify(Name, {coordinate, _} = Event) when is_atom(Name) -> |
| 109 | + notify(Name, {coordinate, _} = Event) -> |
| 110 110 | do_notify(Name, Event). |
| 111 111 | |
| 112 112 | do_notify(Name, Event) -> |
| @@ -68,7 +68,6 @@ start_link() -> | |
| 68 68 | |
| 69 69 | -spec init(term()) -> {ok, {supervisor:sup_flags(), [supervisor:child_spec()]}}. |
| 70 70 | init([]) -> |
| 71 | - ets:new(?MODULE, [named_table, ordered_set, public, {read_concurrency, true}]), |
| 72 71 | AChild = #{id => amoc_coordinator_worker_sup, |
| 73 72 | start => {amoc_coordinator_worker_sup, start_link, []}, |
| 74 73 | restart => transient, |