aboutsummaryrefslogtreecommitdiffstats
path: root/lib/tv/src/tv_table_owner.erl
diff options
context:
space:
mode:
authorErlang/OTP <[email protected]>2009-11-20 14:54:40 +0000
committerErlang/OTP <[email protected]>2009-11-20 14:54:40 +0000
commit84adefa331c4159d432d22840663c38f155cd4c1 (patch)
treebff9a9c66adda4df2106dfd0e5c053ab182a12bd /lib/tv/src/tv_table_owner.erl
downloadotp-84adefa331c4159d432d22840663c38f155cd4c1.tar.gz
otp-84adefa331c4159d432d22840663c38f155cd4c1.tar.bz2
otp-84adefa331c4159d432d22840663c38f155cd4c1.zip
The R13B03 release.OTP_R13B03
Diffstat (limited to 'lib/tv/src/tv_table_owner.erl')
-rw-r--r--lib/tv/src/tv_table_owner.erl122
1 files changed, 122 insertions, 0 deletions
diff --git a/lib/tv/src/tv_table_owner.erl b/lib/tv/src/tv_table_owner.erl
new file mode 100644
index 0000000000..bccac6c236
--- /dev/null
+++ b/lib/tv/src/tv_table_owner.erl
@@ -0,0 +1,122 @@
+%%
+%% %CopyrightBegin%
+%%
+%% Copyright Ericsson AB 1998-2009. All Rights Reserved.
+%%
+%% The contents of this file are subject to the Erlang Public License,
+%% Version 1.1, (the "License"); you may not use this file except in
+%% compliance with the License. You should have received a copy of the
+%% Erlang Public License along with this software. If not, it can be
+%% retrieved online at http://www.erlang.org/.
+%%
+%% Software distributed under the License is distributed on an "AS IS"
+%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
+%% the License for the specific language governing rights and limitations
+%% under the License.
+%%
+%% %CopyrightEnd%
+-module(tv_table_owner).
+
+
+
+-export([create/5
+ ]).
+
+
+-export([internal_create/3,
+ start/0,
+ init/0
+ ]).
+
+
+
+-define(REGISTERED_NAME, tv_table_owner).
+
+
+
+create(mnesia, _Node, _LocalNode, _TableName, _Options) ->
+ error;
+create(ets, _Node, true, TabName, Options) ->
+ case catch internal_create(ets, TabName, Options) of
+ {TabName, Pid} when is_pid(Pid) ->
+ {ok, {TabName,Pid}};
+ {TabNo, Pid} when is_pid(Pid) ->
+ {ok, {TabNo,Pid}};
+ _OtherResult ->
+ error
+ end;
+create(ets, Node, false, TabName, Options) ->
+ case catch rpc:block_call(Node, ?MODULE, internal_create, [ets, TabName, Options]) of
+ {TabName, Pid} when is_pid(Pid) ->
+ {ok, {TabName,Pid}};
+ {TabNo, Pid} when is_pid(Pid) ->
+ {ok, {TabNo,Pid}};
+ _OtherResult ->
+ error
+ end.
+
+
+
+
+
+internal_create(ets, TabName, Options) ->
+ ?MODULE:start(),
+ ?REGISTERED_NAME ! {create, self(), ets, TabName, Options},
+ receive
+ {?REGISTERED_NAME, Result} ->
+ Result
+ after
+ 5000 ->
+ error
+ end.
+
+
+
+
+
+
+start() ->
+ case whereis(?REGISTERED_NAME) of
+ undefined ->
+ ServerPid = spawn(?MODULE, init, []),
+ case catch register(?REGISTERED_NAME, ServerPid) of
+ true ->
+ ok;
+ {'EXIT', _Reason} ->
+ exit(ServerPid, kill),
+ timer:sleep(500),
+ start()
+ end;
+ Pid when is_pid(Pid) ->
+ ok
+ end.
+
+
+
+
+
+
+
+
+init() ->
+ %% Currently no initialisations!
+ loop().
+
+
+
+
+
+
+loop() ->
+ receive
+
+ {create, Sender, ets, TabName, Options} ->
+ Sender ! {?REGISTERED_NAME, (catch ets:new(TabName, Options))},
+ loop();
+
+
+ _Other ->
+ loop()
+
+ end.
+