Allow epocxy_ets_fsm to give up ownership of an ets table

Author: jaynel

src/epocxy_ets_fsm.erl

@@ -30,7 +30,8 @@
 -export([
          start_link/0,
          create_ets_table/1, create_ets_table/2,
-         delete_ets_table/1
+         delete_ets_table/1,
+         change_owner/2
         ]).
 
 %% gen_fsm state functions
@@ -56,6 +57,7 @@
 -spec create_ets_table(ets_concurrency()) -> ets:tid().
 -spec create_ets_table(atom(), ets_concurrency()) -> ets:tid().
 -spec delete_ets_table(atom() | ets:tid()) -> ok.
+-spec change_owner(atom() | ets:tid(), pid()) -> ok.
 
 start_link() ->
     gen_fsm:start_link({local, ?SERVER}, ?MODULE, {}, []).
@@ -72,6 +74,9 @@ create_ets_table(Name, Concurrency_Type)
 delete_ets_table(Table_Id_Or_Name) ->
     gen_fsm:sync_send_event(?SERVER, {delete_ets_table, Table_Id_Or_Name}).
 
+change_owner(Table_Id_Or_Name, New_Owner) ->
+    gen_fsm:sync_send_event(?SERVER, {change_owner, Table_Id_Or_Name, New_Owner}).
+
 make_options(none)           -> make_base_options([]);
 make_options(read_only)      -> make_base_options([{read_concurrency,  true}]);
 make_options(write_only)     -> make_base_options([{write_concurrency, true}]);
@@ -110,9 +115,13 @@ code_change (_OldVsn,  State_Name, #eef_state{} = State, _Extra) -> {ok, State_N
              (delete_ets_cmd(), from(), internal_state()) -> ok;
              (stop_cmd(),       from(), internal_state()) -> {stop, normal}.
 
-'READY'({create_ets_table, Name, Options}, _From, #eef_state{} = State) when is_atom(Name), is_list(Options)   -> {reply, ets:new(Name,   Options), 'READY', State};
-'READY'({create_ets_table, Options},       _From, #eef_state{} = State) when                is_list(Options)   -> {reply, ets:new(noname, Options), 'READY', State};
-'READY'({delete_ets_table, Table},         _From, #eef_state{} = State) when is_atom(Table); is_integer(Table) -> {reply, ets:delete(Table),        'READY', State};
+-define(READY(__Cmd), 'READY'(__Cmd, _From, #eef_state{} = State)).
+-define(REPLY(__Reply), {reply, __Reply, 'READY', State}).
+
+?READY({create_ets_table, Options})       when is_list(Options)                  -> ?REPLY(ets:new(noname, Options));
+?READY({create_ets_table, Name, Options}) when is_list(Options), is_atom(Name)   -> ?REPLY(ets:new(Name,   Options));
+?READY({delete_ets_table, Table})         when is_atom(Table); is_integer(Table) -> ?REPLY(ets:delete(Table));
+?READY({change_owner,     Table, Pid})    when is_atom(Table); is_integer(Table) -> ?REPLY(ets:give_away(Table, Pid, {}));
 
 %% Stop the ets owner FSM process.
 'READY'(stop, _From, #eef_state{}) -> {stop, normal}.