aboutsummaryrefslogtreecommitdiffstats
path: root/lib/snmp/test/snmp_manager_user.erl
diff options
context:
space:
mode:
authorErlang/OTP <otp@erlang.org>2009-11-20 14:54:40 +0000
committerErlang/OTP <otp@erlang.org>2009-11-20 14:54:40 +0000
commit84adefa331c4159d432d22840663c38f155cd4c1 (patch)
treebff9a9c66adda4df2106dfd0e5c053ab182a12bd /lib/snmp/test/snmp_manager_user.erl
downloadotp-84adefa331c4159d432d22840663c38f155cd4c1.tar.gz
otp-84adefa331c4159d432d22840663c38f155cd4c1.tar.bz2
otp-84adefa331c4159d432d22840663c38f155cd4c1.zip
The R13B03 release.OTP_R13B03
Diffstat (limited to 'lib/snmp/test/snmp_manager_user.erl')
-rw-r--r--lib/snmp/test/snmp_manager_user.erl935
1 files changed, 935 insertions, 0 deletions
diff --git a/lib/snmp/test/snmp_manager_user.erl b/lib/snmp/test/snmp_manager_user.erl
new file mode 100644
index 0000000000..07b56bde39
--- /dev/null
+++ b/lib/snmp/test/snmp_manager_user.erl
@@ -0,0 +1,935 @@
+%%
+%% %CopyrightBegin%
+%%
+%% Copyright Ericsson AB 2005-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%
+%%
+
+%%----------------------------------------------------------------------
+%% Purpose: Utility functions for the (snmp manager) user test(s).
+%%----------------------------------------------------------------------
+
+-module(snmp_manager_user).
+
+-behaviour(snmpm_user).
+%% -behaviour(snmpm_user_old).
+
+
+%%----------------------------------------------------------------------
+%% Include files
+%%----------------------------------------------------------------------
+-include("test_server.hrl").
+-include("snmp_test_lib.hrl").
+
+
+%%----------------------------------------------------------------------
+%% External exports
+%%----------------------------------------------------------------------
+-export([
+ start_link/0, start_link/1, start_link/2,
+ start/0, start/1, start/2,
+ stop/0,
+ info/0,
+ system_info/0,
+ simulate_crash/1,
+ register_agent/2, register_agent/3,
+ unregister_agent/1, unregister_agent/2,
+ agent_info/2, agent_info/3,
+ update_agent_info/3, update_agent_info/4,
+ which_all_agents/0, which_own_agents/0,
+ load_mib/1, unload_mib/1,
+ sync_get/1, sync_get/2, sync_get/3,
+ async_get/1, async_get/2, async_get/3,
+ sync_get_next/1, sync_get_next/2, sync_get_next/3,
+ async_get_next/1, async_get_next/2, async_get_next/3,
+ sync_set/1, sync_set/2, sync_set/3,
+ async_set/1, async_set/2, async_set/3,
+ sync_get_bulk/3, sync_get_bulk/4, sync_get_bulk/5,
+ async_get_bulk/3, async_get_bulk/4, async_get_bulk/5,
+ name_to_oid/1, oid_to_name/1,
+ purify_oid/1
+ ]).
+
+
+%%----------------------------------------------------------------------
+%% Internal exports
+%%----------------------------------------------------------------------
+
+-export([
+ main/4
+ ]).
+
+-export([
+ handle_error/3,
+ handle_agent/4,
+ handle_pdu/4,
+ handle_trap/3,
+ handle_inform/3,
+ handle_report/3,
+ handle_pdu/5, % For backwards compatibillity
+ handle_trap/4, % For backwards compatibillity
+ handle_inform/4, % For backwards compatibillity
+ handle_report/4 % For backwards compatibillity
+ ]).
+
+
+-define(SERVER, ?MODULE).
+
+-record(state, {parent, id, reqs = []}).
+%% -record(request, {from, ref, tmr, req_id, type}).
+
+
+%%----------------------------------------------------------------------
+%% The user API
+%%----------------------------------------------------------------------
+
+start() ->
+ start(self()).
+
+start(Parent) ->
+ start(Parent, test_user).
+
+start(Parent, Id) ->
+ proc_lib:start(?MODULE, main, [true, Parent, self(), Id]).
+
+start_link() ->
+ start_link(self()).
+start_link(Parent) ->
+ start_link(Parent, test_user).
+
+start_link(Parent, Id) ->
+ proc_lib:start_link(?MODULE, main, [true, Parent, self(), Id]).
+
+stop() ->
+ cast(stop).
+
+info() ->
+ call(info).
+
+system_info() ->
+ call(system_info).
+
+simulate_crash(Reason) ->
+ call({simulate_crash, Reason}).
+
+register_agent(TargetName, Config)
+ when is_list(TargetName) andalso is_list(Config) ->
+ call({register_agent, TargetName, Config});
+register_agent(Addr, Port) ->
+ register_agent(Addr, Port, []).
+
+register_agent(Addr, Port, Conf) ->
+ call({register_agent, Addr, Port, Conf}).
+
+unregister_agent(TargetName) ->
+ call({unregister_agent, TargetName}).
+unregister_agent(Addr, Port) ->
+ call({unregister_agent, Addr, Port}).
+
+agent_info(TargetName, Item) ->
+ call({agent_info, TargetName, Item}).
+agent_info(Addr, Port, Item) ->
+ call({agent_info, Addr, Port, Item}).
+
+update_agent_info(TargetName, Item, Val) ->
+ call({update_agent_info, TargetName, Item, Val}).
+update_agent_info(Addr, Port, Item, Val) ->
+ call({update_agent_info, Addr, Port, Item, Val}).
+
+which_all_agents() ->
+ call(which_all_agents).
+
+which_own_agents() ->
+ call(which_own_agents).
+
+load_mib(Mib) ->
+ call({load_mib, Mib}).
+
+unload_mib(Mib) ->
+ call({unload_mib, Mib}).
+
+%% --
+
+sync_get(Oids) ->
+ call({sync_get, Oids}).
+
+sync_get(Addr_or_TargetName, Oids) ->
+ call({sync_get, Addr_or_TargetName, Oids}).
+
+sync_get(Addr, Port, Oids) ->
+ call({sync_get, Addr, Port, Oids}).
+
+%% --
+
+async_get(Oids) ->
+ call({async_get, Oids}).
+
+async_get(Addr_or_TargetName, Oids) ->
+ call({async_get, Addr_or_TargetName, Oids}).
+
+async_get(Addr, Port, Oids) ->
+ call({async_get, Addr, Port, Oids}).
+
+%% --
+
+sync_get_next(Oids) ->
+ call({sync_get_next, Oids}).
+
+sync_get_next(Addr_or_TargetName, Oids) ->
+ call({sync_get_next, Addr_or_TargetName, Oids}).
+
+sync_get_next(Addr, Port, Oids) ->
+ call({sync_get_next, Addr, Port, Oids}).
+
+%% --
+
+async_get_next(Oids) ->
+ call({async_get_next, Oids}).
+
+async_get_next(Addr_or_TargetName, Oids) ->
+ call({async_get_next, Addr_or_TargetName, Oids}).
+
+async_get_next(Addr, Port, Oids) ->
+ call({async_get_next, Addr, Port, Oids}).
+
+%% --
+
+sync_set(VAV) ->
+ call({sync_set, VAV}).
+
+sync_set(Addr_or_TargetName, VAV) ->
+ call({sync_set, Addr_or_TargetName, VAV}).
+
+sync_set(Addr, Port, VAV) ->
+ call({sync_set, Addr, Port, VAV}).
+
+%% --
+
+async_set(VAV) ->
+ call({async_set, VAV}).
+
+async_set(Addr_or_TargetName, VAV) ->
+ call({async_set, Addr_or_TargetName, VAV}).
+
+async_set(Addr, Port, VAV) ->
+ call({async_set, Addr, Port, VAV}).
+
+%% --
+
+sync_get_bulk(NonRep, MaxRep, Oids) ->
+ call({sync_get_bulk, NonRep, MaxRep, Oids}).
+
+sync_get_bulk(Addr_or_TargetName, NonRep, MaxRep, Oids) ->
+ call({sync_get_bulk, Addr_or_TargetName, NonRep, MaxRep, Oids}).
+
+sync_get_bulk(Addr, Port, NonRep, MaxRep, Oids) ->
+ call({sync_get_bulk, Addr, Port, NonRep, MaxRep, Oids}).
+
+%% --
+
+async_get_bulk(NonRep, MaxRep, Oids) ->
+ call({async_get_bulk, NonRep, MaxRep, Oids}).
+
+async_get_bulk(Addr_or_TargetName, NonRep, MaxRep, Oids) ->
+ call({async_get_bulk, Addr_or_TargetName, NonRep, MaxRep, Oids}).
+
+async_get_bulk(Addr, Port, NonRep, MaxRep, Oids) ->
+ call({async_get_bulk, Addr, Port, NonRep, MaxRep, Oids}).
+
+%% --
+
+name_to_oid(Name) ->
+ call({name_to_oid, Name}).
+
+oid_to_name(Oid) ->
+ call({oid_to_name, Oid}).
+
+purify_oid(Oid) ->
+ call({purify_oid, Oid}).
+
+
+%%----------------------------------------------------------------------
+
+main(Debug, Parent, Starter, Id) ->
+ put(debug, Debug),
+ d("main -> entry with"
+ "~n Parent: ~p"
+ "~n Starter: ~p"
+ "~n Id: ~p", [Parent, Starter, Id]),
+ case (catch do_init(Id)) of
+ ok ->
+ proc_lib:init_ack(Starter, {ok, self()}),
+ loop(#state{parent = Parent, id = Id});
+ Error ->
+ d("main -> error: "
+ "~p", [Error]),
+ proc_lib:init_ack(Starter, Error)
+ end.
+
+do_init(Id) ->
+ erlang:register(?SERVER, self()),
+ snmpm:register_user(Id, ?MODULE, self()).
+
+
+%%----------------------------------------------------------------------
+
+loop(#state{parent = Parent, id = Id} = S) ->
+ d("loop -> entry"),
+ receive
+ {stop, _From} ->
+ d("loop -> received stop request"),
+ exit(normal);
+
+ {{simulate_crash, Reason}, From, Ref} ->
+ d("loop -> received simulate_crash request"),
+ reply(From, ok, Ref),
+ exit(Reason);
+
+ {info, From, Ref} ->
+ d("loop -> received info request"),
+ Res = snmpm:info(),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {system_info, From, Ref} ->
+ d("loop -> received system_info request"),
+ Res = snmpm_config:system_info(),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{register_agent, TargetName, Conf}, From, Ref} ->
+ d("loop -> received register_agent request"),
+ Res = snmpm:register_agent(Id, TargetName, Conf),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{register_agent, Addr, Port, Conf}, From, Ref} ->
+ d("loop -> received register_agent request"),
+ Res = snmpm:register_agent(Id, Addr, Port, Conf),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{unregister_agent, TargetName}, From, Ref} ->
+ d("loop -> received unregister_agent request"),
+ Res = snmpm:unregister_agent(Id, TargetName),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{unregister_agent, Addr, Port}, From, Ref} ->
+ d("loop -> received unregister_agent request"),
+ Res = snmpm:unregister_agent(Id, Addr, Port),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{agent_info, TargetName, Item}, From, Ref} ->
+ d("loop -> received agent_info request with"
+ "~n TargetName: ~p"
+ "~n Item: ~p", [TargetName, Item]),
+ Res = snmpm:agent_info(TargetName, Item),
+ d("loop -> agent_info for ~p"
+ "~n Res: ~p", [Item, Res]),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{agent_info, Addr, Port, Item}, From, Ref} ->
+ d("loop -> received agent_info request with"
+ "~n Addr: ~p"
+ "~n Port: ~p"
+ "~n Item: ~p", [Addr, Port, Item]),
+ Res = snmpm:agent_info(Addr, Port, Item),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{update_agent_info, TargetName, Item, Val}, From, Ref} ->
+ d("loop -> received update_agent_info request with"
+ "~n TargetName: ~p"
+ "~n Item: ~p"
+ "~n Val: ~p", [TargetName, Item, Val]),
+ Res = snmpm:update_agent_info(Id, TargetName, Item, Val),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{update_agent_info, Addr, Port, Item, Val}, From, Ref} ->
+ d("loop -> received update_agent_info request with"
+ "~n Addr: ~p"
+ "~n Port: ~p"
+ "~n Item: ~p"
+ "~n Val: ~p", [Addr, Port, Item, Val]),
+ Res = snmpm:update_agent_info(Id, Addr, Port, Item, Val),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {which_all_agents, From, Ref} ->
+ d("loop -> received which_all_agents request"),
+ Res = snmpm:which_agents(),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {which_own_agents, From, Ref} ->
+ d("loop -> received which_own_agents request"),
+ Res = snmpm:which_agents(Id),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{load_mib, Mib}, From, Ref} ->
+ d("loop -> received load_mib request"),
+ Res = snmpm:load_mib(Mib),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{unload_mib, Mib}, From, Ref} ->
+ d("loop -> received unload_mib request"),
+ Res = snmpm:unload_mib(Mib),
+ reply(From, Res, Ref),
+ loop(S);
+
+
+ %%
+ %% -- (sync) get-request --
+ %%
+
+ %% No agent specified, so send it to all of them
+ {{sync_get, Oids}, From, Ref} ->
+ d("loop -> received sync_get request "
+ "(for every agent of this user)"),
+ Res = [snmpm:sync_get(Id, TargetName, Oids) ||
+ TargetName <- snmpm:which_agents(Id)],
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_get, TargetName, Oids}, From, Ref} when is_list(TargetName) ->
+ d("loop -> received sync_get request with"
+ "~n TargetName: ~p"
+ "~n Oids: ~p", [TargetName, Oids]),
+ Res = snmpm:sync_get(Id, TargetName, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_get, Addr, Oids}, From, Ref} ->
+ d("loop -> received sync_get request with"
+ "~n Addr: ~p"
+ "~n Oids: ~p", [Addr, Oids]),
+ Res = snmpm:g(Id, Addr, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_get, Addr, Port, Oids}, From, Ref} ->
+ d("loop -> received sync_get request with"
+ "~n Addr: ~p"
+ "~n Port: ~p"
+ "~n Oids: ~p", [Addr, Port, Oids]),
+ Res = snmpm:g(Id, Addr, Port, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+
+ %%
+ %% -- (async) get-request --
+ %%
+
+ %% No agent specified, so send it to all of them
+ {{async_get, Oids}, From, Ref} ->
+ d("loop -> received async_get request"),
+ Res = [snmpm:async_get(Id, TargetName, Oids) ||
+ TargetName <- snmpm:which_agents(Id)],
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_get, TargetName, Oids}, From, Ref} when is_list(TargetName) ->
+ d("loop -> received async_get request with"
+ "~n TargetName: ~p"
+ "~n Oids: ~p", [TargetName, Oids]),
+ Res = snmpm:async_get(Id, TargetName, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_get, Addr, Oids}, From, Ref} ->
+ d("loop -> received async_get request"),
+ Res = snmpm:ag(Id, Addr, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_get, Addr, Port, Oids}, From, Ref} ->
+ d("loop -> received async_get request"),
+ Res = snmpm:ag(Id, Addr, Port, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+
+ %%
+ %% -- (sync) get_next-request --
+ %%
+
+ %% No agent specified, so send it to all of them
+ {{sync_get_next, Oids}, From, Ref} ->
+ d("loop -> received sync_get_next request"),
+ Res = [snmpm:sync_get_next(Id, TargetName, Oids) ||
+ TargetName <- snmpm:which_agents(Id)],
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_get_next, TargetName, Oids}, From, Ref} when is_list(TargetName) ->
+ d("loop -> received sync_get_next request with"
+ "~n TargetName: ~p"
+ "~n Oids: ~p", [TargetName, Oids]),
+ Res = snmpm:sync_get_next(Id, TargetName, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_get_next, Addr, Oids}, From, Ref} ->
+ d("loop -> received sync_get_next request"),
+ Res = snmpm:gn(Id, Addr, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_get_next, Addr, Port, Oids}, From, Ref} ->
+ d("loop -> received sync_get_next request"),
+ Res = snmpm:gn(Id, Addr, Port, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+
+ %%
+ %% -- (async) get_next-request --
+ %%
+
+ %% No agent specified, so send it to all of them
+ {{async_get_next, Oids}, From, Ref} ->
+ d("loop -> received async_get_next request"),
+ Res = [snmpm:async_get_next(Id, TargetName, Oids) ||
+ TargetName <- snmpm:which_agents(Id)],
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_get_next, TargetName, Oids}, From, Ref} when is_list(TargetName) ->
+ d("loop -> received async_get_next request with"
+ "~n TargetName: ~p"
+ "~n Oids: ~p", [TargetName, Oids]),
+ Res = snmpm:async_get_next(Id, TargetName, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_get_next, Addr, Oids}, From, Ref} ->
+ d("loop -> received async_get_next request"),
+ Res = snmpm:agn(Id, Addr, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_get_next, Addr, Port, Oids}, From, Ref} ->
+ d("loop -> received async_get_next request"),
+ Res = snmpm:agn(Id, Addr, Port, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+
+ %%
+ %% -- (sync) set-request --
+ %%
+
+ {{sync_set, VAV}, From, Ref} ->
+ d("loop -> received sync_set request"),
+ Res = [snmpm:sync_set(Id, TargetName, VAV) ||
+ TargetName <- snmpm:which_agents(Id)],
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_set, TargetName, VAV}, From, Ref} when is_list(TargetName) ->
+ d("loop -> received sync_set request"),
+ Res = snmpm:sync_set(Id, TargetName, VAV),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_set, Addr, VAV}, From, Ref} ->
+ d("loop -> received sync_set request"),
+ Res = snmpm:s(Id, Addr, VAV),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_set, Addr, Port, VAV}, From, Ref} ->
+ d("loop -> received sync_set request"),
+ Res = snmpm:s(Id, Addr, Port, VAV),
+ reply(From, Res, Ref),
+ loop(S);
+
+
+ %%
+ %% -- (async) set-request --
+ %%
+
+ {{async_set, VAV}, From, Ref} ->
+ d("loop -> received async_set request"),
+ Res = [snmpm:async_set(Id, TargetName, VAV) ||
+ TargetName <- snmpm:which_agents(Id)],
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_set, TargetName, VAV}, From, Ref} when is_list(TargetName) ->
+ d("loop -> received async_set request"),
+ Res = snmpm:async_set(Id, TargetName, VAV),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_set, Addr, VAV}, From, Ref} ->
+ d("loop -> received async_set request"),
+ Res = snmpm:as(Id, Addr, VAV),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_set, Addr, Port, VAV}, From, Ref} ->
+ d("loop -> received async_set request"),
+ Res = snmpm:as(Id, Addr, Port, VAV),
+ reply(From, Res, Ref),
+ loop(S);
+
+
+ %%
+ %% -- (sync) get-bulk-request --
+ %%
+
+ %% No agent specified, so send it to all of them
+ {{sync_get_bulk, NonRep, MaxRep, Oids}, From, Ref} ->
+ d("loop -> received sync_get_bulk request with"
+ "~n NonRep: ~w"
+ "~n MaxRep: ~w"
+ "~n Oids: ~p", [NonRep, MaxRep, Oids]),
+ Res = [snmpm:sync_get_bulk(Id, TargetName, NonRep, MaxRep, Oids) ||
+ TargetName <- snmpm:which_agents(Id)],
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_get_bulk, TargetName, NonRep, MaxRep, Oids}, From, Ref} when is_list(TargetName) ->
+ d("loop -> received sync_get_bulk request with"
+ "~n TargetName: ~p"
+ "~n NonRep: ~w"
+ "~n MaxRep: ~w"
+ "~n Oids: ~p", [TargetName, NonRep, MaxRep, Oids]),
+ Res = snmpm:sync_get_bulk(Id, TargetName, NonRep, MaxRep, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_get_bulk, Addr, NonRep, MaxRep, Oids}, From, Ref} ->
+ d("loop -> received sync_get_bulk request with"
+ "~n Addr: ~p"
+ "~n NonRep: ~w"
+ "~n MaxRep: ~w"
+ "~n Oids: ~p", [Addr, NonRep, MaxRep, Oids]),
+ Res = snmpm:gb(Id, Addr, NonRep, MaxRep, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{sync_get_bulk, Addr, Port, NonRep, MaxRep, Oids}, From, Ref} ->
+ d("loop -> received sync_get_bulk request with"
+ "~n Addr: ~p"
+ "~n Port: ~w"
+ "~n NonRep: ~w"
+ "~n MaxRep: ~w"
+ "~n Oids: ~p", [Addr, Port, NonRep, MaxRep, Oids]),
+ Res = snmpm:gb(Id, Addr, Port, NonRep, MaxRep, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+
+ %%
+ %% -- (async) get-bulk-request --
+ %%
+
+ %% No agent specified, so send it to all of them
+ {{async_get_bulk, NonRep, MaxRep, Oids}, From, Ref} ->
+ d("loop -> received async_get_bulk request with"
+ "~n NonRep: ~w"
+ "~n MaxRep: ~w"
+ "~n Oids: ~p", [NonRep, MaxRep, Oids]),
+ Res = [snmpm:async_get_bulk(Id, TargetName, NonRep, MaxRep, Oids) ||
+ TargetName <- snmpm:which_agents(Id)],
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_get_bulk, TargetName, NonRep, MaxRep, Oids}, From, Ref} when is_list(TargetName) ->
+ d("loop -> received async_get_bulk request with"
+ "~n TargetName: ~p"
+ "~n NonRep: ~w"
+ "~n MaxRep: ~w"
+ "~n Oids: ~p", [TargetName, NonRep, MaxRep, Oids]),
+ Res = snmpm:async_get_bulk(Id, TargetName, NonRep, MaxRep, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_get_bulk, Addr, NonRep, MaxRep, Oids}, From, Ref} ->
+ d("loop -> received async_get_bulk request with"
+ "~n Addr: ~p"
+ "~n NonRep: ~w"
+ "~n MaxRep: ~w"
+ "~n Oids: ~p", [Addr, NonRep, MaxRep, Oids]),
+ Res = snmpm:agb(Id, Addr, NonRep, MaxRep, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{async_get_bulk, Addr, Port, NonRep, MaxRep, Oids}, From, Ref} ->
+ d("loop -> received async_get_bulk request with"
+ "~n Addr: ~p"
+ "~n Port: ~w"
+ "~n NonRep: ~w"
+ "~n MaxRep: ~w"
+ "~n Oids: ~p", [Addr, Port, NonRep, MaxRep, Oids]),
+ Res = snmpm:agb(Id, Addr, Port, NonRep, MaxRep, Oids),
+ reply(From, Res, Ref),
+ loop(S);
+
+
+ %%
+ %% -- logical name translation --
+ %%
+
+ {{name_to_oid, Name}, From, Ref} ->
+ d("loop -> received name_to_oid request for"
+ "~n Name: ~p", [Name]),
+ Res = snmpm:name_to_oid(Name),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{oid_to_name, Oid}, From, Ref} ->
+ d("loop -> received oid_to_name request for"
+ "~n Oid: ~p", [Oid]),
+ Res = snmpm:oid_to_name(Oid),
+ reply(From, Res, Ref),
+ loop(S);
+
+ {{purify_oid, Oid}, From, Ref} ->
+ d("loop -> received purify_oid request for"
+ "~n Oid: ~p", [Oid]),
+ Res = do_purify_oid(Oid),
+ reply(From, Res, Ref),
+ loop(S);
+
+
+ %% SNMP manager callback messages (from our callback API):
+
+ {handle_error, _Pid, ReqId, Reason} ->
+ d("loop -> received error callback from manager for ~w:"
+ "~n ~p", [ReqId, Reason]),
+ Parent ! {async_event, ReqId, {error, Reason}},
+ loop(S);
+
+ {handle_agent, _Pid, Addr, Port, SnmpInfo} ->
+ d("loop -> received agent callback from manager for ~n ~p:~w",
+ [Addr, Port]),
+ Parent ! {async_event, {Addr, Port}, {agent, SnmpInfo}},
+ loop(S);
+
+ {handle_pdu, _Pid, _TargetName, ReqId, SnmpResponse} ->
+ d("loop -> received pdu callback from manager for ~w", [ReqId]),
+ Parent ! {async_event, ReqId, {pdu, SnmpResponse}},
+ loop(S);
+
+ %% For backwards compatibillity
+ {handle_pdu, _Pid, _Addr, _Port, ReqId, SnmpResponse} ->
+ d("loop -> received pdu callback from manager for ~w", [ReqId]),
+ Parent ! {async_event, ReqId, {pdu, SnmpResponse}},
+ loop(S);
+
+ {handle_trap, _Pid, TargetName, SnmpTrap} ->
+ d("loop -> received trap callback from manager for "
+ "~n ~p",
+ "~n ~p",
+ [TargetName, SnmpTrap]),
+ Parent ! {async_event, TargetName, {trap, SnmpTrap}},
+ loop(S);
+
+ %% For backwards compatibillity
+ {handle_trap, _Pid, Addr, Port, SnmpTrap} ->
+ d("loop -> received trap callback from manager for "
+ "~n ~p:~w",
+ "~n ~p",
+ [Addr, Port, SnmpTrap]),
+ Parent ! {async_event, {Addr, Port}, {trap, SnmpTrap}},
+ loop(S);
+
+ {handle_inform, Pid, TargetName, SnmpInform} ->
+ d("loop -> received inform callback from manager for "
+ "~n ~p",
+ "~n ~p",
+ [TargetName, SnmpInform]),
+ Parent ! {async_event, TargetName, {inform, Pid, SnmpInform}},
+ loop(S);
+
+ %% For backwards compatibillity
+ {handle_inform, Pid, Addr, Port, SnmpInform} ->
+ d("loop -> received inform callback from manager for "
+ "~n ~p:~w",
+ "~n ~p",
+ [Addr, Port, SnmpInform]),
+ Parent ! {async_event, {Addr, Port}, {inform, Pid, SnmpInform}},
+ loop(S);
+
+ {handle_report, _Pid, TargetName, SnmpReport} ->
+ d("loop -> received report callback from manager for "
+ "~n ~p",
+ "~n ~p",
+ [TargetName, SnmpReport]),
+ Parent ! {async_event, TargetName, {report, SnmpReport}},
+ loop(S);
+
+ %% For backwards compatibillity
+ {handle_report, _Pid, Addr, Port, SnmpReport} ->
+ d("loop -> received report callback from manager for "
+ "~n ~p:~w",
+ "~n ~p",
+ [Addr, Port, SnmpReport]),
+ Parent ! {async_event, {Addr, Port}, {report, SnmpReport}},
+ loop(S);
+
+ {'EXIT', Parent, Reason} ->
+ d("received exit signal from parent: ~n~p", [Reason]),
+ info("received exit signal from parent: ~n~p", [Reason]),
+ exit(Reason);
+
+ Unknown ->
+ d("received unknown message: ~n~p", [Unknown]),
+ info("received unknown message: ~n~p", [Unknown]),
+ loop(S)
+ end.
+
+
+%% -------------
+
+do_purify_oid([A|T]) when is_atom(A) ->
+ case snmpm:name_to_oid(A) of
+ {ok, [Oid|_]} ->
+ verify_pure_oid(lists:flatten([Oid|T]));
+ {error, not_found} ->
+ {error, {not_found, A}};
+ {error, _} = Error ->
+ Error
+ end;
+do_purify_oid(L) when is_list(L) ->
+ verify_pure_oid(lists:flatten(L));
+do_purify_oid(X) ->
+ {error, {unpure_oid, X}}.
+
+verify_pure_oid([]) ->
+ [];
+verify_pure_oid([H | T]) when is_integer(H) andalso (H >= 0) ->
+ [H | verify_pure_oid(T)];
+verify_pure_oid([H | _]) ->
+ throw({error, {not_pure_oid, H}}).
+
+
+%% -------------
+
+info(F, A) ->
+ error_logger:info_msg("TEST MGR USER " ++ F ++ "~n", A).
+
+
+%% -------------
+
+call(Req) ->
+ call(Req, 5000).
+
+call(Req, To) when is_integer(To) ->
+ Ref = make_ref(),
+ ?SERVER ! {Req, self(), Ref},
+ receive
+ {Reply, Ref} ->
+ Reply
+ after To ->
+ {error, timeout}
+ end.
+
+reply(Pid, Reply, Ref) ->
+ Pid ! {Reply, Ref}.
+
+cast(Msg) ->
+ ?SERVER ! {Msg, self()},
+ ok.
+
+
+%%----------------------------------------------------------------------
+%% User callback functions:
+%%----------------------------------------------------------------------
+
+handle_error(ReqId, Reason, UserPid) ->
+ UserPid ! {handle_error, self(), ReqId, Reason},
+ ignore.
+
+
+handle_agent(Addr, Port, SnmpInfo, UserPid) ->
+ UserPid ! {handle_agent, self(), Addr, Port, SnmpInfo},
+ ignore.
+
+
+handle_pdu(TargetName, ReqId, SnmpResponse, UserPid) ->
+ UserPid ! {handle_pdu, self(), TargetName, ReqId, SnmpResponse},
+ ignore.
+
+%% For backwards compatibillity
+handle_pdu(Addr, Port, ReqId, SnmpResponse, UserPid) ->
+ UserPid ! {handle_pdu, self(), Addr, Port, ReqId, SnmpResponse},
+ ignore.
+
+
+handle_trap(TargetName, SnmpTrap, UserPid) ->
+ UserPid ! {handle_trap, self(), TargetName, SnmpTrap},
+ ok.
+
+%% For backwards compatibillity
+handle_trap(Addr, Port, SnmpTrap, UserPid) ->
+ UserPid ! {handle_trap, self(), Addr, Port, SnmpTrap},
+ ok.
+
+
+handle_inform(TargetName, SnmpInform, UserPid) ->
+ UserPid ! {handle_inform, self(), TargetName, SnmpInform},
+ receive
+ {handle_inform_no_response, TargetName} ->
+ no_reply;
+ {handle_inform_response, TargetName} ->
+ ok
+ end.
+
+%% For backwards compatibillity
+handle_inform(Addr, Port, SnmpInform, UserPid) ->
+ UserPid ! {handle_inform, self(), Addr, Port, SnmpInform},
+ receive
+ {handle_inform_no_response, {Addr, Port}} ->
+ no_reply;
+ {handle_inform_response, {Addr, Port}} ->
+ ok
+ end.
+
+
+handle_report(TargetName, SnmpReport, UserPid) ->
+ UserPid ! {handle_report, self(), TargetName, SnmpReport},
+ ok.
+
+%% For backwards compatibillity
+handle_report(Addr, Port, SnmpReport, UserPid) ->
+ UserPid ! {handle_report, self(), Addr, Port, SnmpReport},
+ ok.
+
+
+%%----------------------------------------------------------------------
+%% Debug
+%%----------------------------------------------------------------------
+
+d(F) ->
+ d(F, []).
+
+d(F, A) ->
+ d(get(debug), F, A).
+
+d(true, F, A) ->
+ io:format("~w:" ++ F ++ "~n", [?SERVER|A]);
+d(_, _, _) ->
+ ok.