aboutsummaryrefslogtreecommitdiffstats
path: root/lib/snmp/src/agent/snmpa_misc_sup.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/snmp/src/agent/snmpa_misc_sup.erl
downloadotp-84adefa331c4159d432d22840663c38f155cd4c1.tar.gz
otp-84adefa331c4159d432d22840663c38f155cd4c1.tar.bz2
otp-84adefa331c4159d432d22840663c38f155cd4c1.zip
The R13B03 release.OTP_R13B03
Diffstat (limited to 'lib/snmp/src/agent/snmpa_misc_sup.erl')
-rw-r--r--lib/snmp/src/agent/snmpa_misc_sup.erl158
1 files changed, 158 insertions, 0 deletions
diff --git a/lib/snmp/src/agent/snmpa_misc_sup.erl b/lib/snmp/src/agent/snmpa_misc_sup.erl
new file mode 100644
index 0000000000..488d3f7921
--- /dev/null
+++ b/lib/snmp/src/agent/snmpa_misc_sup.erl
@@ -0,0 +1,158 @@
+%%
+%% %CopyrightBegin%
+%%
+%% Copyright Ericsson AB 1997-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(snmpa_misc_sup).
+
+-include("snmp_debug.hrl").
+
+-behaviour(supervisor).
+
+%% External exports
+-export([
+ start_link/0,
+ start_mib_server/4, stop_mib_server/1,
+ start_net_if/6, stop_net_if/1,
+ start_note_store/3, stop_note_store/1
+ ]).
+
+%% Internal exports
+-export([init/1]).
+
+-define(SERVER, ?MODULE).
+
+
+%%%-----------------------------------------------------------------
+%%% This is a supervisor for the mib and net_ifprocesses.
+%%% Each agent has one mib process.
+%%%-----------------------------------------------------------------
+
+start_link() ->
+ ?d("start_link -> entry", []),
+ supervisor:start_link({local, ?SERVER}, ?MODULE, []).
+
+
+%%-----------------------------------------------------------------
+%% When the agent starts, it calls this function. If there already
+%% exist a mib process for the agent, this one is used. Otherwise
+%% a new one is started.
+%%-----------------------------------------------------------------
+start_mib_server(Prio, Ref, Mibs, Opts) ->
+ ?d("start_mib_server -> entry with"
+ "~n Prio: ~p"
+ "~n Ref: ~p"
+ "~n Mibs: ~p"
+ "~n Opts: ~p", [Prio, Ref, Mibs, Opts]),
+ SupName = ?SERVER,
+ start_mibserver(SupName, Ref, [Prio, Mibs, Opts]).
+
+start_mibserver(SupName, Ref, Args) ->
+ Children = supervisor:which_children(SupName),
+ case lists:keysearch({mib, Ref}, 1, Children) of
+ {value, {_, Pid, _, _}} -> {ok, Pid};
+ _ ->
+ Mib = {{mib, Ref},
+ {snmpa_mib, start_link, Args},
+ transient, 10000, worker, [snmpa_mib]},
+ supervisor:start_child(SupName, Mib)
+ end.
+
+stop_mib_server(Ref) ->
+ SupName = ?SERVER,
+ case whereis(SupName) of
+ undefined ->
+ ok;
+ _ ->
+ supervisor:terminate_child(SupName, {mib, Ref}),
+ supervisor:delete_child(SupName, {mib, Ref})
+ end.
+
+
+start_net_if(Prio, NoteStore, Ref, Master, Mod, Opts) ->
+ ?d("start_mib -> entry with"
+ "~n Prio: ~p"
+ "~n NoteStore: ~p"
+ "~n Ref: ~p"
+ "~n Master: ~p"
+ "~n Mod: ~p"
+ "~n Opts: ~p",
+ [Prio, NoteStore, Ref, Master, Mod, Opts]),
+ SupName = ?SERVER,
+ start_netif(SupName, Ref, Mod, [Prio, NoteStore, Master, Opts]).
+
+start_netif(SupName, Ref, Mod, Args) ->
+ %% make sure we start from scratch...
+ Children = supervisor:which_children(SupName),
+ case lists:keysearch({net_if, Ref}, 1, Children) of
+ {value, {_, _Pid, _, _}} ->
+ stop_net_if(Ref);
+ _ ->
+ ok
+ end,
+ NetIf = {{net_if, Ref},
+ {Mod, start_link, Args},
+ permanent, 2000, worker, [Mod]},
+ supervisor:start_child(SupName, NetIf).
+
+stop_net_if(Ref) ->
+ SupName = ?SERVER,
+ case whereis(SupName) of
+ undefined ->
+ ok;
+ _ ->
+ supervisor:terminate_child(SupName, {net_if, Ref}),
+ supervisor:delete_child(SupName, {net_if, Ref})
+ end.
+
+
+start_note_store(Prio, Ref, Opts) ->
+ ?d("start_note_store -> entry with"
+ "~n Prio: ~p"
+ "~n Ref: ~p"
+ "~n Opts: ~p", [Prio, Ref, Opts]),
+ SupName = ?SERVER,
+ start_notestore(SupName, Ref, [Prio, snmpa, Opts]).
+
+start_notestore(SupName, Ref, Args) ->
+ %% make sure we start from scratch...
+ Children = supervisor:which_children(SupName),
+ case lists:keysearch({note_store, Ref}, 1, Children) of
+ {value, {_, _Pid, _, _}} ->
+ stop_note_store(Ref);
+ _ ->
+ ok
+ end,
+ Mod = snmp_note_store,
+ Note = {{note_store, Ref},
+ {Mod, start_link, Args},
+ permanent, 2000, worker, [Mod]},
+ supervisor:start_child(SupName, Note).
+
+stop_note_store(Ref) ->
+ SupName = ?SERVER,
+ case whereis(SupName) of
+ undefined ->
+ ok;
+ _ ->
+ supervisor:terminate_child(SupName, {note_store, Ref}),
+ supervisor:delete_child(SupName, {note_store, Ref})
+ end.
+
+
+init([]) ->
+ SupFlags = {one_for_all, 0, 3600},
+ {ok, {SupFlags, []}}.