diff options
Diffstat (limited to 'lib/snmp/src/agent/snmpa_misc_sup.erl')
| -rw-r--r-- | lib/snmp/src/agent/snmpa_misc_sup.erl | 158 |
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, []}}. |