%% %% %CopyrightBegin% %% %% Copyright Ericsson AB 2003-2014. 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: %% %% Test: ts:run(snmp, snmp_manager_test, [batch]). %% Test: ts:run(snmp, snmp_manager_test, event_tests, [batch]). %% Test: ts:run(snmp, snmp_manager_test, inform_swarm, [batch]). %% %%---------------------------------------------------------------------- -module(snmp_manager_test). %%---------------------------------------------------------------------- %% Include files %%---------------------------------------------------------------------- -include_lib("test_server/include/test_server.hrl"). -include("snmp_test_lib.hrl"). -include("snmp_test_data/Test2.hrl"). -include_lib("snmp/include/snmp_types.hrl"). -include_lib("snmp/include/STANDARD-MIB.hrl"). -include_lib("snmp/src/manager/snmpm_internal.hrl"). %%---------------------------------------------------------------------- %% External exports %%---------------------------------------------------------------------- -export([ all/0, groups/0, init_per_group/2, end_per_group/2, init_per_testcase/2, end_per_testcase/2, init_per_suite/1, end_per_suite/1, simple_start_and_stop1/1, simple_start_and_stop2/1, simple_start_and_monitor_crash1/1, simple_start_and_monitor_crash2/1, notify_started01/1, notify_started02/1, register_user1/1, register_agent1/1, register_agent2/1, register_agent3/1, info/1, simple_sync_get1/1, simple_sync_get2/1, simple_sync_get3/1, simple_async_get1/1, simple_async_get2/1, simple_async_get3/1, simple_sync_get_next1/1, simple_sync_get_next2/1, simple_sync_get_next3/1, simple_async_get_next1/1, simple_async_get_next2/1, simple_async_get_next3/1, simple_sync_set1/1, simple_sync_set2/1, simple_sync_set3/1, simple_async_set1/1, simple_async_set2/1, simple_async_set3/1, simple_sync_get_bulk1/1, simple_sync_get_bulk2/1, simple_sync_get_bulk3/1, simple_async_get_bulk1/1, simple_async_get_bulk2/1, simple_async_get_bulk3/1, misc_async1/1, misc_async2/1, discovery/1, trap1/1, trap2/1, inform1/1, inform2/1, inform3/1, inform4/1, inform_swarm/1, report/1, otp8015_1/1, otp8395_1/1 ]). %%---------------------------------------------------------------------- %% Internal exports %%---------------------------------------------------------------------- %% -export([async_exec/2]). %%---------------------------------------------------------------------- %% Macros and constants %%---------------------------------------------------------------------- -define(AGENT_PORT, 4000). -define(AGENT_MMS, 1024). -define(AGENT_ENGINE_ID, "agentEngine"). -define(MGR_PORT, 5000). -define(MGR_MMS, 1024). -define(MGR_ENGINE_ID, "mgrEngine"). -define(NS_TIMEOUT, 10000). -define(DEFAULT_MNESIA_DEBUG, none). %%---------------------------------------------------------------------- %% Records %%---------------------------------------------------------------------- %%====================================================================== %% External functions %%====================================================================== init_per_suite(Config0) when is_list(Config0) -> ?DBG("init_per_suite -> entry with" "~n Config0: ~p", [Config0]), Config1 = snmp_test_lib:init_suite_top_dir(?MODULE, Config0), Config2 = snmp_test_lib:fix_data_dir(Config1), %% Mib-dirs %% data_dir is trashed by the test-server / common-test %% so there is no point in fixing it... MibDir = snmp_test_lib:lookup(data_dir, Config2), StdMibDir = filename:join([code:priv_dir(snmp), "mibs"]), [{mib_dir, MibDir}, {std_mib_dir, StdMibDir} | Config2]. end_per_suite(Config) when is_list(Config) -> ?DBG("end_per_suite -> entry with" "~n Config: ~p", [Config]), Config. init_per_testcase(Case, Config) when is_list(Config) -> io:format(user, "~n~n*** INIT ~w:~w ***~n~n", [?MODULE, Case]), p(Case, "init_per_testcase begin when" "~n Nodes: ~p~n~n", [erlang:nodes()]), %% This version of the API, based on Addr and Port, has been deprecated DeprecatedApiCases = [ simple_sync_get1, simple_async_get1, simple_sync_get_next1, simple_async_get_next1, simple_sync_set1, simple_async_set1, simple_sync_get_bulk1, simple_async_get_bulk1, misc_async1 ], Result = case lists:member(Case, DeprecatedApiCases) of true -> %% ?SKIP(api_no_longer_supported); {skip, api_no_longer_supported}; false -> init_per_testcase2(Case, Config) end, p(Case, "init_per_testcase end when" "~n Nodes: ~p" "~n Result: ~p" "~n~n", [Result, erlang:nodes()]), Result. init_per_testcase2(Case, Config) -> ?DBG("init_per_testcase2 -> " "~n Case: ~p" "~n Config: ~p" "~n Nodes: ~p", [Case, Config, erlang:nodes()]), CaseTopDir = snmp_test_lib:init_testcase_top_dir(Case, Config), %% -- Manager dirs -- MgrTopDir = filename:join(CaseTopDir, "manager/"), ?DBG("init_per_testcase2 -> try create manager top dir: ~n~p", [MgrTopDir]), ?line ok = file:make_dir(MgrTopDir), MgrConfDir = filename:join(MgrTopDir, "conf/"), ?line ok = file:make_dir(MgrConfDir), MgrDbDir = filename:join(MgrTopDir, "db/"), ?line ok = file:make_dir(MgrDbDir), MgrLogDir = filename:join(MgrTopDir, "log/"), ?line ok = file:make_dir(MgrLogDir), %% -- Agent dirs -- AgTopDir = filename:join(CaseTopDir, "agent/"), ?line ok = file:make_dir(AgTopDir), AgConfDir = filename:join(AgTopDir, "conf/"), ?line ok = file:make_dir(AgConfDir), AgDbDir = filename:join(AgTopDir, "db/"), ?line ok = file:make_dir(AgDbDir), AgLogDir = filename:join(AgTopDir, "log/"), ?line ok = file:make_dir(AgLogDir), Family = proplists:get_value(ipfamily, Config, inet), Conf = [{watchdog, ?WD_START(?MINS(5))}, {ipfamily, Family}, {ip, ?LOCALHOST(Family)}, {case_top_dir, CaseTopDir}, {agent_dir, AgTopDir}, {agent_conf_dir, AgConfDir}, {agent_db_dir, AgDbDir}, {agent_log_dir, AgLogDir}, {manager_agent_target_name, "agent01"}, {manager_dir, MgrTopDir}, {manager_conf_dir, MgrConfDir}, {manager_db_dir, MgrDbDir}, {manager_log_dir, MgrLogDir} | Config], Conf2 = init_per_testcase3(Case, Conf), ?DBG("init [~w] Nodes [2]: ~p", [Case, erlang:nodes()]), Conf2. init_per_testcase3(Case, Config) -> ApiCases02 = [ simple_sync_get2, simple_async_get2, simple_sync_get_next2, simple_async_get_next2, simple_sync_set2, simple_async_set2, simple_sync_get_bulk2, simple_async_get_bulk2, misc_async2, otp8395_1 ], ApiCases03 = [ simple_sync_get3, simple_async_get3, simple_sync_get_next3, simple_async_get_next3, simple_sync_set3, simple_async_set3, simple_sync_get_bulk3, simple_async_get_bulk3 ], Cases = [ trap1, trap2, inform1, inform2, inform3, inform4, inform_swarm, report ] ++ ApiCases02 ++ ApiCases03, case lists:member(Case, Cases) of true -> NoAutoInformCases = [inform1, inform2, inform3, inform_swarm], AutoInform = not lists:member(Case, NoAutoInformCases), Conf1 = if Case =:= inform_swarm -> Verb = [{manager_config_verbosity, silence}, {manager_note_store_verbosity, silence}, {manager_server_verbosity, info}, {manager_net_if_verbosity, info}, {agent_verbosity, info}, {agent_net_if_verbosity, info}], Verb ++ Config; Case =:= otp8395_1 -> [{manager_atl_seqno, true} | Config]; true -> Config end, Conf2 = init_agent(Conf1), Conf3 = init_manager(AutoInform, Conf2), Conf4 = init_mgr_user(Conf3), case lists:member(Case, ApiCases02 ++ ApiCases03) of true -> init_mgr_user_data2(Conf4); false -> init_mgr_user_data1(Conf4) end; false -> Config end. end_per_testcase(Case, Config) when is_list(Config) -> p(Case, "end_per_testcase begin when" "~n Nodes: ~p~n~n", [erlang:nodes()]), ?DBG("fin [~w] Nodes [1]: ~p", [Case, erlang:nodes()]), Dog = ?config(watchdog, Config), ?WD_STOP(Dog), Conf1 = lists:keydelete(watchdog, 1, Config), Conf2 = end_per_testcase2(Case, Conf1), ?DBG("fin [~w] Nodes [2]: ~p", [Case, erlang:nodes()]), %% TopDir = ?config(top_dir, Conf2), %% ?DEL_DIR(TopDir), p(Case, "end_per_testcase end when" "~n Nodes: ~p~n~n", [erlang:nodes()]), Conf2. end_per_testcase2(Case, Config) -> ApiCases02 = [ simple_sync_get2, simple_async_get2, simple_sync_get_next2, simple_async_get_next2, simple_sync_set2, simple_async_set2, simple_sync_get_bulk2, simple_async_get_bulk2, misc_async2, otp8395_1 ], ApiCases03 = [ simple_sync_get3, simple_async_get3, simple_sync_get_next3, simple_async_get_next3, simple_sync_set3, simple_async_set3, simple_sync_get_bulk3, simple_async_get_bulk3 ], Cases = [ trap1, trap2, inform1, inform2, inform3, inform4, inform_swarm, report ] ++ ApiCases02 ++ ApiCases03, case lists:member(Case, Cases) of true -> Conf1 = case lists:member(Case, ApiCases02 ++ ApiCases03) of true -> fin_mgr_user_data2(Config); false -> fin_mgr_user_data1(Config) end, Conf2 = fin_mgr_user(Conf1), Conf3 = fin_manager(Conf2), fin_agent(Conf3); false -> Config end. %%====================================================================== %% Test case definitions %%====================================================================== all() -> [ {group, start_and_stop_tests}, {group, misc_tests}, {group, user_tests}, {group, agent_tests}, {group, request_tests}, {group, request_tests_mt}, {group, event_tests}, {group, event_tests_mt}, discovery, {group, tickets}, {group, ipv6}, {group, ipv6_mt} ]. groups() -> [ {start_and_stop_tests, [], [ simple_start_and_stop1, simple_start_and_stop2, simple_start_and_monitor_crash1, simple_start_and_monitor_crash2, notify_started01, notify_started02 ] }, {misc_tests, [], [ info ] }, {user_tests, [], [ register_user1 ] }, {agent_tests, [], [ register_agent1, register_agent2, register_agent3 ] }, {request_tests, [], [ {group, get_tests}, {group, get_next_tests}, {group, set_tests}, {group, bulk_tests}, {group, misc_request_tests} ] }, {request_tests_mt, [], [ {group, get_tests}, {group, get_next_tests}, {group, set_tests}, {group, bulk_tests}, {group, misc_request_tests} ] }, {get_tests, [], [ simple_sync_get1, simple_sync_get2, simple_sync_get3, simple_async_get1, simple_async_get2, simple_async_get3 ] }, {get_next_tests, [], [ simple_sync_get_next1, simple_sync_get_next2, simple_sync_get_next3, simple_async_get_next1, simple_async_get_next2, simple_async_get_next3 ] }, {set_tests, [], [ simple_sync_set1, simple_sync_set2, simple_sync_set3, simple_async_set1, simple_async_set2, simple_async_set3 ] }, {bulk_tests, [], [ simple_sync_get_bulk1, simple_sync_get_bulk2, simple_sync_get_bulk3, simple_async_get_bulk1, simple_async_get_bulk2, simple_async_get_bulk3 ] }, {misc_request_tests, [], [ misc_async1, misc_async2 ] }, {event_tests, [], [ trap1, trap2, inform1, inform2, inform3, inform4, inform_swarm, report ] }, {event_tests_mt, [], [ trap1, trap2, inform1, inform2, inform3, inform4, inform_swarm, report ] }, {tickets, [], [ {group, otp8015}, {group, otp8395} ] }, {otp8015, [], [ otp8015_1 ] }, {otp8395, [], [ otp8395_1 ] }, {ipv6, [], [ simple_sync_get3, inform1 ] }, {ipv6_mt, [], [ simple_sync_get3, inform1 ] } ]. init_per_group(request_tests_mt = GroupName, Config) -> snmp_test_lib:init_group_top_dir( GroupName, [{manager_net_if_module, snmpm_net_if_mt} | Config]); init_per_group(event_tests_mt = GroupName, Config) -> snmp_test_lib:init_group_top_dir( GroupName, [{manager_net_if_module, snmpm_net_if_mt} | Config]); init_per_group(ipv6_mt, Config) -> init_per_group(ipv6, [{manager_net_if_module, snmpm_net_if_mt} | Config]); init_per_group(ipv6 = GroupName, Config) -> case ct:require(ipv6_hosts) of ok -> ipv6_init(snmp_test_lib:init_group_top_dir(GroupName, Config)); _ -> {skip, "Host does not support IPV6"} end; init_per_group(GroupName, Config) -> snmp_test_lib:init_group_top_dir(GroupName, Config). end_per_group(_GroupName, Config) -> %% Do we really need to do this? lists:keydelete(snmp_group_top_dir, 1, Config). %%====================================================================== %% Test functions %%====================================================================== simple_start_and_stop1(suite) -> []; simple_start_and_stop1(Config) when is_list(Config) -> %% ?SKIP(not_yet_implemented), process_flag(trap_exit, true), put(tname,ssas1), p("starting with Config: ~n~p", [Config]), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), write_manager_conf(ConfDir), Opts = [{server, [{verbosity, trace}]}, {net_if, [{verbosity, trace}]}, {note_store, [{verbosity, trace}]}, {config, [{verbosity, trace}, {dir, ConfDir}, {db_dir, DbDir}]}], p("try starting manager"), ok = snmpm:start_link(Opts), ?SLEEP(1000), p("manager started, now try to stop"), ok = snmpm:stop(), ?SLEEP(1000), p("end"), ok. %%====================================================================== simple_start_and_stop2(suite) -> []; simple_start_and_stop2(Config) when is_list(Config) -> %% ?SKIP(not_yet_implemented), process_flag(trap_exit, true), put(tname,ssas2), p("starting with Config: ~p~n", [Config]), ManagerNode = start_manager_node(), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), write_manager_conf(ConfDir), Opts = [{server, [{verbosity, trace}]}, {net_if, [{verbosity, trace}]}, {note_store, [{verbosity, trace}]}, {config, [{verbosity, trace}, {dir, ConfDir}, {db_dir, DbDir}]}], p("try load snmp application"), ?line ok = load_snmp(ManagerNode), p("try set manager env for the snmp application"), ?line ok = set_mgr_env(ManagerNode, Opts), p("try starting snmp application (with only manager)"), ?line ok = start_snmp(ManagerNode), p("started"), ?SLEEP(1000), p("try stopping snmp application (with only manager)"), ?line ok = stop_snmp(ManagerNode), ?SLEEP(1000), stop_node(ManagerNode), ?SLEEP(1000), p("end"), ok. %%====================================================================== simple_start_and_monitor_crash1(suite) -> []; simple_start_and_monitor_crash1(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname,ssamc1), p("starting with Config: ~n~p", [Config]), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), write_manager_conf(ConfDir), Opts = [{server, [{verbosity, trace}]}, {net_if, [{verbosity, trace}]}, {note_store, [{verbosity, trace}]}, {config, [{verbosity, trace}, {dir, ConfDir}, {db_dir, DbDir}]}], p("try starting manager"), ok = snmpm:start(Opts), ?SLEEP(1000), p("create the monitor"), Ref = snmpm:monitor(), p("make sure it has not already crashed..."), receive {'DOWN', Ref, process, Obj1, Reason1} -> ?FAIL({unexpected_down, Obj1, Reason1}) after 1000 -> ok end, p("stop the manager"), ok = snmpm:stop(), p("await the down-message"), receive {'DOWN', Ref, process, Obj2, Reason2} -> p("received expected down-message: " "~n Obj2: ~p" "~n Reason2: ~p", [Obj2, Reason2]), ok after 1000 -> ?FAIL(timeout) end, p("end"), ok. %%====================================================================== simple_start_and_monitor_crash2(suite) -> []; simple_start_and_monitor_crash2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname,ssamc2), p("starting with Config: ~n~p", [Config]), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), write_manager_conf(ConfDir), Opts = [{restart_type, permanent}, {server, [{verbosity, trace}]}, {net_if, [{verbosity, trace}]}, {note_store, [{verbosity, trace}]}, {config, [{verbosity, trace}, {dir, ConfDir}, {db_dir, DbDir}]}], p("try starting manager"), ok = snmpm:start(Opts), ?SLEEP(1000), p("create the monitor"), Ref = snmpm:monitor(), p("make sure it has not already crashed..."), receive {'DOWN', Ref, process, Obj1, Reason1} -> ?FAIL({unexpected_down, Obj1, Reason1}) after 1000 -> ok end, p("crash the manager"), simulate_crash(), p("await the down-message"), receive {'DOWN', Ref, process, Obj2, Reason2} -> p("received expected down-message: " "~n Obj2: ~p" "~n Reason2: ~p", [Obj2, Reason2]), ok after 1000 -> ?FAIL(timeout) end, p("end"), ok. %% The server supervisor allow 5 restarts in 500 msec. server_pid() -> whereis(snmpm_server). -define(MAX_KILLS, 6). simulate_crash() -> simulate_crash(0, server_pid()). simulate_crash(?MAX_KILLS, _) -> ?SLEEP(1000), case server_pid() of P when is_pid(P) -> exit({error, {still_alive, P}}); _ -> ok end; simulate_crash(NumKills, Pid) when (NumKills < ?MAX_KILLS) and is_pid(Pid) -> p("similate_crash -> ~w, ~p", [NumKills, Pid]), Ref = erlang:monitor(process, Pid), exit(Pid, kill), receive {'DOWN', Ref, process, _Object, _Info} -> p("received expected 'DOWN' message"), simulate_crash(NumKills + 1, server_pid()) after 1000 -> case server_pid() of P when is_pid(P) -> exit({error, {no_down_from_server, P}}); _ -> ok end end; simulate_crash(NumKills, _) -> ?SLEEP(10), simulate_crash(NumKills, server_pid()). %%====================================================================== notify_started01(suite) -> []; notify_started01(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname,ns01), p("starting with Config: ~n~p", [Config]), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), write_manager_conf(ConfDir), Opts = [{server, [{verbosity, log}]}, {net_if, [{verbosity, silence}]}, {note_store, [{verbosity, silence}]}, {config, [{verbosity, log}, {dir, ConfDir}, {db_dir, DbDir}]}], p("request start notification (1)"), Pid1 = snmpm:notify_started(10000), receive {snmpm_start_timeout, Pid1} -> p("received expected start timeout"), ok; Any1 -> ?FAIL({unexpected_message, Any1}) after 15000 -> ?FAIL({unexpected_timeout, Pid1}) end, p("request start notification (2)"), Pid2 = snmpm:notify_started(10000), p("start the snmpm starter"), Pid = snmpm_starter(Opts, 5000), p("await the start notification"), Ref = receive {snmpm_started, Pid2} -> p("received started message -> create the monitor"), snmpm:monitor(); Any2 -> ?FAIL({unexpected_message, Any2}) after 15000 -> ?FAIL({unexpected_timeout, Pid2}) end, p("[~p] make sure it has not already crashed...", [Ref]), receive {'DOWN', Ref, process, Obj1, Reason1} -> ?FAIL({unexpected_down, Obj1, Reason1}) after 1000 -> ok end, p("stop the manager"), Pid ! {stop, self()}, %ok = snmpm:stop(), p("await the down-message"), receive {'DOWN', Ref, process, Obj2, Reason2} -> p("received expected down-message: " "~n Obj2: ~p" "~n Reason2: ~p", [Obj2, Reason2]), ok after 5000 -> ?FAIL(down_timeout) end, p("end"), ok. snmpm_starter(Opts, To) -> Parent = self(), spawn( fun() -> ?SLEEP(To), ok = snmpm:start(Opts), receive {stop, Parent} -> snmpm:stop() end end). %%====================================================================== notify_started02(suite) -> []; notify_started02(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname,ns02), %% %% The point of this is to catch machines running %% SLES9 (2.6.5) LinuxVersionVerify = fun() -> case os:cmd("uname -m") of "i686" ++ _ -> %% io:format("found an i686 machine, " %% "now check version~n", []), case os:version() of {2, 6, Rev} when Rev >= 16 -> true; {2, Min, _} when Min > 6 -> true; {Maj, _, _} when Maj > 2 -> true; _ -> false end; _ -> true end end, Skippable = [{unix, [{linux, LinuxVersionVerify}]}], Condition = fun() -> ?OS_BASED_SKIP(Skippable) end, ?NON_PC_TC_MAYBE_SKIP(Config, Condition), %% p("starting with Config: ~n~p", [Config]), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), write_manager_conf(ConfDir), Opts = [{server, [{verbosity, log}]}, {net_if, [{verbosity, silence}]}, {note_store, [{verbosity, silence}]}, {config, [{verbosity, log}, {dir, ConfDir}, {db_dir, DbDir}]}], p("start snmpm client process"), Pid1 = ns02_loop1_start(), p("start snmpm starter process"), Pid2 = ns02_loop2_start(Opts), p("await snmpm client process exit"), receive {'EXIT', Pid1, normal} -> ok; {'EXIT', Pid1, Reason1} -> ?FAIL(Reason1) after 25000 -> ?FAIL(timeout) end, p("await snmpm starter process exit"), receive {'EXIT', Pid2, normal} -> ok; {'EXIT', Pid2, Reason2} -> ?FAIL(Reason2) after 5000 -> ?FAIL(timeout) end, p("end"), ok. ns02_loop1_start() -> spawn_link(fun() -> ns02_loop1() end). ns02_loop1() -> put(tname,ns02_loop1), p("starting"), ns02_loop1(dummy, snmpm:notify_started(?NS_TIMEOUT), 5). ns02_loop1(_Ref, _Pid, 0) -> p("done"), exit(normal); ns02_loop1(Ref, Pid, N) -> p("entry when" "~n Ref: ~p" "~n Pid: ~p" "~n N: ~p", [Ref, Pid, N]), receive {snmpm_started, Pid} -> p("received expected started message (~w)", [N]), ns02_loop1(snmpm:monitor(), dummy, N); {snmpm_start_timeout, Pid} -> p("unexpected timout"), ?FAIL({unexpected_start_timeout, Pid}); {'DOWN', Ref, process, Obj, Reason} -> p("received expected DOWN message (~w) with" "~n Obj: ~p" "~n Reason: ~p", [N, Obj, Reason]), ns02_loop1(dummy, snmpm:notify_started(?NS_TIMEOUT), N-1) after 10000 -> ?FAIL(timeout) end. ns02_loop2_start(Opts) -> spawn_link(fun() -> ns02_loop2(Opts) end). ns02_loop2(Opts) -> put(tname,ns02_loop2), p("starting"), ns02_loop2(Opts, 5). ns02_loop2(_Opts, 0) -> p("done"), exit(normal); ns02_loop2(Opts, N) -> p("entry when N: ~p", [N]), ?SLEEP(2000), p("start manager"), snmpm:start(Opts), ?SLEEP(2000), p("stop manager"), snmpm:stop(), ns02_loop2(Opts, N-1). %%====================================================================== info(suite) -> []; info(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname,info), p("starting with Config: ~n~p", [Config]), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), write_manager_conf(ConfDir), Opts = [{server, [{verbosity, trace}]}, {net_if, [{verbosity, trace}]}, {note_store, [{verbosity, trace}]}, {config, [{verbosity, trace}, {dir, ConfDir}, {db_dir, DbDir}]}], p("try starting manager"), ok = snmpm:start(Opts), ?SLEEP(1000), p("manager started, now get info"), Info = snmpm:info(), p("got info, now verify: ~n~p", [Info]), ok = verify_info( Info ), p("info verified, now try to stop"), ok = snmpm:stop(), ?SLEEP(1000), p("end"), ok. verify_info(Info) when is_list(Info) -> Keys = [{server, [process_memory, db_memory]}, {config, [process_memory, db_memory]}, {net_if, [process_memory, port_info]}, {note_store, [process_memory, db_memory]}, stats_counters], verify_info(Keys, Info); verify_info(BadInfo) -> {error, {bad_info, BadInfo}}. verify_info([], _) -> ok; verify_info([Key|Keys], Info) when is_atom(Key) -> case lists:keymember(Key, 1, Info) of true -> verify_info(Keys, Info); false -> {error, {missing_info, {Key, Info}}} end; verify_info([{Key, SubKeys}|Keys], Info) -> case lists:keysearch(Key, 1, Info) of {value, {Key, SubInfo}} -> case verify_info(SubKeys, SubInfo) of ok -> verify_info(Keys, Info); {error, {missing_info, {SubKey, _}}} -> {error, {missing_subinfo, {Key, SubKey, Info}}} end; false -> {error, {missing_info, {Key, Info}}} end. %%====================================================================== register_user1(suite) -> []; register_user1(Config) when is_list(Config) -> %% ?SKIP(not_yet_implemented). process_flag(trap_exit, true), put(tname,ru1), p("starting with Config: ~p~n", [Config]), ManagerNode = start_manager_node(), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), write_manager_conf(ConfDir), Opts = [{server, [{verbosity, trace}]}, {net_if, [{verbosity, trace}]}, {note_store, [{verbosity, trace}]}, {config, [{verbosity, trace}, {dir, ConfDir}, {db_dir, DbDir}]}], p("load snmp application"), ?line ok = load_snmp(ManagerNode), p("set manager env for the snmp application"), ?line ok = set_mgr_env(ManagerNode, Opts), p("starting snmp application (with only manager)"), ?line ok = start_snmp(ManagerNode), p("started"), ?SLEEP(1000), p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("try register user(s)"), ?line ok = mgr_register_user(ManagerNode, calvin, snmpm_user_default, [self(), "various misc info"]), Users1 = mgr_which_users(ManagerNode), p("users: ~p~n", [Users1]), ?line ok = verify_users(Users1, [calvin]), p("manager info: ~p~n", [mgr_info(ManagerNode)]), ?line ok = mgr_register_user(ManagerNode, hobbe, snmpm_user_default, {"misc info", self()}), Users2 = mgr_which_users(ManagerNode), p("users: ~p~n", [Users2]), ?line ok = verify_users(Users2, [calvin, hobbe]), p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("try unregister user(s)"), ?line ok = mgr_unregister_user(ManagerNode, calvin), Users3 = mgr_which_users(ManagerNode), p("users: ~p~n", [Users3]), ?line ok = verify_users(Users3, [hobbe]), p("manager info: ~p~n", [mgr_info(ManagerNode)]), ?line ok = mgr_unregister_user(ManagerNode, hobbe), Users4 = mgr_which_users(ManagerNode), p("users: ~p~n", [Users4]), ?line ok = verify_users(Users4, []), p("manager info: ~p~n", [mgr_info(ManagerNode)]), ?SLEEP(1000), p("stop snmp application (with only manager)"), ?line ok = stop_snmp(ManagerNode), ?SLEEP(1000), stop_node(ManagerNode), ?SLEEP(1000), p("end"), ok. verify_users([], []) -> ok; verify_users(ActualUsers, []) -> {error, {unexpected_users, ActualUsers}}; verify_users(ActualUsers0, [User|RegUsers]) -> case lists:delete(User, ActualUsers0) of ActualUsers0 -> {error, {not_registered, User}}; ActualUsers -> verify_users(ActualUsers, RegUsers) end. %%====================================================================== register_agent1(doc) -> ["Test registration of agents with the OLD interface functions"]; register_agent1(suite) -> []; register_agent1(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname,ra1), p("starting with Config: ~p~n", [Config]), ManagerNode = start_manager_node(), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), write_manager_conf(ConfDir), Opts = [{server, [{verbosity, trace}]}, {net_if, [{verbosity, trace}]}, {note_store, [{verbosity, trace}]}, {config, [{verbosity, trace}, {dir, ConfDir}, {db_dir, DbDir}]}], p("load snmp application"), ?line ok = load_snmp(ManagerNode), p("set manager env for the snmp application"), ?line ok = set_mgr_env(ManagerNode, Opts), p("starting snmp application (with only manager)"), ?line ok = start_snmp(ManagerNode), p("started"), ?SLEEP(1000), p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("register user(s) user_alfa & user_beta"), ?line ok = mgr_register_user(ManagerNode, user_alfa, snmpm_user_default, []), ?line ok = mgr_register_user(ManagerNode, user_beta, snmpm_user_default, []), p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("register agent(s)"), ?line ok = mgr_register_agent(ManagerNode, user_alfa, 5000, []), ?line ok = mgr_register_agent(ManagerNode, user_alfa, 5001, []), ?line ok = mgr_register_agent(ManagerNode, user_beta, 5002, []), ?line ok = mgr_register_agent(ManagerNode, user_beta, 5003, []), p("verify all agent(s): expect 4"), case mgr_which_agents(ManagerNode) of Agents1 when length(Agents1) =:= 4 -> p("all agents: ~p~n", [Agents1]), ok; Agents1 -> ?FAIL({agent_registration_failure, Agents1}) end, p("verify user_alfa agent(s)"), case mgr_which_agents(ManagerNode, user_alfa) of Agents2 when length(Agents2) =:= 2 -> p("calvin agents: ~p~n", [Agents2]), ok; Agents2 -> ?FAIL({agent_registration_failure, Agents2}) end, p("verify user_beta agent(s)"), case mgr_which_agents(ManagerNode, user_beta) of Agents3 when length(Agents3) =:= 2 -> p("hobbe agents: ~p~n", [Agents3]), ok; Agents3 -> ?FAIL({agent_registration_failure, Agents3}) end, p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("unregister user user_alfa"), ?line ok = mgr_unregister_user(ManagerNode, user_alfa), p("verify all agent(s): expect 2"), case mgr_which_agents(ManagerNode) of Agents4 when length(Agents4) =:= 2 -> p("all agents: ~p~n", [Agents4]), ok; Agents4 -> ?FAIL({agent_unregistration_failure, Agents4}) end, p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("unregister user_beta agents"), ?line ok = mgr_unregister_agent(ManagerNode, user_beta, 5002), ?line ok = mgr_unregister_agent(ManagerNode, user_beta, 5003), p("verify all agent(s): expect 0"), case mgr_which_agents(ManagerNode) of [] -> ok; Agents5 -> p("all agents: ~p~n", [Agents5]), ?FAIL({agent_unregistration_failure, Agents5}) end, p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("unregister user hobbe"), ?line ok = mgr_unregister_user(ManagerNode, user_beta), p("manager info: ~p~n", [mgr_info(ManagerNode)]), ?SLEEP(1000), p("stop snmp application (with only manager)"), ?line ok = stop_snmp(ManagerNode), ?SLEEP(1000), stop_node(ManagerNode), ?SLEEP(1000), p("end"), ok. %%====================================================================== register_agent2(doc) -> ["Test registration of agents with the NEW interface functions"]; register_agent2(suite) -> []; register_agent2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, ra2), p("starting with Config: ~p~n", [Config]), ManagerNode = start_manager_node(), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), LocalHost = snmp_test_lib:localhost(), write_manager_conf(ConfDir), Opts = [{server, [{verbosity, trace}]}, {net_if, [{verbosity, trace}]}, {note_store, [{verbosity, trace}]}, {config, [{verbosity, trace}, {dir, ConfDir}, {db_dir, DbDir}]}], p("load snmp application"), ?line ok = load_snmp(ManagerNode), p("set manager env for the snmp application"), ?line ok = set_mgr_env(ManagerNode, Opts), p("starting snmp application (with only manager)"), ?line ok = start_snmp(ManagerNode), p("started"), ?SLEEP(1000), p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("register user(s) user_alfa & user_beta"), ?line ok = mgr_register_user(ManagerNode, user_alfa, snmpm_user_default, []), ?line ok = mgr_register_user(ManagerNode, user_beta, snmpm_user_default, []), p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("register agent(s)"), TargetName1 = "agent1", ?line ok = mgr_register_agent(ManagerNode, user_alfa, TargetName1, [{address, LocalHost}, {port, 5001}, {engine_id, "agentEngineId-1"}]), TargetName2 = "agent2", ?line ok = mgr_register_agent(ManagerNode, user_alfa, TargetName2, [{address, LocalHost}, {port, 5002}, {engine_id, "agentEngineId-2"}]), TargetName3 = "agent3", ?line ok = mgr_register_agent(ManagerNode, user_beta, TargetName3, [{address, LocalHost}, {port, 5003}, {engine_id, "agentEngineId-3"}]), TargetName4 = "agent4", ?line ok = mgr_register_agent(ManagerNode, user_beta, TargetName4, [{address, LocalHost}, {port, 5004}, {engine_id, "agentEngineId-4"}]), p("verify all agent(s): expect 4"), case mgr_which_agents(ManagerNode) of Agents1 when length(Agents1) =:= 4 -> p("all agents: ~p~n", [Agents1]), ok; Agents1 -> ?FAIL({agent_registration_failure, Agents1}) end, p("verify user_alfa agent(s)"), case mgr_which_agents(ManagerNode, user_alfa) of Agents2 when length(Agents2) =:= 2 -> p("calvin agents: ~p~n", [Agents2]), ok; Agents2 -> ?FAIL({agent_registration_failure, Agents2}) end, p("verify user_beta agent(s)"), case mgr_which_agents(ManagerNode, user_beta) of Agents3 when length(Agents3) =:= 2 -> p("hobbe agents: ~p~n", [Agents3]), ok; Agents3 -> ?FAIL({agent_registration_failure, Agents3}) end, p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("unregister user user_alfa"), ?line ok = mgr_unregister_user(ManagerNode, user_alfa), p("verify all agent(s): expect 2"), case mgr_which_agents(ManagerNode) of Agents4 when length(Agents4) =:= 2 -> p("all agents: ~p~n", [Agents4]), ok; Agents4 -> ?FAIL({agent_unregistration_failure, Agents4}) end, p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("unregister user_beta agents"), ?line ok = mgr_unregister_agent(ManagerNode, user_beta, TargetName3), ?line ok = mgr_unregister_agent(ManagerNode, user_beta, TargetName4), p("verify all agent(s): expect 0"), case mgr_which_agents(ManagerNode) of [] -> ok; Agents5 -> p("all agents: ~p~n", [Agents5]), ?FAIL({agent_unregistration_failure, Agents5}) end, p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("unregister user user_beta"), ?line ok = mgr_unregister_user(ManagerNode, user_beta), p("manager info: ~p~n", [mgr_info(ManagerNode)]), ?SLEEP(1000), p("stop snmp application (with only manager)"), ?line ok = stop_snmp(ManagerNode), ?SLEEP(1000), stop_node(ManagerNode), ?SLEEP(1000), p("end"), ok. %%====================================================================== register_agent3(doc) -> ["Test registration of agents with the NEW interface functions " "and specifying transport domain"]; register_agent3(suite) -> []; register_agent3(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, ra3), p("starting with Config: ~p~n", [Config]), ManagerNode = start_manager_node(), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), LocalHost = snmp_test_lib:localhost(), write_manager_conf(ConfDir), Opts = [{server, [{verbosity, trace}]}, {net_if, [{verbosity, trace}]}, {note_store, [{verbosity, trace}]}, {config, [{verbosity, trace}, {dir, ConfDir}, {db_dir, DbDir}]}], p("load snmp application"), ?line ok = load_snmp(ManagerNode), p("set manager env for the snmp application"), ?line ok = set_mgr_env(ManagerNode, Opts), p("starting snmp application (with only manager)"), ?line ok = start_snmp(ManagerNode), p("started"), ?SLEEP(1000), p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("register user(s) user_alfa & user_beta"), ?line ok = mgr_register_user(ManagerNode, user_alfa, snmpm_user_default, []), ?line ok = mgr_register_user(ManagerNode, user_beta, snmpm_user_default, []), p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("register agent(s)"), TargetName1 = "agent2", ?line ok = mgr_register_agent(ManagerNode, user_alfa, TargetName1, [{tdomain, transportDomainUdpIpv4}, {address, LocalHost}, {port, 5001}, {engine_id, "agentEngineId-1"}]), TargetName2 = "agent3", ?line ok = mgr_register_agent(ManagerNode, user_alfa, TargetName2, [{tdomain, transportDomainUdpIpv6}, {address, {0,0,0,0,0,0,0,1}}, {port, 5002}, {engine_id, "agentEngineId-2"}]), TargetName3 = "agent4", ?line {error, {unsupported_domain, _} = Reason4} = mgr_register_agent(ManagerNode, user_beta, TargetName3, [{tdomain, transportDomainTcpIpv4}, {address, LocalHost}, {port, 5003}, {engine_id, "agentEngineId-3"}]), p("Expected registration failure: ~p", [Reason4]), TargetName4 = "agent5", ?line {error, {unknown_domain, _} = Reason5} = mgr_register_agent(ManagerNode, user_beta, TargetName4, [{tdomain, transportDomainUdpIpv4_bad}, {address, LocalHost}, {port, 5004}, {engine_id, "agentEngineId-4"}]), p("Expected registration failure: ~p", [Reason5]), p("verify all agent(s): expect 2"), case mgr_which_agents(ManagerNode) of Agents1 when length(Agents1) =:= 2 -> p("all agents: ~p~n", [Agents1]), ok; Agents1 -> ?FAIL({agent_registration_failure, Agents1}) end, p("verify user_alfa agent(s)"), case mgr_which_agents(ManagerNode, user_alfa) of Agents2 when length(Agents2) =:= 2 -> p("calvin agents: ~p~n", [Agents2]), ok; Agents2 -> ?FAIL({agent_registration_failure, Agents2}) end, p("verify user_beta agent(s)"), case mgr_which_agents(ManagerNode, user_beta) of Agents3 when length(Agents3) =:= 0 -> p("hobbe agents: ~p~n", [Agents3]), ok; Agents3 -> ?FAIL({agent_registration_failure, Agents3}) end, p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("unregister user user_alfa"), ?line ok = mgr_unregister_user(ManagerNode, user_alfa), p("verify all agent(s): expect 0"), case mgr_which_agents(ManagerNode) of Agents4 when length(Agents4) =:= 0 -> p("all agents: ~p~n", [Agents4]), ok; Agents4 -> ?FAIL({agent_unregistration_failure, Agents4}) end, p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("verify all agent(s): expect 0"), case mgr_which_agents(ManagerNode) of [] -> ok; Agents5 -> p("all agents: ~p~n", [Agents5]), ?FAIL({agent_unregistration_failure, Agents5}) end, p("manager info: ~p~n", [mgr_info(ManagerNode)]), p("unregister user user_beta"), ?line ok = mgr_unregister_user(ManagerNode, user_beta), p("manager info: ~p~n", [mgr_info(ManagerNode)]), ?SLEEP(1000), p("stop snmp application (with only manager)"), ?line ok = stop_snmp(ManagerNode), ?SLEEP(1000), stop_node(ManagerNode), ?SLEEP(1000), p("end"), ok. %%====================================================================== simple_sync_get1(doc) -> ["Simple sync get-request - Old style (Addr & Port)"]; simple_sync_get1(suite) -> []; simple_sync_get1(Config) when is_list(Config) -> ?SKIP(api_no_longer_supported), process_flag(trap_exit, true), put(tname, ssg1), p("starting with Config: ~p~n", [Config]), Node = ?config(manager_node, Config), Addr = ?config(manager_agent_target_name, Config), Port = ?AGENT_PORT, p("issue get-request without loading the mib"), Oids1 = [?sysObjectID_instance, ?sysDescr_instance, ?sysUpTime_instance], ?line ok = do_simple_sync_get(Node, Addr, Port, Oids1), p("issue get-request after first loading the mibs"), ?line ok = mgr_user_load_mib(Node, std_mib()), Oids2 = [[sysObjectID, 0], [sysDescr, 0], [sysUpTime, 0]], ?line ok = do_simple_sync_get(Node, Addr, Port, Oids2), p("Display log"), display_log(Config), p("done"), ok. do_simple_sync_get(Node, Addr, Port, Oids) -> ?line {ok, Reply, _Rem} = mgr_user_sync_get(Node, Addr, Port, Oids), ?DBG("~n Reply: ~p" "~n Rem: ~w", [Reply, _Rem]), %% verify that the operation actually worked: %% The order should be the same, so no need to seach ?line ok = case Reply of {noError, 0, [#varbind{oid = ?sysObjectID_instance, value = SysObjectID}, #varbind{oid = ?sysDescr_instance, value = SysDescr}, #varbind{oid = ?sysUpTime_instance, value = SysUpTime}]} -> p("expected result from get: " "~n SysObjectID: ~p" "~n SysDescr: ~s" "~n SysUpTime: ~w", [SysObjectID, SysDescr, SysUpTime]), ok; {noError, 0, Vbs} -> p("unexpected varbinds: ~n~p", [Vbs]), {error, {unexpected_vbs, Vbs}}; Else -> p("unexpected reply: ~n~p", [Else]), {error, {unexpected_response, Else}} end, ok. %%====================================================================== simple_sync_get2(doc) -> ["Simple sync get-request - Version 2 API (TargetName)"]; simple_sync_get2(suite) -> []; simple_sync_get2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, ssg2), do_simple_sync_get2(Config), display_log(Config), ok. do_simple_sync_get2(Config) -> Get = fun(Node, TargetName, Oids) -> mgr_user_sync_get(Node, TargetName, Oids) end, PostVerify = fun() -> ok end, do_simple_sync_get2(Config, Get, PostVerify). do_simple_sync_get2(Config, Get, PostVerify) -> p("starting with Config: ~p~n", [Config]), Node = ?config(manager_node, Config), TargetName = ?config(manager_agent_target_name, Config), p("issue get-request without loading the mib"), Oids1 = [?sysObjectID_instance, ?sysDescr_instance, ?sysUpTime_instance], ?line ok = do_simple_sync_get2(Node, TargetName, Oids1, Get, PostVerify), p("issue get-request after first loading the mibs"), ?line ok = mgr_user_load_mib(Node, std_mib()), Oids2 = [[sysObjectID, 0], [sysDescr, 0], [sysUpTime, 0]], ?line ok = do_simple_sync_get2(Node, TargetName, Oids2, Get, PostVerify), ok. do_simple_sync_get2(Node, TargetName, Oids, Get, PostVerify) when is_function(Get, 3) andalso is_function(PostVerify, 0) -> ?line {ok, Reply, _Rem} = Get(Node, TargetName, Oids), ?DBG("~n Reply: ~p" "~n Rem: ~w", [Reply, _Rem]), %% verify that the operation actually worked: %% The order should be the same, so no need to seach ?line ok = case Reply of {noError, 0, [#varbind{oid = ?sysObjectID_instance, value = SysObjectID}, #varbind{oid = ?sysDescr_instance, value = SysDescr}, #varbind{oid = ?sysUpTime_instance, value = SysUpTime}]} -> p("expected result from get: " "~n SysObjectID: ~p" "~n SysDescr: ~s" "~n SysUpTime: ~w", [SysObjectID, SysDescr, SysUpTime]), PostVerify(); {noError, 0, Vbs} -> p("unexpected varbinds: ~n~p", [Vbs]), {error, {unexpected_vbs, Vbs}}; Else -> p("unexpected reply: ~n~p", [Else]), {error, {unexpected_response, Else}} end, ok. %%====================================================================== simple_sync_get3(doc) -> ["Simple sync get-request - Version 3 API (TargetName and send-opts)"]; simple_sync_get3(suite) -> []; simple_sync_get3(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, ssg3), do_simple_sync_get3(Config), display_log(Config), ok. do_simple_sync_get3(Config) -> Self = self(), Msg = simple_sync_get3, Fun = fun() -> Self ! Msg end, Extra = {?SNMPM_EXTRA_INFO_TAG, Fun}, SendOpts = [ {extra, Extra} ], Get = fun(Node, TargetName, Oids) -> mgr_user_sync_get2(Node, TargetName, Oids, SendOpts) end, PostVerify = fun() -> receive Msg -> ok end end, do_simple_sync_get2(Config, Get, PostVerify). %%====================================================================== simple_async_get1(doc) -> ["Simple (async) get-request - Old style (Addr & Port)"]; simple_async_get1(suite) -> []; simple_async_get1(Config) when is_list(Config) -> ?SKIP(api_no_longer_supported), process_flag(trap_exit, true), put(tname, sag1), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), Addr = ?config(ip, Config), Port = ?AGENT_PORT, ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), Exec = fun(Data) -> async_g_exec1(MgrNode, Addr, Port, Data) end, Requests = [ { 1, [?sysObjectID_instance], Exec, fun(X) -> sag_verify(X, [?sysObjectID_instance]) end }, { 2, [?sysDescr_instance, ?sysUpTime_instance], Exec, fun(X) -> sag_verify(X, [?sysObjectID_instance, ?sysUpTime_instance]) end }, { 3, [[sysObjectID, 0], [sysDescr, 0], [sysUpTime, 0]], Exec, fun(X) -> sag_verify(X, [?sysObjectID_instance, ?sysDescr_instance, ?sysUpTime_instance]) end }, { 4, [?sysObjectID_instance, ?sysDescr_instance, ?sysUpTime_instance], Exec, fun(X) -> sag_verify(X, [?sysObjectID_instance, ?sysDescr_instance, ?sysUpTime_instance]) end } ], p("manager info when starting test: ~n~p", [mgr_info(MgrNode)]), p("agent info when starting test: ~n~p", [agent_info(AgentNode)]), ?line ok = async_exec(Requests, []), p("manager info when ending test: ~n~p", [mgr_info(MgrNode)]), p("agent info when ending test: ~n~p", [agent_info(AgentNode)]), display_log(Config), ok. async_g_exec1(Node, Addr, Port, Oids) -> mgr_user_async_get(Node, Addr, Port, Oids). sag_verify({noError, 0, _Vbs}, any) -> p("verified [any]"), ok; sag_verify({noError, 0, Vbs}, Exp) -> ?DBG("verified first stage ok: " "~n Vbs: ~p" "~n Exp: ~p", [Vbs, Exp]), sag_verify_vbs(Vbs, Exp); sag_verify(Error, _) -> {error, {unexpected_response, Error}}. sag_verify_vbs([], []) -> ?DBG("verified second stage ok", []), ok; sag_verify_vbs(Vbs, []) -> {error, {unexpected_vbs, Vbs}}; sag_verify_vbs([], Exp) -> {error, {expected_vbs, Exp}}; sag_verify_vbs([#varbind{oid = Oid}|Vbs], [any|Exp]) -> p("verified [any] oid ~w", [Oid]), sag_verify_vbs(Vbs, Exp); sag_verify_vbs([#varbind{oid = Oid, value = Value}|Vbs], [Oid|Exp]) -> p("verified oid ~w [~p]", [Oid, Value]), sag_verify_vbs(Vbs, Exp); sag_verify_vbs([#varbind{oid = Oid, value = Value}|Vbs], [{Oid,Value}|Exp]) -> p("verified oid ~w and ~p", [Oid, Value]), sag_verify_vbs(Vbs, Exp); sag_verify_vbs([Vb|_], [E|_]) -> {error, {unexpected_vb, Vb, E}}. %%====================================================================== simple_async_get2(doc) -> ["Simple (async) get-request - Version 2 API (TargetName)"]; simple_async_get2(suite) -> []; simple_async_get2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, sag2), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), Get = fun(Oids) -> async_g_exec2(MgrNode, TargetName, Oids) end, PostVerify = fun(Res) -> Res end, do_simple_async_sync_get2(Config, MgrNode, AgentNode, Get, PostVerify), display_log(Config), ok. do_simple_async_sync_get2(Config, MgrNode, AgentNode, Get, PostVerify) -> ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), do_simple_async_sync_get2(fun() -> mgr_info(MgrNode) end, fun() -> agent_info(AgentNode) end, Get, PostVerify). do_simple_async_sync_get2(MgrInfo, AgentInfo, Get, PostVerify) when is_function(MgrInfo, 0) andalso is_function(AgentInfo, 0) andalso is_function(Get, 1) andalso is_function(PostVerify, 1) -> Requests = [ { 1, [?sysObjectID_instance], Get, fun(X) -> PostVerify(sag_verify(X, [?sysObjectID_instance])) end}, { 2, [?sysDescr_instance, ?sysUpTime_instance], Get, fun(X) -> PostVerify(sag_verify(X, [?sysObjectID_instance, ?sysUpTime_instance])) end}, { 3, [[sysObjectID, 0], [sysDescr, 0], [sysUpTime, 0]], Get, fun(X) -> PostVerify(sag_verify(X, [?sysObjectID_instance, ?sysDescr_instance, ?sysUpTime_instance])) end}, { 4, [?sysObjectID_instance, ?sysDescr_instance, ?sysUpTime_instance], Get, fun(X) -> PostVerify(sag_verify(X, [?sysObjectID_instance, ?sysDescr_instance, ?sysUpTime_instance])) end} ], p("manager info when starting test: ~n~p", [MgrInfo()]), p("agent info when starting test: ~n~p", [AgentInfo()]), ?line ok = async_exec(Requests, []), p("manager info when ending test: ~n~p", [MgrInfo()]), p("agent info when ending test: ~n~p", [AgentInfo()]), ok. async_g_exec2(Node, TargetName, Oids) -> mgr_user_async_get(Node, TargetName, Oids). %%====================================================================== simple_async_get3(doc) -> ["Simple (async) get-request - Version 3 API (TargetName and send-opts)"]; simple_async_get3(suite) -> []; simple_async_get3(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, sag3), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), Self = self(), Msg = simple_async_get3, Fun = fun() -> Self ! Msg end, Extra = {?SNMPM_EXTRA_INFO_TAG, Fun}, SendOpts = [ {extra, Extra} ], Get = fun(Oids) -> async_g_exec3(MgrNode, TargetName, Oids, SendOpts) end, PostVerify = fun(ok) -> receive Msg -> ok end; (Error) -> Error end, do_simple_async_sync_get2(Config, MgrNode, AgentNode, Get, PostVerify), display_log(Config), ok. async_g_exec3(Node, TargetName, Oids, SendOpts) -> mgr_user_async_get2(Node, TargetName, Oids, SendOpts). %%====================================================================== simple_sync_get_next1(doc) -> ["Simple (sync) get_next-request - " "Old style (Addr & Port)"]; simple_sync_get_next1(suite) -> []; simple_sync_get_next1(Config) when is_list(Config) -> ?SKIP(api_no_longer_supported), process_flag(trap_exit, true), put(tname, ssgn1), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), Addr = ?config(ip, Config), Port = ?AGENT_PORT, %% -- 1 -- Oids01 = [[1,3,7,1]], VF01 = fun(X) -> verify_ssgn_reply1(X, [{[1,3,7,1],endOfMibView}]) end, ?line ok = do_simple_get_next(1, MgrNode, Addr, Port, Oids01, VF01), ?line ok = mgr_user_load_mib(MgrNode, std_mib()), %% -- 2 -- Oids02 = [[sysDescr], [1,3,7,1]], VF02 = fun(X) -> verify_ssgn_reply1(X, [?sysDescr_instance, endOfMibView]) end, ?line ok = do_simple_get_next(2, MgrNode, Addr, Port, Oids02, VF02), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), %% -- 3 -- ?line {ok, [TCnt2|_]} = mgr_user_name_to_oid(MgrNode, tCnt2), Oids03 = [[TCnt2, 1]], VF03 = fun(X) -> verify_ssgn_reply1(X, [{fl([TCnt2,2]), 100}]) end, ?line ok = do_simple_get_next(3, MgrNode, Addr, Port, Oids03, VF03), %% -- 4 -- Oids04 = [[TCnt2, 2]], VF04 = fun(X) -> verify_ssgn_reply1(X, [{fl([TCnt2,2]), endOfMibView}]) end, ?line ok = do_simple_get_next(4, MgrNode, Addr, Port, Oids04, VF04), %% -- 5 -- ?line {ok, [TGenErr1|_]} = mgr_user_name_to_oid(MgrNode, tGenErr1), Oids05 = [TGenErr1], VF05 = fun(X) -> verify_ssgn_reply2(X, {genErr, 1, [TGenErr1]}) end, ?line ok = do_simple_get_next(5, MgrNode, Addr, Port, Oids05, VF05), %% -- 6 -- ?line {ok, [TGenErr2|_]} = mgr_user_name_to_oid(MgrNode, tGenErr2), Oids06 = [TGenErr2], VF06 = fun(X) -> verify_ssgn_reply2(X, {genErr, 1, [TGenErr2]}) end, ?line ok = do_simple_get_next(6, MgrNode, Addr, Port, Oids06, VF06), %% -- 7 -- ?line {ok, [TGenErr3|_]} = mgr_user_name_to_oid(MgrNode, tGenErr3), Oids07 = [[sysDescr], TGenErr3], VF07 = fun(X) -> verify_ssgn_reply2(X, {genErr, 2, [?sysDescr, TGenErr3]}) end, ?line ok = do_simple_get_next(7, MgrNode, Addr, Port, Oids07, VF07), %% -- 8 -- ?line {ok, [TTooBig|_]} = mgr_user_name_to_oid(MgrNode, tTooBig), Oids08 = [TTooBig], VF08 = fun(X) -> verify_ssgn_reply2(X, {tooBig, 0, []}) end, ?line ok = do_simple_get_next(8, MgrNode, Addr, Port, Oids08, VF08), display_log(Config), ok. do_simple_get_next(N, Node, Addr, Port, Oids, Verify) -> p("issue get-next command ~w", [N]), case mgr_user_sync_get_next(Node, Addr, Port, Oids) of {ok, Reply, _Rem} -> ?DBG("get-next ok:" "~n Reply: ~p" "~n Rem: ~w", [Reply, _Rem]), Verify(Reply); Error -> {error, {unexpected_reply, Error}} end. verify_ssgn_reply1({noError, 0, _Vbs}, any) -> ok; verify_ssgn_reply1({noError, 0, Vbs}, Expected) -> check_ssgn_vbs(Vbs, Expected); verify_ssgn_reply1(R, _) -> {error, {unexpected_reply, R}}. verify_ssgn_reply2({ErrStatus, ErrIdx, _Vbs}, {ErrStatus, ErrIdx, any}) -> ok; verify_ssgn_reply2({ErrStatus, ErrIdx, Vbs}, {ErrStatus, ErrIdx, Expected}) -> check_ssgn_vbs(Vbs, Expected); verify_ssgn_reply2(R, _) -> {error, {unexpected_reply, R}}. check_ssgn_vbs([], []) -> ok; check_ssgn_vbs(Unexpected, []) -> {error, {unexpected_vbs, Unexpected}}; check_ssgn_vbs([], Expected) -> {error, {expected_vbs, Expected}}; check_ssgn_vbs([#varbind{value = endOfMibView}|R], [endOfMibView|Expected]) -> check_ssgn_vbs(R, Expected); check_ssgn_vbs([#varbind{oid = Oid}|R], [Oid|Expected]) -> check_ssgn_vbs(R, Expected); check_ssgn_vbs([#varbind{oid = Oid, value = Value}|R], [{Oid, Value}|Expected]) -> check_ssgn_vbs(R, Expected); check_ssgn_vbs([Vb|_], [E|_]) -> {error, {unexpected_vb, Vb, E}}. %%====================================================================== simple_sync_get_next2(doc) -> ["Simple (sync) get_next-request - Version 2 API (TargetName)"]; simple_sync_get_next2(suite) -> []; simple_sync_get_next2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, ssgn2), p("starting with Config: ~p~n", [Config]), GetNext = fun(Node, TargetName, Oids) -> mgr_user_sync_get_next(Node, TargetName, Oids) end, PostVerify = fun(Res) -> Res end, do_simple_sync_get_next2(Config, GetNext, PostVerify), display_log(Config), ok. do_simple_sync_get_next2(Config, GetNext, PostVerify) when is_function(GetNext, 3) andalso is_function(PostVerify, 1) -> MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), %% -- 1 -- Oids01 = [[1,3,7,1]], VF01 = fun(X) -> verify_ssgn_reply1(X, [{[1,3,7,1],endOfMibView}]) end, ?line ok = do_simple_get_next(1, MgrNode, TargetName, Oids01, VF01, GetNext, PostVerify), ?line ok = mgr_user_load_mib(MgrNode, std_mib()), %% -- 2 -- Oids02 = [[sysDescr], [1,3,7,1]], VF02 = fun(X) -> verify_ssgn_reply1(X, [?sysDescr_instance, endOfMibView]) end, ?line ok = do_simple_get_next(2, MgrNode, TargetName, Oids02, VF02, GetNext, PostVerify), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), %% -- 3 -- ?line {ok, [TCnt2|_]} = mgr_user_name_to_oid(MgrNode, tCnt2), Oids03 = [[TCnt2, 1]], VF03 = fun(X) -> verify_ssgn_reply1(X, [{fl([TCnt2,2]), 100}]) end, ?line ok = do_simple_get_next(3, MgrNode, TargetName, Oids03, VF03, GetNext, PostVerify), %% -- 4 -- Oids04 = [[TCnt2, 2]], VF04 = fun(X) -> verify_ssgn_reply1(X, [{fl([TCnt2,2]), endOfMibView}]) end, ?line ok = do_simple_get_next(4, MgrNode, TargetName, Oids04, VF04, GetNext, PostVerify), %% -- 5 -- ?line {ok, [TGenErr1|_]} = mgr_user_name_to_oid(MgrNode, tGenErr1), Oids05 = [TGenErr1], VF05 = fun(X) -> verify_ssgn_reply2(X, {genErr, 1, [TGenErr1]}) end, ?line ok = do_simple_get_next(5, MgrNode, TargetName, Oids05, VF05, GetNext, PostVerify), %% -- 6 -- ?line {ok, [TGenErr2|_]} = mgr_user_name_to_oid(MgrNode, tGenErr2), Oids06 = [TGenErr2], VF06 = fun(X) -> verify_ssgn_reply2(X, {genErr, 1, [TGenErr2]}) end, ?line ok = do_simple_get_next(6, MgrNode, TargetName, Oids06, VF06, GetNext, PostVerify), %% -- 7 -- ?line {ok, [TGenErr3|_]} = mgr_user_name_to_oid(MgrNode, tGenErr3), Oids07 = [[sysDescr], TGenErr3], VF07 = fun(X) -> verify_ssgn_reply2(X, {genErr, 2, [?sysDescr, TGenErr3]}) end, ?line ok = do_simple_get_next(7, MgrNode, TargetName, Oids07, VF07, GetNext, PostVerify), %% -- 8 -- ?line {ok, [TTooBig|_]} = mgr_user_name_to_oid(MgrNode, tTooBig), Oids08 = [TTooBig], VF08 = fun(X) -> verify_ssgn_reply2(X, {tooBig, 0, []}) end, ?line ok = do_simple_get_next(8, MgrNode, TargetName, Oids08, VF08, GetNext, PostVerify), ok. do_simple_get_next(N, Node, TargetName, Oids, Verify, GetNext, PostVerify) -> p("issue get-next command ~w", [N]), case GetNext(Node, TargetName, Oids) of {ok, Reply, _Rem} -> ?DBG("get-next ok:" "~n Reply: ~p" "~n Rem: ~w", [Reply, _Rem]), PostVerify(Verify(Reply)); Error -> {error, {unexpected_reply, Error}} end. %%====================================================================== simple_sync_get_next3(doc) -> ["Simple (sync) get_next-request - " "Version 3 API (TargetName with send-opts)"]; simple_sync_get_next3(suite) -> []; simple_sync_get_next3(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, ssgn3), p("starting with Config: ~p~n", [Config]), Self = self(), Msg = simple_sync_get_next3, Fun = fun() -> Self ! Msg end, Extra = {?SNMPM_EXTRA_INFO_TAG, Fun}, SendOpts = [ {extra, Extra} ], GetNext = fun(Node, TargetName, Oids) -> mgr_user_sync_get_next2(Node, TargetName, Oids, SendOpts) end, PostVerify = fun(ok) -> receive Msg -> ok end; (Error) -> Error end, do_simple_sync_get_next2(Config, GetNext, PostVerify), display_log(Config), ok. %%====================================================================== simple_async_get_next1(doc) -> ["Simple (async) get_next-request - " "Old style (Addr & Port)"]; simple_async_get_next1(suite) -> []; simple_async_get_next1(Config) when is_list(Config) -> ?SKIP(api_no_longer_supported), process_flag(trap_exit, true), put(tname, ssgn1), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), Addr = ?config(ip, Config), Port = ?AGENT_PORT, ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), Exec = fun(X) -> async_gn_exec1(MgrNode, Addr, Port, X) end, ?line {ok, [TCnt2|_]} = mgr_user_name_to_oid(MgrNode, tCnt2), ?line {ok, [TGenErr1|_]} = mgr_user_name_to_oid(MgrNode, tGenErr1), ?line {ok, [TGenErr2|_]} = mgr_user_name_to_oid(MgrNode, tGenErr2), ?line {ok, [TGenErr3|_]} = mgr_user_name_to_oid(MgrNode, tGenErr3), ?line {ok, [TTooBig|_]} = mgr_user_name_to_oid(MgrNode, tTooBig), Requests = [ {1, [[1,3,7,1]], Exec, fun(X) -> verify_ssgn_reply1(X, [{[1,3,7,1], endOfMibView}]) end}, {2, [[sysDescr], [1,3,7,1]], Exec, fun(X) -> verify_ssgn_reply1(X, [?sysDescr_instance, endOfMibView]) end}, {3, [[TCnt2, 1]], Exec, fun(X) -> verify_ssgn_reply1(X, [{fl([TCnt2,2]), 100}]) end}, {4, [[TCnt2, 2]], Exec, fun(X) -> verify_ssgn_reply1(X, [{fl([TCnt2,2]), endOfMibView}]) end}, {5, [TGenErr1], Exec, fun(X) -> verify_ssgn_reply2(X, {genErr, 1, [TGenErr1]}) end}, {6, [TGenErr2], Exec, fun(X) -> verify_ssgn_reply2(X, {genErr, 1, [TGenErr2]}) end}, {7, [[sysDescr], TGenErr3], Exec, fun(X) -> verify_ssgn_reply2(X, {genErr, 2, [TGenErr3]}) end}, {8, [TTooBig], Exec, fun(X) -> verify_ssgn_reply2(X, {tooBig, 0, []}) end} ], p("manager info when starting test: ~n~p", [mgr_info(MgrNode)]), p("agent info when starting test: ~n~p", [agent_info(AgentNode)]), ?line ok = async_exec(Requests, []), p("manager info when ending test: ~n~p", [mgr_info(MgrNode)]), p("agent info when ending test: ~n~p", [agent_info(AgentNode)]), display_log(Config), ok. async_gn_exec1(Node, Addr, Port, Oids) -> mgr_user_async_get_next(Node, Addr, Port, Oids). %%====================================================================== simple_async_get_next2(doc) -> ["Simple (async) get_next-request - Version 2 API (TargetName)"]; simple_async_get_next2(suite) -> []; simple_async_get_next2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, ssgn2), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), GetNext = fun(Oids) -> async_gn_exec2(MgrNode, TargetName, Oids) end, PostVerify = fun(Res) -> Res end, do_simple_async_get_next2(MgrNode, AgentNode, GetNext, PostVerify), display_log(Config), ok. do_simple_async_get_next2(MgrNode, AgentNode, GetNext, PostVerify) when is_function(GetNext, 1) andalso is_function(PostVerify, 1) -> ?line {ok, [TCnt2|_]} = mgr_user_name_to_oid(MgrNode, tCnt2), ?line {ok, [TGenErr1|_]} = mgr_user_name_to_oid(MgrNode, tGenErr1), ?line {ok, [TGenErr2|_]} = mgr_user_name_to_oid(MgrNode, tGenErr2), ?line {ok, [TGenErr3|_]} = mgr_user_name_to_oid(MgrNode, tGenErr3), ?line {ok, [TTooBig|_]} = mgr_user_name_to_oid(MgrNode, tTooBig), Requests = [ {1, [[1,3,7,1]], GetNext, fun(X) -> PostVerify( verify_ssgn_reply1(X, [{[1,3,7,1], endOfMibView}])) end}, {2, [[sysDescr], [1,3,7,1]], GetNext, fun(X) -> PostVerify( verify_ssgn_reply1(X, [?sysDescr_instance, endOfMibView])) end}, {3, [[TCnt2, 1]], GetNext, fun(X) -> PostVerify( verify_ssgn_reply1(X, [{fl([TCnt2,2]), 100}])) end}, {4, [[TCnt2, 2]], GetNext, fun(X) -> PostVerify( verify_ssgn_reply1(X, [{fl([TCnt2,2]), endOfMibView}])) end}, {5, [TGenErr1], GetNext, fun(X) -> PostVerify( verify_ssgn_reply2(X, {genErr, 1, [TGenErr1]})) end}, {6, [TGenErr2], GetNext, fun(X) -> PostVerify( verify_ssgn_reply2(X, {genErr, 1, [TGenErr2]})) end}, {7, [[sysDescr], TGenErr3], GetNext, fun(X) -> PostVerify( verify_ssgn_reply2(X, {genErr, 2, [TGenErr3]})) end}, {8, [TTooBig], GetNext, fun(X) -> PostVerify( verify_ssgn_reply2(X, {tooBig, 0, []})) end} ], p("manager info when starting test: ~n~p", [mgr_info(MgrNode)]), p("agent info when starting test: ~n~p", [agent_info(AgentNode)]), ?line ok = async_exec(Requests, []), p("manager info when ending test: ~n~p", [mgr_info(MgrNode)]), p("agent info when ending test: ~n~p", [agent_info(AgentNode)]), ok. async_gn_exec2(Node, TargetName, Oids) -> mgr_user_async_get_next(Node, TargetName, Oids). %%====================================================================== simple_async_get_next3(doc) -> ["Simple (async) get_next-request - " "Version 3 API (TargetName with send-opts)"]; simple_async_get_next3(suite) -> []; simple_async_get_next3(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, ssgn2), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), Self = self(), Msg = simple_async_get_next3, Fun = fun() -> Self ! Msg end, Extra = {?SNMPM_EXTRA_INFO_TAG, Fun}, SendOpts = [ {extra, Extra} ], GetNext = fun(Oids) -> async_gn_exec3(MgrNode, TargetName, Oids, SendOpts) end, PostVerify = fun(ok) -> receive Msg -> ok end; (Error) -> Error end, do_simple_async_get_next2(MgrNode, AgentNode, GetNext, PostVerify), display_log(Config), ok. async_gn_exec3(Node, TargetName, Oids, SendOpts) -> mgr_user_async_get_next2(Node, TargetName, Oids, SendOpts). %%====================================================================== simple_sync_set1(doc) -> ["Simple (sync) set-request - " "Old style (Addr & Port)"]; simple_sync_set1(suite) -> []; simple_sync_set1(Config) when is_list(Config) -> ?SKIP(api_no_longer_supported), process_flag(trap_exit, true), put(tname, sss1), p("starting with Config: ~p~n", [Config]), Node = ?config(manager_node, Config), Addr = ?config(ip, Config), Port = ?AGENT_PORT, p("issue set-request without loading the mib"), Val11 = "Arne Anka", Val12 = "Stockholm", VAVs1 = [ {?sysName_instance, s, Val11}, {?sysLocation_instance, s, Val12} ], ?line ok = do_simple_set1(Node, Addr, Port, VAVs1), p("issue set-request after first loading the mibs"), ?line ok = mgr_user_load_mib(Node, std_mib()), Val21 = "Sune Anka", Val22 = "Gothenburg", VAVs2 = [ {[sysName, 0], Val21}, {[sysLocation, 0], Val22} ], ?line ok = do_simple_set1(Node, Addr, Port, VAVs2), display_log(Config), ok. do_simple_set1(Node, Addr, Port, VAVs) -> [SysName, SysLoc] = value_of_vavs(VAVs), ?line {ok, Reply, _Rem} = mgr_user_sync_set(Node, Addr, Port, VAVs), ?DBG("~n Reply: ~p" "~n Rem: ~w", [Reply, _Rem]), %% verify that the operation actually worked: %% The order should be the same, so no need to seach %% The value we get should be exactly the same as we sent ?line ok = case Reply of {noError, 0, [#varbind{oid = ?sysName_instance, value = SysName}, #varbind{oid = ?sysLocation_instance, value = SysLoc}]} -> ok; {noError, 0, Vbs} -> {error, {unexpected_vbs, Vbs}}; Else -> p("unexpected reply: ~n~p", [Else]), {error, {unexpected_response, Else}} end, ok. value_of_vavs(VAVs) -> value_of_vavs(VAVs, []). value_of_vavs([], Acc) -> lists:reverse(Acc); value_of_vavs([{_Oid, _Type, Val}|VAVs], Acc) -> value_of_vavs(VAVs, [Val|Acc]); value_of_vavs([{_Oid, Val}|VAVs], Acc) -> value_of_vavs(VAVs, [Val|Acc]). %%====================================================================== simple_sync_set2(doc) -> ["Simple (sync) set-request - Version 2 API (TargetName)"]; simple_sync_set2(suite) -> []; simple_sync_set2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, sss2), p("starting with Config: ~p~n", [Config]), Set = fun(Node, TargetName, VAVs) -> mgr_user_sync_set(Node, TargetName, VAVs) end, PostVerify = fun() -> ok end, do_simple_sync_set2(Config, Set, PostVerify), display_log(Config), ok. do_simple_sync_set2(Config, Set, PostVerify) when is_function(Set, 3) andalso is_function(PostVerify, 0) -> Node = ?config(manager_node, Config), TargetName = ?config(manager_agent_target_name, Config), p("issue set-request without loading the mib"), Val11 = "Arne Anka", Val12 = "Stockholm", VAVs1 = [ {?sysName_instance, s, Val11}, {?sysLocation_instance, s, Val12} ], ?line ok = do_simple_set2(Node, TargetName, VAVs1, Set, PostVerify), p("issue set-request after first loading the mibs"), ?line ok = mgr_user_load_mib(Node, std_mib()), Val21 = "Sune Anka", Val22 = "Gothenburg", VAVs2 = [ {[sysName, 0], Val21}, {[sysLocation, 0], Val22} ], ?line ok = do_simple_set2(Node, TargetName, VAVs2, Set, PostVerify), ok. do_simple_set2(Node, TargetName, VAVs, Set, PostVerify) -> [SysName, SysLoc] = value_of_vavs(VAVs), ?line {ok, Reply, _Rem} = Set(Node, TargetName, VAVs), ?DBG("~n Reply: ~p" "~n Rem: ~w", [Reply, _Rem]), %% verify that the operation actually worked: %% The order should be the same, so no need to seach %% The value we get should be exactly the same as we sent ?line ok = case Reply of {noError, 0, [#varbind{oid = ?sysName_instance, value = SysName}, #varbind{oid = ?sysLocation_instance, value = SysLoc}]} -> PostVerify(); {noError, 0, Vbs} -> {error, {unexpected_vbs, Vbs}}; Else -> p("unexpected reply: ~n~p", [Else]), {error, {unexpected_response, Else}} end, ok. %%====================================================================== simple_sync_set3(doc) -> ["Simple (sync) set-request - Version 3 API (TargetName with send-opts)"]; simple_sync_set3(suite) -> []; simple_sync_set3(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, sss3), p("starting with Config: ~p~n", [Config]), Self = self(), Msg = simple_sync_set3, Fun = fun() -> Self ! Msg end, Extra = {?SNMPM_EXTRA_INFO_TAG, Fun}, SendOpts = [ {extra, Extra} ], Set = fun(Node, TargetName, VAVs) -> mgr_user_sync_set2(Node, TargetName, VAVs, SendOpts) end, PostVerify = fun() -> receive Msg -> ok end end, do_simple_sync_set2(Config, Set, PostVerify), display_log(Config), ok. %%====================================================================== simple_async_set1(doc) -> ["Simple (async) set-request - " "Old style (Addr & Port)"]; simple_async_set1(suite) -> []; simple_async_set1(Config) when is_list(Config) -> ?SKIP(api_no_longer_supported), process_flag(trap_exit, true), put(tname, sas1), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), Addr = ?config(ip, Config), Port = ?AGENT_PORT, ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), Exec = fun(X) -> async_s_exec1(MgrNode, Addr, Port, X) end, Requests = [ {1, [{?sysName_instance, s, "Arne Anka"}], Exec, fun(X) -> sas_verify(X, [?sysName_instance]) end}, {2, [{?sysLocation_instance, s, "Stockholm"}, {?sysName_instance, s, "Arne Anka"}], Exec, fun(X) -> sas_verify(X, [?sysLocation_instance, ?sysName_instance]) end}, {3, [{[sysName, 0], "Gothenburg"}, {[sysLocation, 0], "Sune Anka"}], Exec, fun(X) -> sas_verify(X, [?sysName_instance, ?sysLocation_instance]) end} ], p("manager info when starting test: ~n~p", [mgr_info(MgrNode)]), p("agent info when starting test: ~n~p", [agent_info(AgentNode)]), ?line ok = async_exec(Requests, []), p("manager info when ending test: ~n~p", [mgr_info(MgrNode)]), p("agent info when ending test: ~n~p", [agent_info(AgentNode)]), display_log(Config), ok. async_s_exec1(Node, Addr, Port, VAVs) -> mgr_user_async_set(Node, Addr, Port, VAVs). sas_verify({noError, 0, _Vbs}, any) -> p("verified [any]"), ok; sas_verify({noError, 0, Vbs}, Expected) -> ?DBG("verified stage 1: " "~n Vbs: ~p" "~n Exp: ~p", [Vbs, Expected]), sas_verify_vbs(Vbs, Expected); sas_verify(Error, _) -> {error, {unexpected_reply, Error}}. sas_verify_vbs([], []) -> ok; sas_verify_vbs(Vbs, []) -> {error, {unexpected_vbs, Vbs}}; sas_verify_vbs([], Exp) -> {error, {expected_vbs, Exp}}; sas_verify_vbs([#varbind{oid = Oid}|Vbs], [any|Exp]) -> p("verified [any] oid ~w", [Oid]), sas_verify_vbs(Vbs, Exp); sas_verify_vbs([#varbind{oid = Oid, value = Value}|Vbs], [Oid|Exp]) -> p("verified oid ~w [~p]", [Oid, Value]), sas_verify_vbs(Vbs, Exp); sas_verify_vbs([#varbind{oid = Oid, value = Value}|Vbs], [{Oid,Value}|Exp]) -> p("verified oid ~w and ~p", [Oid, Value]), sas_verify_vbs(Vbs, Exp); sas_verify_vbs([Vb|_], [E|_]) -> {error, {unexpected_vb, Vb, E}}. %%====================================================================== simple_async_set2(doc) -> ["Simple (async) set-request - Version 2 API (TargetName)"]; simple_async_set2(suite) -> []; simple_async_set2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, sas2), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), Set = fun(Oids) -> async_s_exec2(MgrNode, TargetName, Oids) end, PostVerify = fun(Res) -> Res end, do_simple_async_set2(MgrNode, AgentNode, Set, PostVerify), display_log(Config), ok. do_simple_async_set2(MgrNode, AgentNode, Set, PostVerify) -> Requests = [ {1, [{?sysName_instance, s, "Arne Anka"}], Set, fun(X) -> PostVerify(sas_verify(X, [?sysName_instance])) end}, {2, [{?sysLocation_instance, s, "Stockholm"}, {?sysName_instance, s, "Arne Anka"}], Set, fun(X) -> PostVerify(sas_verify(X, [?sysLocation_instance, ?sysName_instance])) end}, {3, [{[sysName, 0], "Gothenburg"}, {[sysLocation, 0], "Sune Anka"}], Set, fun(X) -> PostVerify(sas_verify(X, [?sysName_instance, ?sysLocation_instance])) end} ], p("manager info when starting test: ~n~p", [mgr_info(MgrNode)]), p("agent info when starting test: ~n~p", [agent_info(AgentNode)]), ?line ok = async_exec(Requests, []), p("manager info when ending test: ~n~p", [mgr_info(MgrNode)]), p("agent info when ending test: ~n~p", [agent_info(AgentNode)]), ok. async_s_exec2(Node, TargetName, VAVs) -> mgr_user_async_set(Node, TargetName, VAVs). %%====================================================================== simple_async_set3(doc) -> ["Simple (async) set-request - Version 3 API (TargetName with send-opts)"]; simple_async_set3(suite) -> []; simple_async_set3(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, sas3), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), Self = self(), Msg = simple_async_set3, Fun = fun() -> Self ! Msg end, Extra = {?SNMPM_EXTRA_INFO_TAG, Fun}, SendOpts = [ {extra, Extra} ], Set = fun(Oids) -> async_s_exec3(MgrNode, TargetName, Oids, SendOpts) end, PostVerify = fun(ok) -> receive Msg -> ok end; (Res) -> Res end, do_simple_async_set2(MgrNode, AgentNode, Set, PostVerify), display_log(Config), ok. async_s_exec3(Node, TargetName, VAVs, SendOpts) -> mgr_user_async_set2(Node, TargetName, VAVs, SendOpts). %%====================================================================== simple_sync_get_bulk1(doc) -> ["Simple (sync) get_bulk-request - " "Old style (Addr & Port)"]; simple_sync_get_bulk1(suite) -> []; simple_sync_get_bulk1(Config) when is_list(Config) -> ?SKIP(api_no_longer_supported), process_flag(trap_exit, true), put(tname, ssgb1), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), Addr = ?config(ip, Config), Port = ?AGENT_PORT, %% -- 1 -- ?line ok = do_simple_get_bulk1(1, MgrNode, Addr, Port, 1, 1, [], fun verify_ssgb_reply1/1), %% -- 2 -- ?line ok = do_simple_get_bulk1(2, MgrNode, Addr, Port, -1, 1, [], fun verify_ssgb_reply1/1), %% -- 3 -- ?line ok = do_simple_get_bulk1(3, MgrNode, Addr, Port, -1, -1, [], fun verify_ssgb_reply1/1), ?line ok = mgr_user_load_mib(MgrNode, std_mib()), %% -- 4 -- VF04 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView]) end, ?line ok = do_simple_get_bulk1(4, MgrNode, Addr, Port, 2, 0, [[sysDescr],[1,3,7,1]], VF04), %% -- 5 -- ?line ok = do_simple_get_bulk1(5, MgrNode, Addr, Port, 1, 2, [[sysDescr],[1,3,7,1]], VF04), %% -- 6 -- VF06 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView]) end, ?line ok = do_simple_get_bulk1(6, MgrNode, Addr, Port, 0, 2, [[sysDescr],[1,3,7,1]], VF06), %% -- 7 -- VF07 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView]) end, ?line ok = do_simple_get_bulk1(7, MgrNode, Addr, Port, 2, 2, [[sysDescr],[1,3,7,1],[sysDescr],[1,3,7,1]], VF07), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), %% -- 8 -- VF08 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, ?sysDescr_instance]) end, ?line ok = do_simple_get_bulk1(8, MgrNode, Addr, Port, 1, 2, [[sysDescr],[sysDescr],[tTooBig]], VF08), %% -- 9 -- ?line ok = do_simple_get_bulk1(9, MgrNode, Addr, Port, 1, 12, [[tDescr2], [sysDescr]], fun verify_ssgb_reply1/1), %% -- 10 -- VF10 = fun(X) -> verify_ssgb_reply3(X, [{?sysDescr, 'NULL'}, {?sysObjectID, 'NULL'}, {?tGenErr1, 'NULL'}, {?sysDescr, 'NULL'}]) end, ?line ok = do_simple_get_bulk1(10, MgrNode, Addr, Port, 2, 2, [[sysDescr], [sysObjectID], [tGenErr1], [sysDescr]], VF10), %% -- 11 -- ?line {ok, [TCnt2|_]} = mgr_user_name_to_oid(MgrNode, tCnt2), p("TCnt2: ~p", [TCnt2]), VF11 = fun(X) -> verify_ssgb_reply2(X, [{fl([TCnt2,2]), 100}, {fl([TCnt2,2]), endOfMibView}]) end, ?line ok = do_simple_get_bulk1(11, MgrNode, Addr, Port, 0, 2, [[TCnt2, 1]], VF11), display_log(Config), ok. fl(L) -> lists:flatten(L). do_simple_get_bulk1(N, Node, Addr, Port, NonRep, MaxRep, Oids, Verify) -> p("issue get-bulk command ~w", [N]), case mgr_user_sync_get_bulk(Node, Addr, Port, NonRep, MaxRep, Oids) of {ok, Reply, _Rem} -> ?DBG("get-bulk ok:" "~n Reply: ~p" "~n Rem: ~w", [Reply, _Rem]), Verify(Reply); Error -> {error, {unexpected_reply, Error}} end. verify_ssgb_reply1({noError, 0, []}) -> ok; verify_ssgb_reply1(X) -> {error, {unexpected_reply, X}}. verify_ssgb_reply2({noError, 0, Vbs}, ExpectedVbs) -> check_ssgb_vbs(Vbs, ExpectedVbs); verify_ssgb_reply2(Error, _) -> {error, {unexpected_reply, Error}}. verify_ssgb_reply3({genErr, 3, Vbs}, ExpectedVbs) -> check_ssgb_vbs(Vbs, ExpectedVbs); verify_ssgb_reply3(Unexpected, _) -> {error, {unexpected_reply, Unexpected}}. check_ssgb_vbs([], []) -> ok; check_ssgb_vbs(Unexpected, []) -> {error, {unexpected_vbs, Unexpected}}; check_ssgb_vbs([], Expected) -> {error, {expected_vbs, Expected}}; check_ssgb_vbs([#varbind{value = endOfMibView}|R], [endOfMibView|Expected]) -> check_ssgb_vbs(R, Expected); check_ssgb_vbs([#varbind{oid = Oid}|R], [Oid|Expected]) -> check_ssgb_vbs(R, Expected); check_ssgb_vbs([#varbind{oid = Oid, value = Value}|R], [{Oid, Value}|Expected]) -> check_ssgb_vbs(R, Expected); check_ssgb_vbs([R|_], [E|_]) -> {error, {unexpected_vb, R, E}}. %%====================================================================== simple_sync_get_bulk2(doc) -> ["Simple (sync) get_bulk-request - Version 2 API (TargetName)"]; simple_sync_get_bulk2(suite) -> []; simple_sync_get_bulk2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, ssgb2), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), GetBulk = fun(NonRep, MaxRep, Oids) -> mgr_user_sync_get_bulk(MgrNode, TargetName, NonRep, MaxRep, Oids) end, PostVerify = fun(Res) -> Res end, do_simple_sync_get_bulk2(Config, MgrNode, AgentNode, GetBulk, PostVerify), display_log(Config), ok. do_simple_sync_get_bulk2(Config, MgrNode, AgentNode, GetBulk, PostVerify) -> %% -- 1 -- ?line ok = do_simple_get_bulk2(1, 1, 1, [], fun verify_ssgb_reply1/1, GetBulk, PostVerify), %% -- 2 -- ?line ok = do_simple_get_bulk2(2, -1, 1, [], fun verify_ssgb_reply1/1, GetBulk, PostVerify), %% -- 3 -- ?line ok = do_simple_get_bulk2(3, -1, -1, [], fun verify_ssgb_reply1/1, GetBulk, PostVerify), ?line ok = mgr_user_load_mib(MgrNode, std_mib()), %% -- 4 -- VF04 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView]) end, ?line ok = do_simple_get_bulk2(4, 2, 0, [[sysDescr],[1,3,7,1]], VF04, GetBulk, PostVerify), %% -- 5 -- ?line ok = do_simple_get_bulk2(5, 1, 2, [[sysDescr],[1,3,7,1]], VF04, GetBulk, PostVerify), %% -- 6 -- VF06 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView]) end, ?line ok = do_simple_get_bulk2(6, 0, 2, [[sysDescr],[1,3,7,1]], VF06, GetBulk, PostVerify), %% -- 7 -- VF07 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView]) end, ?line ok = do_simple_get_bulk2(7, 2, 2, [[sysDescr],[1,3,7,1],[sysDescr],[1,3,7,1]], VF07, GetBulk, PostVerify), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), %% -- 8 -- VF08 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, ?sysDescr_instance]) end, ?line ok = do_simple_get_bulk2(8, 1, 2, [[sysDescr],[sysDescr],[tTooBig]], VF08, GetBulk, PostVerify), %% -- 9 -- ?line ok = do_simple_get_bulk2(9, 1, 12, [[tDescr2], [sysDescr]], fun verify_ssgb_reply1/1, GetBulk, PostVerify), %% -- 10 -- VF10 = fun(X) -> verify_ssgb_reply3(X, [{?sysDescr, 'NULL'}, {?sysObjectID, 'NULL'}, {?tGenErr1, 'NULL'}, {?sysDescr, 'NULL'}]) end, ?line ok = do_simple_get_bulk2(10, 2, 2, [[sysDescr], [sysObjectID], [tGenErr1], [sysDescr]], VF10, GetBulk, PostVerify), %% -- 11 -- ?line {ok, [TCnt2|_]} = mgr_user_name_to_oid(MgrNode, tCnt2), p("TCnt2: ~p", [TCnt2]), VF11 = fun(X) -> verify_ssgb_reply2(X, [{fl([TCnt2,2]), 100}, {fl([TCnt2,2]), endOfMibView}]) end, ?line ok = do_simple_get_bulk2(11, 0, 2, [[TCnt2, 1]], VF11, GetBulk, PostVerify), ok. do_simple_get_bulk2(N, NonRep, MaxRep, Oids, Verify, GetBulk, PostVerify) when is_function(Verify, 1) andalso is_function(GetBulk, 3) andalso is_function(PostVerify) -> p("issue get-bulk command ~w", [N]), case GetBulk(NonRep, MaxRep, Oids) of {ok, Reply, _Rem} -> ?DBG("get-bulk ok:" "~n Reply: ~p" "~n Rem: ~w", [Reply, _Rem]), PostVerify(Verify(Reply)); Error -> {error, {unexpected_reply, Error}} end. %%====================================================================== simple_sync_get_bulk3(doc) -> ["Simple (sync) get_bulk-request - " "Version 3 API (TargetName with send-opts)"]; simple_sync_get_bulk3(suite) -> []; simple_sync_get_bulk3(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, ssgb3), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), Self = self(), Msg = simple_async_set3, Fun = fun() -> Self ! Msg end, Extra = {?SNMPM_EXTRA_INFO_TAG, Fun}, SendOpts = [ {extra, Extra} ], GetBulk = fun(NonRep, MaxRep, Oids) -> mgr_user_sync_get_bulk2(MgrNode, TargetName, NonRep, MaxRep, Oids, SendOpts) end, PostVerify = fun(ok) -> receive Msg -> ok end; (Res) -> Res end, do_simple_sync_get_bulk2(Config, MgrNode, AgentNode, GetBulk, PostVerify), display_log(Config), ok. %%====================================================================== simple_async_get_bulk1(doc) -> ["Simple (async) get_bulk-request - " "Old style (Addr & Port)"]; simple_async_get_bulk1(suite) -> []; simple_async_get_bulk1(Config) when is_list(Config) -> ?SKIP(api_no_longer_supported), process_flag(trap_exit, true), put(tname, sagb1), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), Addr = ?config(ip, Config), Port = ?AGENT_PORT, ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), Exec = fun(Data) -> async_gb_exec1(MgrNode, Addr, Port, Data) end, %% We re-use the verification functions from the ssgb test-case VF04 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView]) end, VF06 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView]) end, VF07 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView]) end, VF08 = fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, ?sysDescr_instance]) end, VF10 = fun(X) -> verify_ssgb_reply3(X, [{?sysDescr, 'NULL'}, {?sysObjectID, 'NULL'}, {?tGenErr1, 'NULL'}, {?sysDescr, 'NULL'}]) end, ?line {ok, [TCnt2|_]} = mgr_user_name_to_oid(MgrNode, tCnt2), VF11 = fun(X) -> verify_ssgb_reply2(X, [{fl([TCnt2,2]), 100}, {fl([TCnt2,2]), endOfMibView}]) end, Requests = [ { 1, {1, 1, []}, Exec, fun verify_ssgb_reply1/1}, { 2, {-1, 1, []}, Exec, fun verify_ssgb_reply1/1}, { 3, {-1, -1, []}, Exec, fun verify_ssgb_reply1/1}, { 4, {2, 0, [[sysDescr],[1,3,7,1]]}, Exec, VF04}, { 5, {1, 2, [[sysDescr],[1,3,7,1]]}, Exec, VF04}, { 6, {0, 2, [[sysDescr],[1,3,7,1]]}, Exec, VF06}, { 7, {2, 2, [[sysDescr],[1,3,7,1],[sysDescr],[1,3,7,1]]}, Exec, VF07}, { 8, {1, 2, [[sysDescr],[sysDescr],[tTooBig]]}, Exec, VF08}, { 9, {1, 12, [[tDescr2], [sysDescr]]}, Exec, fun verify_ssgb_reply1/1}, {10, {2, 2, [[sysDescr],[sysObjectID], [tGenErr1],[sysDescr]]}, Exec, VF10}, {11, {0, 2, [[TCnt2, 1]]}, Exec, VF11}, {12, {2, 0, [[sysDescr],[1,3,7,1]]}, Exec, VF04}, {13, {1, 12, [[tDescr2], [sysDescr]]}, Exec, fun verify_ssgb_reply1/1}, {14, {2, 2, [[sysDescr],[sysObjectID],[tGenErr1],[sysDescr]]}, Exec, VF10}, {15, {0, 2, [[TCnt2, 1]]}, Exec, VF11}, {16, {2, 2, [[sysDescr],[1,3,7,1],[sysDescr],[1,3,7,1]]}, Exec, VF07}, {17, {2, 2, [[sysDescr],[sysObjectID], [tGenErr1],[sysDescr]]}, Exec, VF10} ], p("manager info when starting test: ~n~p", [mgr_info(MgrNode)]), p("agent info when starting test: ~n~p", [agent_info(AgentNode)]), ?line ok = async_exec(Requests, []), p("manager info when ending test: ~n~p", [mgr_info(MgrNode)]), p("agent info when ending test: ~n~p", [agent_info(AgentNode)]), display_log(Config), ok. async_gb_exec1(Node, Addr, Port, {NR, MR, Oids}) -> mgr_user_async_get_bulk(Node, Addr, Port, NR, MR, Oids). %%====================================================================== simple_async_get_bulk2(doc) -> ["Simple (async) get_bulk-request - Version 2 API (TargetName)"]; simple_async_get_bulk2(suite) -> []; simple_async_get_bulk2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, sagb2), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), GetBulk = fun(Data) -> async_gb_exec2(MgrNode, TargetName, Data) end, PostVerify = fun(Res) -> Res end, do_simple_async_get_bulk2(MgrNode, AgentNode, GetBulk, PostVerify), display_log(Config), ok. do_simple_async_get_bulk2(MgrNode, AgentNode, GetBulk, PostVerify) -> %% We re-use the verification functions from the ssgb test-case VF04 = fun(X) -> PostVerify( verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView])) end, VF06 = fun(X) -> PostVerify( verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView])) end, VF07 = fun(X) -> PostVerify( verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView])) end, VF08 = fun(X) -> PostVerify( verify_ssgb_reply2(X, [?sysDescr_instance, ?sysDescr_instance])) end, VF10 = fun(X) -> PostVerify( verify_ssgb_reply3(X, [{?sysDescr, 'NULL'}, {?sysObjectID, 'NULL'}, {?tGenErr1, 'NULL'}, {?sysDescr, 'NULL'}])) end, ?line {ok, [TCnt2|_]} = mgr_user_name_to_oid(MgrNode, tCnt2), VF11 = fun(X) -> PostVerify( verify_ssgb_reply2(X, [{fl([TCnt2,2]), 100}, {fl([TCnt2,2]), endOfMibView}])) end, Requests = [ { 1, {1, 1, []}, GetBulk, fun(X) -> PostVerify(verify_ssgb_reply1(X)) end}, { 2, {-1, 1, []}, GetBulk, fun(X) -> PostVerify(verify_ssgb_reply1(X)) end}, { 3, {-1, -1, []}, GetBulk, fun(X) -> PostVerify(verify_ssgb_reply1(X)) end}, { 4, {2, 0, [[sysDescr],[1,3,7,1]]}, GetBulk, VF04}, { 5, {1, 2, [[sysDescr],[1,3,7,1]]}, GetBulk, VF04}, { 6, {0, 2, [[sysDescr],[1,3,7,1]]}, GetBulk, VF06}, { 7, {2, 2, [[sysDescr],[1,3,7,1],[sysDescr],[1,3,7,1]]}, GetBulk, VF07}, { 8, {1, 2, [[sysDescr],[sysDescr],[tTooBig]]}, GetBulk, VF08}, { 9, {1, 12, [[tDescr2], [sysDescr]]}, GetBulk, fun(X) -> PostVerify(verify_ssgb_reply1(X)) end}, {10, {2, 2, [[sysDescr],[sysObjectID], [tGenErr1],[sysDescr]]}, GetBulk, VF10}, {11, {0, 2, [[TCnt2, 1]]}, GetBulk, VF11}, {12, {2, 0, [[sysDescr],[1,3,7,1]]}, GetBulk, VF04}, {13, {1, 12, [[tDescr2], [sysDescr]]}, GetBulk, fun(X) -> PostVerify(verify_ssgb_reply1(X)) end}, {14, {2, 2, [[sysDescr],[sysObjectID],[tGenErr1],[sysDescr]]}, GetBulk, VF10}, {15, {0, 2, [[TCnt2, 1]]}, GetBulk, VF11}, {16, {2, 2, [[sysDescr],[1,3,7,1],[sysDescr],[1,3,7,1]]}, GetBulk, VF07}, {17, {2, 2, [[sysDescr],[sysObjectID], [tGenErr1],[sysDescr]]}, GetBulk, VF10} ], p("manager info when starting test: ~n~p", [mgr_info(MgrNode)]), p("agent info when starting test: ~n~p", [agent_info(AgentNode)]), ?line ok = async_exec(Requests, []), p("manager info when ending test: ~n~p", [mgr_info(MgrNode)]), p("agent info when ending test: ~n~p", [agent_info(AgentNode)]), ok. async_gb_exec2(Node, TargetName, {NR, MR, Oids}) -> mgr_user_async_get_bulk(Node, TargetName, NR, MR, Oids). %%====================================================================== simple_async_get_bulk3(doc) -> ["Simple (async) get_bulk-request - " "Version 3 API (TargetName with send-opts)"]; simple_async_get_bulk3(suite) -> []; simple_async_get_bulk3(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, sagb3), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), Self = self(), Msg = simple_async_get_bulk3, Fun = fun() -> Self ! Msg end, Extra = {?SNMPM_EXTRA_INFO_TAG, Fun}, SendOpts = [ {extra, Extra} ], GetBulk = fun(Data) -> async_gb_exec3(MgrNode, TargetName, Data, SendOpts) end, PostVerify = fun(ok) -> receive Msg -> ok end; (Res) -> Res end, do_simple_async_get_bulk2(MgrNode, AgentNode, GetBulk, PostVerify), display_log(Config), ok. async_gb_exec3(Node, TargetName, {NR, MR, Oids}, SendOpts) -> mgr_user_async_get_bulk2(Node, TargetName, NR, MR, Oids, SendOpts). %%====================================================================== misc_async1(doc) -> ["Misc (async) request(s) - " "Old style (Addr & Port)"]; misc_async1(suite) -> []; misc_async1(Config) when is_list(Config) -> ?SKIP(api_no_longer_supported), process_flag(trap_exit, true), put(tname, ms1), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), Addr = ?config(ip, Config), Port = ?AGENT_PORT, ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), ExecG = fun(Data) -> async_g_exec1(MgrNode, Addr, Port, Data) end, ExecGN = fun(Data) -> async_gn_exec1(MgrNode, Addr, Port, Data) end, ExecS = fun(Data) -> async_s_exec1(MgrNode, Addr, Port, Data) end, ExecGB = fun(Data) -> async_gb_exec1(MgrNode, Addr, Port, Data) end, ?line {ok, [TCnt2|_]} = mgr_user_name_to_oid(MgrNode, tCnt2), ?line {ok, [TGenErr1|_]} = mgr_user_name_to_oid(MgrNode, tGenErr1), ?line {ok, [TGenErr2|_]} = mgr_user_name_to_oid(MgrNode, tGenErr2), ?line {ok, [TGenErr3|_]} = mgr_user_name_to_oid(MgrNode, tGenErr3), ?line {ok, [TTooBig|_]} = mgr_user_name_to_oid(MgrNode, tTooBig), Requests = [ { 1, [?sysObjectID_instance], ExecG, fun(X) -> sag_verify(X, [?sysObjectID_instance]) end }, { 2, {1, 1, []}, ExecGB, fun verify_ssgb_reply1/1}, { 3, {-1, 1, []}, ExecGB, fun verify_ssgb_reply1/1}, { 4, [{?sysLocation_instance, s, "Stockholm"}, {?sysName_instance, s, "Arne Anka"}], ExecS, fun(X) -> sas_verify(X, [?sysLocation_instance, ?sysName_instance]) end}, { 5, [[sysDescr], [1,3,7,1]], ExecGN, fun(X) -> verify_ssgn_reply1(X, [?sysDescr_instance, endOfMibView]) end}, { 6, [[sysObjectID, 0], [sysDescr, 0], [sysUpTime, 0]], ExecG, fun(X) -> sag_verify(X, [?sysObjectID_instance, ?sysDescr_instance, ?sysUpTime_instance]) end}, { 7, [TGenErr2], ExecGN, fun(X) -> verify_ssgn_reply2(X, {genErr, 1, [TGenErr2]}) end}, { 8, {2, 0, [[sysDescr],[1,3,7,1]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView]) end}, { 9, {1, 2, [[sysDescr],[1,3,7,1]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView]) end}, {10, [TGenErr1], ExecGN, fun(X) -> verify_ssgn_reply2(X, {genErr, 1, [TGenErr1]}) end}, {11, {0, 2, [[sysDescr],[1,3,7,1]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView]) end}, {12, [{[sysName, 0], "Gothenburg"}, {[sysLocation, 0], "Sune Anka"}], ExecS, fun(X) -> sas_verify(X, [?sysName_instance, ?sysLocation_instance]) end}, {13, {2, 2, [[sysDescr],[1,3,7,1],[sysDescr],[1,3,7,1]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView]) end}, {14, {1, 2, [[sysDescr],[sysDescr],[tTooBig]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, ?sysDescr_instance]) end}, {15, {1, 12, [[tDescr2], [sysDescr]]}, ExecGB, fun verify_ssgb_reply1/1}, {16, {2, 2, [[sysDescr],[sysObjectID], [tGenErr1],[sysDescr]]}, ExecGB, fun(X) -> verify_ssgb_reply3(X, [{?sysDescr, 'NULL'}, {?sysObjectID, 'NULL'}, {?tGenErr1, 'NULL'}, {?sysDescr, 'NULL'}]) end}, {17, [[sysDescr], TGenErr3], ExecGN, fun(X) -> verify_ssgn_reply2(X, {genErr, 2, [TGenErr3]}) end}, {18, {0, 2, [[TCnt2, 1]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [{fl([TCnt2,2]), 100}, {fl([TCnt2,2]), endOfMibView}]) end}, {19, [TTooBig], ExecGN, fun(X) -> verify_ssgn_reply2(X, {tooBig, 0, []}) end}, {20, [TTooBig], ExecGN, fun(X) -> verify_ssgn_reply2(X, {tooBig, 0, []}) end} ], p("manager info when starting test: ~n~p", [mgr_info(MgrNode)]), p("agent info when starting test: ~n~p", [agent_info(AgentNode)]), ?line ok = async_exec(Requests, []), p("manager info when ending test: ~n~p", [mgr_info(MgrNode)]), p("agent info when ending test: ~n~p", [agent_info(AgentNode)]), display_log(Config), ok. %%====================================================================== misc_async2(doc) -> ["Misc (async) request(s) - Version 2 API (TargetName)"]; misc_async2(suite) -> []; misc_async2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, ms2), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), TargetName = ?config(manager_agent_target_name, Config), ?line ok = mgr_user_load_mib(MgrNode, std_mib()), Test2Mib = test2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), ExecG = fun(Data) -> async_g_exec2(MgrNode, TargetName, Data) end, ExecGN = fun(Data) -> async_gn_exec2(MgrNode, TargetName, Data) end, ExecS = fun(Data) -> async_s_exec2(MgrNode, TargetName, Data) end, ExecGB = fun(Data) -> async_gb_exec2(MgrNode, TargetName, Data) end, ?line {ok, [TCnt2|_]} = mgr_user_name_to_oid(MgrNode, tCnt2), ?line {ok, [TGenErr1|_]} = mgr_user_name_to_oid(MgrNode, tGenErr1), ?line {ok, [TGenErr2|_]} = mgr_user_name_to_oid(MgrNode, tGenErr2), ?line {ok, [TGenErr3|_]} = mgr_user_name_to_oid(MgrNode, tGenErr3), ?line {ok, [TTooBig|_]} = mgr_user_name_to_oid(MgrNode, tTooBig), Requests = [ { 1, [?sysObjectID_instance], ExecG, fun(X) -> sag_verify(X, [?sysObjectID_instance]) end }, { 2, {1, 1, []}, ExecGB, fun verify_ssgb_reply1/1}, { 3, {-1, 1, []}, ExecGB, fun verify_ssgb_reply1/1}, { 4, [{?sysLocation_instance, s, "Stockholm"}, {?sysName_instance, s, "Arne Anka"}], ExecS, fun(X) -> sas_verify(X, [?sysLocation_instance, ?sysName_instance]) end}, { 5, [[sysDescr], [1,3,7,1]], ExecGN, fun(X) -> verify_ssgn_reply1(X, [?sysDescr_instance, endOfMibView]) end}, { 6, [[sysObjectID, 0], [sysDescr, 0], [sysUpTime, 0]], ExecG, fun(X) -> sag_verify(X, [?sysObjectID_instance, ?sysDescr_instance, ?sysUpTime_instance]) end}, { 7, [TGenErr2], ExecGN, fun(X) -> verify_ssgn_reply2(X, {genErr, 1, [TGenErr2]}) end}, { 8, {2, 0, [[sysDescr],[1,3,7,1]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView]) end}, { 9, {1, 2, [[sysDescr],[1,3,7,1]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView]) end}, {10, [TGenErr1], ExecGN, fun(X) -> verify_ssgn_reply2(X, {genErr, 1, [TGenErr1]}) end}, {11, {0, 2, [[sysDescr],[1,3,7,1]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView]) end}, {12, [{[sysName, 0], "Gothenburg"}, {[sysLocation, 0], "Sune Anka"}], ExecS, fun(X) -> sas_verify(X, [?sysName_instance, ?sysLocation_instance]) end}, {13, {2, 2, [[sysDescr],[1,3,7,1],[sysDescr],[1,3,7,1]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, endOfMibView, ?sysDescr_instance, endOfMibView, ?sysObjectID_instance, endOfMibView]) end}, {14, {1, 2, [[sysDescr],[sysDescr],[tTooBig]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [?sysDescr_instance, ?sysDescr_instance]) end}, {15, {1, 12, [[tDescr2], [sysDescr]]}, ExecGB, fun verify_ssgb_reply1/1}, {16, {2, 2, [[sysDescr],[sysObjectID], [tGenErr1],[sysDescr]]}, ExecGB, fun(X) -> verify_ssgb_reply3(X, [{?sysDescr, 'NULL'}, {?sysObjectID, 'NULL'}, {?tGenErr1, 'NULL'}, {?sysDescr, 'NULL'}]) end}, {17, [[sysDescr], TGenErr3], ExecGN, fun(X) -> verify_ssgn_reply2(X, {genErr, 2, [TGenErr3]}) end}, {18, {0, 2, [[TCnt2, 1]]}, ExecGB, fun(X) -> verify_ssgb_reply2(X, [{fl([TCnt2,2]), 100}, {fl([TCnt2,2]), endOfMibView}]) end}, {19, [TTooBig], ExecGN, fun(X) -> verify_ssgn_reply2(X, {tooBig, 0, []}) end}, {20, [TTooBig], ExecGN, fun(X) -> verify_ssgn_reply2(X, {tooBig, 0, []}) end} ], p("manager info when starting test: ~n~p", [mgr_info(MgrNode)]), p("agent info when starting test: ~n~p", [agent_info(AgentNode)]), ?line ok = async_exec(Requests, []), p("manager info when ending test: ~n~p", [mgr_info(MgrNode)]), p("agent info when ending test: ~n~p", [agent_info(AgentNode)]), display_log(Config), ok. %%====================================================================== discovery(suite) -> []; discovery(Config) when is_list(Config) -> ?SKIP(not_yet_implemented). %%====================================================================== %% %% Utility functions for cases trap1 and trap2 %% collect_traps(N) -> collect_traps(N, []). collect_traps(0, TrapInfo) -> TrapInfo; collect_traps(N, Acc) -> receive {async_event, _From, {trap, TrapInfo}} -> p("collect_traps -> received trap: ~n ~p", [TrapInfo]), collect_traps(N-1, [TrapInfo|Acc]) after 10000 -> p("collect_traps -> still awaiting ~w trap(s) - giving up", [N]), Acc end. verify_traps([], []) -> p("verify_traps -> done"), ok; verify_traps([], Verifiers) -> p("verify_traps -> done when ~w verifiers remain", [length(Verifiers)]), {error, {failed_verify, [Id || {Id, _} <- Verifiers]}}; verify_traps([Trap|Traps], Verifiers0) -> p("verify_traps -> entry"), case verify_trap(Trap, Verifiers0) of {ok, Id} -> p("verify_traps -> trap verified: ~p", [Id]), Verifiers = lists:keydelete(Id, 1, Verifiers0), verify_traps(Traps, Verifiers); error -> p("verify_traps -> failed verifying trap: ~n ~p", [Trap]), {error, {failed_verifying_trap, Trap}} end. verify_trap(Trap, []) -> p("verify_trap -> could not verify trap:" "~n Trap: ~p", [Trap]), error; verify_trap(Trap, [{Id, Verifier}|Verifiers]) -> p("verify_trap -> entry with" "~n Id: ~p" "~n Trap: ~p", [Id, Trap]), case Verifier(Trap) of ok -> p("verify_trap -> verified"), {ok, Id}; {error, _} -> p("verify_trap -> not verified"), verify_trap(Trap, Verifiers) end. %%====================================================================== trap1(suite) -> []; trap1(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname,t1), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), ?line ok = mgr_user_load_mib(MgrNode, snmpv2_mib()), Test2Mib = test2_mib(Config), TestTrapMib = test_trap_mib(Config), TestTrapv2Mib = test_trap_v2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapMib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapv2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, TestTrapMib), ?line ok = agent_load_mib(AgentNode, TestTrapv2Mib), %% Version 1 trap verification function: VerifyTrap_v1 = fun(Ent, Gen, Spec, ExpVBs, Trap) -> case Trap of {Ent, Gen, Spec, _Timestamp, VBs} -> p("trap info as expected"), case (catch validate_vbs(MgrNode, ExpVBs, VBs)) of ok -> p("valid trap"), ok; Error -> p("invalid trap: ~n Error: ~p", [Error]), Error end; {Enteprise, Generic, Spec, Timestamp, VBs} -> p("unepxected v1 trap info:" "~n Enteprise: ~p" "~n Generic: ~p" "~n Spec: ~p" "~n Timestamp: ~p" "~n VBs: ~p", [Enteprise, Generic, Spec, Timestamp, VBs]), ExpTrap = {Ent, Gen, Spec, ignore, ExpVBs}, Reason = {unexpected_trap, {ExpTrap, Trap}}, {error, Reason}; {Err, Idx, VBs} -> p("unexpected trap info: " "~n Err: ~p" "~n Idx: ~p" "~n VBs: ~p", [Err, Idx, VBs]), Reason = {unexpected_status, {Err, Idx, VBs}}, {error, Reason} end end, %% Version 2 trap verification function: VerifyTrap_v2 = fun(ExpVBs, Trap) -> case Trap of {noError, 0, VBs0} -> p("trap info as expected: ~n~p", [VBs0]), %% The first two are a timestamp and oid [_,_|VBs] = VBs0, case (catch validate_vbs(MgrNode, ExpVBs, VBs)) of ok -> p("valid trap"), ok; Error -> p("invalid trap: ~n Error: ~p", [Error]), Error end; {Err, Idx, VBs} -> p("unexpected error status: " "~n Err: ~p" "~n Idx: ~p" "~n VBs: ~p", [Err, Idx, VBs]), Reason = {unexpected_status, {Err, Idx, VBs}}, {error, Reason} end end, %% -- command 1 -- %% Collect various info about the manager and the agent Cmd1 = fun() -> p("manager info: ~n~p", [mgr_info(MgrNode)]), p("agent info: ~n~p", [agent_info(AgentNode)]), ok end, %% -- command 2 -- %% Make the agent send trap(s) (both a v1 and a v2 trap) Cmd2 = fun() -> VBs = [{ifIndex, [1], 1}, {ifAdminStatus, [1], 1}, {ifOperStatus, [1], 2}], agent_send_trap(AgentNode, linkUp, "standard trap", VBs), ok end, %% -- command 3 -- %% Version 1 trap verify function Cmd3_VerifyTrap_v1 = fun(Trap) -> Ent = [1,2,3], Gen = 3, Spec = 0, ExpVBs = [{[ifIndex, 1], 1}, {[ifAdminStatus, 1], 1}, {[ifOperStatus, 1], 2}], VerifyTrap_v1(Ent, Gen, Spec, ExpVBs, Trap) end, %% Version 2 trap verify function Cmd3_VerifyTrap_v2 = fun(Trap) -> ExpVBs = [{[ifIndex, 1], 1}, {[ifAdminStatus, 1], 1}, {[ifOperStatus, 1], 2}], VerifyTrap_v2(ExpVBs, Trap) end, %% Verify the two traps. The order of them is unknown Cmd3 = fun() -> Verifiers = [{"v1 trap verifier", Cmd3_VerifyTrap_v1}, {"v2 trap verifier", Cmd3_VerifyTrap_v2}], verify_traps(collect_traps(2), Verifiers) end, Cmd4 = fun() -> ?SLEEP(1000), ok end, Commands = [ {1, "Manager and agent info at start of test", Cmd1}, {2, "Send trap from agent", Cmd2}, {3, "Await trap(s) to manager", Cmd3}, {4, "Sleep some time (1 sec)", Cmd4}, {5, "Manager and agent info after test completion", Cmd1} ], command_handler(Commands), display_log(Config), ok. %%====================================================================== trap2(suite) -> []; trap2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname,t2), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), ?line ok = mgr_user_load_mib(MgrNode, snmpv2_mib()), Test2Mib = test2_mib(Config), TestTrapMib = test_trap_mib(Config), TestTrapv2Mib = test_trap_v2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapMib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapv2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, TestTrapMib), ?line ok = agent_load_mib(AgentNode, TestTrapv2Mib), %% Version 1 trap verification function: VerifyTrap_v1 = fun(Ent, Gen, Spec, ExpVBs, Trap) -> case Trap of {Ent, Gen, Spec, _Timestamp, VBs} -> p("trap info as expected"), case (catch validate_vbs(MgrNode, ExpVBs, VBs)) of ok -> p("valid trap"), ok; Error -> p("invalid trap: ~n Error: ~p", [Error]), Error end; {Enteprise, Generic, Spec, Timestamp, VBs} -> p("unepxected v1 trap info:" "~n Enteprise: ~p" "~n Generic: ~p" "~n Spec: ~p" "~n Timestamp: ~p" "~n VBs: ~p", [Enteprise, Generic, Spec, Timestamp, VBs]), ExpTrap = {Ent, Gen, Spec, ignore, ExpVBs}, Reason = {unexpected_trap, {ExpTrap, Trap}}, {error, Reason}; {Err, Idx, VBs} -> p("unexpected trap info: " "~n Err: ~p" "~n Idx: ~p" "~n VBs: ~p", [Err, Idx, VBs]), Reason = {unexpected_status, {Err, Idx, VBs}}, {error, Reason} end end, %% Version 2 trap verification function: VerifyTrap_v2 = fun(ExpVBs, Trap) -> case Trap of {noError, 0, VBs0} -> p("trap info as expected: ~n~p", [VBs0]), %% The first two are a timestamp and oid [_,_|VBs] = VBs0, case (catch validate_vbs(MgrNode, ExpVBs, VBs)) of ok -> p("valid trap"), ok; Error -> p("invalid trap: ~n Error: ~p", [Error]), Error end; {Err, Idx, VBs} -> p("unexpected error status: " "~n Err: ~p" "~n Idx: ~p" "~n VBs: ~p", [Err, Idx, VBs]), Reason = {unexpected_status, {Err, Idx, VBs}}, {error, Reason} end end, %% -- command 1 -- %% Collect various info about the manager and the agent Cmd1 = fun() -> p("manager info: ~n~p", [mgr_info(MgrNode)]), p("agent info: ~n~p", [agent_info(AgentNode)]), ok end, %% -- command 2 -- %% Make the agent send trap(s) (both a v1 and a v2 trap) Cmd2 = fun() -> VBs = [{sysContact, "pelle"}], agent_send_trap(AgentNode, testTrap1, "standard trap", VBs), ok end, %% -- command 3 -- %% Version 1 trap verify function Cmd3_VerifyTrap_v1 = fun(Trap) -> Ent = [1,2,3], Gen = 1, Spec = 0, ExpVBs = [{[system, [4,0]], "pelle"}], VerifyTrap_v1(Ent, Gen, Spec, ExpVBs, Trap) end, %% Version 2 trap verify function Cmd3_VerifyTrap_v2 = fun(Trap) -> ExpVBs = [{[system, [4,0]], "pelle"}, {[snmpTrapEnterprise,0], any}], VerifyTrap_v2(ExpVBs, Trap) end, %% Verify the two traps. The order of them is unknown Cmd3 = fun() -> Verifiers = [{"v1 trap verifier", Cmd3_VerifyTrap_v1}, {"v2 trap verifier", Cmd3_VerifyTrap_v2}], verify_traps(collect_traps(2), Verifiers) end, %% -- command 4 -- %% Make the agent send another set of trap(s) (both a v1 and a v2 trap) Cmd4 = fun() -> VBs = [{ifIndex, [1], 1}, {ifAdminStatus, [1], 1}, {ifOperStatus, [1], 2}], agent_send_trap(AgentNode, linkUp, "standard trap", VBs), ok end, %% -- command 5 -- %% Expected varbinds ExpVBs5 = [{[ifIndex, 1], 1}, {[ifAdminStatus, 1], 1}, {[ifOperStatus, 1], 2}], %% Version 1 trap verify function Cmd5_VerifyTrap_v1 = fun(Trap) -> Ent = [1,2,3], Gen = 3, Spec = 0, VerifyTrap_v1(Ent, Gen, Spec, ExpVBs5, Trap) end, %% Version 2 trap verify function Cmd5_VerifyTrap_v2 = fun(Trap) -> VerifyTrap_v2(ExpVBs5, Trap) end, %% Verify the two traps. The order of them is unknown Cmd5 = fun() -> Verifiers = [{"v1 trap verifier", Cmd5_VerifyTrap_v1}, {"v2 trap verifier", Cmd5_VerifyTrap_v2}], verify_traps(collect_traps(2), Verifiers) end, %% -- command 6 -- %% Some sleep before we are done Cmd6 = fun() -> ?SLEEP(1000), ok end, Commands = [ {1, "Manager and agent info at start of test", Cmd1}, {2, "Send first trap(s) from agent", Cmd2}, {3, "Await the trap(s) from agent", Cmd3}, {4, "Send second trap(s) from agent", Cmd4}, {5, "Await the trap(s) from the agent", Cmd5}, {6, "Sleep some time (1 sec)", Cmd6}, {7, "Manager and agent info after test completion", Cmd1} ], command_handler(Commands), display_log(Config), ok. %%====================================================================== inform1(suite) -> []; inform1(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname,i1), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), ?line ok = mgr_user_load_mib(MgrNode, snmpv2_mib()), Test2Mib = test2_mib(Config), TestTrapMib = test_trap_mib(Config), TestTrapv2Mib = test_trap_v2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapMib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapv2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, TestTrapMib), ?line ok = agent_load_mib(AgentNode, TestTrapv2Mib), Cmd1 = fun() -> p("manager info: ~n~p", [mgr_info(MgrNode)]), p("manager system info: ~n~p", [mgr_sys_info(MgrNode)]), p("agent info: ~n~p", [agent_info(AgentNode)]), ok end, Cmd2 = fun() -> agent_send_notif(AgentNode, testTrapv22, "standard inform"), ok end, Cmd3 = fun() -> receive {async_event, From, {inform, Pid, Inform}} -> p("received inform"), case Inform of {noError, 0, VBs} when is_list(VBs) -> case (catch validate_testTrapv22_vbs(MgrNode, VBs)) of ok -> p("valid inform"), Pid ! {handle_inform_no_response, From}, ok; Error -> p("invalid inform: ~n Error: ~p", [Error]), Error end; {Err, Idx, VBs} -> p("unexpected error status: " "~n Err: ~p" "~n Idx: ~p" "~n VBs: ~p", [Err, Idx, VBs]), Reason = {unexpected_status, {Err, Idx, VBs}}, {error, Reason} end after 10000 -> receive Any -> {error, {timeout_crap, Any}} after 1000 -> {error, timeout} end end end, Cmd4 = fun() -> receive {async_event, From, {inform, Pid, Inform}} -> p("received inform"), case Inform of {noError, 0, VBs} when is_list(VBs) -> case (catch validate_testTrapv22_vbs(MgrNode, VBs)) of ok -> p("valid inform"), Pid ! {handle_inform_response, From}, ok; Error -> p("invalid inform: ~n Error: ~p", [Error]), Error end; {Err, Idx, VBs} -> p("unexpected error status: " "~n Err: ~p" "~n Idx: ~p" "~n VBs: ~p", [Err, Idx, VBs]), Reason = {unexpected_status, {Err, Idx, VBs}}, {error, Reason} end after 20000 -> receive Any -> {error, {timeout_crap, Any}} after 1000 -> {error, timeout} end end end, Cmd5 = fun() -> ?SLEEP(5000), ok end, Commands = [ {1, "Manager and agent info at start of test", Cmd1}, {2, "Send notifcation [no receiver] from agent", Cmd2}, {3, "Await first inform to manager - do not reply", Cmd3}, {4, "Await second inform to manager - reply", Cmd4}, {5, "Sleep some time (5 sec)", Cmd5}, {6, "Manager and agent info after test completion", Cmd1} ], command_handler(Commands), display_log(Config), ok. %%====================================================================== inform2(suite) -> []; inform2(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, i2), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), %% Addr = ?config(ip, Config), %% Port = ?AGENT_PORT, ?line ok = mgr_user_load_mib(MgrNode, snmpv2_mib()), Test2Mib = test2_mib(Config), TestTrapMib = test_trap_mib(Config), TestTrapv2Mib = test_trap_v2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapMib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapv2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, TestTrapMib), ?line ok = agent_load_mib(AgentNode, TestTrapv2Mib), Cmd1 = fun() -> p("manager info: ~n~p", [mgr_info(MgrNode)]), p("agent info: ~n~p", [agent_info(AgentNode)]), ok end, Cmd2 = fun() -> agent_send_notif(AgentNode, testTrapv22, {inform2_tag1, self()}, "standard inform", []), ok end, Cmd3 = fun() -> receive {snmp_targets, inform2_tag1, Addrs} -> p("sent inform to ~p", [Addrs]), ok after 10000 -> receive Any -> {error, {timeout_crap, Any}} after 1000 -> {error, timeout} end end end, Cmd4 = fun() -> receive {async_event, From, {inform, Pid, Inform}} -> p("received inform"), case Inform of {noError, 0, VBs} when is_list(VBs) -> case (catch validate_testTrapv22_vbs(MgrNode, VBs)) of ok -> p("valid inform"), Pid ! {handle_inform_no_response, From}, ok; Error -> p("invalid inform: ~n Error: ~p", [Error]), Error end; {Err, Idx, VBs} -> p("unexpected error status: " "~n Err: ~p" "~n Idx: ~p" "~n VBs: ~p", [Err, Idx, VBs]), Reason = {unexpected_status, {Err, Idx, VBs}}, {error, Reason} end after 10000 -> receive Any -> {error, {timeout_crap, Any}} after 1000 -> {error, timeout} end end end, Cmd5 = fun() -> receive {async_event, From, {inform, Pid, Inform}} -> p("received inform"), case Inform of {noError, 0, VBs} when is_list(VBs) -> case (catch validate_testTrapv22_vbs(MgrNode, VBs)) of ok -> p("valid inform"), Pid ! {handle_inform_response, From}, ok; Error -> p("invalid inform: ~n Error: ~p", [Error]), Error end; {Err, Idx, VBs} -> p("unexpected error status: " "~n Err: ~p" "~n Idx: ~p" "~n VBs: ~p", [Err, Idx, VBs]), Reason = {unexpected_status, {Err, Idx, VBs}}, {error, Reason} end after 20000 -> receive Any -> {error, {timeout_crap, Any}} after 1000 -> {error, timeout} end end end, Cmd6 = fun() -> receive {snmp_notification, inform2_tag1, {got_response, Addr}} -> p("received expected \"got response\" notification " "from: " "~n ~p", [Addr]), ok; {snmp_notification, inform2_tag1, {no_response, Addr}} -> p(" received expected \"no response\" " "notification from: " "~n ~p", [Addr]), {error, no_response} after 10000 -> receive Any -> {error, {timeout_crap, Any}} after 1000 -> {error, timeout} end end end, Cmd7 = fun() -> ?SLEEP(5000), ok end, Commands = [ {1, "Manager and agent info at start of test", Cmd1}, {2, "Send notifcation [no receiver] from agent", Cmd2}, {3, "Await inform-sent acknowledge from agent", Cmd3}, {4, "Await first inform to manager - do not reply", Cmd4}, {5, "Await second inform to manager - reply", Cmd5}, {6, "await inform-acknowledge from agent", Cmd6}, {7, "Sleep some time (5 sec)", Cmd7}, {8, "Manager and agent info after test completion", Cmd1} ], command_handler(Commands), display_log(Config), ok. %%====================================================================== inform3(suite) -> []; inform3(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname,i3), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), ?line ok = mgr_user_load_mib(MgrNode, snmpv2_mib()), Test2Mib = test2_mib(Config), TestTrapMib = test_trap_mib(Config), TestTrapv2Mib = test_trap_v2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapMib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapv2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, TestTrapMib), ?line ok = agent_load_mib(AgentNode, TestTrapv2Mib), Cmd1 = fun() -> p("manager info: ~n~p", [mgr_info(MgrNode)]), p("agent info: ~n~p", [agent_info(AgentNode)]), ok end, Cmd2 = fun() -> agent_send_notif(AgentNode, testTrapv22, {inform3_tag1, self()}, "standard inform", []), ok end, Cmd3 = fun() -> receive {snmp_targets, inform3_tag1, [_Addr]} -> p("received inform-sent acknowledgement", []), ok after 10000 -> receive Crap -> {error, {timeout_crap, Crap}} after 0 -> {error, timeout} end end end, Cmd4 = fun() -> receive {async_event, From, {inform, Pid, Inform}} -> p("received inform"), case Inform of {noError, 0, VBs} when is_list(VBs) -> case (catch validate_testTrapv22_vbs(MgrNode, VBs)) of ok -> p("valid inform"), Pid ! {handle_inform_no_response, From}, ok; Error -> p("invalid inform: ~n Error: ~p", [Error]), Error end; {Err, Idx, VBs} -> p("unexpected error status: " "~n Err: ~p" "~n Idx: ~p" "~n VBs: ~p", [Err, Idx, VBs]), Reason = {unexpected_status, {Err, Idx, VBs}}, {error, Reason} end after 50000 -> receive Any -> {error, {timeout_crap, Any}} after 0 -> {error, timeout} end end end, Cmd7 = fun() -> receive {snmp_notification, inform3_tag1, {no_response, Addr}} -> p("received expected \"no response\" notification " "from: " "~n ~p", [Addr]), ok; {snmp_notification, inform3_tag1, {got_response, Addr}} -> p(" received unexpected \"got response\" " "notification from: " "~n ~p", [Addr]), {error, {got_response, Addr}} after 120000 -> receive Crap -> {error, {timeout_crap, Crap}} after 0 -> {error, timeout} end end end, Cmd8 = fun() -> ?SLEEP(1000), ok end, Commands = [ {1, "Manager and agent info at start of test", Cmd1}, {2, "Send notifcation from agent", Cmd2}, {3, "await inform-sent acknowledge from agent", Cmd3}, {4, "Await first inform to manager - do not reply", Cmd4}, {5, "Await first inform to manager - do not reply", Cmd4}, {6, "Await first inform to manager - do not reply", Cmd4}, {7, "await inform-acknowledge from agent", Cmd7}, {8, "Sleep some time (1 sec)", Cmd8}, {9, "Manager and agent info after test completion", Cmd1} ], command_handler(Commands), display_log(Config), ok. %%====================================================================== inform4(suite) -> []; inform4(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname,i4), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), ?line ok = mgr_user_load_mib(MgrNode, snmpv2_mib()), Test2Mib = test2_mib(Config), TestTrapMib = test_trap_mib(Config), TestTrapv2Mib = test_trap_v2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapMib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapv2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, TestTrapMib), ?line ok = agent_load_mib(AgentNode, TestTrapv2Mib), Cmd1 = fun() -> p("manager info: ~n~p", [mgr_info(MgrNode)]), p("agent info: ~n~p", [agent_info(AgentNode)]), ok end, Cmd2 = fun() -> agent_send_notif(AgentNode, testTrapv22, "standard inform"), ok end, Cmd3 = fun() -> receive {async_event, From, {inform, Pid, Inform}} -> p("received inform"), case Inform of {noError, 0, VBs} when is_list(VBs) -> case (catch validate_testTrapv22_vbs(MgrNode, VBs)) of ok -> p("valid inform"), %% Actually, as we have %% configured the manager in %% this test case (irb = auto) %% it has already responded Pid ! {handle_inform_response, From}, ok; Error -> p("invalid inform: ~n Error: ~p", [Error]), Error end; {Err, Idx, VBs} -> p("unexpected error status: " "~n Err: ~p" "~n Idx: ~p" "~n VBs: ~p", [Err, Idx, VBs]), Reason = {unexpected_status, {Err, Idx, VBs}}, {error, Reason} end after 20000 -> receive Any -> {error, {crap, Any}} after 1000 -> {error, timeout} end end end, %% This is the a result of erroneous configuration. %% Cmd4 = %% fun() -> %% receive %% {async_event, _ReqId, {error, Reason}} -> %% p("received error"), %% case Reason of %% {failed_processing_message, %% {securityError, usmStatsUnknownEngineIDs}} -> %% p("expected error"), %% ok; %% _ -> %% p("unexpected error: " %% "~n Reason: ~p", [Reason]), %% {error, {unexpected_error, Reason}} %% end %% after 20000 -> %% receive %% Any -> %% {error, {crap, Any}} %% after 1000 -> %% {error, timeout} %% end %% end %% end, Cmd5 = fun() -> ?SLEEP(1000), ok end, Commands = [ {1, "Manager and agent info at start of test", Cmd1}, {2, "Send notifcation [no receiver] from agent", Cmd2}, {3, "Await inform to manager", Cmd3}, %% {4, "Await error info (because of erroneous config)", Cmd4}, {5, "Sleep some time (1 sec)", Cmd5}, {6, "Manager and agent info after test completion", Cmd1} ], command_handler(Commands), display_log(Config), ok. %%====================================================================== %% %% Test: ts:run(snmp, snmp_manager_test, inform_swarm, [batch]). inform_swarm(suite) -> []; inform_swarm(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, is), p("starting with Config: ~p~n", [Config]), MgrNode = ?config(manager_node, Config), AgentNode = ?config(agent_node, Config), ?line ok = mgr_user_load_mib(MgrNode, snmpv2_mib()), Test2Mib = test2_mib(Config), TestTrapMib = test_trap_mib(Config), TestTrapv2Mib = test_trap_v2_mib(Config), ?line ok = mgr_user_load_mib(MgrNode, Test2Mib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapMib), ?line ok = mgr_user_load_mib(MgrNode, TestTrapv2Mib), ?line ok = agent_load_mib(AgentNode, Test2Mib), ?line ok = agent_load_mib(AgentNode, TestTrapMib), ?line ok = agent_load_mib(AgentNode, TestTrapv2Mib), NumInforms = 100, Collector = self(), Generator = erlang:spawn( fun() -> receive {Collector, start} -> ok end, Seqs = lists:seq(1, NumInforms), lists:foreach( fun(N) -> p("send notification ~w", [N]), agent_send_notif(AgentNode, testTrapv22, {{inform2_tag1, N}, Collector}, "standard inform", []), %% Sleep some [(N div 10)*100 ms] %% every tenth notification if N rem 10 == 0 -> %% Time to sleep some Sleep = (N div 10) * 50, p("sleep ~w [~w]", [Sleep, N]), ?SLEEP(Sleep); true -> ok end end, Seqs), ok end), Cmd1 = fun() -> p("manager info: ~n~p", [mgr_info(MgrNode)]), p("agent info: ~n~p", [agent_info(AgentNode)]), ok end, Cmd2 = fun() -> Generator ! {Collector, start}, ok end, Cmd3 = fun() -> inform_swarm_collector(NumInforms) end, Cmd4 = fun() -> ?SLEEP(1000), ok end, Commands = [ {1, "Manager and agent info at start of test", Cmd1}, {2, "Send notifcation(s) from agent", Cmd2}, {3, "Await send-ack(s)/inform(s)/response(s)", Cmd3}, {4, "Sleep some time (1 sec)", Cmd4}, {5, "Manager and agent info after test completion", Cmd1} ], command_handler(Commands), display_log(Config), ok. inform_swarm_collector(N) -> inform_swarm_collector(N, 0, 0, 0, 10000). %% Note that we need to deal with re-transmissions! %% That is, the agent did not receive the ack in time, %% and therefor did a re-transmit. This means that we %% expect to receive more inform's then we actually %% sent. So for sucess we assume: %% %% SentAckCnt = N %% RespCnt = N %% RecvCnt >= N %% inform_swarm_collector(N, SentAckCnt, RecvCnt, RespCnt, _) when ((N == SentAckCnt) and (N == RespCnt) and (N =< RecvCnt)) -> p("inform_swarm_collector -> done when" "~n N: ~w" "~n SentAckCnt: ~w" "~n RecvCnt: ~w" "~n RespCnt: ~w", [N, SentAckCnt, RecvCnt, RespCnt]), ok; inform_swarm_collector(N, SentAckCnt, RecvCnt, RespCnt, Timeout) -> p("inform_swarm_collector -> entry with" "~n N: ~w" "~n SentAckCnt: ~w" "~n RecvCnt: ~w" "~n RespCnt: ~w", [N, SentAckCnt, RecvCnt, RespCnt]), receive {snmp_targets, {inform2_tag1, Id}, [_Addr]} -> p("received inform-sent acknowledgement for ~w", [Id]), inform_swarm_collector(N, SentAckCnt+1, RecvCnt, RespCnt, Timeout); %% The manager has received the actual inform {async_event, From, {inform, Pid, Inform}} -> p("received inform"), case Inform of {noError, 0, VBs} when is_list(VBs) -> Pid ! {handle_inform_response, From}, inform_swarm_collector(N, SentAckCnt, RecvCnt+1, RespCnt, Timeout); {Err, Idx, VBs} -> p(" unexpected error status: " "~n Err: ~p" "~n Idx: ~p" "~n VBs: ~p", [Err, Idx, VBs]), Reason = {unexpected_status, {Err, Idx, VBs}}, {error, Reason} end; %% The agent has received ack from the manager {snmp_notification, {inform2_tag1, Id}, {got_response, Addr}} -> p("received expected \"got response\" for ~w" "notification from: " "~n ~p", [Id, Addr]), inform_swarm_collector(N, SentAckCnt, RecvCnt, RespCnt+1, Timeout); %% The agent did not received ack from the manager in time {snmp_notification, inform2_tag1, {no_response, Addr}} -> p(" received expected \"no response\" notification " "from: " "~n ~p", [Addr]), Reason = {no_response, Addr, {N, SentAckCnt, RecvCnt, RespCnt}}, {error, Reason} after Timeout -> %% Give up when we have been dead in the water for Timeout ms {error, {timeout, N, SentAckCnt, RecvCnt, RespCnt}} end. %%====================================================================== report(suite) -> []; report(Config) when is_list(Config) -> ?SKIP(not_yet_implemented). %%====================================================================== otp8015_1(doc) -> ["OTP-8015:1 - testing the new api-function."]; otp8015_1(suite) -> []; otp8015_1(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, otp8015_1), p("starting with Config: ~p~n", [Config]), ConfDir = ?config(manager_conf_dir, Config), DbDir = ?config(manager_db_dir, Config), write_manager_conf(ConfDir), Opts = [{server, [{verbosity, trace}]}, {net_if, [{verbosity, trace}]}, {note_store, [{verbosity, trace}]}, {config, [{verbosity, trace}, {dir, ConfDir}, {db_dir, DbDir}]}], p("starting manager"), ok = snmpm:start_link(Opts), ?SLEEP(1000), snmpm:load_mib(std_mib()), snmpm:load_mib(test_trap_mib(Config)), p("manager started, now sleep some"), ?SLEEP(1000), p("loaded mibs: ~p", [snmpm:which_mibs()]), p("get some type(s) from the mibs"), {ok, 'Counter32'} = snmpm:oid_to_type(?snmpOutTraps), {ok, [IfIndex]} = snmpm:name_to_oid(ifIndex), {ok, 'INTEGER'} = snmpm:oid_to_type(IfIndex), p("stop manager"), ok = snmpm:stop(), ?SLEEP(1000), p("end"), ok. %%====================================================================== otp8395_1(doc) -> ["OTP-8395:1 - simple get with ATL sequence numbering."]; otp8395_1(suite) -> []; otp8395_1(Config) when is_list(Config) -> process_flag(trap_exit, true), put(tname, otp8395_1), do_simple_sync_get2(Config). %%====================================================================== %% async snmp utility functions %%====================================================================== async_exec([], Acc) -> p("all async request's sent => now await reponses"), async_verify(async_collector(Acc, [])); async_exec([{Id, Data, Exec, Ver}|Reqs], Acc) -> p("issue async request ~w", [Id]), ?line {ok, ReqId} = Exec(Data), async_exec(Reqs, [{ReqId, Id, Ver}|Acc]). async_collector([], Acc) -> p("received replies for all requests - now sort"), lists:keysort(1, Acc); async_collector(Expected, Acc) -> receive {async_event, ReqId, Reply} -> p("received async event with request-id ~w", [ReqId]), case lists:keysearch(ReqId, 1, Expected) of {value, {_, Id, Ver}} -> p("event was for request ~w", [Id]), Expected2 = lists:keydelete(ReqId, 1, Expected), async_collector(Expected2, [{Id, Ver, Reply}|Acc]); false -> % Duplicate reply? ?FAIL({unexpected_async_event, ReqId, Reply}) end after 10000 -> ?FAIL({timeout, {Expected, Acc}}) end. async_verify([]) -> ok; async_verify([{Id, Verify, Reply}|Replies]) -> p("verify reply ~w", [Id]), Verify(Reply), async_verify(Replies). %%====================================================================== %% Internal functions %%====================================================================== %% -- Verify varbinds -- validate_vbs(Node, ExpVBs, VBs) -> validate_vbs(purify_oids(Node, ExpVBs), VBs). validate_testTrapv22_vbs(Node, VBs) -> ExpVBs = [{[sysUpTime, 0], any}, {[snmpTrapOID, 0], ?system ++ [0,1]}], validate_vbs(purify_oids(Node, ExpVBs), VBs). validate_vbs([], []) -> ok; validate_vbs(Exp, []) -> {error, {expected_vbs, Exp}}; validate_vbs([], VBs) -> {error, {unexpected_vbs, VBs}}; validate_vbs([any|Exp], [_|VBs]) -> validate_vbs(Exp, VBs); validate_vbs([{_, any}|Exp], [#varbind{}|VBs]) -> validate_vbs(Exp, VBs); validate_vbs([{Oid, Val}|Exp], [#varbind{oid = Oid, value = Val}|VBs]) -> validate_vbs(Exp, VBs); validate_vbs([{Oid, Val1}|_], [#varbind{oid = Oid, value = Val2}|_]) -> {error, {unexpected_vb_value, Oid, Val1, Val2}}; validate_vbs([{Oid1, _}|_], [#varbind{oid = Oid2}|_]) -> {error, {unexpected_vb_oid, Oid1, Oid2}}. purify_oids(_, []) -> []; purify_oids(Node, [{Oid, Val}|Oids]) -> [{purify_oid(Node, Oid), Val}| purify_oids(Node, Oids)]. purify_oid(Node, Oid) -> case mgr_user_purify_oid(Node, Oid) of Oid2 when is_list(Oid2) -> Oid2; {error, _} = Error -> throw(Error) end. %% -- Test case command handler (executor) --- command_handler([]) -> ok; command_handler([{No, Desc, Cmd}|Cmds]) -> p("command_handler -> command ~w: " "~n ~s", [No, Desc]), case (catch Cmd()) of ok -> p("command_handler -> ~w: ok",[No]), command_handler(Cmds); {error, Reason} -> p(" command_handler -> ~w error: ~n~p",[No, Reason]), ?line ?FAIL({command_failed, No, Reason}); Error -> p(" command_handler -> ~w unexpected: ~n~p",[No, Error]), ?line ?FAIL({unexpected_command_result, No, Error}) end. %% -- Misc manager functions -- init_manager(AutoInform, Config) -> ?LOG("init_manager -> entry with" "~n AutoInform: ~p" "~n Config: ~p", [AutoInform, Config]), %% -- %% Start node %% ?line Node = start_manager_node(), %% The point with this (try catch block) is to be %% able to do some cleanup in case we fail to %% start some of the apps. That is, if we fail to %% start the apps (mnesia, crypto and snmp agent) %% we stop the (agent) node! try begin %% -- %% Start and initiate crypto on manager node %% ?line ok = init_crypto(Node), %% %% Write manager config %% ?line ok = write_manager_config(Config), IRB = case AutoInform of true -> auto; _ -> user end, Conf = [{manager_node, Node}, {irb, IRB} | Config], Vsns = [v1,v2,v3], start_manager(Node, Vsns, Conf) end catch T:E -> StackTrace = ?STACK(), p("Failure during manager start: " "~n Error Type: ~p" "~n Error: ~p" "~n StackTrace: ~p", [T, E, StackTrace]), %% And now, *try* to cleanup (catch stop_node(Node)), ?FAIL({failed_starting_manager, T, E, StackTrace}) end. fin_manager(Config) -> Node = ?config(manager_node, Config), StopMgrRes = stop_manager(Node), StopCryptoRes = fin_crypto(Node), StopNode = stop_node(Node), p("fin_agent -> stop apps and (mgr node ~p) node results: " "~n SNMP Mgr: ~p" "~n Crypto: ~p" "~n Node: ~p", [Node, StopMgrRes, StopCryptoRes, StopNode]), Config. %% -- Misc agent functions -- init_agent(Config) -> ?LOG("init_agent -> entry with" "~n Config: ~p", [Config]), %% -- %% Retrieve some dir's %% Dir = ?config(agent_dir, Config), MibDir = ?config(mib_dir, Config), %% -- %% Start node %% ?line Node = start_agent_node(), %% The point with this (try catch block) is to be %% able to do some cleanup in case we fail to %% start some of the apps. That is, if we fail to %% start the apps (mnesia, crypto and snmp agent) %% we stop the (agent) node! try begin %% -- %% Start and initiate mnesia on agent node %% ?line ok = init_mnesia(Node, Dir, ?config(mnesia_debug, Config)), %% -- %% Start and initiate crypto on agent node %% ?line ok = init_crypto(Node), %% %% Write agent config %% Vsns = [v1,v2], ?line ok = write_agent_config(Vsns, Config), Conf = [{agent_node, Node}, {mib_dir, MibDir} | Config], %% %% Start the agent %% start_agent(Node, Vsns, Conf) end catch T:E -> StackTrace = ?STACK(), p("Failure during agent start: " "~n Error Type: ~p" "~n Error: ~p" "~n StackTrace: ~p", [T, E, StackTrace]), %% And now, *try* to cleanup (catch stop_node(Node)), ?FAIL({failed_starting_agent, T, E, StackTrace}) end. fin_agent(Config) -> Node = ?config(agent_node, Config), StopAgentRes = stop_agent(Node), StopCryptoRes = fin_crypto(Node), StopMnesiaRes = fin_mnesia(Node), StopNode = stop_node(Node), p("fin_agent -> stop apps and (agent node ~p) node results: " "~n SNMP Agent: ~p" "~n Crypto: ~p" "~n Mnesia: ~p" "~n Node: ~p", [Node, StopAgentRes, StopCryptoRes, StopMnesiaRes, StopNode]), Config. init_mnesia(Node, Dir, MnesiaDebug) when ((MnesiaDebug =/= none) andalso (MnesiaDebug =/= debug) andalso (MnesiaDebug =/= trace)) -> init_mnesia(Node, Dir, ?DEFAULT_MNESIA_DEBUG); init_mnesia(Node, Dir, MnesiaDebug) -> ?DBG("init_mnesia -> load application mnesia", []), ?line ok = load_mnesia(Node), ?DBG("init_mnesia -> application mnesia: set_env dir: ~n~p",[Dir]), ?line ok = set_mnesia_env(Node, dir, filename:join(Dir, "mnesia")), %% Just in case, only set (known to be) valid values for debug if ((MnesiaDebug =:= debug) orelse (MnesiaDebug =:= trace)) -> ?DBG("init_mnesia -> application mnesia: set_env debug: ~w", [MnesiaDebug]), ?line ok = set_mnesia_env(Node, debug, MnesiaDebug); true -> ok end, ?DBG("init_mnesia -> create mnesia schema",[]), ?line case create_schema(Node) of ok -> ok; {error, {Node, {already_exists, Node}}} -> ?line ok = delete_schema(Node), ?line ok = create_schema(Node); Error -> ?FAIL({failed_creating_mnesia_schema, Error}) end, ?DBG("init_mnesia -> start application mnesia",[]), ?line ok = start_mnesia(Node), ?DBG("init_mnesia -> create tables",[]), ?line ok = create_tables(Node), ok. fin_mnesia(Node) -> ?line ok = delete_tables(Node), ?line ok = stop_mnesia(Node), ok. init_crypto(Node) -> ?line ok = load_crypto(Node), ?line ok = start_crypto(Node), ok. fin_crypto(Node) -> ?line ok = stop_crypto(Node), ok. %% -- Misc application wrapper functions -- load_app(Node, App) -> VerifySuccess = fun(ok) -> ok; ({error, {already_loaded, LoadedApp}}) when (LoadedApp =:= App) -> ok; ({error, Reason}) -> p("failed loading app ~w on ~p: " "~n ~p", [App, Node, Reason]), ?FAIL({failed_load, Node, App, Reason}) end, do_load_app(Node, App, VerifySuccess). do_load_app(Node, App, VerifySuccess) when (Node =:= node()) andalso is_atom(App) -> %% Local app exec(fun() -> application:load(App) end, VerifySuccess); do_load_app(Node, App, VerifySuccess) -> %% Remote app exec(fun() -> rcall(Node, application, load, [App]) end, VerifySuccess). start_app(Node, App) -> VerifySuccess = fun(ok) -> ok; ({error, {already_started, LoadedApp}}) when (LoadedApp =:= App) -> ok; ({error, Reason}) -> p("failed starting app ~w on ~p: " "~n ~p", [App, Node, Reason]), ?FAIL({failed_start, Node, App, Reason}) end, start_app(Node, App, VerifySuccess). start_app(Node, App, VerifySuccess) when (Node =:= node()) andalso is_atom(App) -> exec(fun() -> application:start(App) end, VerifySuccess); start_app(Node, App, VerifySuccess) -> exec(fun() -> rcall(Node, application, start, [App]) end, VerifySuccess). stop_app(Node, App) -> VerifySuccess = fun(ok) -> ok; ({error, {not_started, LoadedApp}}) when (LoadedApp =:= App) -> ok; ({error, Reason}) -> p("failed stopping app ~w on ~p: " "~n ~p", [App, Node, Reason]), ?FAIL({failed_stop, Node, App, Reason}) end, stop_app(Node, App, VerifySuccess). stop_app(Node, App, VerifySuccess) when (Node =:= node()) andalso is_atom(App) -> exec(fun() -> application:stop(App) end, VerifySuccess); stop_app(Node, App, VerifySuccess) when is_atom(App) -> exec(fun() -> rcall(Node, application, stop, [App]) end, VerifySuccess). set_app_env(Node, App, Key, Val) -> VerifySuccess = fun(ok) -> ok; ({error, Reason}) -> p("failed setting app ~w env on ~p" "~n Key: ~p" "~n Val: ~p" "~n Reason: ~p" "~n ~p", [App, Node, Key, Val, Reason]), ?FAIL({failed_set_app_env, Node, App, Key, Val, Reason}) end, set_app_env(Node, App, Key, Val, VerifySuccess). set_app_env(Node, App, Key, Val, VerifySuccess) when (Node =:= node()) andalso is_atom(App) -> exec(fun() -> application:set_env(App, Key, Val) end, VerifySuccess); set_app_env(Node, App, Key, Val, VerifySuccess) when is_atom(App) -> exec(fun() -> rcall(Node, application, set_env, [App, Key, Val]) end, VerifySuccess). exec(Cmd, VerifySuccess) -> VerifySuccess(Cmd()). %% -- Misc snmp wrapper functions -- load_snmp(Node) -> load_app(Node, snmp). start_snmp(Node) -> start_app(Node, snmp). stop_snmp(Node) -> stop_app(Node, snmp). set_agent_env(Node, Env) -> set_snmp_env(Node, agent, Env). set_mgr_env(Node, Env) -> set_snmp_env(Node, manager, Env). set_snmp_env(Node, Entity, Env) -> set_app_env(Node, snmp, Entity, Env). mgr_info(Node) -> rcall(Node, snmpm, info, []). mgr_sys_info(Node) -> rcall(Node, snmpm_config, system_info, []). %% mgr_register_user(Node, Id, Data) -> %% mgr_register_user(Node, Id, ?MODULE, Data). mgr_register_user(Node, Id, Mod, Data) when is_atom(Mod) -> rcall(Node, snmpm, register_user, [Id, Mod, Data]). mgr_unregister_user(Node, Id) -> rcall(Node, snmpm, unregister_user, [Id]). mgr_which_users(Node) -> rcall(Node, snmpm, which_users, []). %% mgr_register_agent(Node, Id) -> %% mgr_register_agent(Node, Id, []). %% mgr_register_agent(Node, Id, Conf) when is_list(Conf) -> %% mgr_register_agent(Node, Id, 5000, Conf). mgr_register_agent(Node, Id, Port, Conf) when is_integer(Port) andalso is_list(Conf) -> Localhost = snmp_test_lib:localhost(), mgr_register_agent(Node, Id, Localhost, Port, Conf); mgr_register_agent(Node, Id, TargetName, Config) when is_list(TargetName) andalso is_list(Config) -> rcall(Node, snmpm, register_agent, [Id, TargetName, Config]). mgr_register_agent(Node, Id, Addr, Port, Conf) when is_integer(Port) andalso is_list(Conf) -> rcall(Node, snmpm, register_agent, [Id, Addr, Port, Conf]). %% mgr_unregister_agent(Node, Id) -> %% mgr_unregister_agent(Node, Id, 4000). mgr_unregister_agent(Node, Id, Port) when is_integer(Port) -> Localhost = snmp_test_lib:localhost(), rcall(Node, snmpm, unregister_agent, [Id, Localhost, Port]); mgr_unregister_agent(Node, Id, TargetName) when is_list(TargetName) -> rcall(Node, snmpm, unregister_agent, [Id, TargetName]). mgr_which_agents(Node) -> rcall(Node, snmpm, which_agents, []). mgr_which_agents(Node, Id) -> rcall(Node, snmpm, which_agents, [Id]). %% -- Misc crypto wrapper functions -- load_crypto(Node) -> load_app(Node, crypto). start_crypto(Node) -> start_app(Node, crypto). stop_crypto(Node) -> stop_app(Node, crypto). %% -- Misc mnesia wrapper functions -- load_mnesia(Node) -> load_app(Node, mnesia). start_mnesia(Node) -> start_app(Node, mnesia). stop_mnesia(Node) -> stop_app(Node, mnesia). set_mnesia_env(Node, Key, Val) -> set_app_env(Node, mnesia, Key, Val). create_schema(Node) -> rcall(Node, mnesia, create_schema, [[Node]]). delete_schema(Node) -> rcall(Node, mnesia, delete_schema, [[Node]]). create_table(Node, Table) -> rcall(Node, mnesia, create_table, [Table]). delete_table(Node, Table) -> rcall(Node, mnesia, delete_table, [Table]). create_tables(Node) -> Tab1 = [{name, friendsTable2}, {ram_copies, [Node]}, {snmp, [{key, integer}]}, {attributes, [a1,a2,a3]}], Tab2 = [{name, kompissTable2}, {ram_copies, [Node]}, {snmp, [{key, integer}]}, {attributes, [a1,a2,a3]}], Tab3 = [{name, snmp_variables}, {attributes, [a1,a2]}], Tabs = [Tab1, Tab2, Tab3], create_tables(Node, Tabs). create_tables(_Node, []) -> ok; create_tables(Node, [Tab|Tabs]) -> case create_table(Node, Tab) of {atomic, ok} -> create_tables(Node, Tabs); Error -> ?FAIL({failed_creating_table, Node, Tab, Error}) end. delete_tables(Node) -> Tabs = [friendsTable2, kompissTable2, snmp_variables], delete_tables(Node, Tabs). %% delete_mib_storage_tables(Node) -> %% Tabs = [snmpa_mib_data, snmpa_mib_tree, snmpa_symbolic_store], %% delete_tables(Node, Tabs). delete_tables(Node, Tabs) -> lists:foreach(fun(Tab) -> delete_table(Node, Tab) end, Tabs). %% -- Misc manager user wrapper functions -- init_mgr_user(Conf) -> ?DBG("init_mgr_user -> entry with" "~n Conf: ~p", [Conf]), Node = ?config(manager_node, Conf), %% UserId = ?config(user_id, Conf), ?line {ok, User} = mgr_user_start(Node), ?DBG("start_mgr_user -> User: ~p", [User]), link(User), [{user_pid, User} | Conf]. fin_mgr_user(Conf) -> User = ?config(user_pid, Conf), unlink(User), Node = ?config(manager_node, Conf), ?line ok = mgr_user_stop(Node), Conf. init_mgr_user_data1(Conf) -> Node = ?config(manager_node, Conf), TargetName = ?config(manager_agent_target_name, Conf), IpFamily = ?config(ipfamily, Conf), Ip = ?config(ip, Conf), Port = ?AGENT_PORT, ?line ok = case IpFamily of inet -> mgr_user_register_agent( Node, TargetName, [{address, Ip}, {port, Port}, {engine_id, "agentEngine"}]); inet6 -> mgr_user_register_agent( Node, TargetName, [{tdomain, transportDomainUdpIpv6}, {taddress, {Ip, Port}}, {engine_id, "agentEngine"}]) end, _Agents = mgr_user_which_own_agents(Node), ?DBG("Own agents: ~p", [_Agents]), ?line {ok, _DefAgentConf} = mgr_user_agent_info(Node, TargetName, all), ?DBG("Default agent config: ~n~p", [_DefAgentConf]), ?line ok = mgr_user_update_agent_info(Node, TargetName, community, "all-rights"), ?line ok = mgr_user_update_agent_info(Node, TargetName, sec_name, "all-rights"), ?line ok = mgr_user_update_agent_info(Node, TargetName, engine_id, "agentEngine"), ?line ok = mgr_user_update_agent_info(Node, TargetName, max_message_size, 1024), ?line {ok, _AgentConf} = mgr_user_agent_info(Node, TargetName, all), ?DBG("Updated agent config: ~n~p", [_AgentConf]), Conf. init_mgr_user_data2(Conf) -> ?DBG("init_mgr_user_data2 -> entry with" "~n Conf: ~p", [Conf]), Node = ?config(manager_node, Conf), TargetName = ?config(manager_agent_target_name, Conf), IpFamily = ?config(ipfamily, Conf), Ip = ?config(ip, Conf), Port = ?AGENT_PORT, ?line ok = case IpFamily of inet -> mgr_user_register_agent( Node, TargetName, [{address, Ip}, {port, Port}, {engine_id, "agentEngine"}]); inet6 -> mgr_user_register_agent( Node, TargetName, [{tdomain, transportDomainUdpIpv6}, {taddress, {Ip, Port}}, {engine_id, "agentEngine"}]) end, _Agents = mgr_user_which_own_agents(Node), ?DBG("Own agents: ~p", [_Agents]), ?line {ok, _DefAgentConf} = mgr_user_agent_info(Node, TargetName, all), ?DBG("Default agent config: ~n~p", [_DefAgentConf]), ?line ok = mgr_user_update_agent_info(Node, TargetName, community, "all-rights"), ?line ok = mgr_user_update_agent_info(Node, TargetName, sec_name, "all-rights"), ?line ok = mgr_user_update_agent_info(Node, TargetName, max_message_size, 1024), ?line {ok, _AgentConf} = mgr_user_agent_info(Node, TargetName, all), ?DBG("Updated agent config: ~n~p", [_AgentConf]), Conf. fin_mgr_user_data1(Conf) -> Node = ?config(manager_node, Conf), TargetName = ?config(manager_agent_target_name, Conf), mgr_user_unregister_agent(Node, TargetName), mgr_user_which_own_agents(Node), Conf. fin_mgr_user_data2(Conf) -> Node = ?config(manager_node, Conf), TargetName = ?config(manager_agent_target_name, Conf), mgr_user_unregister_agent(Node, TargetName), mgr_user_which_own_agents(Node), Conf. mgr_user_start(Node) -> mgr_user_start(Node, snmp_manager_test_user). mgr_user_start(Node, Id) -> rcall(Node, snmp_manager_user, start, [self(), Id]). mgr_user_stop(Node) -> rcall(Node, snmp_manager_user, stop, []). %% mgr_user_register_agent(Node) -> %% mgr_user_register_agent(Node, ?LOCALHOST(), ?AGENT_PORT, []). %% mgr_user_register_agent(Node, TargetName) when is_list(TargetName) -> %% mgr_user_register_agent(Node, TargetName, []); %% mgr_user_register_agent(Node, Addr) -> %% mgr_user_register_agent(Node, Addr, ?AGENT_PORT, []). mgr_user_register_agent(Node, TargetName, Conf) when is_list(TargetName) andalso is_list(Conf) -> rcall(Node, snmp_manager_user, register_agent, [TargetName, Conf]). %% %% mgr_user_register_agent(Node, Addr, Port) -> %% mgr_user_register_agent(Node, Addr, Port, []). %% mgr_user_register_agent(Node, Addr, Port, Conf) -> %% rcall(Node, snmp_manager_user, register_agent, [Addr, Port, Conf]). %% %% mgr_user_unregister_agent(Node) -> %% mgr_user_unregister_agent(Node, ?LOCALHOST(), ?AGENT_PORT). mgr_user_unregister_agent(Node, TargetName) when is_list(TargetName) -> rcall(Node, snmp_manager_user, unregister_agent, [TargetName]). %% %% mgr_user_unregister_agent(Node, Addr, Port) -> %% rcall(Node, snmp_manager_user, unregister_agent, [Addr, Port]). %% mgr_user_agent_info(Node, TargetName, Item) when is_list(TargetName) andalso is_atom(Item) -> rcall(Node, snmp_manager_user, agent_info, [TargetName, Item]). %% %% mgr_user_agent_info(Node, Addr, Port, Item) when is_atom(Item) -> %% rcall(Node, snmp_manager_user, agent_info, [Addr, Port, Item]). %% %% mgr_user_update_agent_info(Node, Item, Val) when atom(Item) -> %% mgr_user_update_agent_info(Node, ?LOCALHOST(), ?AGENT_PORT, Item, Val). mgr_user_update_agent_info(Node, TargetName, Item, Val) when is_list(TargetName) andalso is_atom(Item) -> rcall(Node, snmp_manager_user, update_agent_info, [TargetName, Item, Val]). %% %% mgr_user_update_agent_info(Node, Addr, Port, Item, Val) when is_atom(Item) -> %% rcall(Node, snmp_manager_user, update_agent_info, %% [Addr, Port, Item, Val]). %% %% mgr_user_which_all_agents(Node) -> %% rcall(Node, snmp_manager_user, which_all_agents, []). mgr_user_which_own_agents(Node) -> rcall(Node, snmp_manager_user, which_own_agents, []). mgr_user_load_mib(Node, Mib) -> rcall(Node, snmp_manager_user, load_mib, [Mib]). %% mgr_user_sync_get(Node, Oids) -> %% mgr_user_sync_get(Node, ?LOCALHOST(), ?AGENT_PORT, Oids). mgr_user_sync_get(Node, TargetName, Oids) when is_list(TargetName) -> rcall(Node, snmp_manager_user, sync_get, [TargetName, Oids]). %% mgr_user_sync_get(Node, Addr, Port, Oids) -> rcall(Node, snmp_manager_user, sync_get, [Addr, Port, Oids]). %% mgr_user_sync_get2(Node, TargetName, Oids, SendOpts) when is_list(TargetName) -> rcall(Node, snmp_manager_user, sync_get2, [TargetName, Oids, SendOpts]). %% mgr_user_async_get(Node, Oids) -> %% mgr_user_async_get(Node, ?LOCALHOST(), ?AGENT_PORT, Oids). mgr_user_async_get(Node, TargetName, Oids) when is_list(TargetName) -> rcall(Node, snmp_manager_user, async_get, [TargetName, Oids]). %% mgr_user_async_get(Node, Addr, Port, Oids) -> rcall(Node, snmp_manager_user, async_get, [Addr, Port, Oids]). %% mgr_user_async_get2(Node, TargetName, Oids, SendOpts) when is_list(TargetName) -> rcall(Node, snmp_manager_user, async_get2, [TargetName, Oids, SendOpts]). %% mgr_user_sync_get_next(Node, Oids) -> %% mgr_user_sync_get_next(Node, ?LOCALHOST(), ?AGENT_PORT, Oids). mgr_user_sync_get_next(Node, TargetName, Oids) when is_list(TargetName) -> rcall(Node, snmp_manager_user, sync_get_next, [TargetName, Oids]). %% mgr_user_sync_get_next(Node, Addr, Port, Oids) -> rcall(Node, snmp_manager_user, sync_get_next, [Addr, Port, Oids]). %% mgr_user_sync_get_next2(Node, TargetName, Oids, SendOpts) when is_list(TargetName) -> rcall(Node, snmp_manager_user, sync_get_next2, [TargetName, Oids, SendOpts]). %% mgr_user_async_get_next(Node, Oids) -> %% mgr_user_async_get_next(Node, ?LOCALHOST(), ?AGENT_PORT, Oids). mgr_user_async_get_next(Node, TargetName, Oids) when is_list(TargetName) -> rcall(Node, snmp_manager_user, async_get_next, [TargetName, Oids]). %% mgr_user_async_get_next(Node, Addr, Port, Oids) -> rcall(Node, snmp_manager_user, async_get_next, [Addr, Port, Oids]). %% mgr_user_async_get_next2(Node, TargetName, Oids, SendOpts) when is_list(TargetName) -> rcall(Node, snmp_manager_user, async_get_next2, [TargetName, Oids, SendOpts]). %% mgr_user_sync_set(Node, VAV) -> %% mgr_user_sync_set(Node, ?LOCALHOST(), ?AGENT_PORT, VAV). mgr_user_sync_set(Node, TargetName, VAV) when is_list(TargetName) -> rcall(Node, snmp_manager_user, sync_set, [TargetName, VAV]). %% mgr_user_sync_set(Node, Addr, Port, VAV) -> rcall(Node, snmp_manager_user, sync_set, [Addr, Port, VAV]). %% mgr_user_sync_set2(Node, TargetName, VAV, SendOpts) when is_list(TargetName) -> rcall(Node, snmp_manager_user, sync_set2, [TargetName, VAV, SendOpts]). %% mgr_user_async_set(Node, VAV) -> %% mgr_user_async_set(Node, ?LOCALHOST(), ?AGENT_PORT, VAV). mgr_user_async_set(Node, TargetName, VAV) when is_list(TargetName) -> rcall(Node, snmp_manager_user, async_set, [TargetName, VAV]). %% mgr_user_async_set(Node, Addr, Port, VAV) -> rcall(Node, snmp_manager_user, async_set, [Addr, Port, VAV]). %% mgr_user_async_set2(Node, TargetName, VAV, SendOpts) when is_list(TargetName) -> rcall(Node, snmp_manager_user, async_set2, [TargetName, VAV, SendOpts]). %% mgr_user_sync_get_bulk(Node, NonRep, MaxRep, Oids) -> %% mgr_user_sync_get_bulk(Node, ?LOCALHOST(), ?AGENT_PORT, %% NonRep, MaxRep, Oids). mgr_user_sync_get_bulk(Node, TargetName, NonRep, MaxRep, Oids) when is_list(TargetName) -> rcall(Node, snmp_manager_user, sync_get_bulk, [TargetName, NonRep, MaxRep, Oids]). %% mgr_user_sync_get_bulk(Node, Addr, Port, NonRep, MaxRep, Oids) -> rcall(Node, snmp_manager_user, sync_get_bulk, [Addr, Port, NonRep, MaxRep, Oids]). %% mgr_user_sync_get_bulk2(Node, TargetName, NonRep, MaxRep, Oids, SendOpts) when is_list(TargetName) -> rcall(Node, snmp_manager_user, sync_get_bulk2, [TargetName, NonRep, MaxRep, Oids, SendOpts]). %% mgr_user_async_get_bulk(Node, NonRep, MaxRep, Oids) -> %% mgr_user_async_get_bulk(Node, ?LOCALHOST(), ?AGENT_PORT, %% NonRep, MaxRep, Oids). mgr_user_async_get_bulk(Node, TargetName, NonRep, MaxRep, Oids) when is_list(TargetName) -> rcall(Node, snmp_manager_user, async_get_bulk, [TargetName, NonRep, MaxRep, Oids]). %% mgr_user_async_get_bulk(Node, Addr, Port, NonRep, MaxRep, Oids) -> rcall(Node, snmp_manager_user, async_get_bulk, [Addr, Port, NonRep, MaxRep, Oids]). %% mgr_user_async_get_bulk2(Node, TargetName, NonRep, MaxRep, Oids, SendOpts) when is_list(TargetName) -> rcall(Node, snmp_manager_user, async_get_bulk2, [TargetName, NonRep, MaxRep, Oids, SendOpts]). mgr_user_purify_oid(Node, Oid) -> rcall(Node, snmp_manager_user, purify_oid, [Oid]). mgr_user_name_to_oid(Node, Name) -> rcall(Node, snmp_manager_user, name_to_oid, [Name]). %% -- Misc manager wrapper functions -- start_manager(Node, Vsns, Config) -> start_manager(Node, Vsns, Config, []). start_manager(Node, Vsns, Conf0, _Opts) -> ?DBG("start_manager -> entry with" "~n Node: ~p" "~n Vsns: ~p" "~n Conf0: ~p" "~n Opts: ~p", [Node, Vsns, Conf0, _Opts]), AtlDir = ?config(manager_log_dir, Conf0), ConfDir = ?config(manager_conf_dir, Conf0), DbDir = ?config(manager_db_dir, Conf0), IRB = ?config(irb, Conf0), ConfigVerbosity = get_opt(manager_config_verbosity, Conf0, trace), NoteStoreVerbosity = get_opt(manager_note_store_verbosity, Conf0, log), ServerVerbosity = get_opt(manager_server_verbosity, Conf0, trace), NetIfVerbosity = get_opt(manager_net_if_verbosity, Conf0, trace), AtlSeqNo = get_opt(manager_atl_seqno, Conf0, false), NetIfConf = case get_opt(manager_net_if_module, Conf0, no_module) of no_module -> [{verbosity, NetIfVerbosity}]; NetIfModule -> [{module, NetIfModule}, {verbosity, NetIfVerbosity}] end, Env = [{versions, Vsns}, {inform_request_behaviour, IRB}, {audit_trail_log, [{type, read_write}, {dir, AtlDir}, {size, {10240, 10}}, {repair, true}, {seqno, AtlSeqNo}]}, {config, [{dir, ConfDir}, {db_dir, DbDir}, {verbosity, ConfigVerbosity}]}, {note_store, [{verbosity, NoteStoreVerbosity}]}, {server, [{verbosity, ServerVerbosity}]}, {net_if, NetIfConf}], ?line ok = set_mgr_env(Node, Env), ?line ok = start_snmp(Node), Conf0. stop_manager(Node) -> stop_snmp(Node). %% -- Misc agent wrapper functions -- start_agent(Node, Vsns, Config) -> start_agent(Node, Vsns, Config, []). start_agent(Node, Vsns, Conf0, _Opts) -> ?DBG("start_agent -> entry with" "~n Node: ~p" "~n Vsns: ~p" "~n Conf0: ~p" "~n Opts: ~p", [Node, Vsns, Conf0, _Opts]), AtlDir = ?config(agent_log_dir, Conf0), ConfDir = ?config(agent_conf_dir, Conf0), DbDir = ?config(agent_db_dir, Conf0), MAV = get_opt(agent_verbosity, Conf0, trace), CV = get_opt(agent_config_verbosity, Conf0, info), LDBV = get_opt(agent_local_db_verbosity, Conf0, info), MSV = get_opt(agent_mib_server_verbosity, Conf0, info), NSV = get_opt(agent_note_store_verbosity, Conf0, info), SSV = get_opt(agent_symbolic_store_verbosity, Conf0, info), NIV = get_opt(agent_net_if_verbosity, Conf0, log), Env = [{versions, Vsns}, {type, master}, {agent_verbosity, MAV}, {audit_trail_log, [{type, read_write}, {dir, AtlDir}, {size, {10240, 10}}, {repair, true}]}, {config, [{dir, ConfDir}, {force_load, false}, {verbosity, CV}]}, {db_dir, DbDir}, {local_db, [{repair, true}, {auto_save, 10000}, {verbosity, LDBV}]}, {mib_server, [{verbosity, MSV}]}, {note_store, [{verbosity, NSV}]}, {stymbolic_store, [{verbosity, SSV}]}, {net_if, [{verbosity, NIV}]}, {multi_threaded, true}], ?line ok = set_agent_env(Node, Env), ?line ok = start_snmp(Node), Conf0. stop_agent(Node) -> stop_snmp(Node). agent_load_mib(Node, Mib) -> rcall(Node, snmpa, load_mibs, [[Mib]]). %% agent_unload_mib(Node, Mib) -> %% rcall(Node, snmpa, unload_mibs, [[Mib]]). %% agent_send_trap(Node, Trap, Community) -> %% Args = [snmp_master_agent, Trap, Community], %% rcall(Node, snmpa, send_trap, Args). agent_send_trap(Node, Trap, Community, VBs) -> Args = [snmp_master_agent, Trap, Community, VBs], rcall(Node, snmpa, send_trap, Args). agent_send_notif(Node, Trap, Name) -> agent_send_notif(Node, Trap, Name, []). agent_send_notif(Node, Trap, Name, VBs) -> agent_send_notif(Node, Trap, no_receiver, Name, VBs). agent_send_notif(Node, Trap, Recv, Name, VBs) -> Args = [snmp_master_agent, Trap, Recv, Name, VBs], rcall(Node, snmpa, send_notification, Args). agent_info(Node) -> rcall(Node, snmpa, info, []). %% agent_which_mibs(Node) -> %% rcall(Node, snmpa, which_mibs, []). %% -- Misc node operation wrapper functions -- start_agent_node() -> start_node(snmp_agent). start_manager_node() -> start_node(snmp_manager). start_node(Name) -> Pa = filename:dirname(code:which(?MODULE)), Args = case init:get_argument('CC_TEST') of {ok, [[]]} -> " -pa /clearcase/otp/libraries/snmp/ebin "; {ok, [[Path]]} -> " -pa " ++ Path; error -> "" end, A = Args ++ " -pa " ++ Pa, case (catch ?START_NODE(Name, A)) of {ok, Node} -> Node; Else -> ?line ?FAIL(Else) end. stop_node(Node) -> rpc:cast(Node, erlang, halt, []), await_stopped(Node, 5). await_stopped(Node, 0) -> p("await_stopped -> ~p still exist: giving up", [Node]), ok; await_stopped(Node, N) -> Nodes = erlang:nodes(), case lists:member(Node, Nodes) of true -> p("await_stopped -> ~p still exist: ~w", [Node, N]), ?SLEEP(1000), await_stopped(Node, N-1); false -> p("await_stopped -> ~p gone: ~w", [Node, N]), ok end. %% -- Misc config wrapper functions -- write_manager_config(Config) -> Dir = ?config(manager_conf_dir, Config), Ip = tuple_to_list(?config(ip, Config)), {Addr, Port} = case ?config(ipfamily, Config) of inet -> {Ip, ?MGR_PORT}; inet6 -> {transportDomainUdpIpv6, {Ip, ?MGR_PORT}} end, snmp_config:write_manager_snmp_files( Dir, Addr, Port, ?MGR_MMS, ?MGR_ENGINE_ID, [], [], []). write_manager_conf(Dir) -> Port = "5000", MMS = "484", EngineID = "\"mgrEngine\"", Str = lists:flatten( io_lib:format("%% Minimum manager config file\n" "{port, ~s}.\n" "{max_message_size, ~s}.\n" "{engine_id, ~s}.\n", [Port, MMS, EngineID])), write_manager_conf(Dir, Str). %% write_manager_conf(Dir, IP, Port, MMS, EngineID) -> %% Str = lists:flatten( %% io_lib:format("{address, ~s}.\n" %% "{port, ~s}.\n" %% "{max_message_size, ~s}.\n" %% "{engine_id, ~s}.\n", %% [IP, Port, MMS, EngineID])), %% write_manager_conf(Dir, Str). write_manager_conf(Dir, Str) -> write_conf_file(Dir, "manager.conf", Str). write_agent_config(Vsns, Conf) -> Dir = ?config(agent_conf_dir, Conf), ?line Ip = tuple_to_list(?config(ip, Conf)), ?line Domain = case ?config(ipfamily, Conf) of inet -> snmpUDPDomain; inet6 -> transportDomainUdpIpv6 end, ?line ok = write_agent_config_files(Dir, Vsns, Domain, Ip), ?line ok = update_agent_usm(Vsns, Dir), ?line ok = update_agent_community(Vsns, Dir), ?line ok = update_agent_vacm(Vsns, Dir), ?line ok = write_agent_target_addr_conf(Dir, Domain, Ip, Vsns), ?line ok = write_agent_target_params_conf(Dir, Vsns), ?line ok = write_agent_notify_conf(Dir), ok. write_agent_config_files(Dir, Vsns, Domain, Ip) -> snmp_config:write_agent_snmp_files( Dir, Vsns, Domain, {Ip, ?MGR_PORT}, {Ip, ?AGENT_PORT}, "mgr-test", trap, none, "", ?AGENT_ENGINE_ID, ?AGENT_MMS). update_agent_usm(Vsns, Dir) -> case lists:member(v3, Vsns) of true -> Conf = [{"agentEngine", "all-rights", "all-rights", zeroDotZero, usmNoAuthProtocol, "", "", usmNoPrivProtocol, "", "", "", "", ""}, {"agentEngine", "no-rights", "no-rights", zeroDotZero, usmNoAuthProtocol, "", "", usmNoPrivProtocol, "", "", "", "", ""}, {"agentEngine", "authMD5", "authMD5", zeroDotZero, usmHMACMD5AuthProtocol, "", "", usmNoPrivProtocol, "", "", "", "passwd_md5xxxxxx", ""}, {"agentEngine", "authSHA", "authSHA", zeroDotZero, usmHMACSHAAuthProtocol, "", "", usmNoPrivProtocol, "", "", "", "passwd_shaxxxxxxxxxx", ""}, {"agentEngine", "privDES", "privDES", zeroDotZero, usmHMACSHAAuthProtocol, "", "", usmDESPrivProtocol, "", "", "", "passwd_shaxxxxxxxxxx", "passwd_desxxxxxx"}, {"mgrEngine", "all-rights", "all-rights", zeroDotZero, usmNoAuthProtocol, "", "", usmNoPrivProtocol, "", "", "", "", ""}, {"mgrEngine", "no-rights", "no-rights", zeroDotZero, usmNoAuthProtocol, "", "", usmNoPrivProtocol, "", "", "", "", ""}, {"mgrEngine", "authMD5", "authMD5", zeroDotZero, usmHMACMD5AuthProtocol, "", "", usmNoPrivProtocol, "", "", "", "passwd_md5xxxxxx", ""}, {"mgrEngine", "authSHA", "authSHA", zeroDotZero, usmHMACSHAAuthProtocol, "", "", usmNoPrivProtocol, "", "", "", "passwd_shaxxxxxxxxxx", ""}, {"mgrEngine", "privDES", "privDES", zeroDotZero, usmHMACSHAAuthProtocol, "", "", usmDESPrivProtocol, "", "", "", "passwd_shaxxxxxxxxxx", "passwd_desxxxxxx"}], snmp_config:update_agent_usm_config(Dir, Conf); false -> ok end. update_agent_community([v3], _Dir) -> ok; update_agent_community(_, Dir) -> Conf = [{"no-rights", "no-rights", "no-rights", "", ""}], snmp_config:update_agent_community_config(Dir, Conf). update_agent_vacm(_Vsns, Dir) -> Conf = [{vacmSecurityToGroup, usm, "authMD5", "initial"}, {vacmSecurityToGroup, usm, "authSHA", "initial"}, {vacmSecurityToGroup, usm, "privDES", "initial"}, {vacmSecurityToGroup, usm, "newUser", "initial"}, {vacmViewTreeFamily, "internet", ?tDescr_instance, excluded, null}], snmp_config:update_agent_vacm_config(Dir, Conf). write_agent_target_addr_conf(Dir, Domain, Ip, Vsns) -> snmp_config:write_agent_snmp_target_addr_conf( Dir, Domain, {Ip, ?MGR_PORT}, 300, 3, Vsns). write_agent_target_params_conf(Dir, Vsns) -> F = fun(v1) -> {"target_v1", v1, v1, "all-rights", noAuthNoPriv}; (v2) -> {"target_v2", v2c, v2c, "all-rights", noAuthNoPriv}; (v3) -> {"target_v3", v3, usm, "all-rights", noAuthNoPriv} end, Conf = [F(Vsn) || Vsn <- Vsns], snmp_config:write_agent_target_params_config(Dir, "", Conf). write_agent_notify_conf(Dir) -> Conf = [{"standard trap", "std_trap", trap}, {"standard inform", "std_inform", inform}], snmp_config:write_agent_notify_config(Dir, "", Conf). write_conf_file(Dir, File, Str) -> ?line {ok, Fd} = file:open(filename:join(Dir, File), write), ?line ok = io:format(Fd, "~s", [Str]), file:close(Fd). %% ------ display_log(Config) -> case lists:keysearch(manager_log_dir, 1, Config) of {value, {_, Dir}} -> case lists:keysearch(manager_node, 1, Config) of {value, {_, Node}} -> LogDir = Dir, Mibs = [], OutFile = j(LogDir, "snmpm_log.txt"), p("~n" "=========================" " < Audit Trail Log > " "=========================" "~n"), rcall(Node, snmpm, log_to_txt, [LogDir, Mibs, OutFile]), rcall(Node, snmpm, log_to_io, [LogDir, Mibs]), p("~n" "=========================" " < / Audit Trail Log > " "=========================" "~n"); false -> p("display_log -> no manager node found"), ok end; false -> p("display_log -> no manager log dir found"), ok end. %% ------ test2_mib(Config) -> j(test_mib_dir(Config), "Test2.bin"). test_trap_mib(Config) -> j(test_mib_dir(Config), "TestTrap.bin"). test_trap_v2_mib(Config) -> j(test_mib_dir(Config), "TestTrapv2.bin"). std_mib() -> j(mib_dir(), "STANDARD-MIB.bin"). snmpv2_mib() -> j(mib_dir(), "SNMPv2-MIB.bin"). test_mib_dir(Config) -> ?config(mib_dir, Config). mib_dir() -> j(code:priv_dir(snmp), "mibs"). j(A, B) -> filename:join(A, B). %% ------ get_opt(Key, Opts, Def) -> snmp_misc:get_option(Key, Opts, Def). %% ------ rcall(Node, Mod, Func, Args) -> case rpc:call(Node, Mod, Func, Args) of {badrpc, nodedown} -> ?FAIL({rpc_failure, Node}); Else -> Else end. %% ------ %% Time in milli sec %% t() -> %% {A,B,C} = os:timestamp(), %% A*1000000000+B*1000+(C div 1000). %% ------ p(F) -> p(F, []). p(F, A) -> p(get(tname), F, A). p(TName, F, A) -> io:format("*** [~w][~s] ***" "~n " ++ F ++ "~n", [TName, formated_timestamp()|A]). formated_timestamp() -> snmp_test_lib:formated_timestamp(). %% p(TName, F, A) -> %% io:format("~w -> " ++ F ++ "~n", [TName|A]). ipv6_init(Config) when is_list(Config) -> [{ipfamily, inet6} | Config].