%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2003-2017. All Rights Reserved.
%%
%% Licensed under the Apache License, Version 2.0 (the "License");
%% you may not use this file except in compliance with the License.
%% You may obtain a copy of the License at
%%
%% http://www.apache.org/licenses/LICENSE-2.0
%%
%% Unless required by applicable law or agreed to in writing, software
%% distributed under the License is distributed on an "AS IS" BASIS,
%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
%% See the License for the specific language governing permissions 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("common_test/include/ct.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]),
%% Preferably this test SUITE should be divided into groups
%% so that if crypto does not work only v3 tests that
%% need crypto will be skipped, but as this is only a
%% problem with one legacy test machine, we will procrastinate
%% until we have a more important reason to fix this.
case snmp_test_lib:crypto_start() of
ok ->
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];
_ ->
{skip, "Crypto did not start"}
end.
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, [], ipv6_tests()},
{ipv6_mt, [], ipv6_tests()}
].
ipv6_tests() ->
[
register_agent1,
simple_sync_get_next3,
simple_async_get2,
simple_sync_get3,
simple_async_get_next2,
simple_sync_set3,
simple_async_set2,
simple_sync_get_bulk2,
simple_async_get_bulk3,
misc_async2,
inform1,
inform_swarm
].
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 = GroupName, Config) ->
{ok, Hostname0} = inet:gethostname(),
case ct:require(ipv6_hosts) of
ok ->
case lists:member(list_to_atom(Hostname0), ct:get_config(ipv6_hosts)) of
true ->
ipv6_init(
snmp_test_lib:init_group_top_dir(
GroupName,
[{manager_net_if_module, snmpm_net_if_mt}
| Config]));
false ->
{skip, "Host does not support IPv6"}
end;
_ ->
{skip, "Test config ipv6_hosts is missing"}
end;
init_per_group(ipv6 = GroupName, Config) ->
{ok, Hostname0} = inet:gethostname(),
case ct:require(ipv6_hosts) of
ok ->
case lists:member(list_to_atom(Hostname0), ct:get_config(ipv6_hosts)) of
true ->
ipv6_init(snmp_test_lib:init_group_top_dir(GroupName, Config));
false ->
{skip, "Host does not support IPv6"}
end;
_ ->
{skip, "Test config ipv6_hosts is missing"}
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 search
?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 search
%% 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 success 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].