%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2003-2011. All Rights Reserved.
%%
%% The contents of this file are subject to the Erlang Public License,
%% Version 1.1, (the "License"); you may not use this file except in
%% compliance with the License. You should have received a copy of the
%% Erlang Public License along with this software. If not, it can be
%% retrieved online at http://www.erlang.org/.
%%
%% Software distributed under the License is distributed on an "AS IS"
%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
%% the License for the specific language governing rights and limitations
%% under the License.
%%
%% %CopyrightEnd%
%%
-module(snmp_agent_test).
%% TODO
%% * Test fault-tolerance (kill master etc)
%%
-compile(export_all).
-define(application, snmp).
-include_lib("kernel/include/file.hrl").
-include_lib("test_server/include/test_server.hrl").
-include("snmp_test_lib.hrl").
-define(SNMP_USE_V3, true).
-include_lib("snmp/include/snmp_types.hrl").
-include_lib("snmp/src/agent/snmpa_atl.hrl").
%% -include_lib("snmp/include/SNMP-COMMUNITY-MIB.hrl").
%% -include_lib("snmp/include/SNMP-VIEW-BASED-ACM-MIB.hrl").
%% -include_lib("snmp/include/SNMP-USER-BASED-SM-MIB.hrl").
-define(klas1, [1,3,6,1,2,1,7]).
-define(klas2, [1,3,6,1,2,1,9]).
-define(klas3, [1,3,6,1,2,1,8,1]).
-define(klas4, [1,3,6,1,2,1,8,4]).
-define(sa, [1,3,6,1,4,1,193,2]).
-define(system, [1,3,6,1,2,1,1]).
-define(snmp, [1,3,6,1,2,1,11]).
-define(snmpTraps, [1,3,6,1,6,3,1,1,5]).
-define(ericsson, [1,3,6,1,4,1,193]).
-define(testTrap, [1,3,6,1,2,1,15,0]).
-define(xDescr, [1,3,6,1,2,1,17,1]).
-define(xDescr2, [1,3,6,1,2,1,17,2]).
-define(active, 1).
-define(notInService, 2).
-define(notReady, 3).
-define(createAndGo, 4).
-define(createAndWait, 5).
-define(destroy, 6).
-define(TRAP_UDP, 5000).
-define(tooBigStr, "ffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffff").
-define(str(X), snmp_pdus:bits_to_str(X)).
-define(break(), begin io:format(user, "break at line ~w: pid: ~p\n",
[?LINE, self()]),
receive cont -> ok end
end).
-define(v1_2(V1,V2),
case get(vsn) of
v1 -> V1;
_ -> V2
end).
-define(v1_2_3(V1,V2,V3),
case get(vsn) of
v1 -> V1;
v2 -> V2;
_ -> V3
end).
all() ->
%% Reqs = [mnesia, distribution, {local_slave_nodes, 2}, {time, 360}],
Conf1 = [{group, all_tcs}],
Conf2 = [{group, tickets2}],
Conf1 ++ Conf2.
groups() ->
[
{all_tcs, [], cases()},
{mib_storage, [],
[
{group, mib_storage_ets},
{group, mib_storage_dets},
{group, mib_storage_mnesia},
{group, mib_storage_size_check_ets},
{group, mib_storage_size_check_dets},
{group, mib_storage_size_check_mnesia},
{group, mib_storage_varm_dets},
{group, mib_storage_varm_mnesia}
]
},
{mib_storage_ets, [], mib_storage_ets_cases()},
{mib_storage_dets, [], mib_storage_dets_cases()},
{mib_storage_mnesia, [], mib_storage_mnesia_cases()},
{mib_storage_size_check_ets, [], mse_size_check_cases()},
{mib_storage_size_check_dets, [], msd_size_check_cases()},
{mib_storage_size_check_mnesia, [], msm_size_check_cases()},
{mib_storage_varm_dets, [], varm_mib_storage_dets_cases()},
{mib_storage_varm_mnesia, [], varm_mib_storage_mnesia_cases()},
{misc, [], misc_cases()},
{test_v1, [], v1_cases()},
{test_v2, [], v2_cases()},
{test_v1_v2, [], v1_v2_cases()},
{test_v3, [], v3_cases()},
{test_multi_threaded, [], mt_cases()},
{multiple_reqs, [], mul_cases()},
{multiple_reqs_2, [], mul_cases_2()},
{v2_inform, [],
[
v2_inform_i
]
},
{v3_security, [],
[
v3_crypto_basic,
v3_md5_auth,
v3_sha_auth,
v3_des_priv
]
},
{standard_mibs, [],
[
snmp_standard_mib,
snmp_community_mib,
snmp_framework_mib,
snmp_target_mib,
snmp_notification_mib,
snmp_view_based_acm_mib
]
},
{standard_mibs_2, [],
[
snmpv2_mib_2,
snmp_community_mib_2,
snmp_framework_mib_2,
snmp_target_mib_2,
snmp_notification_mib_2,
snmp_view_based_acm_mib_2
]
},
{standard_mibs_3, [],
[
snmpv2_mib_3,
snmp_framework_mib_3,
snmp_mpd_mib_3,
snmp_target_mib_3,
snmp_notification_mib_3,
snmp_view_based_acm_mib_3,
snmp_user_based_sm_mib_3
]
},
{reported_bugs, [],
[
otp_1128,
otp_1129,
otp_1131,
otp_1162,
otp_1222,
otp_1298,
otp_1331,
otp_1338,
otp_1342,
otp_2776,
otp_2979,
otp_3187,
otp_3725
]
},
{reported_bugs_2, [],
[
otp_1128_2,
otp_1129_2,
otp_1131_2,
otp_1162_2,
otp_1222_2,
otp_1298_2,
otp_1331_2,
otp_1338_2,
otp_1342_2,
otp_2776_2,
otp_2979_2,
otp_3187_2
]
},
{reported_bugs_3, [],
[
otp_1128_3,
otp_1129_3,
otp_1131_3,
otp_1162_3,
otp_1222_3,
otp_1298_3,
otp_1331_3,
otp_1338_3,
otp_1342_3,
otp_2776_3,
otp_2979_3,
otp_3187_3,
otp_3542
]
},
{tickets1, [],
[
{group, otp_4394},
{group, otp_7157}
]
},
{tickets2, [], [otp8395]},
{otp_4394, [], [otp_4394_test]},
{otp_7157, [], [otp_7157_test]
}
].
init_per_group(all_tcs, Config) ->
init_all(Config);
init_per_group(otp_7157, Config) ->
init_otp_7157(Config);
init_per_group(otp_4394, Config) ->
init_otp_4394(Config);
init_per_group(v2_inform, Config) ->
init_v2_inform(Config);
init_per_group(multiple_reqs_2, Config) ->
init_mul(Config);
init_per_group(multiple_reqs, Config) ->
init_mul(Config);
init_per_group(test_multi_threaded, Config) ->
init_mt(Config);
init_per_group(test_v3, Config) ->
init_v3(Config);
init_per_group(test_v1_v2, Config) ->
init_v1_v2(Config);
init_per_group(test_v2, Config) ->
init_v2(Config);
init_per_group(test_v1, Config) ->
init_v1(Config);
init_per_group(misc, Config) ->
init_misc(Config);
init_per_group(mib_storage_varm_mnesia, Config) ->
init_varm_mib_storage_mnesia(Config);
init_per_group(mib_storage_varm_dets, Config) ->
init_varm_mib_storage_dets(Config);
init_per_group(mib_storage_size_check_mnesia, Config) ->
init_size_check_msm(Config);
init_per_group(mib_storage_size_check_dets, Config) ->
init_size_check_msd(Config);
init_per_group(mib_storage_size_check_ets, Config) ->
init_size_check_mse(Config);
init_per_group(mib_storage_mnesia, Config) ->
init_mib_storage_mnesia(Config);
init_per_group(mib_storage_dets, Config) ->
init_mib_storage_dets(Config);
init_per_group(mib_storage_ets, Config) ->
init_mib_storage_ets(Config);
init_per_group(_GroupName, Config) ->
Config.
end_per_group(all_tcs, Config) ->
finish_all(Config);
end_per_group(otp_7157, Config) ->
finish_otp_7157(Config);
end_per_group(otp_4394, Config) ->
finish_otp_4394(Config);
end_per_group(v2_inform, Config) ->
finish_v2_inform(Config);
end_per_group(multiple_reqs_2, Config) ->
finish_mul(Config);
end_per_group(multiple_reqs, Config) ->
finish_mul(Config);
end_per_group(test_multi_threaded, Config) ->
finish_mt(Config);
end_per_group(test_v3, Config) ->
finish_v3(Config);
end_per_group(test_v1_v2, Config) ->
finish_v1_v2(Config);
end_per_group(test_v2, Config) ->
finish_v2(Config);
end_per_group(test_v1, Config) ->
finish_v1(Config);
end_per_group(misc, Config) ->
finish_misc(Config);
end_per_group(mib_storage_varm_mnesia, Config) ->
finish_varm_mib_storage_mnesia(Config);
end_per_group(mib_storage_varm_dets, Config) ->
finish_varm_mib_storage_dets(Config);
end_per_group(mib_storage_size_check_mnesia, Config) ->
finish_size_check_msm(Config);
end_per_group(mib_storage_size_check_dets, Config) ->
finish_size_check_msd(Config);
end_per_group(mib_storage_size_check_ets, Config) ->
finish_size_check_mse(Config);
end_per_group(mib_storage_mnesia, Config) ->
finish_mib_storage_mnesia(Config);
end_per_group(mib_storage_dets, Config) ->
finish_mib_storage_dets(Config);
end_per_group(mib_storage_ets, Config) ->
finish_mib_storage_ets(Config);
end_per_group(_GroupName, Config) ->
Config.
init_per_testcase(otp8395 = Case, Config) when is_list(Config) ->
?DBG("init_per_testcase -> entry with"
"~n Case: ~p"
"~n Config: ~p", [Case, Config]),
Config2 = init_per_testcase2(Case, init_per_suite(Config)),
otp8395({init, Config2});
init_per_testcase(otp_7157_test = _Case, Config) when is_list(Config) ->
?DBG("init_per_testcase -> entry with"
"~n Case: ~p"
"~n Config: ~p", [_Case, Config]),
Dog = ?WD_START(?MINS(1)),
[{watchdog, Dog}|Config];
init_per_testcase(v2_inform_i = _Case, Config) when is_list(Config) ->
?DBG("init_per_testcase -> entry with"
"~n Case: ~p"
"~n Config: ~p", [_Case, Config]),
Dog = ?WD_START(?MINS(10)),
[{watchdog, Dog}|Config];
init_per_testcase(v3_inform_i = _Case, Config) when is_list(Config) ->
?DBG("init_per_testcase -> entry with"
"~n Case: ~p"
"~n Config: ~p", [_Case, Config]),
Dog = ?WD_START(?MINS(10)),
[{watchdog, Dog}|Config];
init_per_testcase(_Case, Config) when is_list(Config) ->
?DBG("init_per_testcase -> entry with"
"~n Case: ~p"
"~n Config: ~p", [_Case, Config]),
Dog = ?WD_START(?MINS(6)),
[{watchdog, Dog}|Config].
end_per_testcase(otp8395, Config) when is_list(Config) ->
otp8395({fin, Config});
end_per_testcase(_Case, Config) when is_list(Config) ->
?DBG("end_per_testcase -> entry with"
"~n Case: ~p"
"~n Config: ~p", [_Case, Config]),
Dog = ?config(watchdog, Config),
?WD_STOP(Dog),
Config.
init_per_suite(Config) ->
?DBG("init_per_suite -> entry with"
"~n Config: ~p", [Config]),
%% Suite root dir for test suite
PrivDir = ?config(priv_dir, Config),
%% Create top-directory for this sub-suite
SuiteTopDir = filename:join([PrivDir, ?MODULE]),
case file:make_dir(SuiteTopDir) of
ok ->
ok;
{error, eexist} ->
%% This can happen since this is not really a
%% suite-init function.
ok;
{error, Reason} ->
?FAIL({failed_creating_suite_top_dir, SuiteTopDir, Reason})
end,
%% --
%% Fix config (data-dir is not correct):
%%
Config1 = fix_data_dir(Config),
%% Config1 = Config,
%% Mib-dirs
MibDir = ?config(data_dir, Config1),
StdMibDir = filename:join([code:priv_dir(snmp), "mibs"]),
Config2 = [{suite_top_dir, SuiteTopDir},
{mib_dir, MibDir},
{std_mib_dir, StdMibDir} | Config1],
?DBG("init_per_suite -> done when"
"~n Config2: ~p", [Config2]),
Config2.
%% end_per_suite(Config) ->
end_per_suite(Config) ->
Config.
fix_data_dir(Config) ->
DataDir0 = ?config(data_dir, Config),
DataDir1 = filename:split(filename:absname(DataDir0)),
[_|DataDir2] = lists:reverse(DataDir1),
DataDir = filename:join(lists:reverse(DataDir2) ++ [?snmp_test_data]),
Config1 = lists:keydelete(data_dir, 1, Config),
[{data_dir, DataDir} | Config1].
init_per_testcase2(Case, Config) ->
SuiteToDir = ?config(suite_top_dir, Config),
%% Create top-directory for this test-case
CaseTopDir = filename:join([SuiteToDir, Case]),
ok = file:make_dir(CaseTopDir),
%% Create agent top-dir(s)
AgentTopDir = filename:join([CaseTopDir, agent]),
ok = file:make_dir(AgentTopDir),
AgentConfDir = filename:join([AgentTopDir, config]),
ok = file:make_dir(AgentConfDir),
AgentDbDir = filename:join([AgentTopDir, db]),
ok = file:make_dir(AgentDbDir),
AgentLogDir = filename:join([AgentTopDir, log]),
ok = file:make_dir(AgentLogDir),
%% Create sub-agent top-dir(s)
SubAgentTopDir = filename:join([CaseTopDir, sub_agent]),
ok = file:make_dir(SubAgentTopDir),
%% Create manager top-dir(s)
ManagerTopDir = filename:join([CaseTopDir, manager]),
ok = file:make_dir(ManagerTopDir),
[{case_top_dir, CaseTopDir},
{agent_top_dir, AgentTopDir},
{agent_conf_dir, AgentConfDir},
{agent_db_dir, AgentDbDir},
{agent_log_dir, AgentLogDir},
{sub_agent_top_dir, SubAgentTopDir},
{manager_top_dir, ManagerTopDir} | Config].
end_per_testcase2(_Case, Config) ->
Config.
cases() ->
case ?OSTYPE() of
vxworks ->
[
{group, misc},
{group, test_v1},
{group, test_v2},
{group, test_v1_v2},
{group, test_multi_threaded},
{group, mib_storage},
{group, tickets1}
];
_Else ->
[
{group, misc},
{group, test_v1},
{group, test_v2},
{group, test_v1_v2},
{group, test_v3},
{group, test_multi_threaded},
{group, mib_storage},
{group, tickets1}
]
end.
%%%-----------------------------------------------------------------
%%% The test case structure is as follows:
%%%
%%% init_all - starts mnesia,
%%%
%%% init_v1 - starts agent
%%% simple
%%% big - e.g. starts/stops subagent, load/unloads mibs
%%% init_mul
%%% mul_get
%%% mul_set
%%% <etc>
%%% finish_mul
%%% <etc>
%%% finish_v1
%%%
%%% init_v2 - starts agent
%%% finish_v2
%%%
%%% init_bilingual - starts agent
%%% finish_bilingual
%%%
%%% finish_all
%%%
%%% There is still one problem with these testsuites. If one test
%%% fails, it may not be possible to run some other cases, as it
%%% may have e.g. created some row or loaded some table, that it
%%% didn't undo (since it failed).
%%%-----------------------------------------------------------------
init_all(Conf) ->
?DISPLAY_SUITE_INFO(),
snmp_agent_test_lib:init_all(Conf).
finish_all(Conf) ->
snmp_agent_test_lib:finish_all(Conf).
start_v1_agent(Config) ->
snmp_agent_test_lib:start_v1_agent(Config).
start_v1_agent(Config, Opts) ->
snmp_agent_test_lib:start_v1_agent(Config, Opts).
start_v2_agent(Config) ->
snmp_agent_test_lib:start_v2_agent(Config).
start_v2_agent(Config, Opts) ->
snmp_agent_test_lib:start_v2_agent(Config, Opts).
start_v3_agent(Config) ->
snmp_agent_test_lib:start_v3_agent(Config).
start_v3_agent(Config, Opts) ->
snmp_agent_test_lib:start_v3_agent(Config, Opts).
start_bilingual_agent(Config) ->
snmp_agent_test_lib:start_bilingual_agent(Config).
start_multi_threaded_agent(Config) when is_list(Config) ->
snmp_agent_test_lib:start_mt_agent(Config).
stop_agent(Config) ->
snmp_agent_test_lib:stop_agent(Config).
create_tables(SaNode) ->
?line {atomic, ok} = mnesia:create_table([{name, friendsTable2},
{ram_copies, [SaNode]},
{snmp, [{key, integer}]},
{attributes, [a1,a2,a3]}]),
?line {atomic, ok} = mnesia:create_table([{name, kompissTable2},
{ram_copies, [SaNode]},
{snmp, [{key, integer}]},
{attributes, [a1,a2,a3]}]),
?line {atomic, ok} = mnesia:create_table([{name, snmp_variables},
{attributes, [a1,a2]}]).
delete_tables() ->
mnesia:delete_table(friendsTable2),
mnesia:delete_table(kompissTable2),
mnesia:delete_table(snmp_variables).
%% Creation is done in runtime!
delete_mib_storage_mnesia_tables() ->
mnesia:delete_table(snmpa_mib_data),
mnesia:delete_table(snmpa_mib_tree),
mnesia:delete_table(snmpa_symbolic_store).
%%-----------------------------------------------------------------
%% A test case is always one of:
%% - v1 specific case
%% - v2 specific case
%% - v1 and v2 case
%% All v1 specific cases are prefixed with v1_, and all v2 with
%% v2_. E.g. v1_trap/v2_trap.
%%
%% All other cases are shared. However, the testserver uses the name
%% of the case to generate a file for that case. The same case cannot
%% be used in different configurations in the same suite. Therefore
%% all these functions exists in two variants, the base function
%% <base>, and a second version <base>_2. There may be several
%% versions as well, <base>_N.
%%-----------------------------------------------------------------
mib_storage_ets_cases() ->
[mse_simple, mse_v1_processing, mse_big, mse_big2,
mse_loop_mib, mse_api, mse_sa_register, mse_v1_trap,
mse_sa_error, mse_next_across_sa, mse_undo,
mse_standard_mib, mse_community_mib, mse_framework_mib,
mse_target_mib, mse_notification_mib,
mse_view_based_acm_mib, mse_sparse_table, mse_me_of,
mse_mib_of].
mib_storage_dets_cases() ->
[msd_simple, msd_v1_processing, msd_big, msd_big2,
msd_loop_mib, msd_api, msd_sa_register, msd_v1_trap,
msd_sa_error, msd_next_across_sa, msd_undo,
msd_standard_mib, msd_community_mib, msd_framework_mib,
msd_target_mib, msd_notification_mib,
msd_view_based_acm_mib, msd_sparse_table, msd_me_of,
msd_mib_of].
mib_storage_mnesia_cases() ->
[msm_simple, msm_v1_processing, msm_big, msm_big2,
msm_loop_mib, msm_api, msm_sa_register, msm_v1_trap,
msm_sa_error, msm_next_across_sa, msm_undo,
msm_standard_mib, msm_community_mib, msm_framework_mib,
msm_target_mib, msm_notification_mib,
msm_view_based_acm_mib, msm_sparse_table, msm_me_of,
msm_mib_of].
mse_size_check_cases() ->
[mse_size_check].
msd_size_check_cases() ->
[msd_size_check].
msm_size_check_cases() ->
[msm_size_check].
varm_mib_storage_dets_cases() ->
[msd_varm_mib_start].
varm_mib_storage_mnesia_cases() ->
[msm_varm_mib_start].
init_mib_storage_ets(Config) when is_list(Config) ->
?LOG("init_mib_storage_ets -> entry", []),
MibStorage = {snmp_mib_storage,ets},
init_ms(Config, [MibStorage]).
init_mib_storage_dets(Config) when is_list(Config) ->
?LOG("init_mib_storage_ets -> entry", []),
?line AgentDir = ?GCONF(agent_dir, Config),
MibStorage = {snmp_mib_storage,{dets,AgentDir}},
init_ms(Config, [MibStorage]).
init_mib_storage_mnesia(Config) when is_list(Config) ->
?LOG("init_mib_storage_ets -> entry", []),
MibStorage = {snmp_mib_storage,{mnesia,[]}},
init_ms(Config, [MibStorage]).
init_ms(Config, Opts) when is_list(Config) ->
?LOG("init_mib_storage_ets -> entry", []),
?line SaNode = ?GCONF(snmp_sa, Config),
?line create_tables(SaNode),
?line AgentDir = ?GCONF(agent_dir, Config),
?line MgrDir = ?GCONF(mgr_dir, Config),
?line Ip = ?GCONF(ip, Config),
?line config([v1], MgrDir, AgentDir, tuple_to_list(Ip), tuple_to_list(Ip)),
MasterAgentVerbosity = {snmp_master_agent_verbosity, trace},
MibsVerbosity = {snmp_mibserver_verbosity, trace},
SymStoreVerbosity = {snmp_symbolic_store_verbosity, trace},
Opts1 = [MasterAgentVerbosity,MibsVerbosity,SymStoreVerbosity|Opts],
[{vsn, v1} | start_v1_agent(Config,Opts1)].
init_size_check_mse(Config) when is_list(Config) ->
MibStorage = {snmp_mib_storage, ets},
init_size_check_ms(Config, [MibStorage]).
init_size_check_msd(Config) when is_list(Config) ->
AgentDir = ?GCONF(agent_dir, Config),
MibStorage = {snmp_mib_storage, {dets, AgentDir}},
init_size_check_ms(Config, [MibStorage]).
init_size_check_msm(Config) when is_list(Config) ->
MibStorage = {snmp_mib_storage, {mnesia,[]}},
init_size_check_ms(Config, [MibStorage]).
init_size_check_ms(Config, Opts) when is_list(Config) ->
SaNode = ?GCONF(snmp_sa, Config),
%% We are using v3 here, so crypto must be supported or else...
case ?CRYPTO_START() of
ok ->
case ?CRYPTO_SUPPORT() of
{no, Reason} ->
?SKIP({unsupported_encryption, Reason});
yes ->
ok
end;
{error, Reason} ->
?SKIP({failed_starting_crypto, Reason})
end,
create_tables(SaNode),
AgentDir = ?GCONF(agent_dir, Config),
MgrDir = ?GCONF(mgr_dir, Config),
Ip = ?GCONF(ip, Config),
?line ok =
config([v3], MgrDir, AgentDir, tuple_to_list(Ip), tuple_to_list(Ip)),
[{vsn, v3} | start_v3_agent(Config, Opts)].
init_varm_mib_storage_dets(Config) when is_list(Config) ->
?LOG("init_varm_mib_storage_dets -> entry", []),
?line SaNode = ?GCONF(snmp_sa, Config),
?line create_tables(SaNode),
?line AgentDir = ?GCONF(agent_dir, Config),
?line MgrDir = ?GCONF(mgr_dir, Config),
?line Ip = ?GCONF(ip, Config),
?line config([v1], MgrDir, AgentDir, tuple_to_list(Ip), tuple_to_list(Ip)),
MibStorage = {snmp_mib_storage,{dets,AgentDir}},
MasterAgentVerbosity = {snmp_master_agent_verbosity, trace},
MibsVerbosity = {snmp_mibserver_verbosity, trace},
SymStoreVerbosity = {snmp_symbolic_store_verbosity, trace},
Opts = [MibStorage,MasterAgentVerbosity,MibsVerbosity,SymStoreVerbosity],
[{vsn, v1}, {agent_opts,Opts} | Config].
init_varm_mib_storage_mnesia(Config) when is_list(Config) ->
?LOG("init_varm_mib_storage_mnesia -> entry", []),
?line SaNode = ?GCONF(snmp_sa, Config),
?line create_tables(SaNode),
?line AgentDir = ?GCONF(agent_dir, Config),
?line MgrDir = ?GCONF(mgr_dir, Config),
?line Ip = ?GCONF(ip, Config),
?line config([v1], MgrDir, AgentDir, tuple_to_list(Ip), tuple_to_list(Ip)),
MibStorage = {snmp_mib_storage,{mnesia,[]}},
MasterAgentVerbosity = {snmp_master_agent_verbosity, trace},
MibsVerbosity = {snmp_mibserver_verbosity, trace},
SymStoreVerbosity = {snmp_symbolic_store_verbosity, trace},
Opts = [MibStorage,MasterAgentVerbosity,MibsVerbosity,SymStoreVerbosity],
[{vsn, v1}, {agent_opts,Opts} | Config].
finish_mib_storage_ets(Config) when is_list(Config) ->
?LOG("finish_mib_storage_ets -> entry", []),
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
C2 = lists:keydelete(vsn, 1, C1),
lists:keydelete(agent_opts, 1, C2).
finish_mib_storage_dets(Config) when is_list(Config) ->
?LOG("finish_mib_storage_dets -> entry", []),
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
C2 = lists:keydelete(vsn, 1, C1),
lists:keydelete(agent_opts, 1, C2).
finish_mib_storage_mnesia(Config) when is_list(Config) ->
?LOG("finish_mib_storage_mnesia -> entry", []),
delete_tables(),
delete_mib_storage_mnesia_tables(),
C1 = stop_agent(Config),
delete_files(C1),
C2 = lists:keydelete(vsn, 1, C1),
lists:keydelete(agent_opts, 1, C2).
finish_varm_mib_storage_dets(Config) when is_list(Config) ->
?LOG("finish_varm_mib_storage_dets -> entry", []),
delete_tables(),
%% C1 = stop_agent(Config), % In case something went wrong...
delete_files(Config),
C2 = lists:keydelete(vsn, 1, Config),
lists:keydelete(agent_opts, 1, C2).
finish_varm_mib_storage_mnesia(Config) when is_list(Config) ->
?LOG("finish_varm_mib_storage_mnesia -> entry", []),
delete_tables(),
delete_mib_storage_mnesia_tables(),
%% C1 = stop_agent(Config), % In case something went wrong...
delete_files(Config),
C2 = lists:keydelete(vsn, 1, Config),
lists:keydelete(agent_opts, 1, C2).
finish_size_check_mse(Config) when is_list(Config) ->
finish_size_check_ms(Config).
finish_size_check_msd(Config) when is_list(Config) ->
finish_size_check_ms(Config).
finish_size_check_msm(Config) when is_list(Config) ->
finish_size_check_ms(Config).
finish_size_check_ms(Config) when is_list(Config) ->
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
lists:keydelete(vsn, 1, C1).
%% These are just interface functions to fool the test server
mse_simple(X) -> ?P(mse_simple), simple(X).
mse_v1_processing(X) -> ?P(mse_v1_processing), v1_processing(X).
mse_big(X) -> ?P(mse_big), big(X).
mse_big2(X) -> ?P(mse_big2), big2(X).
mse_loop_mib(X) -> ?P(mse_loop_mib), loop_mib(X).
mse_api(X) -> ?P(mse_api), api(X).
mse_sa_register(X) -> ?P(mse_sa_register), sa_register(X).
mse_v1_trap(X) -> ?P(mse_v1_trap), v1_trap(X).
mse_sa_error(X) -> ?P(mse_sa_error), sa_error(X).
mse_next_across_sa(X) -> ?P(mse_next_across_sa), next_across_sa(X).
mse_undo(X) -> ?P(mse_undo), undo(X).
mse_standard_mib(X) -> ?P(mse_standard_mib), snmp_standard_mib(X).
mse_community_mib(X) -> ?P(mse_community_mib), snmp_community_mib(X).
mse_framework_mib(X) -> ?P(mse_framework_mib), snmp_framework_mib(X).
mse_target_mib(X) -> ?P(mse_target_mib), snmp_target_mib(X).
mse_notification_mib(X) -> ?P(mse_notification_mib), snmp_notification_mib(X).
mse_view_based_acm_mib(X) -> ?P(mse_view_based_acm_mib), snmp_view_based_acm_mib(X).
mse_sparse_table(X) -> ?P(mse_sparse_table), sparse_table(X).
mse_me_of(X) -> ?P(mse_me_of), ms_me_of(X).
mse_mib_of(X) -> ?P(mse_mib_of), ms_mib_of(X).
msd_simple(X) -> ?P(msd_simple), simple(X).
msd_v1_processing(X) -> ?P(msd_v1_processing), v1_processing(X).
msd_big(X) -> ?P(msd_big), big(X).
msd_big2(X) -> ?P(msd_big2), big2(X).
msd_loop_mib(X) -> ?P(msd_loop_mib), loop_mib(X).
msd_api(X) -> ?P(msd_api), api(X).
msd_sa_register(X) -> ?P(msd_sa_register), sa_register(X).
msd_v1_trap(X) -> ?P(msd_v1_trap), v1_trap(X).
msd_sa_error(X) -> ?P(msd_sa_error), sa_error(X).
msd_next_across_sa(X) -> ?P(msd_next_across_sa), next_across_sa(X).
msd_undo(X) -> ?P(msd_undo), undo(X).
msd_standard_mib(X) -> ?P(msd_standard_mib), snmp_standard_mib(X).
msd_community_mib(X) -> ?P(msd_community_mib), snmp_community_mib(X).
msd_framework_mib(X) -> ?P(msd_framework_mib), snmp_framework_mib(X).
msd_target_mib(X) -> ?P(msd_target_mib), snmp_target_mib(X).
msd_notification_mib(X) -> ?P(msd_notification_mib), snmp_notification_mib(X).
msd_view_based_acm_mib(X) -> ?P(msd_view_based_acm_mib), snmp_view_based_acm_mib(X).
msd_sparse_table(X) -> ?P(msd_sparse_table), sparse_table(X).
msd_me_of(X) -> ?P(msd_me_of), ms_me_of(X).
msd_mib_of(X) -> ?P(msd_mib_of), ms_mib_of(X).
msm_simple(X) -> ?P(msm_simple), simple(X).
msm_v1_processing(X) -> ?P(msm_v1_processing), v1_processing(X).
msm_big(X) -> ?P(msm_big2), big(X).
msm_big2(X) -> ?P(msm_loop_mib), big2(X).
msm_loop_mib(X) -> ?P(msm_loop_mib), loop_mib(X).
msm_api(X) -> ?P(msm_api), api(X).
msm_sa_register(X) -> ?P(msm_sa_register), sa_register(X).
msm_v1_trap(X) -> ?P(msm_v1_trap), v1_trap(X).
msm_sa_error(X) -> ?P(msm_sa_error), sa_error(X).
msm_next_across_sa(X) -> ?P(msm_next_across_sa), next_across_sa(X).
msm_undo(X) -> ?P(msm_undo), undo(X).
msm_standard_mib(X) -> ?P(msm_standard_mib), snmp_standard_mib(X).
msm_community_mib(X) -> ?P(msm_community_mib), snmp_community_mib(X).
msm_framework_mib(X) -> ?P(msm_framework_mib), snmp_framework_mib(X).
msm_target_mib(X) -> ?P(msm_target_mib), snmp_target_mib(X).
msm_notification_mib(X) -> ?P(msm_notification_mib), snmp_notification_mib(X).
msm_view_based_acm_mib(X) -> ?P(msm_view_based_acm_mib), snmp_view_based_acm_mib(X).
msm_sparse_table(X) -> ?P(msm_sparse_table), sparse_table(X).
msm_me_of(X) -> ?P(msm_me_of), ms_me_of(X).
msm_mib_of(X) -> ?P(msm_mib_of), ms_mib_of(X).
mse_size_check(X) -> ?P(mse_size_check), ms_size_check(X).
msd_size_check(X) -> ?P(msd_size_check), ms_size_check(X).
msm_size_check(X) -> ?P(msm_size_check), ms_size_check(X).
msd_varm_mib_start(X) ->
?P(msd_varm_mib_start),
varm_mib_start(X).
msm_varm_mib_start(X) ->
%% <CONDITIONAL-SKIP>
Skippable = [win32],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(X, Condition),
%% </CONDITIONAL-SKIP>
?P(msm_varm_mib_start),
varm_mib_start(X).
ms_size_check(suite) -> [];
ms_size_check(Config) when is_list(Config) ->
?P(ms_size_check),
init_case(Config),
?LOG("mib server size check...", []),
?line load_master("Test2"),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
?line load_master_std("OTP-SNMPEA-MIB"),
?line load_master_std("SNMP-COMMUNITY-MIB"),
?line load_master_std("SNMP-FRAMEWORK-MIB"),
?line load_master_std("SNMP-MPD-MIB"),
?line load_master_std("SNMP-NOTIFICATION-MIB"),
?line load_master_std("SNMP-TARGET-MIB"),
?line load_master_std("SNMP-USER-BASED-SM-MIB"),
?line load_master_std("SNMP-VIEW-BASED-ACM-MIB"),
?line load_master_std("SNMPv2-MIB"),
?line load_master_std("SNMPv2-TM"),
?SLEEP(2000),
?line display_memory_usage(),
?line unload_master("OTP-SNMPEA-MIB"),
?line unload_master("SNMP-COMMUNITY-MIB"),
?line unload_master("SNMP-FRAMEWORK-MIB"),
?line unload_master("SNMP-MPD-MIB"),
?line unload_master("SNMP-NOTIFICATION-MIB"),
?line unload_master("SNMP-TARGET-MIB"),
?line unload_master("SNMP-USER-BASED-SM-MIB"),
?line unload_master("SNMP-VIEW-BASED-ACM-MIB"),
?line unload_master("SNMPv2-MIB"),
?line unload_master("SNMPv2-TM"),
?line unload_master("TestTrapv2"),
?line unload_master("TestTrap"),
?line unload_master("Test2"),
ok.
varm_mib_start(suite) -> [];
varm_mib_start(Config) when is_list(Config) ->
?P(varm_mib_start),
?LOG("varm_mib_start -> entry", []),
init_case(Config),
%% Start the agent
Opts = ?GCONF(agent_opts, Config),
Config1 = start_v1_agent(Config, Opts),
%% Sleep some in order for the agent to start properly
?DBG("varm_mib_start -> sleep some (before loading mobs)", []),
?SLEEP(5000),
%% Load all the mibs
HardwiredMibs = loaded_mibs(),
?DBG("varm_mib_start -> load all mibs", []),
?line load_master_std("SNMP-COMMUNITY-MIB"),
?line load_master_std("SNMP-FRAMEWORK-MIB"),
?line load_master_std("SNMP-TARGET-MIB"),
?line load_master_std("SNMP-NOTIFICATION-MIB"),
%% Unload the hardwired mibs
?DBG("varm_mib_start -> sleep some (before unloading hardwired mibs)", []),
?SLEEP(1000),
?DBG("varm_mib_start -> unload (hardwired) mibs", []),
?line unload_mibs(HardwiredMibs), %% unload hardwired
?DBG("varm_mib_start -> sleep some (before stopping agent)", []),
?SLEEP(1000),
%% Stop the agent (without deleting the stored files)
?DBG("varm_mib_start -> stop the agent", []),
Config2 = stop_agent(Config1),
%% Sleep some in order for the agent to stop properly
?DBG("varm_mib_start -> sleep some (before re-starting the agent)", []),
?SLEEP(5000),
%% Start the agent (again)
?DBG("varm_mib_start -> start the agent", []),
Config3 = start_v1_agent(Config2, Opts),
?DBG("varm_mib_start -> sleep some (before starting tests)", []),
?SLEEP(5000),
%% Perform the test(s)
?DBG("varm_mib_start -> perform the tests", []),
try_test(snmp_community_mib),
try_test(snmp_framework_mib),
try_test(snmp_target_mib),
try_test(snmp_notification_mib),
%% Stop the agent (without deleting the stored files)
?DBG("varm_mib_start -> stop the agent", []),
stop_agent(Config3),
ok.
-define(snmpTrapCommunity_instance, [1,3,6,1,6,3,18,1,4,0]).
-define(vacmViewSpinLock_instance, [1,3,6,1,6,3,16,1,5,1,0]).
-define(usmStatsNotInTimeWindows_instance, [1,3,6,1,6,3,15,1,1,2,0]).
ms_me_of(suite) -> [];
ms_me_of(Config) when is_list(Config) ->
?P(ms_me_of),
init_case(Config),
?line load_master("Test2"),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
?line load_master_std("OTP-SNMPEA-MIB"),
?line load_master_std("SNMP-COMMUNITY-MIB"),
?line load_master_std("SNMP-FRAMEWORK-MIB"),
?line load_master_std("SNMP-MPD-MIB"),
?line load_master_std("SNMP-NOTIFICATION-MIB"),
?line load_master_std("SNMP-TARGET-MIB"),
?line load_master_std("SNMP-VIEW-BASED-ACM-MIB"),
?SLEEP(2000),
?line display_memory_usage(),
?DBG("ms_me_of -> find ~w from SNMP-COMMUNITY-MIB",
[?snmpTrapCommunity_instance]),
?line ok = me_of(?snmpTrapCommunity_instance),
?DBG("ms_me_of -> find ~w from SNMP-VIEW-BASED-ACM-MIB",
[?vacmViewSpinLock_instance]),
?line ok = me_of(?vacmViewSpinLock_instance),
?DBG("ms_me_of -> find ~w from SNMP-USER-BASED-SM-MIB",
[?usmStatsNotInTimeWindows_instance]),
?line {error, _} = me_of(?usmStatsNotInTimeWindows_instance),
?line unload_master("OTP-SNMPEA-MIB"),
?line unload_master("SNMP-COMMUNITY-MIB"),
?line unload_master("SNMP-FRAMEWORK-MIB"),
?line unload_master("SNMP-MPD-MIB"),
?line unload_master("SNMP-NOTIFICATION-MIB"),
?line unload_master("SNMP-TARGET-MIB"),
?line unload_master("SNMP-VIEW-BASED-ACM-MIB"),
?line unload_master("TestTrapv2"),
?line unload_master("TestTrap"),
?line unload_master("Test2"),
ok.
me_of(Oid) ->
case snmpa:me_of(Oid) of
{ok, #me{oid = Oid}} ->
ok;
{ok, #me{oid = OtherOid}} ->
case lists:reverse(Oid) of
[0|Rest] ->
case lists:reverse(Rest) of
OtherOid ->
ok;
AnotherOid ->
{error, {invalid_oid, Oid, AnotherOid}}
end;
_ ->
{error, {invalid_oid, Oid, OtherOid}}
end;
{error, Reason} ->
{error, Reason};
Else ->
{error, Else}
end.
ms_mib_of(suite) -> [];
ms_mib_of(Config) when is_list(Config) ->
?P(ms_mib_of),
init_case(Config),
?line load_master("Test2"),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
?line load_master_std("OTP-SNMPEA-MIB"),
?line load_master_std("SNMP-COMMUNITY-MIB"),
?line load_master_std("SNMP-FRAMEWORK-MIB"),
?line load_master_std("SNMP-MPD-MIB"),
?line load_master_std("SNMP-NOTIFICATION-MIB"),
?line load_master_std("SNMP-TARGET-MIB"),
?line load_master_std("SNMP-VIEW-BASED-ACM-MIB"),
?SLEEP(2000),
?line display_memory_usage(),
?DBG("ms_mib_of -> find ~w from SNMP-COMMUNITY-MIB",
[?snmpTrapCommunity_instance]),
?line ok = mib_of(?snmpTrapCommunity_instance, 'SNMP-COMMUNITY-MIB'),
?DBG("ms_mib_of -> find ~w from SNMP-VIEW-BASED-ACM-MIB",
[?vacmViewSpinLock_instance]),
?line ok = mib_of(?vacmViewSpinLock_instance, 'SNMP-VIEW-BASED-ACM-MIB'),
?DBG("ms_mib_of -> find ~w from SNMP-USER-BASED-SM-MIB",
[?usmStatsNotInTimeWindows_instance]),
?line {error, _} = mib_of(?usmStatsNotInTimeWindows_instance,
'SNMP-USER-BASED-SM-MIB'),
?line unload_master("OTP-SNMPEA-MIB"),
?line unload_master("SNMP-COMMUNITY-MIB"),
?line unload_master("SNMP-FRAMEWORK-MIB"),
?line unload_master("SNMP-MPD-MIB"),
?line unload_master("SNMP-NOTIFICATION-MIB"),
?line unload_master("SNMP-TARGET-MIB"),
?line unload_master("SNMP-VIEW-BASED-ACM-MIB"),
?line unload_master("TestTrapv2"),
?line unload_master("TestTrap"),
?line unload_master("Test2"),
ok.
mib_of(Oid, ExpectedMibName) ->
?DBG("mib_of -> entry with"
"~n Oid: ~p"
"~n ExpectedMibName: ~p", [Oid, ExpectedMibName]),
%% case snmpa:mib_of(Oid) of
MibOf = snmpa:mib_of(Oid),
?DBG("mib_of -> MibOf: ~n~p", [MibOf]),
case MibOf of
{ok, ExpectedMibName} ->
ok;
{ok, OtherMibName} ->
{error, {invalid_mib, ExpectedMibName, OtherMibName}};
{error, Reason} ->
{error, Reason};
Else ->
?DBG("mib_of -> Else: ~n~p", [Else]),
{error, Else}
end.
init_misc(Config) ->
init_v1(Config).
finish_misc(Config) ->
finish_v1(Config).
misc_cases() ->
[app_info, info_test].
app_info(suite) -> [];
app_info(Config) when is_list(Config) ->
?P(app_info),
SnmpDir = app_dir(snmp),
SslDir = app_dir(ssl),
CryptoDir = app_dir(crypto),
Attr = snmp:module_info(attributes),
AppVsn =
case lists:keysearch(app_vsn, 1, Attr) of
{value, {app_vsn, V}} ->
V;
false ->
"undefined"
end,
io:format("Root dir: ~s~n"
"SNMP: Application dir: ~s~n"
" Application ver: ~s~n"
"SSL: Application dir: ~s~n"
"CRYPTO: Application dir: ~s~n",
[code:root_dir(), SnmpDir, AppVsn, SslDir, CryptoDir]),
ok.
app_dir(App) ->
case code:lib_dir(App) of
D when is_list(D) ->
filename:basename(D);
{error, _Reason} ->
"undefined"
end.
%v1_cases() -> [loop_mib];
v1_cases() ->
[
simple,
db_notify_client,
v1_processing,
big,
big2,
loop_mib,
api,
subagent,
mnesia,
{group, multiple_reqs},
sa_register,
v1_trap,
sa_error,
next_across_sa,
undo,
{group, reported_bugs},
{group, standard_mibs},
sparse_table,
cnt_64,
opaque,
change_target_addr_config
].
init_v1(Config) when is_list(Config) ->
?line SaNode = ?config(snmp_sa, Config),
?line create_tables(SaNode),
?line AgentDir = ?config(agent_dir, Config),
?line MgrDir = ?config(mgr_dir, Config),
?line Ip = ?config(ip, Config),
?line config([v1], MgrDir, AgentDir, tuple_to_list(Ip), tuple_to_list(Ip)),
[{vsn, v1} | start_v1_agent(Config)].
finish_v1(Config) when is_list(Config) ->
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
lists:keydelete(vsn, 1, C1).
v2_cases() ->
[
simple_2,
v2_processing,
big_2,
big2_2,
loop_mib_2,
api_2,
subagent_2,
mnesia_2,
{group, multiple_reqs_2},
sa_register_2,
v2_trap,
{group, v2_inform},
sa_error_2,
next_across_sa_2,
undo_2,
{group, reported_bugs_2},
{group, standard_mibs_2},
v2_types,
implied,
sparse_table_2,
cnt_64_2,
opaque_2,
v2_caps
].
init_v2(Config) when is_list(Config) ->
SaNode = ?config(snmp_sa, Config),
create_tables(SaNode),
AgentDir = ?config(agent_dir, Config),
MgrDir = ?config(mgr_dir, Config),
Ip = ?config(ip, Config),
config([v2], MgrDir, AgentDir, tuple_to_list(Ip), tuple_to_list(Ip)),
[{vsn, v2} | start_v2_agent(Config)].
finish_v2(Config) when is_list(Config) ->
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
lists:keydelete(vsn, 1, C1).
v1_v2_cases() ->
[simple_bi].
init_v1_v2(Config) when is_list(Config) ->
SaNode = ?config(snmp_sa, Config),
create_tables(SaNode),
AgentDir = ?config(agent_dir, Config),
MgrDir = ?config(mgr_dir, Config),
Ip = ?config(ip, Config),
config([v1,v2], MgrDir, AgentDir, tuple_to_list(Ip), tuple_to_list(Ip)),
[{vsn, bilingual} | start_bilingual_agent(Config)].
finish_v1_v2(Config) when is_list(Config) ->
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
lists:keydelete(vsn, 1, C1).
v3_cases() ->
[
simple_3,
v3_processing,
big_3,
big2_3,
api_3,
subagent_3,
mnesia_3,
loop_mib_3,
multiple_reqs_3,
sa_register_3,
v3_trap,
v3_inform,
sa_error_3,
next_across_sa_3,
undo_3,
{group, reported_bugs_3},
{group, standard_mibs_3},
{group, v3_security},
v2_types_3,
implied_3,
sparse_table_3,
cnt_64_3,
opaque_3,
v2_caps_3
].
init_v3(Config) when is_list(Config) ->
%% Make sure crypto works, otherwise start_agent will fail
%% and we will be stuck with a bunch of mnesia tables for
%% the rest of this suite...
?DBG("start_agent -> start crypto app",[]),
case os:type() of
vxworks ->
no_crypto;
_ ->
case ?CRYPTO_START() of
ok ->
case ?CRYPTO_SUPPORT() of
{no, Reason} ->
?SKIP({unsupported_encryption, Reason});
yes ->
ok
end;
{error, Reason} ->
?SKIP({failed_starting_crypto, Reason})
end
end,
SaNode = ?config(snmp_sa, Config),
create_tables(SaNode),
AgentDir = ?config(agent_dir, Config),
MgrDir = ?config(mgr_dir, Config),
Ip = ?config(ip, Config),
?line ok = config([v3], MgrDir, AgentDir,
tuple_to_list(Ip), tuple_to_list(Ip)),
[{vsn, v3} | start_v3_agent(Config)].
finish_v3(Config) when is_list(Config) ->
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
lists:keydelete(vsn, 1, C1).
mt_cases() ->
[
multi_threaded,
mt_trap
].
init_mt(Config) when is_list(Config) ->
SaNode = ?config(snmp_sa, Config),
create_tables(SaNode),
AgentDir = ?config(agent_dir, Config),
MgrDir = ?config(mgr_dir, Config),
Ip = ?config(ip, Config),
?line ok =
config([v2], MgrDir, AgentDir, tuple_to_list(Ip), tuple_to_list(Ip)),
[{vsn, v2} | start_multi_threaded_agent(Config)].
finish_mt(Config) when is_list(Config) ->
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
lists:keydelete(vsn, 1, C1).
%% This one *must* be run first in each case.
init_case(Config) ->
snmp_agent_test_lib:init_case(Config).
load_master(Mib) ->
?DBG("load_master -> entry with"
"~n Mib: ~p", [Mib]),
snmpa:unload_mibs(snmp_master_agent, [Mib]), % Unload for safety
ok = snmpa:load_mibs(snmp_master_agent, [get(mib_dir) ++ Mib]).
load_master_std(Mib) ->
?DBG("load_master_std -> entry with"
"~n Mib: ~p", [Mib]),
snmpa:unload_mibs(snmp_master_agent, [Mib]), % Unload for safety
ok = snmpa:load_mibs(snmp_master_agent, [get(std_mib_dir) ++ Mib]).
unload_master(Mib) ->
?DBG("unload_master -> entry with"
"~n Mib: ~p", [Mib]),
ok = snmpa:unload_mibs(snmp_master_agent, [Mib]).
loaded_mibs() ->
?DBG("loaded_mibs -> entry",[]),
Info = snmpa:info(snmp_master_agent),
{value, {mib_server, MibInfo}} = lists:keysearch(mib_server, 1, Info),
{value, {loaded_mibs, Mibs}} = lists:keysearch(loaded_mibs, 1, MibInfo),
[atom_to_list(Mib) || {Mib,_,_} <- Mibs].
unload_mibs(Mibs) ->
?DBG("unload_mibs -> entry with"
"~n Mibs: ~p", [Mibs]),
ok = snmpa:unload_mibs(snmp_master_agent, Mibs).
start_subagent(SaNode, RegTree, Mib) ->
snmp_agent_test_lib:start_subagent(SaNode, RegTree, Mib).
stop_subagent(SA) ->
snmp_agent_test_lib:stop_subagent(SA).
%%-----------------------------------------------------------------
%% This function takes care of the old OTP-SNMPEA-MIB.
%% Unfortunately, the testcases were written to use the data in the
%% internal tables, and these table are now obsolete and not used
%% by the agent. Therefore, we emulate them by using
%% OLD-SNMPEA-MIB, which uses the default impl. of all tables.
%%
%% These two rows must exist in intCommunityTable
%% {[147,214,36,45], "public", 2, readWrite}.
%% {[147,214,36,45], "standard trap", 2, read}.
%% (But with the manager's IP address)
%%
%%-----------------------------------------------------------------
init_old() ->
snmpa_local_db:table_create_row(intCommunityTable,
get(mip) ++ [6 | "public"],
{get(mip), "public", 2, 2}),
snmpa_local_db:table_create_row(intCommunityTable,
get(mip) ++ [13 | "standard trap"],
{get(mip), "standard trap", 2, 1}),
snmpa_local_db:variable_set(intAgentIpAddress, [127,0,0,1]).
simple(suite) -> [];
simple(Config) when is_list(Config) ->
?P(simple),
init_case(Config),
try_test(simple_standard_test).
simple_2(X) -> ?P(simple_2), simple(X).
simple_bi(suite) -> [];
simple_bi(Config) when is_list(Config) ->
?P(simple_bi),
init_case(Config),
put(vsn, v1), % First, try v1 manager
try_test(simple_standard_test),
put(vsn, v2), % Then, try v2 manager
try_test(simple_standard_test).
simple_3(X) ->
?P(simple_3), simple(X).
big(suite) -> [];
big(Config) when is_list(Config) ->
?P(big),
%% put(sname, {?MODULE, big}),
%% put(verbosity, trace),
{SaNode, _MgrNode, _MibDir} = init_case(Config),
?P1("Starting subagent..."),
?line pong = net_adm:ping(SaNode),
?line {ok, SA} = start_subagent(SaNode, ?klas1, "Klas1"),
?DBG("big -> SA: ~p", [SA]),
?line load_master("OLD-SNMPEA-MIB"),
?line init_old(),
snmpa:dump_mibs(),
snmpa:dump_mibs("dumped_mibs.txt"),
io:format("Local DB: ~n~p~n", [snmpa_local_db:print()]),
try_test(big_test),
?line stop_subagent(SA),
?line unload_master("OLD-SNMPEA-MIB").
big_2(X) -> ?P(big_2), big(X).
big_3(X) -> ?P(big_3), big(X).
big2(suite) -> [];
big2(Config) when is_list(Config) ->
?P(big2),
%% This is exactly the same tests as 'big', but with the
%% v2 equivalent of the mibs.
{SaNode, _MgrNode, _MibDir} = init_case(Config),
?P1("Starting subagent..."),
?line pong = net_adm:ping(SaNode),
?line {ok, SA} = start_subagent(SaNode, ?klas1, "Klas1-v2"),
?line load_master("OLD-SNMPEA-MIB-v2"),
?line init_old(),
try_test(big_test),
?line stop_subagent(SA),
?line unload_master("OLD-SNMPEA-MIB-v2").
big2_2(X) -> ?P(big2_2), big2(X).
big2_3(X) -> ?P(big2_3), big2(X).
multi_threaded(suite) -> [];
multi_threaded(Config) when is_list(Config) ->
?P(multi_threaded),
init_case(Config),
?line load_master("Test1"),
try_test(multi_threaded_test),
?line unload_master("Test1").
mt_trap(suite) -> [];
mt_trap(Config) when is_list(Config) ->
?P(mt_trap),
init_case(Config),
MA = whereis(snmp_master_agent),
?line load_master("Test1"),
?line load_master("TestTrapv2"),
try_test(mt_trap_test, [MA]),
?line unload_master("TestTrapv2"),
?line unload_master("Test1"),
ok.
v2_types(suite) -> [];
v2_types(Config) when is_list(Config) ->
?P(v2_types),
init_case(Config),
?line load_master("Test1"),
try_test(types_v2_test),
?line unload_master("Test1").
v2_types_3(X) -> ?P(v2_types_3), v2_types(X).
implied(suite) -> [];
implied(Config) when is_list(Config) ->
?P(implied),
init_case(Config),
MA = whereis(snmp_master_agent),
?line load_master("Test1"),
try_test(implied_test,[MA]),
?line unload_master("Test1").
implied_3(X) -> ?P(implied_3), implied(X).
sparse_table(suite) -> [];
sparse_table(Config) when is_list(Config) ->
?P(sparse_table),
init_case(Config),
?line load_master("Test1"),
try_test(sparse_table_test),
?line unload_master("Test1").
sparse_table_2(X) -> ?P(sparse_table_2), sparse_table(X).
sparse_table_3(X) -> ?P(sparse_table_3), sparse_table(X).
cnt_64(suite) -> [];
cnt_64(Config) when is_list(Config) ->
?P(cnt_64),
init_case(Config),
MA = whereis(snmp_master_agent),
?line load_master("Test1"),
try_test(cnt_64_test, [MA]),
?line unload_master("Test1").
cnt_64_2(X) -> ?P(cnt_64_2), cnt_64(X).
cnt_64_3(X) -> ?P(cnt_64_3), cnt_64(X).
opaque(suite) -> [];
opaque(Config) when is_list(Config) ->
?P(opaque),
init_case(Config),
?line load_master("Test1"),
try_test(opaque_test),
?line unload_master("Test1").
opaque_2(X) -> ?P(opaque_2), opaque(X).
opaque_3(X) -> ?P(opaque_2), opaque(X).
change_target_addr_config(suite) -> [];
change_target_addr_config(Config) when is_list(Config) ->
?P(change_target_addr_config),
?LOG("change_target_addr_config -> entry",[]),
init_case(Config),
put(sname,snmp_suite),
put(verbosity,trace),
MA = whereis(snmp_master_agent),
?LOG("change_target_addr_config -> load TestTrap",[]),
?line load_master("TestTrap"),
?LOG("change_target_addr_config -> set trace verbosity for local_db",[]),
?line snmpa:verbosity(local_db,trace),
%% First send some traps that will arive att the original manager
?LOG("change_target_addr_config -> send trap",[]),
try_test(ma_trap1, [MA]),
?LOG("change_target_addr_config -> set silence verbosity for local_db",[]),
?line snmpa:verbosity(local_db,silence),
%% Start new dummy listener
?LOG("change_target_addr_config -> start dummy manager",[]),
?line {ok,Pid,NewPort} = dummy_manager_start(MA),
%% Reconfigure
?LOG("change_target_addr_config -> reconfigure",[]),
AgentDir = ?config(agent_dir, Config),
?line rewrite_target_addr_conf(AgentDir, NewPort),
?line snmp_target_mib:reconfigure(AgentDir),
%% Send the trap again
?LOG("change_target_addr_config -> send trap again",[]),
catch dummy_manager_send_trap2(Pid),
?LOG("change_target_addr_config -> await trap ack",[]),
catch dummy_manager_await_trap2_ack(),
?LOG("change_target_addr_config -> stop dummy manager",[]),
?line ok = dummy_manager_stop(Pid),
?LOG("change_target_addr_config -> reset target address config",[]),
?line reset_target_addr_conf(AgentDir),
?LOG("change_target_addr_config -> unload TestTrap",[]),
?line unload_master("TestTrap").
dummy_manager_start(MA) ->
?DBG("dummy_manager_start -> entry",[]),
Pid = spawn(get(mgr_node), ?MODULE,dummy_manager_init,[self(),MA]),
?DBG("dummy_manager_start -> Pid: ~p",[Pid]),
await_dummy_manager_started(Pid).
await_dummy_manager_started(Pid) ->
receive
{dummy_manager_started,Pid,Port} ->
?DBG("dummy_manager_start -> acknowledge received with"
"~n Port: ~p",[Port]),
{ok,Pid,Port};
{'EXIT', Pid, Reason} ->
{error, Pid, Reason};
O ->
?LOG("dummy_manager_start -> received unknown message:"
"~n ~p",[O]),
await_dummy_manager_started(Pid)
end.
dummy_manager_stop(Pid) ->
?DBG("dummy_manager_stop -> entry with Pid: ~p",[Pid]),
Pid ! stop,
receive
{dummy_manager_stopping, Pid} ->
?DBG("dummy_manager_stop -> acknowledge received",[]),
ok
after 10000 ->
?ERR("dummy_manager_stop -> timeout",[]),
timeout
end.
dummy_manager_send_trap2(Pid) ->
?DBG("dummy_manager_send_trap2 -> entry",[]),
Pid ! {send_trap,testTrap2}.
dummy_manager_await_trap2_ack() ->
?DBG("dummy_manager_await_trap2 -> entry",[]),
receive
{received_trap,Trap} ->
?LOG("dummy_manager_await_trap2 -> received trap: ~p",[Trap]),
%% Note:
%% Without this sleep the v2_inform_i testcase failes! There
%% is no relation between these two test cases as far as I
%% able to figure out...
?SLEEP(60000),
ok;
O ->
?ERR("dummy_manager_await_trap2 -> unexpected message: ~p",[O]),
ok
after 10000 ->
?ERR("dummy_manager_await_trap2 -> timeout",[]),
timeout
end.
dummy_manager_init(Parent,MA) ->
?DBG("dummy_manager_init -> entry with"
"~n Parent: ~p"
"~n MA: ~p",[Parent,MA]),
{ok,S} = gen_udp:open(0,[{recbuf,65535}]),
?DBG("dummy_manager_init -> S: ~p",[S]),
{ok,Port} = inet:port(S),
?DBG("dummy_manager_init -> Port: ~p",[Port]),
Parent ! {dummy_manager_started,self(),Port},
dummy_manager_loop(Parent,S,MA).
dummy_manager_loop(P,S,MA) ->
?LOG("dummy_manager_loop -> ready for receive",[]),
receive
{send_trap,Trap} ->
?LOG("dummy_manager_loop -> received trap send request"
"~n Trap: ~p",[Trap]),
snmpa:send_trap(MA, Trap, "standard trap"),
dummy_manager_loop(P,S,MA);
{udp, _UdpId, Ip, UdpPort, Bytes} ->
?LOG("dummy_manager_loop -> received upd message"
"~n from: ~p:~p"
"~n size: ~p",
[Ip, UdpPort, dummy_manager_message_sz(Bytes)]),
R = dummy_manager_handle_message(Bytes),
?DBG("dummy_manager_loop -> R: ~p",[R]),
P ! R,
dummy_manager_loop(P,S,MA);
stop ->
?DBG("dummy_manager_loop -> received stop request",[]),
P ! {dummy_manager_stopping, self()},
gen_udp:close(S),
exit(normal);
O ->
?LOG("dummy_manager_loop -> received unknown message:"
"~n ~p",[O]),
dummy_manager_loop(P,S,MA)
end.
dummy_manager_message_sz(B) when is_binary(B) ->
size(B);
dummy_manager_message_sz(L) when is_list(L) ->
length(L);
dummy_manager_message_sz(_) ->
undefined.
dummy_manager_handle_message(Bytes) ->
case (catch snmp_pdus:dec_message(Bytes)) of
{'EXIT',Reason} ->
?ERR("dummy_manager_handle_message -> "
"failed decoding message only:~n ~p",[Reason]),
{error,Reason};
M ->
?DBG("dummy_manager_handle_message -> decoded message:"
"~n ~p",[M]),
{received_trap,M}
end.
api(suite) -> [];
api(Config) when is_list(Config) ->
?P(api),
init_case(Config),
?line load_master("OLD-SNMPEA-MIB"),
?line init_old(),
try_test(api_test, [node()]),
?line unload_master("OLD-SNMPEA-MIB").
api_2(X) -> ?P(api_2), api(X).
api_3(X) -> ?P(api_3), api(X).
subagent(suite) -> [];
subagent(Config) when is_list(Config) ->
?P(subagent),
{SaNode, _MgrNode, MibDir} = init_case(Config),
?line {ok, SA} = start_subagent(SaNode, ?klas1, "Klas1"),
try_test(load_test_sa),
?P1("Testing unregister subagent..."),
MA = whereis(snmp_master_agent),
rpc:call(SaNode, snmp, unregister_subagent, [MA, SA]),
try_test(unreg_test),
?P1("Loading previous subagent mib in master and testing..."),
?line ok = snmpa:load_mibs(MA, [MibDir ++ "Klas1"]),
try_test(load_test),
?P1("Unloading previous subagent mib in master and testing..."),
?line ok = snmpa:unload_mibs(MA, [MibDir ++ "Klas1"]),
try_test(unreg_test),
?P1("Testing register subagent..."),
rpc:call(SaNode, snmp, register_subagent,
[MA, ?klas1, SA]),
try_test(load_test_sa),
?line stop_subagent(SA),
try_test(unreg_test).
subagent_2(X) -> ?P(subagent_2), subagent(X).
subagent_3(X) ->
%% <CONDITIONAL-SKIP>
Skippable = [{unix, [darwin]}],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(X, Condition),
%% </CONDITIONAL-SKIP>
?P(subagent_3),
subagent(X).
mnesia(suite) -> [];
mnesia(Config) when is_list(Config) ->
?P(mnesia),
{SaNode, _MgrNode, _MibDir} = init_case(Config),
?P1("Starting subagent with mnesia impl..."),
{ok, SA} = start_subagent(SaNode, ?klas2, "Klas2"),
?line load_master("OLD-SNMPEA-MIB"),
?line init_old(),
try_test(big_test_2),
?P1("Testing unregister subagent..."),
MA = whereis(snmp_master_agent),
rpc:call(SaNode, snmp, unregister_subagent, [MA, SA]),
try_test(unreg_test),
?line unload_master("OLD-SNMPEA-MIB"),
?line stop_subagent(SA).
mnesia_2(X) -> ?P(mnesia_2), mnesia(X).
mnesia_3(X) -> ?P(mnesia_3), mnesia(X).
mul_cases() ->
[mul_get, mul_get_err, mul_next, mul_next_err,
mul_set_err].
multiple_reqs_3(_X) ->
{req, [], {conf, init_mul, mul_cases_3(), finish_mul}}.
mul_cases_2() ->
[mul_get_2, mul_get_err_2, mul_next_2, mul_next_err_2,
mul_set_err_2].
mul_cases_3() ->
[mul_get_3, mul_get_err_3, mul_next_3, mul_next_err_3, mul_set_err_3].
init_mul(Config) when is_list(Config) ->
{SaNode, _MgrNode, _MibDir} = init_case(Config),
?line {ok, SA} = start_subagent(SaNode, ?klas1, "Klas1"),
?line load_master("OLD-SNMPEA-MIB"),
?line init_old(),
[{mul_sub, SA} | Config].
finish_mul(Config) when is_list(Config) ->
init_case(Config),
SA = ?config(mul_sub, Config),
?line unload_master("OLD-SNMPEA-MIB"),
?line stop_subagent(SA),
lists:keydelete(mul_sub, 1, Config).
mul_get(suite) -> [];
mul_get(Config) when is_list(Config) ->
?P(mul_get),
init_case(Config),
?P1("Testing multiple get..."),
try_test(do_mul_get).
mul_get_2(X) -> ?P(mul_get_2), mul_get(X).
mul_get_3(X) -> ?P(mul_get_3), mul_get(X).
mul_get_err(suite) -> [];
mul_get_err(Config) when is_list(Config) ->
?P(mul_get_err),
init_case(Config),
?P1("Testing multiple get with error..."),
try_test(do_mul_get_err).
mul_get_err_2(X) -> ?P(mul_get_err_2), mul_get_err(X).
mul_get_err_3(X) -> ?P(mul_get_err_3), mul_get_err(X).
mul_next(suite) -> [];
mul_next(Config) when is_list(Config) ->
?P(mul_next),
init_case(Config),
?P1("Testing multiple next..."),
try_test(do_mul_next).
mul_next_2(X) -> ?P(mul_next_2), mul_next(X).
mul_next_3(X) -> ?P(mul_next_3), mul_next(X).
mul_next_err(suite) -> [];
mul_next_err(Config) when is_list(Config) ->
?P(mul_next_err),
init_case(Config),
?P1("Testing multiple next..."),
try_test(do_mul_next_err).
mul_next_err_2(X) -> ?P(mul_next_err_2), mul_next_err(X).
mul_next_err_3(X) -> ?P(mul_next_err_3), mul_next_err(X).
mul_set(suite) -> [];
mul_set(Config) when is_list(Config) ->
?P(mul_set),
init_case(Config),
?P1("Testing multiple set..."),
try_test(do_mul_set).
mul_set_2(X) -> ?P(mul_set_2), mul_set(X).
mul_set_3(X) -> ?P(mul_set_3), mul_set(X).
mul_set_err(suite) -> [];
mul_set_err(Config) when is_list(Config) ->
?P(mul_set_err),
init_case(Config),
?P1("Testing multiple set with error..."),
try_test(do_mul_set_err).
mul_set_err_2(X) -> ?P(mul_set_err_2), mul_set_err(X).
mul_set_err_3(X) -> ?P(mul_set_err_3), mul_set_err(X).
sa_register(suite) -> [];
sa_register(Config) when is_list(Config) ->
?P(sa_register),
{SaNode, _MgrNode, MibDir} = init_case(Config),
?DBG("sa_register -> start subagent", []),
?P1("start subagent..."),
?line {ok, SA} = start_subagent(SaNode, ?klas1, "Klas1"),
?DBG("sa_register -> unregister subagent", []),
?P1("Testing unregister subagent (2)..."),
MA = whereis(snmp_master_agent),
rpc:call(SaNode, snmp, unregister_subagent, [MA, ?klas1]),
try_test(unreg_test),
?P1("Unloading Klas1..."),
?DBG("sa_register -> unload mibs", []),
snmpa:unload_mibs(SA, [MibDir ++ "Klas1"]),
?P1("Loading SA-MIB..."),
?DBG("sa_register -> unload mibs", []),
snmpa:load_mibs(SA, [MibDir ++ "SA-MIB"]),
?P1("register subagent..."),
?DBG("sa_register -> register subagent", []),
rpc:call(SaNode, snmp, register_subagent, [MA, ?sa, SA]),
try_test(sa_mib),
?P1("stop subagent..."),
?DBG("sa_register -> stop subagent", []),
?line stop_subagent(SA).
sa_register_2(X) -> ?P(sa_register_2), sa_register(X).
sa_register_3(X) -> ?P(sa_register_3), sa_register(X).
v1_trap(suite) -> [];
v1_trap(Config) when is_list(Config) ->
?P(v1_trap),
trap1(Config).
trap1(Config) ->
{SaNode, _MgrNode, _MibDir} = init_case(Config),
?P1("start subagent..."),
?line {ok, SA} = start_subagent(SaNode, ?sa, "SA-MIB"),
?P1("Testing trap sending from master agent..."),
MA = whereis(snmp_master_agent),
?P1("load TestTrap & TestTrapv2..."),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
?P1("Testing trap sending from master-agent..."),
try_test(ma_trap1, [MA]),
try_test(ma_trap2, [MA]),
try_test(ma_v2_2_v1_trap, [MA]),
try_test(ma_v2_2_v1_trap2, [MA]),
?P1("Testing trap sending from subagent..."),
try_test(sa_trap1, [SA]),
try_test(sa_trap2, [SA]),
try_test(sa_trap3, [SA]),
?P1("unload TestTrap & TestTrapv2..."),
?line unload_master("TestTrap"),
?line unload_master("TestTrapv2"),
?P1("stop subagent..."),
?line stop_subagent(SA).
v2_trap(suite) -> [];
v2_trap(Config) when is_list(Config) ->
?P(v2_trap),
trap2(Config).
trap2(Config) ->
{SaNode, _MgrNode, _MibDir} = init_case(Config),
?P1("start subagent..."),
?line {ok, SA} = start_subagent(SaNode, ?sa, "SA-MIB"),
?P1("Testing trap sending from master agent..."),
MA = whereis(snmp_master_agent),
?P1("load TestTrap & TestTrapv2..."),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
?P1("Testing trap sending from master-agent..."),
try_test(ma_v2_trap1, [MA]),
try_test(ma_v2_trap2, [MA]),
try_test(ma_v1_2_v2_trap, [MA]),
try_test(ma_v1_2_v2_trap2, [MA]),
try_test(sa_mib),
?P1("Testing trap sending from subagent..."),
try_test(sa_v1_2_v2_trap1, [SA]),
try_test(sa_v1_2_v2_trap2, [SA]),
try_test(sa_v1_2_v2_trap3, [SA]),
?P1("unload TestTrap & TestTrapv2..."),
?line unload_master("TestTrap"),
?line unload_master("TestTrapv2"),
?P1("stop subagent..."),
?line stop_subagent(SA).
v3_trap(suite) -> [];
v3_trap(Config) when is_list(Config) ->
%% <CONDITIONAL-SKIP>
Skippable = [{unix, [darwin]}],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(Config, Condition),
%% </CONDITIONAL-SKIP>
?P(v3_trap),
trap2(Config).
v3_inform(_X) ->
%% v2_inform(X).
{req, [], {conf, init_v3_inform, [v3_inform_i], finish_v3_inform}}.
init_v2_inform(Config) when is_list(Config) ->
_Dir = ?config(agent_dir, Config),
%% snmp_internal_mib:configure(Dir),
Config.
init_v3_inform(X) ->
init_v2_inform(X).
finish_v2_inform(Config) when is_list(Config) ->
_Dir = ?config(agent_dir, Config),
%% snmp_internal_mib:configure(Dir),
Config.
finish_v3_inform(X) ->
finish_v2_inform(X).
v2_inform_i(suite) -> [];
v2_inform_i(Config) when is_list(Config) ->
?P(v2_inform_i),
inform_i(Config).
inform_i(Config) ->
init_case(Config),
MA = whereis(snmp_master_agent),
?P1("load TestTrap & TestTrapv2..."),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
?P1("Testing inform sending from master agent... "
"~nNOTE! This test takes a few minutes (10) to complete."),
try_test(ma_v2_inform1, [MA]),
try_test(ma_v2_inform2, [MA]),
try_test(ma_v2_inform3, [MA]),
?P1("unload TestTrap & TestTrapv2..."),
?line unload_master("TestTrap"),
?line unload_master("TestTrapv2"),
ok.
v3_inform_i(X) ->
%% <CONDITIONAL-SKIP>
Skippable = [{unix, [darwin]}],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(X, Condition),
%% </CONDITIONAL-SKIP>
?P(v3_inform_i),
inform_i(X).
sa_error(suite) -> [];
sa_error(Config) when is_list(Config) ->
?P(sa_error),
{SaNode, _MgrNode, _MibDir} = init_case(Config),
?P1("load OLD-SNMPEA-MIB..."),
?line load_master("OLD-SNMPEA-MIB"),
?line init_old(),
?P1("start subagent..."),
?line {ok, SA} = start_subagent(SaNode, ?sa, "SA-MIB"),
?P1("Testing sa bad value (is_set_ok)..."),
try_test(sa_errs_bad_value),
?P1("Testing sa gen err (set)..."),
try_test(sa_errs_gen_err),
?P1("Testing too big..."),
try_test(sa_too_big),
?P1("unload OLD-SNMPEA-MIB..."),
?line unload_master("OLD-SNMPEA-MIB"),
?P1("stop subagent..."),
stop_subagent(SA).
sa_error_2(X) ->
?P(sa_error_2),
sa_error(X).
sa_error_3(X) ->
%% <CONDITIONAL-SKIP>
Skippable = [{unix, [darwin]}],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(X, Condition),
%% </CONDITIONAL-SKIP>
?P(sa_error_3),
sa_error(X).
next_across_sa(suite) -> [];
next_across_sa(Config) when is_list(Config) ->
?P(next_across_sa),
{SaNode, _MgrNode, MibDir} = init_case(Config),
MA = whereis(snmp_master_agent),
?P1("start subagent (1)..."),
?line {ok, SA} = start_subagent(SaNode, ?sa, "SA-MIB"),
?P1("Loading another subagent mib (Klas1)..."),
?line ok = snmpa:load_mibs(SA, [MibDir ++ "Klas1"]),
?P1("register subagent..."),
rpc:call(SaNode, snmp, register_subagent, [MA, ?klas1, SA]),
?P1("Load test subagent..."),
try_test(load_test_sa),
?P1("Testing next across subagent (endOfMibView from SA)..."),
try_test(next_across_sa),
?P1("Unloading mib (Klas1)"),
snmpa:unload_mibs(SA, [MibDir ++ "Klas1"]),
rpc:call(SaNode, snmp, unregister_subagent, [MA, ?klas1]),
try_test(unreg_test),
?P1("Starting another subagent (2) "),
?line {ok, SA2} = start_subagent(SaNode, ?klas1, "Klas1"),
?P1("Testing next across subagent (wrong prefix from SA)..."),
try_test(next_across_sa),
?P1("stop subagent (1)..."),
stop_subagent(SA),
?P1("stop subagent (2)..."),
stop_subagent(SA2).
next_across_sa_2(X) ->
?P(next_across_sa_2),
next_across_sa(X).
next_across_sa_3(X) ->
%% <CONDITIONAL-SKIP>
Skippable = [{unix, [darwin]}],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(X, Condition),
%% </CONDITIONAL-SKIP>
?P(next_across_sa_3),
next_across_sa(X).
undo(suite) -> [];
undo(Config) when is_list(Config) ->
?P(undo),
{SaNode, _MgrNode, MibDir} = init_case(Config),
MA = whereis(snmp_master_agent),
?P1("start subagent (1)..."),
?line {ok, SA} = start_subagent(SaNode, ?sa, "SA-MIB"),
?P1("Load Klas3 & Klas4..."),
?line ok = snmpa:load_mibs(MA, [MibDir ++ "Klas3"]),
?line ok = snmpa:load_mibs(MA, [MibDir ++ "Klas4"]),
?P1("Testing undo phase at master agent..."),
try_test(undo_test),
try_test(api_test2),
?P1("Unload Klas3..."),
?line ok = snmpa:unload_mibs(MA, [MibDir ++ "Klas3"]),
?P1("Testing bad return values from instrum. funcs..."),
try_test(bad_return),
?P1("Unload Klas4..."),
?line ok = snmpa:unload_mibs(MA, [MibDir ++ "Klas4"]),
?P1("Testing undo phase at subagent..."),
?line ok = snmpa:load_mibs(SA, [MibDir ++ "Klas3"]),
?line ok = snmpa:load_mibs(SA, [MibDir ++ "Klas4"]),
?line ok = snmpa:register_subagent(MA, ?klas3, SA),
?line ok = snmpa:register_subagent(MA, ?klas4, SA),
try_test(undo_test),
try_test(api_test3),
?P1("Testing undo phase across master/subagents..."),
try_test(undo_test),
try_test(api_test3),
?P1("stop subagent..."),
stop_subagent(SA).
undo_2(X) ->
?P(undo_2),
undo(X).
undo_3(X) ->
%% <CONDITIONAL-SKIP>
Skippable = [{unix, [darwin]}],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(X, Condition),
%% </CONDITIONAL-SKIP>
?P(undo_3),
undo(X).
%% Req. Test2
v1_processing(suite) -> [];
v1_processing(Config) when is_list(Config) ->
?P(v1_processing),
?DBG("v1_processing -> entry", []),
init_case(Config),
?P1("Load Test2..."),
?line load_master("Test2"),
try_test(v1_proc),
?P1("Unload Test2..."),
?line unload_master("Test2").
%% Req. Test2
v2_processing(suite) -> [];
v2_processing(Config) when is_list(Config) ->
?P(v2_processing),
init_case(Config),
?P1("Load Test2..."),
?line load_master("Test2"),
try_test(v2_proc),
?P1("Unload Test2..."),
?line unload_master("Test2").
%% Req. Test2
v3_processing(suite) -> [];
v3_processing(Config) when is_list(Config) ->
?P(v3_processing),
init_case(Config),
?P1("Load Test2..."),
?line load_master("Test2"),
try_test(v2_proc), % same as v2!
?P1("Unload Test2..."),
?line unload_master("Test2").
%% We'll try get/set/trap and inform for all the auth & priv protocols.
%% For informs, the mgr is auth-engine. The agent has to sync. This is
%% accomplished by the first inform sent. That one will generate a
%% report, which makes it in sync. The notification-generating
%% application times out, and send again. This time it'll work.
v3_crypto_basic(suite) -> [];
v3_crypto_basic(_Config) ->
?P(v3_crypto_basic),
EID = [0,0,0,0,0,0,0,0,0,0,0,2],
%% From rfc2274 appendix A.3.1
?line KMd5_1 = snmp:passwd2localized_key(md5, "maplesyrup", EID),
?line [16#52,16#6f,16#5e,16#ed,16#9f,16#cc,16#e2,16#6f,
16#89,16#64,16#c2,16#93,16#07,16#87,16#d8,16#2b] =
KMd5_1,
%% From rfc2274 appendix A.3.2
?line KSHA_1 = snmp:passwd2localized_key(sha, "maplesyrup", EID),
?line [16#66,16#95,16#fe,16#bc,16#92,16#88,16#e3,16#62,16#82,16#23,
16#5f,16#c7,16#15,16#1f,16#12,16#84,16#97,16#b3,16#8f,16#3f] =
KSHA_1,
%% From rfc2274, appendix A.5.1
?line KMd5_2 = snmp:passwd2localized_key(md5, "newsyrup", EID),
?line [16#00,16#00,16#00,16#00,16#00,16#00,16#00,16#00,
16#00,16#00,16#00,16#00,16#00,16#00,16#00,16#00,
16#88,16#05,16#61,16#51,16#41,16#67,16#6c,16#c9,
16#19,16#61,16#74,16#e7,16#42,16#a3,16#25,16#51] =
snmp_user_based_sm_mib:mk_key_change(md5, KMd5_1, KMd5_2, 16,
[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0]),
%% From rfc2274, appendix A.5.2
?line KSHA_2 = snmp:passwd2localized_key(sha, "newsyrup", EID),
?line [16#00,16#00,16#00,16#00,16#00,16#00,16#00,16#00,
16#00,16#00,16#00,16#00,16#00,16#00,16#00,16#00,
16#00,16#00,16#00,16#00,16#9c,16#10,16#17,16#f4,
16#fd,16#48,16#3d,16#2d,16#e8,16#d5,16#fa,16#db,
16#f8,16#43,16#92,16#cb,16#06,16#45,16#70,16#51] =
snmp_user_based_sm_mib:mk_key_change(sha, KSHA_1, KSHA_2, 20,
[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0]),
KSHA_1t = lists:sublist(KSHA_1, 16),
KSHA_2t = lists:sublist(KSHA_2, 16),
?line [16#00,16#00,16#00,16#00,16#00,16#00,16#00,16#00,
16#00,16#00,16#00,16#00,16#00,16#00,16#00,16#00,
16#7e,16#f8,16#d8,16#a4,16#c9,16#cd,16#b2,16#6b,
16#47,16#59,16#1c,16#d8,16#52,16#ff,16#88,16#b5] =
snmp_user_based_sm_mib:mk_key_change(sha, KSHA_1t, KSHA_2t, 16,
[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0]),
%% Try with correct random
?line Kc1 = snmp_user_based_sm_mib:mk_key_change(md5, KMd5_1, KMd5_2),
?line KMd5_2 = snmp_user_based_sm_mib:extract_new_key(md5, KMd5_1, Kc1),
?line Kc2 = snmp_user_based_sm_mib:mk_key_change(sha, KSHA_1, KSHA_2),
?line KSHA_2 = snmp_user_based_sm_mib:extract_new_key(sha, KSHA_1, Kc2),
ok.
v3_md5_auth(suite) -> [];
v3_md5_auth(Config) when is_list(Config) ->
?P(v3_md5_auth),
init_case(Config),
?P1("Testing MD5 authentication...takes a few seconds..."),
AgentDir = ?config(agent_dir, Config),
?line rewrite_target_params_conf(AgentDir, "authMD5", authNoPriv),
?line snmp_target_mib:reconfigure(AgentDir),
MA = whereis(snmp_master_agent),
?line load_master("Test2"),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
try_test(v3_sync, [[{v2_proc, []},
{ma_v2_trap1, [MA]},
{v3_inform_sync, [MA]}]],
[{sec_level, authNoPriv}, {user, "authMD5"}]),
?line unload_master("TestTrapv2"),
?line unload_master("TestTrap"),
?line unload_master("Test2"),
?line reset_target_params_conf(AgentDir).
v3_sha_auth(suite) -> [];
v3_sha_auth(Config) when is_list(Config) ->
?P(v3_sha_auth),
init_case(Config),
?P1("Testing SHA authentication...takes a few seconds..."),
AgentDir = ?config(agent_dir, Config),
?line rewrite_target_params_conf(AgentDir, "authSHA", authNoPriv),
?line snmp_target_mib:reconfigure(AgentDir),
MA = whereis(snmp_master_agent),
?line load_master("Test2"),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
try_test(v3_sync, [[{v2_proc, []},
{ma_v2_trap1, [MA]},
{v3_inform_sync, [MA]}]],
[{sec_level, authNoPriv}, {user, "authSHA"}]),
?line unload_master("TestTrapv2"),
?line unload_master("TestTrap"),
?line unload_master("Test2"),
?line reset_target_params_conf(AgentDir).
v3_des_priv(suite) -> [];
v3_des_priv(Config) when is_list(Config) ->
?P(v3_des_priv),
init_case(Config),
?P1("Testing DES encryption...takes a few seconds..."),
AgentDir = ?config(agent_dir, Config),
?line rewrite_target_params_conf(AgentDir, "privDES", authPriv),
?line snmp_target_mib:reconfigure(AgentDir),
MA = whereis(snmp_master_agent),
snmp_user_based_sm_mib:usmUserTable(print),
?line load_master("Test2"),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
try_test(v3_sync, [[{v2_proc, []},
{ma_v2_trap1, [MA]},
{v3_inform_sync, [MA]}]],
[{sec_level, authPriv}, {user, "privDES"}]),
?line unload_master("TestTrapv2"),
?line unload_master("TestTrap"),
?line unload_master("Test2"),
?line reset_target_params_conf(AgentDir).
%% -define(usmStatsNotInTimeWindows_instance, [1,3,6,1,6,3,15,1,1,2,0]).
%% Make sure mgr is in sync with agent
v3_sync(Funcs) ->
?DBG("v3_sync -> entry with Funcs: ~p",[Funcs]),
g([[sysDescr, 0]]),
expect(432, report, [{?usmStatsNotInTimeWindows_instance, any}]),
g([[sysDescr, 0]]),
expect(433, [{[sysDescr,0], any}]),
lists:foreach(fun({Func, Args}) -> apply(?MODULE, Func, Args) end, Funcs).
v3_inform_sync(MA) ->
?DBG("v3_sync -> entry with MA: ~p => Send notification",[MA]),
?line snmpa:send_notification(MA, testTrapv22, no_receiver,
"standard inform", []),
%% Make sure agent is in sync with mgr...
?DBG("v3_sync -> wait some time: ",[]),
?SLEEP(20000), % more than 1500*10 in target_addr.conf
?DBG("v3_sync -> await response",[]),
?line expect(1, {inform, true},
[{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}]).
v2_caps(suite) -> [];
v2_caps(Config) when is_list(Config) ->
?P(v2_caps),
init_case(Config),
try_test(v2_caps_i, [node()]).
v2_caps_3(X) -> ?P(v2_caps_3), v2_caps(X).
v2_caps_i(Node) ->
?line Idx = rpc:call(Node, snmp, add_agent_caps, [[1,2,3,4,5], "test cap"]),
g([[sysORID, Idx], [sysORDescr, Idx]]),
?line expect(1, [{[sysORID, Idx], [1,2,3,4,5]},
{[sysORDescr, Idx], "test cap"}]),
?line rpc:call(Node, snmp, del_agent_caps, [Idx]),
g([[sysORID, Idx]]),
?line expect(2, [{[sysORID, Idx], noSuchInstance}]).
%% Req. Test2
v1_proc() ->
?DBG("v1_proc -> entry", []),
%% According to RFC1157.
%% Template: <Section>:<list no>
v1_get_p(),
v1_get_next_p(),
v1_set_p().
v1_get_p() ->
%% 4.1.2:1
g([[test2]]),
?line expect(10, noSuchName, 1, [{[test2], 'NULL'}]),
g([[tDescr]]),
?line expect(11, noSuchName, 1, [{[tDescr], 'NULL'}]),
g([[tDescr2,0]]),
?line expect(12, noSuchName, 1, [{[tDescr2,0], 'NULL'}]),
g([[tDescr3,0]]),
?line expect(131, noSuchName, 1, [{[tDescr3,0], 'NULL'}]),
g([[tDescr4,0]]),
?line expect(132, noSuchName, 1, [{[tDescr4,0], 'NULL'}]),
g([[sysDescr, 0], [tDescr,0]]), % Outside mibview
?line expect(14, noSuchName, 2, [{[sysDescr, 0], 'NULL'},
{[tDescr,0], 'NULL'}]),
g([[sysDescr,3]]),
?line expect(15, noSuchName, 1, [{[sysDescr, 3], 'NULL'}]),
%% 4.1.2:2
g([[tTable]]),
?line expect(20, noSuchName, 1, [{[tTable], 'NULL'}]),
g([[tEntry]]),
?line expect(21, noSuchName, 1, [{[tEntry], 'NULL'}]),
%% 4.1.2:3
g([[tTooBig, 0]]),
?line expect(30, tooBig, 0, [{[tTooBig, 0], 'NULL'}]),
%% 4.1.2:4
g([[tGenErr1, 0]]),
?line expect(40, genErr, 1, [{[tGenErr1, 0], 'NULL'}]),
g([[tGenErr2, 0]]),
?line expect(41, genErr, 1, [{[tGenErr2, 0], 'NULL'}]),
g([[sysDescr, 0], [tGenErr3, 0]]),
?line expect(42, genErr, 2, [{[sysDescr, 0], 'NULL'},
{[tGenErr3, 0], 'NULL'}]).
v1_get_next_p() ->
%% 4.1.3:1
gn([[1,3,7,1]]),
?line expect(10, noSuchName, 1, [{[1,3,7,1], 'NULL'}]),
gn([[tDescr2]]),
?line expect(11, tooBig, 0, any),
%% 4.1.3:2
gn([[tTooBig]]),
io:format("We currently don't handle tooBig correct!!!\n"),
% ?line expect(20, tooBig, 0, [{[tTooBig], 'NULL'}]),
?line expect(20, tooBig, 0, any),
%% 4.1.3:3
gn([[tGenErr1]]),
% ?line expect(40, genErr, 1, [{[tGenErr1], 'NULL'}]),
?line expect(40, genErr, 1, any),
gn([[tGenErr2]]),
% ?line expect(41, genErr, 1, [{[tGenErr2], 'NULL'}]),
?line expect(41, genErr, 1, any),
gn([[sysDescr], [tGenErr3]]),
% ?line expect(42, genErr, 2, [{[sysDescr], 'NULL'},
% {[tGenErr3], 'NULL'}]).
?line expect(42, genErr, 2, any).
v1_set_p() ->
%% 4.1.5:1
s([{[1,3,7,0], i, 4}]),
?line expect(10, noSuchName, 1, [{[1,3,7,0], 4}]),
s([{[tDescr,0], s, "outside mibview"}]),
?line expect(11, noSuchName, 1, [{[tDescr,0], "outside mibview"}]),
s([{[tDescr3,0], s, "read-only"}]),
?line expect(12, noSuchName, 1, [{[tDescr3,0], "read-only"}]),
s([{[tDescr3], s, "noSuchObject"}]),
?line expect(13, noSuchName, 1, [{[tDescr3], "noSuchObject"}]),
s([{[tDescr3,1], s, "noSuchInstance"}]),
?line expect(14, noSuchName, 1, [{[tDescr3,1], "noSuchInstance"}]),
s([{[tDescr2,0], s, "inconsistentName"}]),
?line expect(15, noSuchName, 1, [{[tDescr2,0], "inconsistentName"}]),
%% 4.1.5:2
s([{[tDescr2, 0], i, 4}]),
?line expect(20, badValue, 1, [{[tDescr2, 0], 4}]),
s([{[tDescr2, 0], s, "badValue"}]),
?line expect(21, badValue, 1, [{[tDescr2, 0], "badValue"}]),
%% 4.1.5:3
%% The standard is quite incorrect here. The resp pdu was too big. In
%% the resp pdu, we have the original vbs. In the tooBig pdu we still
%% have to original vbs => the tooBig pdu is too big as well!!! It
%% may not get it to the manager, unless the agent uses 'NULL' instead
%% of the std-like original value.
s([{[tTooBig, 0], s, ?tooBigStr}]),
%% according to std:
% ?line expect(30, tooBig, 0, [{[tTooBig, 0], ?tooBigStr}]),
?line expect(30, tooBig, 0, [{[tTooBig, 0], 'NULL'}]),
%% 4.1.5:4
s([{[tDescr2, 0], s, "is_set_ok_fail"}]),
?line expect(40, genErr, 1, [{[tDescr2, 0], "is_set_ok_fail"}]),
s([{[tDescr2, 0], s, "commit_fail"}]),
?line expect(41, genErr, 1, [{[tDescr2, 0], "commit_fail"}]).
%% Req. Test2
v2_proc() ->
%% According to RFC1905.
%% Template: <Section>:<list no>
?DBG("v2_proc -> entry",[]),
v2_get_p(),
v2_get_next_p(),
v2_get_bulk_p(),
v2_set_p().
v2_get_p() ->
%% 4.2.1:2
?DBG("v2_get_p -> entry",[]),
g([[test2]]),
?line expect(10, [{[test2], noSuchObject}]),
g([[tDescr]]),
?line expect(11, [{[tDescr], noSuchObject}]),
g([[tDescr4,0]]),
?line expect(12, [{[tDescr4,0], noSuchObject}]),
g([[sysDescr, 0], [tDescr,0]]), % Outside mibview
?line expect(13, [{[sysDescr,0], "Erlang SNMP agent"},
{[tDescr,0], noSuchObject}]),
g([[tTable]]),
?line expect(14, [{[tTable], noSuchObject}]),
g([[tEntry]]),
?line expect(15, [{[tEntry], noSuchObject}]),
%% 4.2.1:3
g([[tDescr2,0]]), %% instrum ret noSuchName!!!
?line expect(20, [{[tDescr2,0], noSuchInstance}]),
g([[tDescr3,0]]),
?line expect(21, [{[tDescr3,0], noSuchInstance}]),
g([[sysDescr,3]]),
?line expect(22, [{[sysDescr, 3], noSuchInstance}]),
g([[tIndex,1]]),
?line expect(23, [{[tIndex, 1], noSuchInstance}]),
%% 4.2.1 - any other error: genErr
g([[tGenErr1, 0]]),
?line expect(30, genErr, 1, [{[tGenErr1, 0], 'NULL'}]),
g([[tGenErr2, 0]]),
?line expect(31, genErr, 1, [{[tGenErr2, 0], 'NULL'}]),
g([[sysDescr, 0], [tGenErr3, 0]]),
?line expect(32, genErr, 2, [{[sysDescr, 0], 'NULL'},
{[tGenErr3, 0], 'NULL'}]),
%% 4.2.1 - tooBig
g([[tTooBig, 0]]),
?line expect(40, tooBig, 0, []).
v2_get_next_p() ->
%% 4.2.2:2
?DBG("v2_get_next_p -> entry",[]),
gn([[1,3,7,1]]),
?line expect(10, [{[1,3,7,1], endOfMibView}]),
gn([[sysDescr], [1,3,7,1]]),
?line expect(11, [{[sysDescr, 0], "Erlang SNMP agent"},
{[1,3,7,1], endOfMibView}]),
gn([[tCnt2, 1]]),
?line expect(12, [{[tCnt2,2], 100}]),
gn([[tCnt2, 2]]),
?line expect(12, [{[tCnt2,2], endOfMibView}]),
%% 4.2.2 - any other error: genErr
gn([[tGenErr1]]),
?line expect(20, genErr, 1, [{[tGenErr1], 'NULL'}]),
gn([[tGenErr2]]),
?line expect(21, genErr, 1, [{[tGenErr2], 'NULL'}]),
gn([[sysDescr], [tGenErr3]]),
?line expect(22, genErr, 2, [{[sysDescr], 'NULL'},
{[tGenErr3], 'NULL'}]),
%% 4.2.2 - tooBig
gn([[tTooBig]]),
?line expect(20, tooBig, 0, []).
v2_get_bulk_p() ->
%% 4.2.3
?DBG("v2_get_bulk_p -> entry",[]),
gb(1, 1, []),
?line expect(10, []),
gb(-1, 1, []),
?line expect(11, []),
gb(-1, -1, []),
?line expect(12, []),
gb(-1, -1, []),
?line expect(13, []),
gb(2, 0, [[sysDescr], [1,3,7,1]]),
?line expect(14, [{[sysDescr, 0], "Erlang SNMP agent"},
{[1,3,7,1], endOfMibView}]),
gb(1, 2, [[sysDescr], [1,3,7,1]]),
?line expect(15, [{[sysDescr, 0], "Erlang SNMP agent"},
{[1,3,7,1], endOfMibView}]),
gb(0, 2, [[sysDescr], [1,3,7,1]]),
?line expect(16, [{[sysDescr, 0], "Erlang SNMP agent"},
{[1,3,7,1], endOfMibView},
{[sysObjectID, 0], [1,2,3]},
{[1,3,7,1], endOfMibView}]),
gb(2, 2, [[sysDescr], [1,3,7,1], [sysDescr], [1,3,7,1]]),
?line expect(17, [{[sysDescr, 0], "Erlang SNMP agent"},
{[1,3,7,1], endOfMibView},
{[sysDescr, 0], "Erlang SNMP agent"},
{[1,3,7,1], endOfMibView},
{[sysObjectID, 0], [1,2,3]},
{[1,3,7,1], endOfMibView}]),
gb(1, 2, [[sysDescr], [sysDescr], [tTooBig]]),
?line expect(18, [{[sysDescr, 0], "Erlang SNMP agent"},
{[sysDescr, 0], "Erlang SNMP agent"}]),
gb(1,12, [[tDescr2], [sysDescr]]), % next one after tDescr2 is tTooBig.
?line expect(19, []),
gb(2,2, [[sysDescr], [sysObjectID], [tGenErr1], [sysDescr]]),
?line expect(20, genErr, 3, [{[sysDescr], 'NULL'},
{[sysObjectID], 'NULL'},
{[tGenErr1], 'NULL'},
{[sysDescr], 'NULL'}]),
gb(0, 2, [[tCnt2, 1]]),
?line expect(21, [{[tCnt2,2], 100},
{[tCnt2,2], endOfMibView}]).
v2_set_p() ->
%% 4.2.5:1
?DBG("v2_set_p -> entry",[]),
s([{[1,3,7,0], i, 4}]),
?line expect(10, noAccess, 1, [{[1,3,7,0], 4}]),
s([{[tDescr,0], s, "outside mibview"}]),
?line expect(11, noAccess, 1, [{[tDescr,0], "outside mibview"}]),
%% 4.2.5:2
s([{[1,3,6,1,0], s, "noSuchObject"}]),
?line expect(20, notWritable, 1, [{[1,3,6,1,0], "noSuchObject"}]),
%% 4.2.5:3
s([{[tDescr2, 0], i, 4}]),
?line expect(30, wrongType, 1, [{[tDescr2, 0], 4}]),
s([{[tDescr2, 0], s, "badValue"}]),
?line expect(31, badValue, 1, [{[tDescr2, 0], "badValue"}]),
%% 4.2.5:4
s([{[tStr, 0], s, ""}]),
?line expect(40, wrongLength, 1, [{[tStr, 0], ""}]),
s([{[tStr, 0], s, "12345"}]),
?line expect(40, wrongLength, 1, [{[tStr, 0], "12345"}]),
%% 4.2.5:5 - N/A
%% 4.2.5:6
s([{[tInt1, 0], i, 0}]),
?line expect(60, wrongValue, 1, [{[tInt1, 0], 0}]),
s([{[tInt1, 0], i, 5}]),
?line expect(61, wrongValue, 1, [{[tInt1, 0], 5}]),
s([{[tInt2, 0], i, 0}]),
?line expect(62, wrongValue, 1, [{[tInt2, 0], 0}]),
s([{[tInt2, 0], i, 5}]),
?line expect(63, wrongValue, 1, [{[tInt2, 0], 5}]),
s([{[tInt3, 0], i, 5}]),
?line expect(64, wrongValue, 1, [{[tInt3, 0], 5}]),
%% 4.2.5:7
s([{[tDescrX, 1, 1], s, "noCreation"}]),
?line expect(70, noCreation, 1, [{[tDescrX, 1, 1], "noCreation"}]),
%% 4.2.5:8
s([{[tDescrX, 1, 2], s, "inconsistentName"}]),
?line expect(80, inconsistentName, 1,
[{[tDescrX, 1, 2], "inconsistentName"}]),
%% 4.2.5:9
s([{[tCnt, 1, 2], i, 5}]),
?line expect(90, notWritable, 1, [{[tCnt, 1, 2], 5}]),
s([{[tDescr3,0], s, "read-only"}]),
?line expect(90, notWritable, 1, [{[tDescr3,0], "read-only"}]),
%% 4.2.5:10
s([{[tDescr2,0], s, "inconsistentValue"}]),
?line expect(100, inconsistentValue, 1,
[{[tDescr2,0], "inconsistentValue"}]),
%% 4.2.5:11
s([{[tDescr2,0], s, "resourceUnavailable"}]),
?line expect(110, resourceUnavailable, 1,
[{[tDescr2,0],"resourceUnavailable"}]),
%% 4.2.5:12
s([{[tDescr2, 0], s, "is_set_ok_fail"}]),
?line expect(120, genErr, 1, [{[tDescr2, 0], "is_set_ok_fail"}]).
%% commitFailed and undoFailed is tested by the 'undo' case.
%% Req. OLD-SNMPEA-MIB
table_test() ->
io:format("Testing simple get, next and set on communityTable...~n"),
%% {[147,214,36,45], "public", 2, readWrite}.
%% {[147,214,36,45], "standard trap", 2, read}.
Key1c3 = [intCommunityViewIndex,get(mip),is("public")],
Key2c3 = [intCommunityViewIndex,get(mip),is("standard trap")],
Key1c4 = [intCommunityAccess,get(mip),is("public")],
EndKey = [intCommunityEntry,[9],get(mip),is("public")],
gn([[intCommunityEntry]]),
?line expect(7, [{Key1c3, 2}]),
gn([[intCommunityTable]]),
?line expect(71, [{Key1c3, 2}]),
gn([[community]]),
?line expect(72, [{Key1c3, 2}]),
gn([[otpSnmpeaMIB]]),
?line expect(73, [{Key1c3, 2}]),
gn([[ericsson]]),
?line expect(74, [{Key1c3, 2}]),
gn([Key1c3]),
?line expect(8, [{Key2c3, 2}]),
gn([Key2c3]),
?line expect(9, [{Key1c4, 2}]),
gn([EndKey]),
AgentIp = [intAgentIpAddress,0],
?line expect(10, [{AgentIp, any}]),
g([Key1c3]),
?line expect(11, [{Key1c3, 2}]),
g([EndKey]),
?line ?v1_2(expect(12, noSuchName, 1, any),
expect(12, [{EndKey, noSuchObject}])),
io:format("Testing row creation/deletion on communityTable...~n"),
NewKeyc3 = [intCommunityViewIndex,get(mip),is("test")],
NewKeyc4 = [intCommunityAccess,get(mip),is("test")],
NewKeyc5 = [intCommunityStatus,get(mip),is("test")],
s([{NewKeyc5, ?createAndGo}]),
?line expect(14, ?v1_2(badValue, inconsistentValue), 1,any),
s([{NewKeyc5, ?createAndGo}, {NewKeyc3, 2}, {NewKeyc4, 2}]),
?line expect(15, [{NewKeyc5, ?createAndGo},{NewKeyc3, 2}, {NewKeyc4, 2}]),
g([NewKeyc4]),
?line expect(16, [{NewKeyc4, 2}]),
s([{NewKeyc5, ?destroy}]),
?line expect(17, [{NewKeyc5, ?destroy}]),
s([{NewKeyc4, 2}]),
?line expect(18, ?v1_2(noSuchName, inconsistentName), 1,[{NewKeyc4, 2}]),
s([{NewKeyc5, ?createAndWait}]),
?line expect(19, [{NewKeyc5, ?createAndWait}]),
g([NewKeyc5]),
?line expect(20, [{NewKeyc5, ?notReady}]),
s([{NewKeyc4, 2}]),
?line expect(21, [{NewKeyc4, 2}]),
g([NewKeyc5]),
?line expect(22, [{NewKeyc5, ?notReady}]),
s([{NewKeyc3, 2}]),
?line expect(23, [{NewKeyc3, 2}]),
g([NewKeyc5]),
?line expect(24, [{NewKeyc5, ?notInService}]),
s([{NewKeyc5, ?active}]),
?line expect(25, [{NewKeyc5, ?active}]),
s([{NewKeyc5, ?destroy}]),
?line expect(26, [{NewKeyc5, ?destroy}]),
s([{NewKeyc3, 3}]),
?line expect(27, ?v1_2(noSuchName, inconsistentName), 1,[{NewKeyc3, 3}]),
otp_1128().
%% Req. system group
simple_standard_test() ->
?DBG("simple_standard_test -> entry",[]),
gn([[1,1]]),
?line expect(1, [{[sysDescr,0], "Erlang SNMP agent"}]),
gn([[1,3]]),
?line expect(11, [{[sysDescr,0], "Erlang SNMP agent"}]),
gn([[1,3,6]]),
?line expect(12, [{[sysDescr,0], "Erlang SNMP agent"}]),
gn([[1,3,6,1]]),
?line expect(13, [{[sysDescr,0], "Erlang SNMP agent"}]),
gn([[1,3,6,1,2]]),
?line expect(14, [{[sysDescr,0], "Erlang SNMP agent"}]),
gn([[1,3,6,1,2,1]]),
?line expect(15, [{[sysDescr,0], "Erlang SNMP agent"}]),
gn([[1,3,6,1,2,1,1]]),
?line expect(16, [{[sysDescr,0], "Erlang SNMP agent"}]),
gn([[sysDescr]]),
?line expect(17, [{[sysDescr,0], "Erlang SNMP agent"}]),
g([[sysDescr,0]]),
?line expect(2, [{[sysDescr,0], "Erlang SNMP agent"}]),
g([[sysDescr]]),
?line ?v1_2(expect(3, noSuchName, 1, any),
expect(3, [{[sysDescr], noSuchObject}])),
g([[1,6,7,0]]),
?line ?v1_2(expect(41, noSuchName, 1, any),
expect(3, [{[1,6,7,0], noSuchObject}])),
gn([[1,13]]),
?line ?v1_2(expect(4, noSuchName,1, any),
expect(4, [{[1,13], endOfMibView}])),
s([{[sysLocation, 0], "new_value"}]),
?line expect(5, [{[sysLocation, 0], "new_value"}]),
g([[sysLocation, 0]]),
?line expect(6, [{[sysLocation, 0], "new_value"}]),
io:format("Testing noSuchName and badValue...~n"),
s([{[sysServices,0], 3}]),
?line expect(61, ?v1_2(noSuchName, notWritable), 1, any),
s([{[sysLocation, 0], i, 3}]),
?line expect(62, ?v1_2(badValue, wrongType), 1, any),
?DBG("simple_standard_test -> done",[]),
ok.
%% This is run in the agent node
db_notify_client(suite) -> [];
db_notify_client(Config) when is_list(Config) ->
?P(db_notify_client),
{SaNode, MgrNode, MibDir} = init_case(Config),
?DBG("db_notify_client -> case initiated: "
"~n SaNode: ~p"
"~n MgrNode: ~p"
"~n MibDir: ~p", [SaNode, MgrNode, MibDir]),
?DBG("db_notify_client -> maximize verbosity", []),
snmpa_local_db:verbosity(trace),
Self = self(),
?DBG("db_notify_client -> register self (~p) notify client", [Self]),
snmpa_local_db:register_notify_client(self(),?MODULE),
%% This call (to the manager) will issue to set operations, so
%% we expect to receive to notify(insert) calls.
try_test(db_notify_client_test),
?DBG("db_notify_client -> await first notify",[]),
receive
{db_notify_test_reply, insert} ->
?DBG("db_notify_client -> first notify received",[]),
ok
after 10000 ->
?FAIL({timeout, waiting_for_first_event})
end,
?DBG("db_notify_client -> await second notify",[]),
receive
{db_notify_test_reply, insert} ->
?DBG("db_notify_client -> second notify received",[]),
ok
after 10000 ->
?FAIL({timeout, waiting_for_second_event})
end,
?DBG("db_notify_client -> unregister self (~p) notify client", [Self]),
snmpa_local_db:unregister_notify_client(self()),
?DBG("db_notify_client -> minimize verbosity", []),
snmpa_local_db:verbosity(silence),
?DBG("db_notify_client -> done", []),
ok.
%% This is run in the manager node
db_notify_client_test() ->
?DBG("set first new sysLocation",[]),
s([{[sysLocation, 0], "new_value"}]),
?line expect(5, [{[sysLocation, 0], "new_value"}]),
?DBG("set second new sysLocation",[]),
s([{[sysLocation, 0], "new_value"}]),
?line expect(5, [{[sysLocation, 0], "new_value"}]).
notify(Pid, What) ->
?DBG("notify(~p,~p) -> called",[Pid,What]),
Pid ! {db_notify_test_reply, What}.
%% Req: system group, OLD-SNMPEA-MIB, Klas1
big_test() ->
%% put(sname, {?MODULE, big_test}),
%% put(verbosity, trace),
?DBG("big_test -> testing simple next/get/set @ master agent...",[]),
simple_standard_test(),
?DBG("big_test -> testing simple next/get/set @ subagent...",[]),
gn([[klas1]]),
?line expect(1, [{[fname,0], ""}]),
g([[fname,0]]),
?line expect(2, [{[fname,0], ""}]),
s([{[fname,0], s, "test set"}]),
?line expect(3, [{[fname,0], "test set"}]),
g([[fname,0]]),
?line expect(4, [{[fname,0], "test set"}]),
?DBG("big_test -> "
"testing next from last instance in master to subagent...",[]),
gn([[?v1_2(sysServices, sysORLastChange),0]]),
?line expect(5, [{[fname,0], "test set"}]),
gn([[1,1],
[?v1_2(sysServices, sysORLastChange),0]]),
?line expect(51, [{[sysDescr,0], "Erlang SNMP agent"},
{[fname,0], "test set"}]),
s([{[fname,0], s, ""}]),
?line expect(52, [{[fname,0], ""}]),
table_test(),
?DBG("big_test -> adding one row in subagent table",[]),
_FTab = [friendsEntry],
s([{[friendsEntry, [2, 3]], s, "kompis3"},
{[friendsEntry, [3, 3]], i, ?createAndGo}]),
?line expect(6, [{[friendsEntry, [2, 3]], "kompis3"},
{[friendsEntry, [3, 3]], ?createAndGo}]),
g([[friendsEntry, [2, 3]],
[friendsEntry, [3, 3]]]),
?line expect(7, [{[friendsEntry, [2, 3]], "kompis3"},
{[friendsEntry, [3, 3]], ?active}]),
s([{[friendsEntry, [3, 3]], i, ?destroy}]),
?line expect(8, [{[friendsEntry, [3, 3]], ?destroy}]),
otp_1131(),
?DBG("big_test -> adding two rows in subagent table with special INDEX",
[]),
s([{[kompissEntry, [1, 3]], s, "kompis3"},
{[kompissEntry, [2, 3]], i, ?createAndGo}]),
?line expect(9, [{[kompissEntry, [1, 3]], "kompis3"},
{[kompissEntry, [2, 3]], ?createAndGo}]),
g([[kompissEntry, [1, 3]],
[kompissEntry, [2, 3]]]),
?line expect(10, [{[kompissEntry, [1, 3]], "kompis3"},
{[kompissEntry, [2, 3]], ?active}]),
gn([[kompissEntry, [1]],
[kompissEntry, [2]]]),
?line expect(11, [{[kompissEntry, [1, 3]], "kompis3"},
{[kompissEntry, [2, 3]], ?active}]),
s([{[kompissEntry, [1, 2]], s, "kompis3"},
{[kompissEntry, [2, 2]], i, ?createAndGo}]),
?line expect(12, [{[kompissEntry, [1, 2]], "kompis3"},
{[kompissEntry, [2, 2]], ?createAndGo}]),
gn([[kompissEntry, [1, 1]],
[kompissEntry, [2, 1]]]),
?line expect(13, [{[kompissEntry, [1, 2]], "kompis3"},
{[kompissEntry, [2, 2]], ?active}]),
s([{[kompissEntry, [2, 3]], i, ?destroy}]),
?line expect(14, [{[kompissEntry, [2, 3]], ?destroy}]),
s([{[kompissEntry, [2, 2]], i, ?destroy}]),
?line expect(15, [{[kompissEntry, [2, 2]], ?destroy}]),
?DBG("big_test -> done",[]),
ok.
%% Req. system group, Klas2, OLD-SNMPEA-MIB
big_test_2() ->
?P1("Testing simple next/get/set @ master agent (2)..."),
simple_standard_test(),
?P1("Testing simple next/get/set @ subagent (2)..."),
gn([[klas2]]),
?line expect(1, [{[fname2,0], ""}]),
g([[fname2,0]]),
?line expect(2, [{[fname2,0], ""}]),
s([{[fname2,0], s, "test set"}]),
?line expect(3, [{[fname2,0], "test set"}]),
g([[fname2,0]]),
?line expect(4, [{[fname2,0], "test set"}]),
otp_1298(),
?P1("Testing next from last object in master to subagent (2)..."),
gn([[?v1_2(sysServices, sysORLastChange),0]]),
?line expect(5, [{[fname2,0], "test set"}]),
gn([[1,1],
[?v1_2(sysServices, sysORLastChange),0]]),
?line expect(51, [{[sysDescr,0], "Erlang SNMP agent"},
{[fname2,0], "test set"}]),
table_test(),
?P1("Adding one row in subagent table (2)"),
_FTab = [friendsEntry2],
s([{[friendsEntry2, [2, 3]], s, "kompis3"},
{[friendsEntry2, [3, 3]], i, ?createAndGo}]),
?line expect(6, [{[friendsEntry2, [2, 3]], "kompis3"},
{[friendsEntry2, [3, 3]], ?createAndGo}]),
g([[friendsEntry2, [2, 3]],
[friendsEntry2, [3, 3]]]),
?line expect(7, [{[friendsEntry2, [2, 3]], "kompis3"},
{[friendsEntry2, [3, 3]], ?active}]),
s([{[friendsEntry2, [3, 3]], i, ?destroy}]),
?line expect(8, [{[friendsEntry2, [3, 3]], ?destroy}]),
?P1("Adding two rows in subagent table with special INDEX (2)"),
s([{[kompissEntry2, [1, 3]], s, "kompis3"},
{[kompissEntry2, [2, 3]], i, ?createAndGo}]),
?line expect(9, [{[kompissEntry2, [1, 3]], "kompis3"},
{[kompissEntry2, [2, 3]], ?createAndGo}]),
g([[kompissEntry2, [1, 3]],
[kompissEntry2, [2, 3]]]),
?line expect(10, [{[kompissEntry2, [1, 3]], "kompis3"},
{[kompissEntry2, [2, 3]], ?active}]),
gn([[kompissEntry2, [1]],
[kompissEntry2, [2]]]),
?line expect(11, [{[kompissEntry2, [1, 3]], "kompis3"},
{[kompissEntry2, [2, 3]], ?active}]),
s([{[kompissEntry2, [1, 2]], s, "kompis3"},
{[kompissEntry2, [2, 2]], i, ?createAndGo}]),
?line expect(12, [{[kompissEntry2, [1, 2]], "kompis3"},
{[kompissEntry2, [2, 2]], ?createAndGo}]),
gn([[kompissEntry2, [1, 1]],
[kompissEntry2, [2, 1]]]),
?line expect(13, [{[kompissEntry2, [1, 2]], "kompis3"},
{[kompissEntry2, [2, 2]], ?active}]),
s([{[kompissEntry2, [2, 3]], i, ?destroy}]),
?line expect(14, [{[kompissEntry2, [2, 3]], ?destroy}]),
s([{[kompissEntry2, [2, 2]], i, ?destroy}]),
?line expect(15, [{[kompissEntry2, [2, 2]], ?destroy}]),
ok.
%% Req. Test1
multi_threaded_test() ->
?P1("Testing multi threaded agent..."),
g([[multiStr,0]]),
Pid = get_multi_pid(),
g([[sysUpTime,0]]),
?line expect(1, [{[sysUpTime,0], any}]),
s([{[sysLocation, 0], s, "pelle"}]),
?line expect(2, [{[sysLocation, 0], "pelle"}]),
Pid ! continue,
?line expect(3, [{[multiStr,0], "ok"}]),
s([{[multiStr, 0], s, "block"}]),
Pid2 = get_multi_pid(),
g([[sysUpTime,0]]),
?line expect(4, [{[sysUpTime,0], any}]),
g([[multiStr,0]]),
Pid3 = get_multi_pid(),
g([[sysUpTime,0]]),
?line expect(5, [{[sysUpTime,0], any}]),
s([{[sysLocation, 0], s, "kalle"}]),
Pid3 ! continue,
?line expect(6, [{[multiStr,0], "ok"}]),
Pid2 ! continue,
?line expect(7, [{[multiStr,0], "block"}]),
?line expect(8, [{[sysLocation,0], "kalle"}]).
%% Req. Test1, TestTrapv2
mt_trap_test(MA) ->
?P1("Testing trap-sending with multi threaded agent..."),
?DBG("mt_trap_test(01) -> issue testTrapv22 (standard trap)", []),
snmpa:send_trap(MA, testTrapv22, "standard trap"),
?DBG("mt_trap_test(02) -> await v2trap", []),
?line expect(mt_trap_test_1, v2trap,
[{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}]),
?DBG("mt_trap_test(03) -> issue mtTrap (standard trap)", []),
snmpa:send_trap(MA, mtTrap, "standard trap"),
Pid = get_multi_pid(),
?DBG("mt_trap_test(04) -> multi pid: ~p. Now request sysUpTime...", [Pid]),
g([[sysUpTime,0]]),
?DBG("mt_trap_test(06) -> await sysUpTime", []),
?line expect(mt_trap_test_2, [{[sysUpTime,0], any}]),
?DBG("mt_trap_test(07) -> issue testTrapv22 (standard trap)", []),
snmpa:send_trap(MA, testTrapv22, "standard trap"),
?DBG("mt_trap_test(08) -> await v2trap", []),
?line expect(mt_trap_test_3, v2trap,
[{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}]),
?DBG("mt_trap_test(09) -> send continue to multi-pid", []),
Pid ! continue,
?DBG("mt_trap_test(10) -> await v2trap", []),
?line expect(mt_trap_test_4, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?testTrap ++ [2]},
{[multiStr,0], "ok"}]),
?DBG("mt_trap_test(11) -> done", []),
ok.
get_multi_pid() ->
get_multi_pid(10).
get_multi_pid(0) ->
?line ?FAIL(no_global_name);
get_multi_pid(N) ->
?SLEEP(1000),
case global:whereis_name(snmp_multi_tester) of
Pid when is_pid(Pid) -> Pid;
_ -> get_multi_pid(N-1)
end.
%% Req. Test1
types_v2_test() ->
?P1("Testing v2 types..."),
s([{[bits1,0], 2#10}]),
?line expect(1, [{[bits1,0], ?str(2#10)}]),
g([[bits1,0]]),
?line expect(2, [{[bits1,0], ?str(2#101)}]),
s([{[bits2,0], 2#11000000110}]),
?line expect(3, [{[bits2,0], ?str(2#11000000110)}]),
g([[bits2,0]]),
?line expect(4, [{[bits2,0], ?str(2#11000000110)}]),
g([[bits3,0]]),
?line expect(50, genErr, 1, any),
g([[bits4,0]]),
?line expect(51, genErr, 1, any),
s([{[bits1,0], s, [2#10]}]),
?line expect(6, ?v1_2(badValue, wrongValue), 1, any),
s([{[bits2,0], 2#11001001101010011}]),
?line expect(7, ?v1_2(badValue, wrongValue), 1, any).
%% Req. Test1
implied_test(MA) ->
?LOG("implied_test -> start",[]),
?P1("Testing IMPLIED..."),
snmpa:verbosity(MA,trace),
snmpa:verbosity(MA,trace),
%% Create two rows, check that they are get-nexted in correct order.
Idx1 = "apa",
Idx2 = "qq",
?DBG("implied_test -> (send) create row 1 '~s' in table 1",[Idx1]),
s([{[testStatus, Idx1], i, ?createAndGo}, {[testDescr, Idx1],s,"row 1"}]),
?line expect(1, [{[testStatus, Idx1], ?createAndGo},
{[testDescr, Idx1], "row 1"}]),
?DBG("implied_test -> (send) create row 2 '~s' in table 1",[Idx2]),
s([{[testStatus, Idx2], i, ?createAndGo}, {[testDescr, Idx2],s,"row 2"}]),
?line expect(2, [{[testStatus, Idx2], ?createAndGo},
{[testDescr, Idx2], "row 2"}]),
?DBG("implied_test -> get-next(testDescr)",[]),
gn([[testDescr]]),
?line expect(3, [{[testDescr,Idx1], "row 1"}]),
?DBG("implied_test -> get-next(testDescr) of row 1",[]),
gn([[testDescr,Idx1]]),
?line expect(4, [{[testDescr,Idx2], "row 2"}]),
% Delete the rows
?DBG("implied_test -> (send) delete row 1 '~s' from table 1",[Idx1]),
s([{[testStatus, Idx1], i, ?destroy}]),
?line expect(5, [{[testStatus, Idx1], ?destroy}]),
?DBG("implied_test -> (send) delete row 2 '~s' from table 1",[Idx2]),
s([{[testStatus, Idx2], i, ?destroy}]),
?line expect(6, [{[testStatus, Idx2], ?destroy}]),
%% Try the same in other table
Idx3 = [1, "apa"],
Idx4 = [1, "qq"],
?DBG("implied_test -> (send) create row 1 '~s' in table 2",[Idx3]),
s([{[testStatus2, Idx3], i, ?createAndGo}, {[testDescr2,Idx3],s,"row 1"}]),
?line expect(1, [{[testStatus2, Idx3], ?createAndGo},
{[testDescr2, Idx3], "row 1"}]),
?DBG("implied_test -> (send) create row 2 '~s' in table 2",[Idx4]),
s([{[testStatus2, Idx4], i, ?createAndGo}, {[testDescr2,Idx4],s,"row 2"}]),
?line expect(2, [{[testStatus2, Idx4], ?createAndGo},
{[testDescr2, Idx4], "row 2"}]),
?DBG("implied_test -> get-next(testDescr2)",[]),
gn([[testDescr2]]),
?line expect(3, [{[testDescr2,Idx3], "row 1"}]),
?DBG("implied_test -> get-next(testDescr2) of row 1",[]),
gn([[testDescr2,Idx3]]),
?line expect(4, [{[testDescr2,Idx4], "row 2"}]),
% Delete the rows
?DBG("implied_test -> (send) delete row 1 '~s' from table 2",[Idx3]),
s([{[testStatus2, Idx3], i, ?destroy}]),
?line expect(5, [{[testStatus2, Idx3], ?destroy}]),
?DBG("implied_test -> (send) delete row 2 '~s' from table 2",[Idx4]),
s([{[testStatus2, Idx4], i, ?destroy}]),
?line expect(6, [{[testStatus2, Idx4], ?destroy}]),
snmpa:verbosity(MA,log),
?LOG("implied_test -> done",[]).
%% Req. Test1
sparse_table_test() ->
?P1("Testing sparse table..."),
%% Create two rows, check that they are get-nexted in correct order.
Idx1 = 1,
Idx2 = 2,
s([{[sparseStatus, Idx1], i, ?createAndGo},
{[sparseDescr, Idx1], s, "row 1"}]),
?line expect(1, [{[sparseStatus, Idx1], ?createAndGo},
{[sparseDescr, Idx1], "row 1"}]),
s([{[sparseStatus, Idx2], i, ?createAndGo},
{[sparseDescr, Idx2], s, "row 2"}]),
?line expect(2, [{[sparseStatus, Idx2], ?createAndGo},
{[sparseDescr, Idx2], "row 2"}]),
?v1_2(gn([[sparseIndex], [sparseDescr,Idx1], [sparseDescr,Idx2],
[sparseStatus,Idx1], [sparseStatus,Idx2]]),
gb(0,5,[[sparseIndex]])),
?line expect(3, [{[sparseDescr,Idx1], "row 1"},
{[sparseDescr,Idx2], "row 2"},
{[sparseStatus,Idx1], ?active},
{[sparseStatus,Idx2], ?active},
{[sparseStr,0], "slut"}]),
% Delete the rows
s([{[sparseStatus, Idx1], i, ?destroy}]),
?line expect(4, [{[sparseStatus, Idx1], ?destroy}]),
s([{[sparseStatus, Idx2], i, ?destroy}]),
?line expect(5, [{[sparseStatus, Idx2], ?destroy}]).
%% Req. Test1
cnt_64_test(MA) ->
?LOG("start cnt64 test (~p)",[MA]),
snmpa:verbosity(MA, trace),
?LOG("start cnt64 test",[]),
?P1("Testing Counter64, and at the same time, "
"RowStatus is not last column"),
?DBG("get cnt64",[]),
g([[cnt64,0]]),
?DBG("await response",[]),
?line ?v1_2(expect(1, noSuchName, 1, any),
expect(1, [{[cnt64,0],18446744073709551615}])),
?DBG("get-next cnt64",[]),
gn([[cnt64]]),
?DBG("await response",[]),
?line ?v1_2(expect(2, [{[cnt64Str,0], "after cnt64"}]),
expect(2, [{[cnt64,0],18446744073709551615}])),
?DBG("send cntTrap",[]),
snmpa:send_trap(MA,cntTrap,"standard trap",[
{sysContact, "pelle"},
{cnt64, 10},
{sysLocation, "here"}
]),
?DBG("await response",[]),
?line ?v1_2(expect(3, trap, [test], 6, 1, [{[sysContact,0], "pelle"},
{[sysLocation,0], "here"}]),
expect(3, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?testTrap ++ [1]},
{[sysContact,0], "pelle"},
{[cnt64,0], 10},
{[sysLocation,0], "here"}])),
%% Create two rows, check that they are get-nexted in correct order.
Idx1 = 1,
Idx2 = 2,
?DBG("create row (cntStatus): ~p",[Idx1]),
s([{[cntStatus, Idx1], i, ?createAndGo}]),
?DBG("await response",[]),
?line expect(1, [{[cntStatus, Idx1], ?createAndGo}]),
?DBG("create row (cntStatus): ~p",[Idx2]),
s([{[cntStatus, Idx2], i, ?createAndGo}]),
?DBG("await response",[]),
?line expect(2, [{[cntStatus, Idx2], ?createAndGo}]),
?DBG("get-next (cntIndex)",[]),
gn([[cntIndex]]),
?DBG("await response",[]),
?line ?v1_2(expect(3, [{[cntStatus,Idx1], ?active}]),
expect(3, [{[cntCnt,Idx1], 0}])),
% Delete the rows
?DBG("delete row (cntStatus): ~p",[Idx1]),
s([{[cntStatus, Idx1], i, ?destroy}]),
?DBG("await response",[]),
?line expect(4, [{[cntStatus, Idx1], ?destroy}]),
?DBG("delete row (cntStatus): ~p",[Idx2]),
s([{[cntStatus, Idx2], i, ?destroy}]),
?DBG("await response",[]),
?line expect(5, [{[cntStatus, Idx2], ?destroy}]),
catch snmpa:verbosity(MA,log),
?DBG("done",[]),
ok.
%% Req. Test1
opaque_test() ->
?P1("Testing Opaque datatype..."),
g([[opaqueObj,0]]),
?line expect(1, [{[opaqueObj,0], "opaque-data"}]).
%% Req. OLD-SNMPEA-MIB
api_test(MaNode) ->
?line {value, OID} = rpc:call(MaNode, snmp, name_to_oid,
[intAgentIpAddress]),
?line {value, intAgentIpAddress} = rpc:call(MaNode, snmp,
oid_to_name, [OID]),
?line false = rpc:call(MaNode, snmp, name_to_oid, [intAgentIpAddres]),
?line false = rpc:call(MaNode, snmp, oid_to_name,
[[1,5,32,3,54,3,3,34,4]]),
?line {value, 2} = rpc:call(MaNode, snmp, enum_to_int,
[intViewType, excluded]),
?line {value, excluded} = rpc:call(MaNode, snmp, int_to_enum,
[intViewType, 2]),
?line false = rpc:call(MaNode, snmp, enum_to_int, [intViewType, exclude]),
?line false = rpc:call(MaNode, snmp, enum_to_int,
[intAgentIpAddress, exclude]),
?line false = rpc:call(MaNode, snmp, enum_to_int,
[intAgentIpAddre, exclude]),
?line false = rpc:call(MaNode, snmp, int_to_enum, [intViewType, 3]),
?line false = rpc:call(MaNode, snmp, int_to_enum, [intAgentIpAddress, 2]),
?line false = rpc:call(MaNode, snmp, int_to_enum, [intAgentIpAddre, 2]),
?line {value, active} = rpc:call(MaNode, snmp,
int_to_enum, ['RowStatus', ?active]),
?line {value, ?destroy} = rpc:call(MaNode, snmp,
enum_to_int, ['RowStatus', destroy]),
?line false = rpc:call(MaNode, snmp,
enum_to_int, ['RowStatus', xxxdestroy]),
?line false = rpc:call(MaNode, snmp,
enum_to_int, ['xxRowStatus', destroy]),
?line false = rpc:call(MaNode, snmp, int_to_enum, ['RowStatus', 25]),
?line false = rpc:call(MaNode, snmp, int_to_enum, ['xxRowStatus', 1]),
?line case snmp:date_and_time() of
List when is_list(List), length(List) == 8 -> ok;
List when is_list(List), length(List) == 11 -> ok
end.
%% Req. Klas3
api_test2() ->
g([[fname3,0]]),
?line expect(1, [{[fname3,0], "ok"}]),
g([[fname4,0]]),
?line expect(2, [{[fname4,0], 1}]).
api_test3() ->
g([[fname3,0]]),
?line expect(1, [{[fname3,0], "ok"}]).
unreg_test() ->
gn([[?v1_2(sysServices, sysORLastChange),0]]),
?line expect(1, [{[snmpInPkts, 0], any}]).
load_test() ->
gn([[?v1_2(sysServices, sysORLastChange),0]]),
?line expect(1, [{[fname,0], ""}]).
%% Req. Klas1
load_test_sa() ->
gn([[?v1_2(sysServices,sysORLastChange), 0]]),
?line expect(1, [{[fname,0], any}]).
%% Req. system group, Klas1, OLD-SNMPEA-MIB
do_mul_get() ->
Key1c3 = [intCommunityEntry,[3],get(mip),is("public")],
Key1c4 = [intCommunityEntry,[4],get(mip),is("public")],
s([{[fname,0], s, "test set"}]),
?line expect(3, [{[fname,0], "test set"}]),
g([[sysDescr,0], Key1c4, [fname,0],Key1c3,
[sysName,0]]),
?line expect(1, [{[sysDescr,0], "Erlang SNMP agent"},
{Key1c4, 2},
{[fname,0], "test set"},
{Key1c3, 2},
{[sysName,0], "test"}]),
g([[1,3,7,1], Key1c4, [sysDescr,0], [1,3,7,2], Key1c3, [sysDescr,0]]),
?line ?v1_2(expect(2, noSuchName, [1,4], any),
expect(2, [{[1,3,7,1], noSuchObject},
{Key1c4, 2},
{[sysDescr,0], "Erlang SNMP agent"},
{[1,3,7,2], noSuchObject},
{Key1c3, 2},
{[sysDescr,0], "Erlang SNMP agent"}])).
%% Req. v1, system group, Klas1, OLD-SNMPEA-MIB, *ej* Klas3.
do_mul_get_err() ->
Key1c3 = [intCommunityEntry,[3],get(mip),is("public")],
Key1c4 = [intCommunityEntry,[4],get(mip),is("public")],
s([{[fname,0], s, "test set"}]),
?line expect(3, [{[fname,0], "test set"}]),
g([[sysDescr,0],Key1c4,[fname,0], Key1c3, [sysName,2]]),
?line ?v1_2(expect(1, noSuchName, 5, any),
expect(1, [{[sysDescr,0], "Erlang SNMP agent"},
{Key1c4, 2},
{[fname,0], "test set"},
{Key1c3, 2},
{[sysName,2], noSuchInstance}])),
g([[sysDescr,0],Key1c4,[fname3,0], Key1c3, [sysName,1]]),
?line ?v1_2(expect(1, noSuchName, [3,5], any),
expect(1, [{[sysDescr,0], "Erlang SNMP agent"},
{Key1c4, 2},
{[fname3,0], noSuchObject},
{Key1c3, 2},
{[sysName,1], noSuchInstance}])).
%% Req. system group, Klas1, OLD-SNMPEA-MIB
do_mul_next() ->
Key1c3s = [intCommunityEntry,[3],get(mip),is("publi")],
Key1c4s = [intCommunityEntry,[4],get(mip),is("publi")],
Key1c3 = [intCommunityEntry,[3],get(mip),is("public")],
Key1c4 = [intCommunityEntry,[4],get(mip),is("public")],
s([{[fname,0], s, "test set"}]),
?line expect(3, [{[fname,0], "test set"}]),
gn([[sysDescr], Key1c4s, [fname],Key1c3s,[sysName]]),
?line expect(1, [{[sysDescr,0], "Erlang SNMP agent"},
{Key1c4, 2}, {[fname,0], "test set"},
{Key1c3, 2}, {[sysName,0], "test"}]).
%% Req. system group, Klas1, OLD-SNMPEA-MIB
do_mul_next_err() ->
Key1c3s = [intCommunityEntry,[3],get(mip),is("publi")],
Key1c4s = [intCommunityEntry,[4],get(mip),is("publi")],
Key1c3 = [intCommunityEntry,[3],get(mip),is("public")],
Key1c4 = [intCommunityEntry,[4],get(mip),is("public")],
s([{[fname,0], s, "test set"}]),
?line expect(3, [{[fname,0], "test set"}]),
gn([[sysDescr], Key1c4s, [1,3,6,999], [fname],[1,3,90], Key1c3s,[sysName]]),
?line ?v1_2(expect(1, noSuchName, [3,5], any),
expect(1, [{[sysDescr,0], "Erlang SNMP agent"},
{Key1c4, 2},
{[1,3,6,999], endOfMibView},
{[fname,0], "test set"},
{[1,3,90], endOfMibView},
{Key1c3, 2},
{[sysName,0], "test"}])).
%% Req. system group, Klas1, OLD-SNMPEA-MIB
do_mul_set() ->
?P1("Adding one row in subagent table, and one in master table"),
NewKeyc3 = [intCommunityEntry,[3],get(mip),is("test")],
NewKeyc4 = [intCommunityEntry,[4],get(mip),is("test")],
NewKeyc5 = [intCommunityEntry,[5],get(mip),is("test")],
s([{[friendsEntry, [2, 3]], "kompis3"},
{NewKeyc3, 2},
{[sysLocation,0], "new_value"},
{NewKeyc5, ?createAndGo},
{NewKeyc4, 2},
{[friendsEntry, [3, 3]], ?createAndGo}]),
?line expect(1, [{[friendsEntry, [2, 3]], "kompis3"},
{NewKeyc3, 2},
{[sysLocation,0], "new_value"},
{NewKeyc5, ?createAndGo},
{NewKeyc4, 2},
{[friendsEntry, [3, 3]], ?createAndGo}]),
g([[friendsEntry, [2, 3]],
[sysLocation,0],
[friendsEntry, [3, 3]]]),
?line expect(2, [{[friendsEntry, [2, 3]], "kompis3"},
{[sysLocation,0], "new_value"},
{[friendsEntry, [3, 3]], ?active}]),
g([NewKeyc4]),
?line expect(3, [{NewKeyc4, 2}]),
s([{[friendsEntry, [3, 3]], ?destroy},
{NewKeyc5, ?destroy}]),
?line expect(4, [{[friendsEntry, [3, 3]], ?destroy},
{NewKeyc5, ?destroy}]).
%% Req. system group, Klas1, OLD-SNMPEA-MIB
do_mul_set_err() ->
NewKeyc3 = [intCommunityEntry,[3],get(mip),is("test")],
NewKeyc4 = [intCommunityEntry,[4],get(mip),is("test")],
NewKeyc5 = [intCommunityEntry,[5],get(mip),is("test")],
?P1("Adding one row in subagent table, and one in master table"),
s([{[friendsEntry, [2, 3]], s, "kompis3"},
{NewKeyc3, 2},
{[sysUpTime,0], 45}, % sysUpTime (readOnly)
{NewKeyc5, ?createAndGo},
{NewKeyc4, 2},
{[friendsEntry, [3, 3]], ?createAndGo}]),
?line expect(1, ?v1_2(noSuchName, notWritable), 3, any),
g([[friendsEntry, [2, 3]]]),
?line ?v1_2(expect(2, noSuchName, 1, any),
expect(2, [{[friendsEntry, [2,3]], noSuchInstance}])),
g([NewKeyc4]),
?line ?v1_2(expect(3, noSuchName, 1, any),
expect(3, [{NewKeyc4, noSuchInstance}])).
%% Req. SA-MIB
sa_mib() ->
g([[sa, [2,0]]]),
?line expect(sa_mib_1, [{[sa, [2,0]], 3}]),
s([{[sa, [1,0]], s, "sa_test"}]),
?line expect(sa_mib_2, [{[sa, [1,0]], "sa_test"}]),
ok.
ma_trap1(MA) ->
ok = snmpa:send_trap(MA, testTrap2, "standard trap"),
?line expect(ma_trap1_1,
trap, [system], 6, 1, [{[system, [4,0]],
"{mbj,eklas}@erlang.ericsson.se"}]),
ok = snmpa:send_trap(MA, testTrap1, "standard trap"),
?line expect(ma_trap1_2,
trap, [1,2,3] , 1, 0, [{[system, [4,0]],
"{mbj,eklas}@erlang.ericsson.se"}]),
ok.
ma_trap2(MA) ->
snmpa:send_trap(MA,testTrap2,"standard trap",[{sysContact,"pelle"}]),
?line expect(ma_trap2_3,
trap, [system], 6, 1, [{[system, [4,0]], "pelle"}]),
ok.
ma_v2_2_v1_trap(MA) ->
snmpa:send_trap(MA,testTrapv22,"standard trap",[{sysContact,"pelle"}]),
?line expect(ma_v2_2_v1_trap_3,
trap, [system], 6, 1, [{[system, [4,0]], "pelle"}]),
ok.
ma_v2_2_v1_trap2(MA) ->
snmpa:send_trap(MA,linkUp,"standard trap",[{ifIndex, [1], 1},
{ifAdminStatus, [1], 1},
{ifOperStatus, [1], 2}]),
?line expect(ma_v2_2_v1_trap2_3,
trap, [1,2,3], 3, 0, [{[ifIndex, 1], 1},
{[ifAdminStatus, 1], 1},
{[ifOperStatus, 1], 2}]),
ok.
sa_trap1(SA) ->
%% io:format("sa_trap1 -> entry with"
%% "~n SA: ~p"
%% "~n node(SA): ~p"
%% "~n self(): ~p"
%% "~n node(): ~p"
%% "~n", [SA, node(SA), self(), node()]),
_VRes = (catch snmpa:verbosity(SA, {subagents, trace})),
%% io:format("sa_trap1 -> SA verbosity set: "
%% "~n VRes: ~p"
%% "~n", [VRes]),
_TSRes = (catch snmpa:send_trap(SA, saTrap, "standard trap")),
%% io:format("sa_trap1 -> SA trap send: "
%% "~n TSRes: ~p"
%% "~n", [TSRes]),
?line expect(sa_trap1_4,
trap, [ericsson], 6, 1, [{[system, [4,0]],
"{mbj,eklas}@erlang.ericsson.se"},
{[sa, [1,0]], "sa_test"}]),
snmpa:verbosity(SA, {subagents, silence}),
ok.
sa_trap2(SA) ->
snmpa:send_trap(SA, saTrap, "standard trap",[{sysContact,"pelle"}]),
?line expect(sa_trap2_5,
trap, [ericsson], 6, 1, [{[system, [4,0]], "pelle"},
{[sa, [1,0]], "sa_test"}]),
ok.
sa_trap3(SA) ->
snmpa:send_trap(SA, saTrap2, "standard trap",
[{intViewSubtree, [4], [1,2,3,4]}]),
?line expect(sa_trap3_6,
trap, [ericsson], 6, 2, [{[system, [4,0]],
"{mbj,eklas}@erlang.ericsson.se"},
{[sa, [1,0]], "sa_test"},
{[intViewSubtree,4],[1,2,3,4]}]),
ok.
ma_v2_trap1(MA) ->
?DBG("ma_v2_traps -> entry with MA = ~p => "
"send standard trap: testTrapv22",[MA]),
snmpa:send_trap(MA, testTrapv22, "standard trap"),
?line expect(1, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}]),
?DBG("ma_v2_traps -> send standard trap: testTrapv21",[]),
snmpa:send_trap(MA, testTrapv21, "standard trap"),
?line expect(2, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?snmp ++ [1]}]),
ok.
ma_v2_trap2(MA) ->
snmpa:send_trap(MA,testTrapv22,"standard trap",[{sysContact,"pelle"}]),
?line expect(3, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]},
{[system, [4,0]], "pelle"}]).
%% Note: This test case takes a while... actually a couple of minutes.
ma_v2_inform1(MA) ->
?DBG("ma_v2_inform1 -> entry with"
"~n MA = ~p => "
"~n send notification: testTrapv22", [MA]),
CmdExpectInform =
fun(No, Response) ->
expect(No,
{inform, Response},
[{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}])
end,
CmdExp =
fun(ok) ->
ok;
({ok, Val}) ->
?DBG("ma_v2_inform -> [cmd2] Val: ~p", [Val]),
ok;
({error, Id, Extra}) ->
{error, {unexpected, Id, Extra}};
(Error) ->
Error
end,
Cmd01 =
fun() ->
snmpa:send_notification(MA, testTrapv22, no_receiver,
"standard inform", []),
ok
end,
Cmd02 =
fun() ->
Res = CmdExpectInform(1, true),
CmdExp(Res)
end,
Tag03 = tag11,
Cmd03 =
fun() ->
snmpa:send_notification(MA, testTrapv22, {Tag03, self()},
"standard inform", []),
ok
end,
Cmd04 =
fun() ->
Res = CmdExpectInform(2, true),
CmdExp(Res)
end,
CmdSnmpTargets =
fun(T) ->
receive
{snmp_targets, T, [Addr]} ->
?DBG("ma_v2_inform1 -> "
"received expected snmp_targets "
"~n with receiver: ~p",[Addr]),
ok;
{snmp_targets, T, Addrs} ->
?ERR("ma_v2_inform1 -> "
"received unexpected snmp_targets"
"~n with receivers: ~n ~p",[Addrs]),
{error, {bad_addrs, Addrs}}
after
5000 ->
?ERR("ma_v2_inform1 -> "
"timeout awaiting snmp_targets [~w]",[T]),
{error, snmp_targets_timeout}
end
end,
Cmd05 = fun() -> CmdSnmpTargets(Tag03) end,
Cmd06 =
fun() ->
receive
{snmp_notification, Tag03, {got_response, Addr}} ->
?DBG("ma_v2_inform1 -> "
"received expected snmp_notification "
"[with manager response] from: ~n ~p",[Addr]),
ok;
{snmp_notification, Tag03, {no_response, Addr}} ->
?ERR("ma_v2_inform1 -> "
"received unexpected snmp_notification "
"[without manager response] from: ~n ~p",
[Addr]),
{error, no_response}
after
20000 ->
?ERR("ma_v2_inform1 -> "
"timeout awaiting snmp_notification [~p]",
[Tag03]),
{error, snmp_notification_timeout}
end
end,
Tag07 = tag12,
Cmd07 =
fun() ->
snmpa:send_notification(MA, testTrapv22, {Tag07, self()},
"standard inform", []),
ok
end,
Cmd08 =
fun() ->
Res = CmdExpectInform(3, false),
CmdExp(Res)
end,
Cmd09 =
fun() ->
CmdSnmpTargets(Tag07)
end,
Cmd10 =
fun() ->
receive
{snmp_notification, Tag07, {got_response, Addr}} ->
?ERR("ma_v2_inform1 -> "
"received unexpected snmp_notification "
"[with manager response] from: ~n ~p", [Addr]),
{error, got_response};
{snmp_notification, Tag07, {no_response, Addr}} ->
?DBG("ma_v2_inform1 -> "
"received expected snmp_notification "
"[without manager response] from: ~n ~p",
[Addr]),
ok
after
240000 ->
?ERR("ma_v2_inform1 -> "
"timeout awaiting snmp_notification [~p]",
[Tag07]),
{error, snmp_notification_timeout}
end
end,
Commands =
[
{ 1, "Send notification [no receiver]", Cmd01},
{ 2, "Expect inform [send response]", Cmd02},
{ 3, "Send notification [tag1]", Cmd03},
{ 4, "Expect inform [send response]", Cmd04},
{ 5, "Expect snmp_targets message [from trap sender]", Cmd05},
{ 6, "Expect snmp_notification [got_response] message [from trap sender]", Cmd06},
{ 7, "Send notification [tag2]", Cmd07},
{ 8, "Expect inform [don't send response]", Cmd08},
{ 9, "Expect snmp_targets message [from trap sender]", Cmd09},
{10, "Expect snmp_notification [no_response] message [from trap sender]", Cmd10}
],
command_handler(Commands).
%% Note: This test case takes a while... actually a couple of minutes.
ma_v2_inform2(MA) ->
?DBG("ma_v2_inform2 -> entry with"
"~n MA = ~p => "
"~n send notification: testTrapv22", [MA]),
CmdExpectInform =
fun(No, Response) ->
expect(No,
{inform, Response},
[{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}])
end,
CmdExp =
fun(ok) ->
ok;
({ok, Val}) ->
?DBG("ma_v2_inform -> [cmd2] Val: ~p", [Val]),
ok;
({error, Id, Extra}) ->
{error, {unexpected, Id, Extra}};
(Error) ->
Error
end,
%% Await callback(s)
CmdAwaitDeliveryCallback =
fun(Kind, Ref, Tag) ->
io:format("CmdAwaitDeliveryCallback -> entry with"
"~n Kind: ~p"
"~n Ref: ~p"
"~n Tag: ~p"
"~n", [Kind, Ref, Tag]),
receive
{Kind, Ref, ok} ->
io:format("CmdAwaitDeliveryCallback(~p,~p) -> received expected result: ok"
"~n", [Tag, Ref]),
ok;
{Kind, Ref, Error} ->
io:format("CmdAwaitDeliveryCallback(~p,~p) -> received unexpected result: "
"~n Error: ~p"
"~n", [Tag, Ref, Error]),
{error, {unexpected_response, Error}}
after
240000 ->
?ERR("ma_v2_inform2 -> "
"timeout awaiting got_response for snmp_notification [~p]",
[Tag]),
{error, snmp_notification_timeout}
end
end,
Tag11 = tag21,
Ref11 = make_ref(),
Extra11 = [{tag, Tag11},
{ref, Ref11},
{recv, self()},
{targets, []},
{address, dummy},
{expected_delivery_result, got_response}],
Recv11 = #snmpa_notification_delivery_info{tag = Tag11,
mod = ?MODULE,
extra = Extra11},
Cmd11 =
fun() ->
snmpa:send_notification(MA, testTrapv22,
Recv11,
"standard inform", []),
ok
end,
Cmd12 =
fun() ->
Res = CmdExpectInform(4, true),
CmdExp(Res)
end,
Cmd13 = fun() -> CmdAwaitDeliveryCallback(targets, Ref11, Tag11) end,
Cmd14 = fun() -> CmdAwaitDeliveryCallback(info, Ref11, Tag11) end,
Commands =
[
{11, "Send notification [tag3]", Cmd11},
{12, "Expect notification message [tag3]", Cmd12},
{13, "Expect targets message [tag3]", Cmd13},
{14, "Expect notification response message [tag3]", Cmd14}
],
command_handler(Commands).
%% Note: This test case takes a while... actually a couple of minutes.
ma_v2_inform3(MA) ->
?DBG("ma_v2_inform3 -> entry with"
"~n MA = ~p => "
"~n send notification: testTrapv22", [MA]),
CmdExpectInform =
fun(No, Response) ->
expect(No,
{inform, Response},
[{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}])
end,
CmdExp =
fun(ok) ->
ok;
({ok, Val}) ->
?DBG("ma_v2_inform3 -> [cmd2] Val: ~p", [Val]),
ok;
({error, Id, Extra}) ->
{error, {unexpected, Id, Extra}};
(Error) ->
Error
end,
%% Await callback(s)
CmdAwaitDeliveryCallback =
fun(Kind, Ref, Tag) ->
io:format("CmdAwaitDeliveryCallback -> entry with"
"~n Kind: ~p"
"~n Ref: ~p"
"~n Tag: ~p"
"~n", [Kind, Ref, Tag]),
receive
{Kind, Ref, ok} ->
io:format("CmdAwaitDeliveryCallback(~p,~p) -> received expected result: ok"
"~n", [Tag, Ref]),
ok;
{Kind, Ref, Error} ->
io:format("CmdAwaitDeliveryCallback(~p,~p) -> received unexpected result: "
"~n Error: ~p"
"~n", [Tag, Ref, Error]),
{error, {unexpected_response, Error}}
after
240000 ->
?ERR("ma_v2_inform3 -> "
"timeout awaiting got_response for snmp_notification [~p]",
[Tag]),
{error, snmp_notification_timeout}
end
end,
Tag15 = tag31,
Ref15 = make_ref(),
Extra15 = [{tag, Tag15},
{ref, Ref15},
{recv, self()},
{targets, []},
{address, dummy},
{expected_delivery_result, no_response}],
Recv15 = #snmpa_notification_delivery_info{tag = Tag15,
mod = ?MODULE,
extra = Extra15},
Cmd15 =
fun() ->
snmpa:send_notification(MA, testTrapv22,
Recv15,
"standard inform", []),
ok
end,
Cmd16 =
fun() ->
Res = CmdExpectInform(5, false),
CmdExp(Res)
end,
Cmd17 = fun() -> CmdAwaitDeliveryCallback(targets, Ref15, Tag15) end,
Cmd18 = fun() -> CmdAwaitDeliveryCallback(info, Ref15, Tag15) end,
Commands =
[
{15, "Send notification [tag31]", Cmd15},
{16, "Expect notification message [tag31]", Cmd16},
{17, "Expect targets message [tag31]", Cmd17},
{18, "Expect notification (no) response message [tag31]", Cmd18}
],
command_handler(Commands).
delivery_targets(Tag, Addresses, Extra) ->
io:format("~w:delivery_targets -> entry with"
"~n Tag: ~p"
"~n Addresses: ~p"
"~n Extra: ~p"
"~n", [?MODULE, Tag, Addresses, Extra]),
{value, {_, Pid}} = lists:keysearch(recv, 1, Extra),
{value, {_, Ref}} = lists:keysearch(ref, 1, Extra),
case lists:keysearch(tag, 1, Extra) of
{value, {_, Tag}} ->
Pid ! {targets, Ref, ok};
{value, {_, OtherTag}} ->
Pid ! {targets, Ref, {error, {wrong_tag, Tag, OtherTag}}}
end,
ok.
delivery_info(Tag, Address, DeliveryResult, Extra) ->
io:format("~w:delivery_info -> entry with"
"~n Tag: ~p"
"~n Address: ~p"
"~n DeliveryResult: ~p"
"~n Extra: ~p"
"~n", [?MODULE, Tag, Address, DeliveryResult, Extra]),
{value, {_, Pid}} = lists:keysearch(recv, 1, Extra),
{value, {_, Ref}} = lists:keysearch(ref, 1, Extra),
case lists:keysearch(tag, 1, Extra) of
{value, {_, Tag}} ->
Pid ! {info, Ref, ok};
{value, {_, OtherTag}} ->
Pid ! {info, Ref, {error, {wrong_tag, Tag, OtherTag}}}
end,
ok.
command_handler([]) ->
ok;
command_handler([{No, Desc, Cmd}|Rest]) ->
?LOG("command_handler -> command ~w: ~n ~s", [No, Desc]),
case (catch Cmd()) of
ok ->
?LOG("command_handler -> ~w: ok",[No]),
command_handler(Rest);
{error, Reason} ->
?ERR("command_handler -> ~w error: ~n~p",[No, Reason]),
?line ?FAIL(Reason);
Error ->
?ERR("command_handler -> ~w unexpected: ~n~p",[No, Error]),
?line ?FAIL({unexpected_command_result, Error})
end.
ma_v1_2_v2_trap(MA) ->
snmpa:send_trap(MA,linkDown,"standard trap",[{ifIndex, [1], 1}]),
?line expect(2, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?snmpTraps ++ [3]},
{[ifIndex, 1], 1},
{[snmpTrapEnterprise, 0], [1,2,3]}]).
ma_v1_2_v2_trap2(MA) ->
snmpa:send_trap(MA,testTrap2,"standard trap",[{sysContact,"pelle"}]),
?line expect(3, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]},
{[system, [4,0]], "pelle"},
{[snmpTrapEnterprise, 0], ?system}]).
sa_v1_2_v2_trap1(SA) ->
snmpa:verbosity(SA, {subagents, trace}),
snmpa:send_trap(SA, saTrap, "standard trap"),
?line expect(trap1_4, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?ericsson ++ [0, 1]},
{[system, [4,0]],
"{mbj,eklas}@erlang.ericsson.se"},
{[sa, [1,0]], "sa_test"},
{[snmpTrapEnterprise, 0], ?ericsson}]),
snmpa:verbosity(SA, {subagents, silence}),
ok.
sa_v1_2_v2_trap2(SA) ->
snmpa:verbosity(SA, {subagents, trace}),
snmpa:send_trap(SA, saTrap, "standard trap",[{sysContact,"pelle"}]),
?line expect(trap2_4, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?ericsson ++ [0, 1]},
{[system, [4,0]], "pelle"},
{[sa, [1,0]], "sa_test"},
{[snmpTrapEnterprise, 0], ?ericsson}]),
snmpa:verbosity(SA, {subagents, silence}),
ok.
sa_v1_2_v2_trap3(SA) ->
snmpa:verbosity(SA, {subagents, trace}),
snmpa:send_trap(SA, saTrap2, "standard trap",
[{intViewSubtree, [4], [1,2,3,4]}]),
?line expect(trap3_4, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?ericsson ++ [0, 2]},
{[system, [4,0]],
"{mbj,eklas}@erlang.ericsson.se"},
{[sa, [1,0]], "sa_test"},
{[intViewSubtree,4],[1,2,3,4]},
{[snmpTrapEnterprise, 0], ?ericsson}]),
snmpa:verbosity(SA, {subagents, silence}),
ok.
%% Req. SA-MIB, OLD-SNMPEA-MIB
sa_errs_bad_value() ->
NewKeyc3 = [intCommunityEntry,[3],get(mip),is("test")],
NewKeyc4 = [intCommunityEntry,[4],get(mip),is("test")],
NewKeyc5 = [intCommunityEntry,[5],get(mip),is("test")],
s([{NewKeyc3, 2},
{[sa, [2,0]], 5}, % badValue (i is_set_ok)
{NewKeyc5, ?createAndGo},
{NewKeyc4, 2}]),
?line expect(1, badValue, 2, any),
s([{NewKeyc3, 2},
{[sa, [2,0]], 6}, % wrongValue (i is_set_ok)
{NewKeyc5, ?createAndGo},
{NewKeyc4, 2}]),
?line expect(1, ?v1_2(badValue, wrongValue), 2, any),
g([NewKeyc4]),
?line ?v1_2(expect(2, noSuchName, 1, any),
expect(2, [{NewKeyc4, noSuchInstance}])).
%% Req. SA-MIB, OLD-SNMPEA-MIB
sa_errs_gen_err() ->
NewKeyc3 = [intCommunityEntry,[3],get(mip),is("test")],
NewKeyc4 = [intCommunityEntry,[4],get(mip),is("test")],
NewKeyc5 = [intCommunityEntry,[5],get(mip),is("test")],
s([{NewKeyc3, 2},{NewKeyc4, 2},
{NewKeyc5, ?createAndGo}, {[sa, [3,0]], 5}]),
?line expect(1, genErr, 4, any),
% The row might have been added; we don't know.
% (as a matter of fact we do - it is added, because the agent
% first sets its own vars, and then th SAs. Lets destroy it.
s([{NewKeyc5, ?destroy}]),
?line expect(2, [{NewKeyc5, ?destroy}]).
%% Req. SA-MIB, OLD-SNMPEA-MIB
sa_too_big() ->
g([[sa, [4,0]]]),
?line expect(1, tooBig).
%% Req. Klas1, system group, snmp group (v1/v2)
next_across_sa() ->
gn([[sysDescr],[klas1,5]]),
?line expect(1, [{[sysDescr,0], "Erlang SNMP agent"},
{[snmpInPkts, 0], any}]).
%% snmp_test_mgr:s([{[fStatus3, 1], 4}, {[fname3,0], "ok"}]). -> noError
%% snmp_test_mgr:s([{[fStatus3, 1], 4}, {[fname3,0], "hoj"}]). -> {badValue, 2}
%% snmp_test_mgr:s([{[fStatus3, 3], 4}, {[fname3,0], "hoj"}]). -> {genErr, 1}
%% snmp_test_mgr:s([{[fStatus3, 4], 4}, {[fname3,0], "ok"}]). -> {genErr, 1}
%% snmp_test_mgr:s([{[fStatus3, 4], 4}, {[fname3,0], "ufail"}]). -> {genErr, 1}
%% snmp_test_mgr:s([{[fStatus3, 1], 4}, {[fname3,0], "xfail"}]). -> {genErr, 2}
%% Req. Klas3, Klas4
undo_test() ->
s([{[fStatus3, 1], 4}, {[fname3,0], "ok"}]),
?line expect(1, [{[fStatus3, 1], 4}, {[fname3,0], "ok"}]),
s([{[fStatus3, 1], 4}, {[fname3,0], "hoj"}]),
?line expect(2, ?v1_2(badValue, inconsistentValue), 2, any),
s([{[fStatus3, 3], 4}, {[fname3,0], "hoj"}]),
?line expect(3, ?v1_2(genErr, undoFailed), 1, any),
s([{[fStatus3, 4], 4}, {[fname3,0], "ok"}]),
?line expect(4, ?v1_2(genErr, commitFailed), 1, any),
% unfortunatly we don't know if we'll get undoFailed or commitFailed.
% it depends on which order the agent traverses the varbind list.
% s([{[fStatus3, 4], 4}, {[fname3,0], "ufail"}]),
% ?line expect(5, ?v1_2(genErr, undoFailed), 1, any),
s([{[fStatus3, 1], 4}, {[fname3,0], "xfail"}]),
?line expect(6, genErr, 2, any).
%% Req. Klas3, Klas4
bad_return() ->
g([[fStatus4,4],
[fName4,4]]),
?line expect(4, genErr, 2, any),
g([[fStatus4,5],
[fName4,5]]),
?line expect(5, genErr, 1, any),
g([[fStatus4,6],
[fName4,6]]),
?line expect(6, genErr, 2, any),
gn([[fStatus4,7],
[fName4,7]]),
?line expect(7, genErr, 2, any),
gn([[fStatus4,8],
[fName4,8]]),
?line expect(8, genErr, 1, any),
gn([[fStatus4,9],
[fName4,9]]),
?line expect(9, genErr, 2, any).
%%%-----------------------------------------------------------------
%%% Test the implementation of standard mibs.
%%% We should *at least* try to GET all variables, just to make
%%% sure the instrumentation functions work.
%%% Note that many of the functions in the standard mib is
%%% already tested by the normal tests.
%%%-----------------------------------------------------------------
%%-----------------------------------------------------------------
%% For this test, the agent is configured for v1.
%% o Test the counters and control objects in SNMP-STANDARD-MIB
%%-----------------------------------------------------------------
snmp_standard_mib(suite) -> [];
snmp_standard_mib(Config) when is_list(Config) ->
?P(snmp_standard_mib),
init_case(Config),
?DBG("snmp_standard_mib -> std_mib_init", []),
try_test(std_mib_init),
?DBG("snmp_standard_mib -> std_mib_a", []),
InBadVsns = try_test(std_mib_a),
put(vsn, v2),
?DBG("snmp_standard_mib -> std_mib_read", []),
try_test(std_mib_read),
put(vsn, v1),
?DBG("snmp_standard_mib -> std_mib_b (~w)", [InBadVsns]),
Bad = try_test(std_mib_b, [InBadVsns]),
?DBG("snmp_standard_mib -> std_mib_read (community: 'bad community')", []),
try_test(std_mib_read, [], [{community, "bad community"}]),
?DBG("snmp_standard_mib -> std_mib_write (community: 'public')", []),
try_test(std_mib_write, [], [{community, "public"}]),
?DBG("snmp_standard_mib -> std_mib_asn_err", []),
try_test(std_mib_asn_err),
?DBG("snmp_standard_mib -> std_mib_c (~w)", [Bad]),
try_test(std_mib_c, [Bad]),
?DBG("snmp_standard_mib -> std_mib_a", []),
try_test(standard_mib_a),
?DBG("snmp_standard_mib -> std_mib_finish", []),
try_test(std_mib_finish),
?DBG("snmp_standard_mib -> std_mib_test_finish", []),
try_test(standard_mib_test_finish, [], [{community, "bad community"}]).
%% Req. SNMP-STANDARD-MIB
standard_mib_a() ->
?line [OutPkts] = get_req(2, [[snmpOutPkts,0]]),
?line [OutPkts2] = get_req(3, [[snmpOutPkts,0]]),
?line OutPkts2 = OutPkts + 1,
%% There are some more counters we could test here, but it's not that
%% important, since they are removed from SNMPv2-MIB.
ok.
%% Req. SNMP-STANDARD-MIB | SNMPv2-MIB
std_mib_init() ->
%% disable authentication failure traps. (otherwise w'd get many of
%% them - this is also a test to see that it works).
s([{[snmpEnableAuthenTraps,0], 2}]),
?line expect(std_mib_init_1, [{[snmpEnableAuthenTraps, 0], 2}]).
%% Req. SNMP-STANDARD-MIB | SNMPv2-MIB
std_mib_finish() ->
%% enable again
s([{[snmpEnableAuthenTraps,0], 1}]),
?line expect(std_mib_finish_1, [{[snmpEnableAuthenTraps, 0], 1}]).
%% Req. SNMP-STANDARD-MIB
standard_mib_test_finish() ->
%% force a authenticationFailure (should result in a trap)
std_mib_write(),
%% check that we got a trap
?line expect(standard_mib_test_finish_2, trap, [1,2,3], 4, 0, []).
%% Req. SNMP-STANDARD-MIB | SNMPv2-MIB
std_mib_read() ->
?DBG("std_mib_read -> entry", []),
g([[sysUpTime,0]]), % try a bad <something>; msg dropped, no reply
?DBG("std_mib_read -> await timeout (i.e. no reply)", []),
?line expect(std_mib_read_1, timeout). % make sure we don't get a trap!
%% Req. SNMP-STANDARD-MIB | SNMPv2-MIB
std_mib_write() ->
?DBG("std_mib_write -> entry", []),
s([{[sysLocation, 0], "new_value"}]).
%% Req. SNMP-STANDARD-MIB | SNMPv2-MIB
std_mib_asn_err() ->
snmp_test_mgr:send_bytes([48,99,67,12,0,0,0,0,0,0,5]).
%%-----------------------------------------------------------------
%% For this test, the agent is configured for v2 and v3.
%% o Test the counters and control objects in SNMPv2-MIB
%%-----------------------------------------------------------------
snmpv2_mib_2(suite) -> [];
snmpv2_mib_2(Config) when is_list(Config) ->
?P(snmpv2_mib_2),
?LOG("snmpv2_mib_2 -> start",[]),
init_case(Config),
?DBG("snmpv2_mib_2 -> standard mib init",[]),
try_test(std_mib_init),
?DBG("snmpv2_mib_2 -> get number of (so far) bad versions",[]),
InBadVsns = try_test(std_mib_a),
?DBG("snmpv2_mib_2 -> make a bad version read",[]),
put(vsn, v1),
try_test(std_mib_read),
?DBG("snmpv2_mib_2 -> bad version read",[]),
put(vsn, v2),
Bad = try_test(std_mib_b, [InBadVsns]),
?DBG("snmpv2_mib_2 -> read with bad community",[]),
try_test(std_mib_read, [], [{community, "bad community"}]),
?DBG("snmpv2_mib_2 -> write with public community",[]),
try_test(std_mib_write, [], [{community, "public"}]),
?DBG("snmpv2_mib_2 -> asn err",[]),
try_test(std_mib_asn_err),
?DBG("snmpv2_mib_2 -> check counters",[]),
try_test(std_mib_c, [Bad]),
?DBG("snmpv2_mib_2 -> get som counters",[]),
try_test(snmpv2_mib_a),
?DBG("snmpv2_mib_2 -> enable auth traps, and await some",[]),
try_test(std_mib_finish),
?DBG("snmpv2_mib_2 -> force auth failure, and await trap, "
"then disable auth traps",[]),
try_test(snmpv2_mib_test_finish, [], [{community, "bad community"}]),
?LOG("snmpv2_mib_2 -> done",[]).
%% Req. SNMPv2-MIB
snmpv2_mib_3(suite) -> [];
snmpv2_mib_3(Config) when is_list(Config) ->
%% <CONDITIONAL-SKIP>
Skippable = [{unix, [darwin]}],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(Config, Condition),
%% </CONDITIONAL-SKIP>
?P(snmpv2_mib_3),
init_case(Config),
InBadVsns = try_test(std_mib_a),
put(vsn, v1),
try_test(std_mib_read),
put(vsn, v3),
_Bad = try_test(std_mib_b, [InBadVsns]),
try_test(snmpv2_mib_a),
try_test(std_mib_finish).
-define(authenticationFailure, [1,3,6,1,6,3,1,1,5,5]).
%% Req. SNMPv2-MIB
snmpv2_mib_test_finish() ->
%% force a authenticationFailure
?DBG("ma_v2_inform -> write to std mib",[]),
std_mib_write(),
%% check that we got a trap
?DBG("ma_v2_inform -> await trap",[]),
?line expect(2, v2trap, [{[sysUpTime,0], any},
{[snmpTrapOID,0], ?authenticationFailure}]),
%% and the the inform
?DBG("ma_v2_inform -> await inform",[]),
?line expect(2, {inform,true}, [{[sysUpTime,0], any},
{[snmpTrapOID,0],?authenticationFailure}]).
%% Req. SNMP-STANDARD-MIB | SNMPv2-MIB
std_mib_a() ->
?line [InPkts] = get_req(2, [[snmpInPkts,0]]),
?line [InPkts2] = get_req(3, [[snmpInPkts,0]]),
?line InPkts2 = InPkts + 1,
?line [InBadVsns] = get_req(4, [[snmpInBadVersions,0]]),
InBadVsns.
%% Req. SNMP-STANDARD-MIB | SNMPv2-MIB
std_mib_b(InBadVsns) ->
?line [InBadVsns2] = get_req(1, [[snmpInBadVersions,0]]),
?line InBadVsns2 = InBadVsns + 1,
?line [InPkts] = get_req(2, [[snmpInPkts,0]]),
?line [InPkts2] = get_req(3, [[snmpInPkts,0]]),
?line InPkts2 = InPkts + 1,
?line [InBadCommunityNames, InBadCommunityUses, InASNErrs] =
get_req(4, [[snmpInBadCommunityNames,0],
[snmpInBadCommunityUses,0],
[snmpInASNParseErrs, 0]]),
{InBadCommunityNames, InBadCommunityUses, InASNErrs}.
%% Req. SNMP-STANDARD-MIB | SNMPv2-MIB
std_mib_c({InBadCommunityNames, InBadCommunityUses, InASNErrs}) ->
?line [InBadCommunityNames2, InBadCommunityUses2, InASNErrs2] =
get_req(1, [[snmpInBadCommunityNames,0],
[snmpInBadCommunityUses,0],
[snmpInASNParseErrs, 0]]),
?line InBadCommunityNames2 = InBadCommunityNames + 1,
?line InBadCommunityUses2 = InBadCommunityUses + 1,
?line InASNErrs2 = InASNErrs + 1.
%% Req. SNMPv2-MIB
snmpv2_mib_a() ->
?line [SetSerial] = get_req(2, [[snmpSetSerialNo,0]]),
s([{[snmpSetSerialNo,0], SetSerial}, {[sysLocation, 0], "val2"}]),
?line expect(snmpv2_mib_a_3, [{[snmpSetSerialNo,0], SetSerial},
{[sysLocation, 0], "val2"}]),
s([{[sysLocation, 0], "val3"}, {[snmpSetSerialNo,0], SetSerial}]),
?line expect(snmpv2_mib_a_4, inconsistentValue, 2,
[{[sysLocation, 0], "val3"},
{[snmpSetSerialNo,0], SetSerial}]),
?line ["val2"] = get_req(5, [[sysLocation,0]]).
%%-----------------------------------------------------------------
%% o Bad community uses/name is tested already
%% in SNMPv2-MIB and STANDARD-MIB.
%% o Test add/deletion of rows.
%%-----------------------------------------------------------------
snmp_community_mib(suite) -> [];
snmp_community_mib(Config) when is_list(Config) ->
?P(snmp_community_mib),
init_case(Config),
?line load_master_std("SNMP-COMMUNITY-MIB"),
try_test(snmp_community_mib),
?line unload_master("SNMP-COMMUNITY-MIB").
snmp_community_mib_2(X) -> ?P(snmp_community_mib_2), snmp_community_mib(X).
%% Req. SNMP-COMMUNITY-MIB
snmp_community_mib() ->
?INF("NOT YET IMPLEMENTED", []),
nyi.
%%-----------------------------------------------------------------
%% o Test engine boots / time
%%-----------------------------------------------------------------
snmp_framework_mib(suite) -> [];
snmp_framework_mib(Config) when is_list(Config) ->
?P(snmp_framework_mib),
init_case(Config),
?line load_master_std("SNMP-FRAMEWORK-MIB"),
try_test(snmp_framework_mib),
?line unload_master("SNMP-FRAMEWORK-MIB").
snmp_framework_mib_2(X) -> ?P(snmp_framework_mib_2), snmp_framework_mib(X).
snmp_framework_mib_3(suite) -> [];
snmp_framework_mib_3(Config) when is_list(Config) ->
?P(snmp_framework_mib_3),
init_case(Config),
try_test(snmp_framework_mib).
%% Req. SNMP-FRAMEWORK-MIB
snmp_framework_mib() ->
?line ["agentEngine"] = get_req(1, [[snmpEngineID,0]]),
?line [EngineTime] = get_req(2, [[snmpEngineTime,0]]),
?SLEEP(5000),
?line [EngineTime2] = get_req(3, [[snmpEngineTime,0]]),
?DBG("snmp_framework_mib -> time(s): "
"~n EngineTime 1 = ~p"
"~n EngineTime 2 = ~p", [EngineTime, EngineTime2]),
if
(EngineTime+7) < EngineTime2 ->
?line ?FAIL({too_large_diff, EngineTime, EngineTime2});
(EngineTime+4) > EngineTime2 ->
?line ?FAIL({too_large_diff, EngineTime, EngineTime2});
true ->
ok
end,
?line case get_req(4, [[snmpEngineBoots,0]]) of
[Boots] when is_integer(Boots) ->
ok;
Else ->
?FAIL(Else)
end,
ok.
%%-----------------------------------------------------------------
%% o Test the counters
%%-----------------------------------------------------------------
snmp_mpd_mib_3(suite) -> [];
snmp_mpd_mib_3(Config) when is_list(Config) ->
%% <CONDITIONAL-SKIP>
Skippable = [{unix, [darwin]}],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(Config, Condition),
%% </CONDITIONAL-SKIP>
?P(snmp_mpd_mib_3),
init_case(Config),
UnknownPDUHs = try_test(snmp_mpd_mib_a),
try_test(snmp_mpd_mib_b, [], [{context_engine_id, "bad engine"}]),
try_test(snmp_mpd_mib_c, [UnknownPDUHs]).
%% Req. SNMP-MPD-MIB
snmp_mpd_mib_a() ->
?line [UnknownSecs, InvalidMsgs] =
get_req(1, [[snmpUnknownSecurityModels,0],
[snmpInvalidMsgs,0]]),
Pdu = #pdu{type = 'get-request',
request_id = 23,
error_status = noError,
error_index = 0,
varbinds = []},
SPdu = #scopedPdu{contextEngineID = "agentEngine",
contextName = "",
data = Pdu},
?line SPDUBytes = snmp_pdus:enc_scoped_pdu(SPdu),
V3Hdr1 = #v3_hdr{msgID = 21,
msgMaxSize = 484,
msgFlags = [7],
msgSecurityModel = 23, % bad sec model
msgSecurityParameters = []},
V3Hdr2 = #v3_hdr{msgID = 21,
msgMaxSize = 484,
msgFlags = [6], % bad flag combination
msgSecurityModel = 3,
msgSecurityParameters = []},
Message1 = #message{version = 'version-3', vsn_hdr = V3Hdr1,
data = SPDUBytes},
Message2 = #message{version = 'version-3', vsn_hdr = V3Hdr2,
data = SPDUBytes},
?line MsgBytes1 = snmp_pdus:enc_message_only(Message1),
?line MsgBytes2 = snmp_pdus:enc_message_only(Message2),
snmp_test_mgr:send_bytes(MsgBytes1),
snmp_test_mgr:send_bytes(MsgBytes2),
?line [UnknownSecs2, InvalidMsgs2, UnknownPDUHs] =
get_req(1, [[snmpUnknownSecurityModels,0],
[snmpInvalidMsgs,0],
[snmpUnknownPDUHandlers, 0]]),
?line UnknownSecs2 = UnknownSecs + 1,
?line InvalidMsgs2 = InvalidMsgs + 1,
UnknownPDUHs.
-define(snmpUnknownPDUHandlers_instance, [1,3,6,1,6,3,11,2,1,3,0]).
snmp_mpd_mib_b() ->
g([[sysUpTime,0]]),
?line expect(1, report, [{?snmpUnknownPDUHandlers_instance, any}]).
snmp_mpd_mib_c(UnknownPDUHs) ->
?line [UnknownPDUHs2] = get_req(1, [[snmpUnknownPDUHandlers, 0]]),
?line UnknownPDUHs2 = UnknownPDUHs + 1.
snmp_target_mib(suite) -> [];
snmp_target_mib(Config) when is_list(Config) ->
?P(snmp_target_mib),
init_case(Config),
?line load_master_std("SNMP-TARGET-MIB"),
try_test(snmp_target_mib),
?line unload_master("SNMP-TARGET-MIB").
snmp_target_mib_2(X) -> ?P(snmp_target_mib_2), snmp_target_mib(X).
snmp_target_mib_3(X) -> ?P(snmp_target_mib_3), snmp_target_mib(X).
snmp_target_mib() ->
?INF("NOT YET IMPLEMENTED", []),
nyi.
snmp_notification_mib(suite) -> [];
snmp_notification_mib(Config) when is_list(Config) ->
?P(snmp_notification_mib),
init_case(Config),
?line load_master_std("SNMP-NOTIFICATION-MIB"),
try_test(snmp_notification_mib),
?line unload_master("SNMP-NOTIFICATION-MIB").
snmp_notification_mib_2(X) -> ?P(snmp_notification_mib_2),
snmp_notification_mib(X).
snmp_notification_mib_3(X) -> ?P(snmp_notification_mib_3),
snmp_notification_mib(X).
snmp_notification_mib() ->
?INF("NOT YET IMPLEMENTED", []),
nyi.
%%-----------------------------------------------------------------
%% o add/delete views and try them
%% o try boundaries
%%-----------------------------------------------------------------
snmp_view_based_acm_mib(suite) -> [];
snmp_view_based_acm_mib(Config) when is_list(Config) ->
?P(snmp_view_based_acm_mib),
init_case(Config),
?line load_master_std("SNMP-VIEW-BASED-ACM-MIB"),
?line load_master("Test2"),
snmp_view_based_acm_mib(),
?line unload_master("Test2"),
?line unload_master("SNMP-VIEW-BASED-ACM-MIB").
snmp_view_based_acm_mib_2(X) ->
?P(snmp_view_based_acm_mib_2),
snmp_view_based_acm_mib(X).
snmp_view_based_acm_mib_3(X) ->
%% <CONDITIONAL-SKIP>
Skippable = [{unix, [darwin]}],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(X, Condition),
%% </CONDITIONAL-SKIP>
?P(snmp_view_based_acm_mib_3),
snmp_view_based_acm_mib(X).
snmp_view_based_acm_mib() ->
snmpa:verbosity(net_if,trace),
snmpa:verbosity(master_agent,trace),
?LOG("start snmp_view_based_acm_mib test",[]),
%% The user "no-rights" is present in USM, and is mapped to security
%% name 'no-rights", which is not present in VACM.
%% So, we'll add rights for it, try them and delete them.
%% We'll give "no-rights" write access to tDescr.0 and read access
%% to tDescr2.0
%% These are the options we'll use to the mgr
Opts = [{user, "no-rights"}, {community, "no-rights"}],
%% Find the valid secmodel, and one invalid secmodel.
{SecMod, InvSecMod} =
case get(vsn) of
v1 -> {?SEC_V1, ?SEC_V2C};
v2 -> {?SEC_V2C, ?SEC_USM};
v3 -> {?SEC_USM, ?SEC_V1}
end,
?DBG("assign rights for 'no-rights'",[]),
?line try_test(use_no_rights, [], Opts),
%% Now, add a mapping from "no-rights" -> "no-rights-group"
GRow1Status = [vacmSecurityToGroupStatus,[SecMod, 9,"no-rights"]],
GRow1 =
[{[vacmGroupName, [SecMod, 9,"no-rights"]], "no-rights-group"},
{GRow1Status, ?createAndGo}],
?DBG("set '~p'",[GRow1]),
?line try_test(do_set, [GRow1]),
?DBG("assign rights for 'no-rights'",[]),
?line try_test(use_no_rights, [], Opts),
%% Create a mapping for another sec model, and make sure it dosn't
%% give us access
GRow2Status = [vacmSecurityToGroupStatus,[InvSecMod, 9,"no-rights"]],
GRow2 = [{[vacmGroupName, [InvSecMod, 9, "no-rights"]], "initial"},
{GRow2Status, ?createAndGo}],
?DBG("set '~p'",[GRow2]),
?line try_test(do_set, [GRow2]),
?DBG("assign rights for 'no-rights'",[]),
?line try_test(use_no_rights, [], Opts),
%% Delete that row
?line try_test(del_row, [GRow2Status]),
RVName = "rv_name",
WVName = "wv_name",
%% Access row
ARow1Idx = [15 | "no-rights-group"] ++ [0, ?SEC_ANY, 1],
ARow1Status = [vacmAccessStatus, ARow1Idx],
ARow1 = [{[vacmAccessContextMatch, ARow1Idx], 1},
{[vacmAccessReadViewName, ARow1Idx], RVName},
{[vacmAccessWriteViewName, ARow1Idx], WVName},
{ARow1Status, ?createAndGo}],
%% This access row would give acces, if InvSecMod was valid.
ARow2Idx = [15 | "no-rights-group"] ++ [0, InvSecMod, 1],
ARow2Status = [vacmAccessStatus, ARow2Idx],
ARow2 = [{[vacmAccessContextMatch, ARow2Idx], 1},
{[vacmAccessReadViewName, ARow2Idx], "internet"},
{[vacmAccessWriteViewName, ARow2Idx], "internet"},
{ARow2Status, ?createAndGo}],
?line try_test(do_set, [ARow2]),
?line try_test(use_no_rights, [], Opts),
%% Delete that row
?line try_test(del_row, [ARow2Status]),
%% Add valid row
?line try_test(do_set, [ARow1]),
?line try_test(use_no_rights, [], Opts),
%% Create the view family
VRow1Idx = mk_ln(RVName) ++ mk_ln(?xDescr), % object access
VRow2Idx = mk_ln(RVName) ++ mk_ln(?xDescr2 ++ [0]), % instance access
VRow3Idx = mk_ln(WVName) ++ mk_ln(?xDescr), % object access
VRow4Idx = mk_ln(WVName) ++ mk_ln(?xDescr ++ [0]), % instance access
VRow1Status = [vacmViewTreeFamilyStatus, VRow1Idx],
VRow2Status = [vacmViewTreeFamilyStatus, VRow2Idx],
VRow3Status = [vacmViewTreeFamilyStatus, VRow3Idx],
VRow4Status = [vacmViewTreeFamilyStatus, VRow4Idx],
?line try_test(add_row, [VRow1Status]),
?line try_test(add_row, [VRow2Status]),
?line try_test(add_row, [VRow3Status]),
%% We're supposed to have access now...
?line try_test(use_rights, [], Opts),
%% Change Row3 to Row4
?line try_test(del_row, [VRow3Status]),
?line try_test(add_row, [VRow4Status]),
%% We should still have access...
?line try_test(use_rights, [], Opts),
%% Delete rows
?line try_test(del_row, [GRow1Status]),
?line try_test(use_no_rights, [], Opts),
%% Delete rest of rows
?line try_test(del_row, [ARow1Status]),
?line try_test(del_row, [VRow1Status]),
?line try_test(del_row, [VRow2Status]),
?line try_test(del_row, [VRow4Status]),
?line try_test(use_no_rights, [], Opts),
snmpa:verbosity(master_agent,log).
do_set(Row) ->
s(Row),
expect(do_set_1, Row).
add_row(RowStatus) ->
s([{RowStatus, ?createAndGo}]),
expect(add_row_1, [{RowStatus, ?createAndGo}]).
del_row(RowStatus) ->
s([{RowStatus, ?destroy}]),
expect(del_row_1, [{RowStatus, ?destroy}]).
use_no_rights() ->
g([[xDescr,0]]),
?v1_2_3(expect(use_no_rights_11, noSuchName, 1, any),
expect(use_no_rights_12, [{[xDescr,0], noSuchObject}]),
expect(use_no_rights_13, authorizationError, 1, any)),
g([[xDescr2,0]]),
?v1_2_3(expect(use_no_rights_21, noSuchName, 1, any),
expect(use_no_rights_22, [{[xDescr2,0], noSuchObject}]),
expect(use_no_rights_23, authorizationError, 1, any)),
gn([[xDescr]]),
?v1_2_3(expect(use_no_rights_31, noSuchName, 1, any),
expect(use_no_rights_32, [{[xDescr], endOfMibView}]),
expect(use_no_rights_33, authorizationError, 1, any)),
s([{[xDescr,0], "tryit"}]),
?v1_2_3(expect(use_no_rights_41, noSuchName, 1, any),
expect(use_no_rights_42, noAccess, 1, any),
expect(use_no_rights_43, authorizationError, 1, any)).
use_rights() ->
g([[xDescr,0]]),
expect(use_rights_1, [{[xDescr,0], any}]),
g([[xDescr2,0]]),
expect(use_rights_2, [{[xDescr2,0], any}]),
s([{[xDescr,0], "tryit"}]),
expect(use_rights_3, noError, 0, any),
g([[xDescr,0]]),
expect(use_rights_4, [{[xDescr,0], "tryit"}]).
mk_ln(X) ->
[length(X) | X].
%%-----------------------------------------------------------------
%% o add/delete users and try them
%% o test all secLevels
%% o test all combinations of protocols
%% o try bad ops; check counters
%%-----------------------------------------------------------------
snmp_user_based_sm_mib_3(suite) -> [];
snmp_user_based_sm_mib_3(Config) when is_list(Config) ->
%% <CONDITIONAL-SKIP>
Skippable = [{unix, [darwin]}],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(Config, Condition),
%% </CONDITIONAL-SKIP>
?P(snmp_user_based_sm_mib_3),
init_case(Config),
_AgentDir = ?config(agent_dir, Config),
?line load_master_std("SNMP-USER-BASED-SM-MIB"),
%% The newUser used here already has VACM access.
%% Add a new user in the simplest way; just createAndGo
try_test(v3_sync, [[{usm_add_user1, []}]],
[{sec_level, authPriv}, {user, "privDES"}]),
%% Try to use the new user
?line load_master("Test2"),
try_test(v3_sync, [[{usm_use_user, []}]],
[{sec_level, authPriv}, {user, "newUser"}]),
?line unload_master("Test2"),
ShaKey1 = snmp:passwd2localized_key(sha, "new sha password", "agentEngine"),
DesKey1 = lists:sublist(ShaKey1, 16),
%% Change the new user's keys - 1
try_test(v3_sync, [[{usm_key_change1, [ShaKey1, DesKey1]}]],
[{sec_level, authPriv}, {user, "newUser"}]),
%% Try to use the new keys
MgrDir = ?config(mgr_dir, Config),
?line rewrite_usm_mgr(MgrDir, ShaKey1, DesKey1),
?line load_master("Test2"),
try_test(v3_sync, [[{usm_use_user, []}]],
[{sec_level, authPriv}, {user, "newUser"}]),
?line unload_master("Test2"),
ShaKey2 = snmp:passwd2localized_key(sha, "newer password", "agentEngine"),
DesKey2 = lists:sublist(ShaKey2, 16),
%% Change the new user's keys - 2
?line try_test(v3_sync,
[[{usm_key_change2, [ShaKey1, DesKey1, ShaKey2, DesKey2]}]],
[{sec_level, authPriv}, {user, "newUser"}]),
%% Try to use the new keys
reset_usm_mgr(MgrDir),
?line rewrite_usm_mgr(MgrDir, ShaKey2, DesKey2),
?line load_master("Test2"),
?line try_test(v3_sync, [[{usm_use_user, []}]],
[{sec_level, authPriv}, {user, "newUser"}]),
?line unload_master("Test2"),
reset_usm_mgr(MgrDir),
%% Change the new user's keys - 3
?line try_test(v3_sync,
[[{usm_key_change3, [ShaKey2, DesKey2, ShaKey1, DesKey1]}]],
[{sec_level, authPriv}, {user, "privDES"}]),
%% Try to use the new keys
?line rewrite_usm_mgr(MgrDir, ShaKey1, DesKey1),
?line load_master("Test2"),
try_test(v3_sync, [[{usm_use_user, []}]],
[{sec_level, authPriv}, {user, "newUser"}]),
?line unload_master("Test2"),
reset_usm_mgr(MgrDir),
%% Try some read requests
?line try_test(v3_sync, [[{usm_read, []}]],
[{sec_level, authPriv}, {user, "privDES"}]),
%% Delete the new user
?line try_test(v3_sync, [[{usm_del_user, []}]],
[{sec_level, authPriv}, {user, "privDES"}]),
%% Try some bad requests
?line try_test(v3_sync, [[{usm_bad, []}]],
[{sec_level, authPriv}, {user, "privDES"}]),
?line unload_master("SNMP-USER-BASED-SM-MIB").
-define(usmUserSecurityName, [1,3,6,1,6,3,15,1,2,2,1,3]).
usm_add_user1() ->
NewRowIndex = [11,"agentEngine", 7, "newUser"],
RowPointer = ?usmUserSecurityName ++ [11|"agentEngine"] ++ [7|"privDES"],
Vbs1 = [{[usmUserCloneFrom, NewRowIndex], RowPointer},
{[usmUserStatus, NewRowIndex], ?createAndGo}],
?line s(Vbs1),
?line expect(1, Vbs1),
ok.
usm_use_user() ->
v2_proc().
%% Change own public keys
usm_key_change1(ShaKey, DesKey) ->
NewRowIndex = [11,"agentEngine", 7, "newUser"],
ShaKeyChange = snmp_user_based_sm_mib:mk_key_change(sha,
"passwd_shaxxxxxxxxxx",
ShaKey),
DesKeyChange = snmp_user_based_sm_mib:mk_key_change(sha,
"passwd_desxxxxxx",
DesKey),
Vbs1 = [{[usmUserAuthKeyChange, NewRowIndex], ShaKeyChange},
{[usmUserPrivKeyChange, NewRowIndex], DesKeyChange}],
s(Vbs1),
?line expect(1, Vbs1).
%% Change own private keys
usm_key_change2(OldShaKey, OldDesKey, ShaKey, DesKey) ->
NewRowIndex = [11,"agentEngine", 7, "newUser"],
ShaKeyChange = snmp_user_based_sm_mib:mk_key_change(sha,
OldShaKey,
ShaKey),
DesKeyChange = snmp_user_based_sm_mib:mk_key_change(sha,
OldDesKey,
DesKey),
Vbs1 = [{[usmUserOwnAuthKeyChange, NewRowIndex], ShaKeyChange},
{[usmUserOwnPrivKeyChange, NewRowIndex], DesKeyChange}],
s(Vbs1),
?line expect(1, Vbs1).
%% Change other's public keys
usm_key_change3(OldShaKey, OldDesKey, ShaKey, DesKey) ->
NewRowIndex = [11,"agentEngine", 7, "newUser"],
ShaKeyChange = snmp_user_based_sm_mib:mk_key_change(sha,
OldShaKey,
ShaKey),
DesKeyChange = snmp_user_based_sm_mib:mk_key_change(sha,
OldDesKey,
DesKey),
Vbs1 = [{[usmUserOwnAuthKeyChange, NewRowIndex], ShaKeyChange}],
s(Vbs1),
?line expect(1, noAccess, 1, any),
Vbs2 = [{[usmUserOwnPrivKeyChange, NewRowIndex], DesKeyChange}],
s(Vbs2),
?line expect(2, noAccess, 1, any),
Vbs3 = [{[usmUserAuthKeyChange, NewRowIndex], ShaKeyChange},
{[usmUserPrivKeyChange, NewRowIndex], DesKeyChange}],
s(Vbs3),
?line expect(1, Vbs3).
usm_read() ->
NewRowIndex = [11,"agentEngine", 7, "newUser"],
?line g([[usmUserSecurityName, NewRowIndex],
[usmUserCloneFrom, NewRowIndex],
[usmUserAuthKeyChange, NewRowIndex],
[usmUserOwnAuthKeyChange, NewRowIndex],
[usmUserPrivKeyChange, NewRowIndex],
[usmUserOwnPrivKeyChange, NewRowIndex]]),
?line expect(1,
[{[usmUserSecurityName, NewRowIndex], "newUser"},
{[usmUserCloneFrom, NewRowIndex], [0,0]},
{[usmUserAuthKeyChange, NewRowIndex], ""},
{[usmUserOwnAuthKeyChange, NewRowIndex], ""},
{[usmUserPrivKeyChange, NewRowIndex], ""},
{[usmUserOwnPrivKeyChange, NewRowIndex], ""}]),
ok.
usm_del_user() ->
NewRowIndex = [11,"agentEngine", 7, "newUser"],
Vbs1 = [{[usmUserStatus, NewRowIndex], ?destroy}],
?line s(Vbs1),
?line expect(1, Vbs1),
ok.
-define(usmUserCloneFrom, [1,3,6,1,6,3,15,1,2,2,1,4]).
-define(usmNoAuthProtocol, [1,3,6,1,6,3,10,1,1,1]).
-define(usmHMACMD5AuthProtocol, [1,3,6,1,6,3,10,1,1,2]).
-define(usmHMACSHAAuthProtocol, [1,3,6,1,6,3,10,1,1,3]).
-define(usmNoPrivProtocol, [1,3,6,1,6,3,10,1,2,1]).
-define(usmDESPrivProtocol, [1,3,6,1,6,3,10,1,2,2]).
usm_bad() ->
NewRowIndex = [11,"agentEngine", 7, "newUser"],
RowPointer1 = ?usmUserSecurityName ++ [11|"agentEngine"] ++ [7|"privDOS"],
Vbs1 = [{[usmUserCloneFrom, NewRowIndex], RowPointer1},
{[usmUserStatus, NewRowIndex], ?createAndGo}],
?line s(Vbs1),
?line expect(1, inconsistentName, 1, any),
RowPointer2 = ?usmUserCloneFrom ++ [11|"agentEngine"] ++ [7|"privDES"],
Vbs2 = [{[usmUserCloneFrom, NewRowIndex], RowPointer2},
{[usmUserStatus, NewRowIndex], ?createAndGo}],
?line s(Vbs2),
?line expect(2, wrongValue, 1, any),
RowPointer3 = ?usmUserSecurityName ++ [11|"agentEngine"] ++ [7|"privDES"],
Vbs3 = [{[usmUserCloneFrom, NewRowIndex], RowPointer3},
{[usmUserStatus, NewRowIndex], ?createAndGo}],
?line s(Vbs3),
?line expect(3, Vbs3),
?line s([{[usmUserAuthProtocol, NewRowIndex], ?usmNoAuthProtocol}]),
?line expect(4, inconsistentValue, 1, any),
?line s([{[usmUserAuthProtocol, NewRowIndex], ?usmHMACMD5AuthProtocol}]),
?line expect(5, inconsistentValue, 1, any),
?line s([{[usmUserAuthProtocol, NewRowIndex], ?usmDESPrivProtocol}]),
?line expect(6, wrongValue, 1, any),
?line s([{[usmUserPrivProtocol, NewRowIndex], ?usmHMACSHAAuthProtocol}]),
?line expect(7, wrongValue, 1, any),
Vbs4 = [{[usmUserStatus, NewRowIndex], ?destroy}],
?line s(Vbs4),
?line expect(1, Vbs4),
ok.
%%-----------------------------------------------------------------
%% Loop through entire MIB, to make sure that all instrum. funcs
%% works.
%% Load all std mibs that are not loaded by default.
%%-----------------------------------------------------------------
loop_mib(suite) -> [];
loop_mib(Config) when is_list(Config) ->
?P(loop_mib),
?LOG("loop_mib -> initiate case",[]),
%% snmpa:verbosity(master_agent,debug),
%% snmpa:verbosity(mib_server,info),
{SaNode, MgrNode, MibDir} = init_case(Config),
?DBG("loop_mib -> ~n"
"\tSaNode: ~p~n"
"\tMgrNode: ~p~n"
"\tMibDir: ~p",[SaNode, MgrNode, MibDir]),
?DBG("loop_mib -> load mib SNMP-COMMUNITY-MIB",[]),
?line load_master_std("SNMP-COMMUNITY-MIB"),
?DBG("loop_mib -> load mib SNMP-MPD-MIB",[]),
?line load_master_std("SNMP-MPD-MIB"),
?DBG("loop_mib -> load mib SNMP-TARGET-MIB",[]),
?line load_master_std("SNMP-TARGET-MIB"),
?DBG("loop_mib -> load mib SNMP-NOTIFICATION-MIB",[]),
?line load_master_std("SNMP-NOTIFICATION-MIB"),
?DBG("loop_mib -> load mib SNMP-FRAMEWORK-MIB",[]),
?line load_master_std("SNMP-FRAMEWORK-MIB"),
?DBG("loop_mib -> load mib SNMP-VIEW-BASED-ACM-MIB",[]),
?line load_master_std("SNMP-VIEW-BASED-ACM-MIB"),
?DBG("loop_mib -> try",[]),
try_test(loop_mib_1),
?DBG("loop_mib -> unload mib SNMP-COMMUNITY-MIB",[]),
?line unload_master("SNMP-COMMUNITY-MIB"),
?DBG("loop_mib -> unload mib SNMP-MPD-MIB",[]),
?line unload_master("SNMP-MPD-MIB"),
?DBG("loop_mib -> unload mib SNMP-TARGET-MIB",[]),
?line unload_master("SNMP-TARGET-MIB"),
?DBG("loop_mib -> unload mib SNMP-NOTIFICATION-MIB",[]),
?line unload_master("SNMP-NOTIFICATION-MIB"),
?DBG("loop_mib -> unload mib SNMP-FRAMEWORK-MIB",[]),
?line unload_master("SNMP-FRAMEWORK-MIB"),
?DBG("loop_mib -> unload mib SNMP-VIEW-BASED-ACM-MIB",[]),
?line unload_master("SNMP-VIEW-BASED-ACM-MIB"),
%% snmpa:verbosity(master_agent,log),
%% snmpa:verbosity(mib_server,silence),
?LOG("loop_mib -> done",[]).
loop_mib_2(suite) -> [];
loop_mib_2(Config) when is_list(Config) ->
?P(loop_mib_2),
?LOG("loop_mib_2 -> initiate case",[]),
{SaNode, MgrNode, MibDir} = init_case(Config),
?DBG("loop_mib_2 -> ~n"
"\tSaNode: ~p~n"
"\tMgrNode: ~p~n"
"\tMibDir: ~p",[SaNode, MgrNode, MibDir]),
?DBG("loop_mib_2 -> load mibs",[]),
?line load_master_std("SNMP-COMMUNITY-MIB"),
?line load_master_std("SNMP-MPD-MIB"),
?line load_master_std("SNMP-TARGET-MIB"),
?line load_master_std("SNMP-NOTIFICATION-MIB"),
?line load_master_std("SNMP-FRAMEWORK-MIB"),
?line load_master_std("SNMP-VIEW-BASED-ACM-MIB"),
try_test(loop_mib_2),
?DBG("loop_mib_2 -> unload mibs",[]),
?line unload_master("SNMP-COMMUNITY-MIB"),
?line unload_master("SNMP-MPD-MIB"),
?line unload_master("SNMP-TARGET-MIB"),
?line unload_master("SNMP-NOTIFICATION-MIB"),
?line unload_master("SNMP-FRAMEWORK-MIB"),
?line unload_master("SNMP-VIEW-BASED-ACM-MIB"),
?LOG("loop_mib_2 -> done",[]).
loop_mib_3(suite) -> [];
loop_mib_3(Config) when is_list(Config) ->
?P(loop_mib_3),
?LOG("loop_mib_3 -> initiate case",[]),
{SaNode, MgrNode, MibDir} = init_case(Config),
?DBG("loop_mib_3 -> ~n"
"\tSaNode: ~p~n"
"\tMgrNode: ~p~n"
"\tMibDir: ~p",[SaNode, MgrNode, MibDir]),
?DBG("loop_mib_3 -> load mibs",[]),
?line load_master_std("SNMP-TARGET-MIB"),
?line load_master_std("SNMP-NOTIFICATION-MIB"),
?line load_master_std("SNMP-VIEW-BASED-ACM-MIB"),
?line load_master_std("SNMP-USER-BASED-SM-MIB"),
try_test(loop_mib_2),
?DBG("loop_mib_3 -> unload mibs",[]),
?line unload_master("SNMP-TARGET-MIB"),
?line unload_master("SNMP-NOTIFICATION-MIB"),
?line unload_master("SNMP-VIEW-BASED-ACM-MIB"),
?line unload_master("SNMP-USER-BASED-SM-MIB"),
?LOG("loop_mib_3 -> done",[]).
%% Req. As many mibs all possible
loop_mib_1() ->
?DBG("loop_mib_1 -> entry",[]),
N = loop_it_1([1,1], 0),
io:format(user, "found ~w varibles\n", [N]),
?line N = if N < 100 -> 100;
true -> N
end.
loop_it_1(Oid, N) ->
?DBG("loop_it_1 -> entry with~n"
"\tOid: ~p~n"
"\tN: ~p",[Oid,N]),
case get_next_req([Oid]) of
#pdu{type = 'get-response',
error_status = noError,
error_index = 0,
varbinds = [#varbind{oid = NOid,
value = Value}]} when NOid > Oid ->
?DBG("loop_it_1 -> "
"~n NOid: ~p"
"~n Value: ~p",[NOid, Value]),
?line [Value2] = get_req(1, [NOid]), % must not be same
?DBG("loop_it_1 -> "
"~n Value2: ~p",[Value2]),
loop_it_1(NOid, N+1);
#pdu{type = 'get-response',
error_status = noError,
error_index = 0,
varbinds = Vbs} ->
exit({unexpected_vbs, ?LINE, Vbs});
#pdu{type = 'get-response',
error_status = noSuchName,
error_index = 1,
varbinds = [_]} ->
?DBG("loop_it_1 -> done: ~p",[N]),
N;
#pdu{type = 'get-response',
error_status = Err,
error_index = Idx,
varbinds = Vbs} ->
exit({unexpected_pdu, ?LINE, Err, Idx, Vbs});
#pdu{type = Type,
error_status = Err,
error_index = Idx,
varbinds = Vbs} ->
exit({unexpected_pdu, ?LINE, Type, Err, Idx, Vbs});
{error, Reason} ->
exit({error, Reason, ?LINE})
end.
%% Req. As many mibs all possible
loop_mib_2() ->
?DBG("loop_mib_1 -> entry",[]),
N = loop_it_2([1,1], 0),
io:format(user, "found ~w varibles\n", [N]),
?line N = if N < 100 -> 100;
true -> N
end.
loop_it_2(Oid, N) ->
?DBG("loop_it_2 -> entry with"
"~n Oid: ~p"
"~n N: ~p",[Oid, N]),
case get_next_req([Oid]) of
#pdu{type = 'get-response',
error_status = noError,
error_index = 0,
varbinds = [#varbind{oid = NOid, value = endOfMibView}]} ->
?DBG("loop_it_2 -> "
"~n NOid: ~p",[NOid]),
N;
#pdu{type = 'get-response',
error_status = noError,
error_index = 0,
varbinds = [#varbind{oid = NOid,
value = Value}]} when NOid > Oid ->
?DBG("loop_it_2 -> "
"~n NOid: ~p"
"~n Value: ~p",[NOid, Value]),
?line [Value2] = get_req(1, [NOid]), % must not be same
?DBG("loop_it_2 -> "
"~n Value2: ~p",[Value2]),
loop_it_2(NOid, N+1);
#pdu{type = 'get-response',
error_status = noError,
error_index = 0,
varbinds = Vbs} ->
exit({unexpected_pdu, ?LINE,
[{varbinds, Vbs},
{get_next_oid, Oid},
{counter, N}]});
#pdu{type = 'get-response',
error_status = ES,
error_index = EI,
varbinds = Vbs} ->
exit({unexpected_pdu, ?LINE,
[{error_status, ES},
{error_index, EI},
{varbinds, Vbs},
{get_next_oid, Oid},
{counter, N}]});
#pdu{type = Type,
error_status = ES,
error_index = EI,
varbinds = Vbs} ->
exit({unexpected_pdu, ?LINE,
[{type, Type},
{error_status, ES},
{error_index, EI},
{varbinds, Vbs},
{get_next_oid, Oid},
{counter, N}]});
{error, Reason} ->
exit({unexpected_result, ?LINE,
[{reason, Reason},
{get_next_oid, Oid},
{counter, N}]})
end.
%%%-----------------------------------------------------------------
%%% Testing of reported bugs and other tickets.
%%%-----------------------------------------------------------------
%% These are (ticket) test cases where the initiation has to be done
%% individually.
%%-----------------------------------------------------------------
%% Ticket: OTP-1128
%% Slogan: Bug in handling of createAndWait set-requests.
%%-----------------------------------------------------------------
otp_1128(suite) -> [];
otp_1128(Config) when is_list(Config) ->
?P(otp_1128),
init_case(Config),
?line load_master("OLD-SNMPEA-MIB"),
?line init_old(),
try_test(otp_1128),
?line unload_master("OLD-SNMPEA-MIB").
otp_1128_2(X) -> ?P(otp_1128_2), otp_1128(X).
otp_1128_3(X) -> ?P(otp_1128_3), otp_1128(X).
otp_1128() ->
io:format("Testing bug reported in ticket OTP-1128...~n"),
NewKeyc3 = [intCommunityViewIndex,get(mip),is("test")],
NewKeyc4 = [intCommunityAccess,get(mip),is("test")],
NewKeyc5 = [intCommunityStatus,get(mip),is("test")],
s([{NewKeyc5, ?createAndWait}, {NewKeyc4, 2}]),
?line expect(28, [{NewKeyc5, ?createAndWait}, {NewKeyc4, 2}]),
g([NewKeyc5]),
?line expect(29, [{NewKeyc5, ?notReady}]),
s([{NewKeyc5, ?active}, {NewKeyc3, 2}]),
?line expect(30, [{NewKeyc5, ?active}, {NewKeyc3, 2}]),
g([NewKeyc5]),
?line expect(31, [{NewKeyc5, ?active}]),
s([{NewKeyc5, ?destroy}]),
?line expect(32, [{NewKeyc5, ?destroy}]).
%%-----------------------------------------------------------------
%% Ticket: OTP-1129, OTP-1169
%% Slogan: snmpa:int_to_enum crashes on bad oids
%%-----------------------------------------------------------------
otp_1129(suite) -> [];
otp_1129(Config) when is_list(Config) ->
?P(otp_1129),
init_case(Config),
?line load_master("Klas3"),
try_test(otp_1129_i, [node()]),
?line unload_master("Klas3").
otp_1129_2(X) -> ?P(otp_1129_2), otp_1129(X).
otp_1129_3(X) -> ?P(otp_1129_3), otp_1129(X).
otp_1129_i(MaNode) ->
io:format("Testing bug reported in ticket OTP-1129...~n"),
false = rpc:call(MaNode, snmp, int_to_enum, [iso, 1]),
false = rpc:call(MaNode, snmp, int_to_enum, [isox, 1]).
%%-----------------------------------------------------------------
%% Ticket: OTP-1131
%% Slogan: Agent crashes / erlang node halts if RowIndex in a
%% setrequest is of bad type, e.g. an INDEX {INTEGER},
%% and RowIdenx [3,2].
%%-----------------------------------------------------------------
otp_1131(suite) -> [];
otp_1131(Config) when is_list(Config) ->
?P(otp_1131),
init_case(Config),
?line load_master("Klas1"),
try_test(otp_1131),
?line unload_master("Klas1").
otp_1131_2(X) -> ?P(otp_1131_2), otp_1131(X).
otp_1131_3(X) ->
%% <CONDITIONAL-SKIP>
%% This is intended to catch Montavista Linux 4.0/ppc (2.6.5)
%% Montavista Linux looks like a Debian distro (/etc/issue)
LinuxVersionVerify =
fun() ->
case os:cmd("uname -m") of
"ppc" ++ _ ->
case file:read_file_info("/etc/issue") of
{ok, _} ->
case os:cmd("grep -i montavista /etc/issue") of
Info when (is_list(Info) andalso
(length(Info) > 0)) ->
case os:version() of
{2, 6, 10} ->
true;
_ ->
false
end;
_ -> % Maybe plain Debian or Ubuntu
false
end;
_ ->
%% Not a Debian based distro
false
end;
_ ->
false
end
end,
Skippable = [{unix, [darwin, {linux, LinuxVersionVerify}]}],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(X, Condition),
%% </CONDITIONAL-SKIP>
?P(otp_1131_3),
otp_1131(X).
otp_1131() ->
io:format("Testing bug reported in ticket OTP-1131...~n"),
s([{[friendsEntry, [2, 3, 1]], s, "kompis3"},
{[friendsEntry, [3, 3, 1]], i, ?createAndGo}]),
?line expect(1, ?v1_2(noSuchName, noCreation), 2, any).
%%-----------------------------------------------------------------
%% Ticket: OTP-1162
%% Slogan: snmp_agent can't handle wrongValue from instrum.func
%%-----------------------------------------------------------------
otp_1162(suite) -> [];
otp_1162(Config) when is_list(Config) ->
?P(otp_1162),
{SaNode, _MgrNode, _MibDir} = init_case(Config),
?line {ok, SA} = start_subagent(SaNode, ?sa, "SA-MIB"),
try_test(otp_1162),
stop_subagent(SA).
otp_1162_2(X) -> ?P(otp_1162_2), otp_1162(X).
otp_1162_3(X) -> ?P(otp_1162_3), otp_1162(X).
otp_1162() ->
s([{[sa, [2,0]], 6}]), % wrongValue (i is_set_ok)
?line expect(1, ?v1_2(badValue, wrongValue), 1, any).
%%-----------------------------------------------------------------
%% Ticket: OTP-1222
%% Slogan: snmp agent crash if faulty index is returned from instrum
%%-----------------------------------------------------------------
otp_1222(suite) -> [];
otp_1222(Config) when is_list(Config) ->
?P(otp_1222),
init_case(Config),
?line load_master("Klas3"),
?line load_master("Klas4"),
try_test(otp_1222),
?line unload_master("Klas3"),
?line unload_master("Klas4").
otp_1222_2(X) -> ?P(otp_1222_2), otp_1222(X).
otp_1222_3(X) -> ?P(otp_1222_3), otp_1222(X).
otp_1222() ->
io:format("Testing bug reported in ticket OTP-1222...~n"),
s([{[fStatus4,1], 4}, {[fName4,1], 1}]),
?line expect(1, genErr, 0, any),
s([{[fStatus4,2], 4}, {[fName4,2], 1}]),
?line expect(2, genErr, 0, any).
%%-----------------------------------------------------------------
%% Ticket: OTP-1298
%% Slogan: Negative INTEGER values are treated as positive.
%%-----------------------------------------------------------------
otp_1298(suite) -> [];
otp_1298(Config) when is_list(Config) ->
?P(otp_1298),
init_case(Config),
?line load_master("Klas2"),
try_test(otp_1298),
?line unload_master("Klas2").
otp_1298_2(X) -> ?P(otp_1298_2), otp_1298(X).
otp_1298_3(X) -> ?P(otp_1298_3), otp_1298(X).
otp_1298() ->
io:format("Testing bug reported in ticket OTP-1298...~n"),
s([{[fint,0], -1}]),
?line expect(1298, [{[fint,0], -1}]).
%%-----------------------------------------------------------------
%% Ticket: OTP-1331
%% Slogan: snmp_generic should return noError when deleting non-ex row
%%-----------------------------------------------------------------
otp_1331(suite) -> [];
otp_1331(Config) when is_list(Config) ->
?P(otp_1331),
init_case(Config),
?line load_master("OLD-SNMPEA-MIB"),
?line init_old(),
try_test(otp_1331),
?line unload_master("OLD-SNMPEA-MIB").
otp_1331_2(X) -> ?P(otp_1331_2), otp_1331(X).
otp_1331_3(X) -> ?P(otp_1331_3), otp_1331(X).
otp_1331() ->
NewKeyc5 = [intCommunityStatus,[127,32,0,0],is("test")],
s([{NewKeyc5, ?destroy}]),
?line expect(1, [{NewKeyc5, ?destroy}]).
%%-----------------------------------------------------------------
%% Ticket: OTP-1338
%% Slogan: snmp bug in initialisation of default values for mnesia tabs
%%-----------------------------------------------------------------
otp_1338(suite) -> [];
otp_1338(Config) when is_list(Config) ->
?P(otp_1338),
init_case(Config),
?line load_master("Klas2"),
try_test(otp_1338),
?line unload_master("Klas2").
otp_1338_2(X) -> ?P(otp_1338_2), otp_1338(X).
otp_1338_3(X) -> ?P(otp_1338_3), otp_1338(X).
otp_1338() ->
s([{[kStatus2, 7], i, ?createAndGo}]),
?line expect(1, [{[kStatus2, 7], ?createAndGo}]),
g([[kName2, 7]]),
?line expect(2, [{[kName2, 7], "JJJ"}]).
%%-----------------------------------------------------------------
%% Ticket: OTP-1342
%% Slogan: default impl of snmp table can't handle bad index access,
%% Set when INDEX is read-write gets into an infinite loop!
%%-----------------------------------------------------------------
otp_1342(suite) -> [];
otp_1342(Config) when is_list(Config) ->
?P(otp_1342),
init_case(Config),
?line load_master("Klas4"),
try_test(otp_1342),
?line unload_master("Klas4").
otp_1342_2(X) -> ?P(otp_1342_2), otp_1342(X).
otp_1342_3(X) -> ?P(otp_1342_3), otp_1342(X).
otp_1342() ->
s([{[fIndex5, 1], i, 1},
{[fName5, 1], i, 3},
{[fStatus5, 1], i, ?createAndGo}]),
?line expect(1, ?v1_2(noSuchName, noCreation), 3, any).
%%-----------------------------------------------------------------
%% Ticket: OTP-1366
%% Slogan: snmp traps not sent to all managers
%% Note: NYI! We need a way to tell the test server that we need
%% mgrs on two different machines.
%%-----------------------------------------------------------------
otp_1366(suite) -> [];
otp_1366(Config) when is_list(Config) ->
?P(otp_1366),
init_case(Config),
?line load_master("OLD-SNMPEA-MIB"),
?line init_old(),
try_test(otp_1366),
?line unload_master("OLD-SNMPEA-MIB").
otp_1366_2(X) -> ?P(otp_1366_2), otp_1366(X).
otp_1366_3(X) -> ?P(otp_1366_3), otp_1366(X).
otp_1366() ->
?INF("NOT YET IMPLEMENTED", []),
'NYI'.
%%-----------------------------------------------------------------
%% Ticket: OTP-2776
%% Slogan: snmp:validate_date_and_time() fails when time is 00:00
%%-----------------------------------------------------------------
otp_2776(suite) -> [];
otp_2776(Config) when is_list(Config) ->
?P(otp_2776),
init_case(Config),
try_test(otp_2776).
otp_2776_2(X) -> ?P(otp_2776_2), otp_2776(X).
otp_2776_3(X) -> ?P(otp_2776_3), otp_2776(X).
otp_2776() ->
io:format("Testing bug reported in ticket OTP-2776...~n"),
Dt01_valid = [19,98,9,1,1,0,23,0,43,0,0],
Dt02_valid = [19,98,9,1,0,0,0,0,43,0,0], % This is what is fixed: 00:00
Dt03_valid = [19,98,2,28,1,0,23,0,43,0,0],
Dt04_invalid = [19,98,2,29,1,0,23,0,43,0,0],
Dt05_valid = [19,96,2,29,1,0,23,0,43,0,0],
Dt06_valid = [20,0,2,29,1,0,23,0,43,0,0],
Dt07_invalid = [19,96,2,30,1,0,23,0,43,0,0], % This is also fixed: 30/2
Dt08_valid = [19,98,4,30,1,0,23,0,43,0,0],
Dt09_invalid = [19,98,4,31,1,0,23,0,43,0,0], % This is also fixed: 31/4
Dt10_invalid = [],
Dt11_invalid = [kalle,hobbe],
L = [{ 1, true, Dt01_valid},
{ 2, true, Dt02_valid},
{ 3, true, Dt03_valid},
{ 4, false, Dt04_invalid},
{ 5, true, Dt05_valid},
{ 6, true, Dt06_valid},
{ 7, false, Dt07_invalid},
{ 8, true, Dt08_valid},
{ 9, false, Dt09_invalid},
{10, false, Dt10_invalid},
{11, false, Dt11_invalid}],
?line ok = validate_dat(L).
validate_dat(L) -> validate_dat(L,[]).
validate_dat([],V) ->
Fun = fun({_,X}) -> case X of
ok -> false;
_ -> true
end
end,
validate_dat1( lists:reverse( lists:filter(Fun,V) ) );
validate_dat([{Id,E,Dat}|T],V) ->
validate_dat(T,[validate_dat2(Id,E,Dat) | V]).
validate_dat1([]) -> ok;
validate_dat1(L) -> {error,L}.
validate_dat2(Id, E, Dat) ->
Res = case {E,snmp:validate_date_and_time(Dat)} of
{E,E} -> ok;
{E,A} -> {E,A}
end,
{Id, Res}.
%%-----------------------------------------------------------------
%% Ticket: OTP-2979
%% Slogan: get-next on more than 1 column in an empty table
%% returns bad response.
%%-----------------------------------------------------------------
otp_2979(suite) -> [];
otp_2979(Config) when is_list(Config) ->
?P(otp_2979),
init_case(Config),
?line load_master("Test1"),
?line init_old(),
try_test(otp_2979),
?line unload_master("Test1").
otp_2979_2(X) -> ?P(otp_2979_2), otp_2979(X).
otp_2979_3(X) -> ?P(otp_2979_3), otp_2979(X).
otp_2979() ->
gn([[sparseDescr], [sparseStatus]]),
?line expect(1, [{[sparseStr,0], "slut"},
{[sparseStr,0], "slut"}]).
%%-----------------------------------------------------------------
%% Ticket: OTP-3187
%% Slogan: get-next on vacmAccessTable for colums > 5 returns
%% endOfTable - should return value.
%%-----------------------------------------------------------------
otp_3187(suite) -> [];
otp_3187(Config) when is_list(Config) ->
?P(otp_3187),
init_case(Config),
?line load_master_std("SNMP-VIEW-BASED-ACM-MIB"),
otp_3187(),
?line unload_master("SNMP-VIEW-BASED-ACM-MIB").
otp_3187_2(X) -> ?P(otp_3187_2), otp_3187(X).
otp_3187_3(X) -> ?P(otp_3187_3), otp_3187(X).
otp_3187() ->
?line Elements =
snmp_view_based_acm_mib:vacmAccessTable(get_next,[],[4,5,6]),
lists:foreach(fun(E) ->
?line if E == endOfTable ->
?FAIL(endOfTable);
true -> ok
end
end, Elements).
%%-----------------------------------------------------------------
%% Ticket: OTP-3542
%% Slogan:
%%-----------------------------------------------------------------
otp_3542(suite) -> [];
otp_3542(Config) when is_list(Config) ->
?P(otp_3542),
init_case(Config),
try_test(otp_3542).
otp_3542() ->
io:format("SNMP v3 discovery...~n"),
?line Res = snmp_test_mgr:d(),
io:format("SNMP v3 discovery result: ~p~n",[Res]).
%%-----------------------------------------------------------------
%% Ticket: OTP-3725
%% Slogan: Slow response time on snmpa:int_to_enum
%%-----------------------------------------------------------------
otp_3725(suite) -> [];
otp_3725(Config) when is_list(Config) ->
?P(otp_3725),
init_case(Config),
?line load_master("OLD-SNMPEA-MIB"),
?line init_old(),
try_test(otp_3725_test, [node()]),
?line unload_master("OLD-SNMPEA-MIB").
%% Req. OLD-SNMPEA-MIB
otp_3725_test(MaNode) ->
io:format("Testing feature requested in ticket OTP-3725...~n"),
?line rpc:call(MaNode,snmpa,verbosity,[symbolic_store,trace]),
?line Db = rpc:call(MaNode,snmp,get_symbolic_store_db,[]),
?DBG("otp_3725_test -> Db = ~p",[Db]),
?line {value, OID} = rpc:call(MaNode, snmp, name_to_oid,
[Db, intAgentIpAddress]),
?DBG("otp_3725_test -> name_to_oid for ~p: ~p",[intAgentIpAddress,OID]),
?line {value, intAgentIpAddress} = rpc:call(MaNode, snmp, oid_to_name,
[Db,OID]),
?DBG("otp_3725_test -> oid_to_name for ~p: ~p",[OID,intAgentIpAddress]),
?line false = rpc:call(MaNode, snmp, name_to_oid, [Db, intAgentIpAddres]),
?line false = rpc:call(MaNode, snmp, oid_to_name,
[Db, [1,5,32,3,54,3,3,34,4]]),
?line {value, 2} = rpc:call(MaNode, snmp, enum_to_int,
[Db, intViewType, excluded]),
?line {value, excluded} = rpc:call(MaNode, snmp, int_to_enum,
[Db, intViewType, 2]),
?line false = rpc:call(MaNode, snmp, enum_to_int,
[Db, intViewType, exclude]),
?line false = rpc:call(MaNode, snmp, enum_to_int,
[Db, intAgentIpAddress, exclude]),
?line false = rpc:call(MaNode, snmp, enum_to_int,
[Db, intAgentIpAddre, exclude]),
?line false = rpc:call(MaNode, snmp, int_to_enum, [Db, intViewType, 3]),
?line false = rpc:call(MaNode, snmp, int_to_enum,
[Db, intAgentIpAddress, 2]),
?line false = rpc:call(MaNode, snmp, int_to_enum,
[Db, intAgentIpAddre, 2]),
?line {value, active} = rpc:call(MaNode, snmp, int_to_enum,
[Db, 'RowStatus', ?active]),
?line {value, ?destroy} = rpc:call(MaNode, snmp, enum_to_int,
[Db, 'RowStatus', destroy]),
?line false = rpc:call(MaNode, snmp, enum_to_int,
[Db, 'RowStatus', xxxdestroy]),
?line false = rpc:call(MaNode, snmp, enum_to_int,
[Db, 'xxRowStatus', destroy]),
?line false = rpc:call(MaNode, snmp, int_to_enum, [Db, 'RowStatus', 25]),
?line false = rpc:call(MaNode, snmp, int_to_enum, [Db, 'xxRowStatus', 1]),
ok.
%%-----------------------------------------------------------------
%% Ticket: OTP-4394
%% Slogan: Target mib tag list check invalid
%%-----------------------------------------------------------------
init_otp_4394(Config) when is_list(Config) ->
?DBG("init_otp_4394 -> entry with"
"~n Config: ~p", [Config]),
?line AgentDir = ?config(agent_dir, Config),
?line MgrDir = ?config(mgr_dir, Config),
?line Ip = ?config(ip, Config),
?line otp_4394_config(AgentDir, MgrDir, Ip),
MasterAgentVerbosity = {master_agent_verbosity, trace},
NetIfVerbosity = {net_if_verbosity, trace},
Opts = [MasterAgentVerbosity,NetIfVerbosity],
[{vsn, v1} | start_v1_agent(Config,Opts)].
otp_4394_config(AgentDir, MgrDir, Ip0) ->
?DBG("otp_4394_config -> entry with"
"~n AgentDir: ~p"
"~n MgrDir: ~p"
"~n Ip0: ~p", [AgentDir, MgrDir, Ip0]),
Vsn = [v1],
Ip = tuple_to_list(Ip0),
?line snmp_config:write_agent_snmp_files(AgentDir, Vsn, Ip,
?TRAP_UDP, Ip, 4000,
"OTP-4394 test"),
?line case update_usm(Vsn, AgentDir) of
true ->
?line copy_file(filename:join(AgentDir, "usm.conf"),
filename:join(MgrDir, "usm.conf")),
?line update_usm_mgr(Vsn, MgrDir);
false ->
?line ok
end,
C1 = {"a", "all-rights", "initial", "", "pc"},
C2 = {"c", "secret", "secret_name", "", "secret_tag"},
?line write_community_conf(AgentDir, [C1, C2]),
?line update_vacm(Vsn, AgentDir),
Ta1 = {"shelob v1",
[134,138,177,177], 5000, 1500, 3, %% Anv�nd Ip och modda
"pc1",
"target_v1", "",
%% [255,255,255,255,0,0],
[],
2048},
Ta2 = {"bifur v1",
[134,138,177,75], 5000, 1500, 3, %% Anv�nd Ip
"pc2",
"target_v1", "",
%% [255,255,255,255,0,0],
[], 2048},
?line write_target_addr_conf(AgentDir, [Ta1, Ta2]),
?line write_target_params_conf(AgentDir, Vsn),
?line write_notify_conf(AgentDir),
ok.
finish_otp_4394(Config) when is_list(Config) ->
?DBG("finish_otp_4394 -> entry", []),
C1 = stop_agent(Config),
delete_files(C1),
erase(mgr_node),
lists:keydelete(vsn, 1, C1).
otp_4394_test(suite) -> [];
otp_4394_test(Config) ->
?P(otp_4394_test),
?DBG("otp_4394_test -> entry", []),
init_case(Config),
try_test(otp_4394_test1),
?DBG("otp_4394_test -> done", []),
ok.
otp_4394_test1() ->
?DBG("otp_4394_test1 -> entry", []),
gn([[1,1]]),
Res =
case snmp_test_mgr:expect(1, [{[sysDescr,0], "Erlang SNMP agent"}]) of
%% {error, 1, {"?",[]}, {"~w",[timeout]}}
{error, 1, _, {_, [timeout]}} ->
?DBG("otp_4394_test1 -> expected result: timeout", []),
ok;
Else ->
Else
end,
?DBG("otp_4394_test1 -> done with: ~p", [Res]),
Res.
%%-----------------------------------------------------------------
%% Ticket: OTP-7157
%% Slogan: Target mib tag list check invalid
%%-----------------------------------------------------------------
init_otp_7157(Config) when is_list(Config) ->
%% <CONDITIONAL-SKIP>
Skippable = [win32],
Condition = fun() -> ?OS_BASED_SKIP(Skippable) end,
?NON_PC_TC_MAYBE_SKIP(Config, Condition),
%% </CONDITIONAL-SKIP>
?DBG("init_otp_7157 -> entry with"
"~n Config: ~p", [Config]),
?line AgentDir = ?config(agent_dir, Config),
?line MgrDir = ?config(mgr_dir, Config),
?line Ip = ?config(ip, Config),
?line config([v2], MgrDir, AgentDir, tuple_to_list(Ip), tuple_to_list(Ip)),
MasterAgentVerbosity = {master_agent_verbosity, trace},
NetIfVerbosity = {net_if_verbosity, trace},
Opts = [MasterAgentVerbosity, NetIfVerbosity],
[{vsn, v2} | start_v2_agent(Config, Opts)].
finish_otp_7157(Config) when is_list(Config) ->
?DBG("finish_otp_7157 -> entry", []),
C1 = stop_agent(Config),
delete_files(C1),
erase(mgr_node),
lists:keydelete(vsn, 1, C1).
otp_7157_test(suite) -> [];
otp_7157_test(Config) ->
?P(otp_7157_test),
?DBG("otp_7157_test -> entry", []),
init_case(Config),
MA = whereis(snmp_master_agent),
?line load_master("Test1"),
try_test(otp_7157_test1, [MA]),
?line unload_master("Test1"),
?DBG("otp_7157_test -> done", []),
ok.
%% ts:run(snmp, snmp_agent_test, [batch]).
otp_7157_test1(MA) ->
?LOG("start otp_7157_test1 test (~p)",[MA]),
snmpa:verbosity(MA, trace),
?LOG("start otp_7157_test1 test",[]),
?P1("Testing that varbinds in traps/notifications are not reordered"),
?DBG("send cntTrap",[]),
snmpa:send_trap(MA, cntTrap, "standard trap"),
?DBG("await response",[]),
%% We don't really care about the values, just the vb order.
?line ok = expect(1, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], any},
{[sysContact, 0], any},
{[cnt64, 0], any},
{[sysLocation, 0], any}]),
?DBG("done", []),
ok.
%%-----------------------------------------------------------------
%% Extra test cases
%% These cases are started in the new way
%%-----------------------------------------------------------------
otp8395({init, Config}) when is_list(Config) ->
?DBG("otp8395(init) -> entry with"
"~n Config: ~p", [Config]),
%% --
%% Start nodes
%%
{ok, AgentNode} = start_node(agent),
%% {ok, SubAgentNode} = start_node(sub_agent),
{ok, ManagerNode} = start_node(manager),
%% --
%% Mnesia init
%%
AgentDbDir = ?config(agent_db_dir, Config),
AgentMnesiaDir = filename:join([AgentDbDir, "mnesia"]),
mnesia_init(AgentNode, AgentMnesiaDir),
%% SubAgentDir = ?config(sub_agent_dir, Config),
%% SubAgentMnesiaDir = filename:join([SubAgentDir, "mnesia"]),
%% mnesia_init(SubAgentNode, SubAgentMnesiaDir),
%% ok = mnesia_create_schema(AgentNode, [AgentNode, SubAgentNode]),
%% ok = mnesia:create_schema([AgentNode, SubAgentNode]),
mnesia_create_schema(AgentNode, [AgentNode]),
mnesia_start(AgentNode),
%% mnesia_start(SubAgentNode),
%% --
%% Host & IP
%%
AgentHost = ?HOSTNAME(AgentNode),
%% SubAgentHost = ?HPSTNAME(SubAgentNode),
ManagerHost = ?HOSTNAME(ManagerNode),
Host = snmp_test_lib:hostname(),
Ip = ?LOCALHOST(),
{ok, AgentIP0} = snmp_misc:ip(AgentHost),
AgentIP = tuple_to_list(AgentIP0),
%% {ok, SubAgentIP0} = snmp_misc:ip(SubAgentHost),
%% SubAgentIP = tuple_to_list(SubAgentIP0),
{ok, ManagerIP0} = snmp_misc:ip(ManagerHost),
ManagerIP = tuple_to_list(ManagerIP0),
%% --
%% Write agent config
%%
Vsns = [v1],
AgentConfDir = ?config(agent_conf_dir, Config),
ManagerConfDir = ?config(manager_top_dir, Config),
snmp_agent_test_lib:config(Vsns,
ManagerConfDir, AgentConfDir,
ManagerIP, AgentIP),
%% --
%% Start the agent
%%
Config2 = start_agent([{host, Host},
{ip, Ip},
{agent_node, AgentNode},
{agent_host, AgentHost},
{agent_ip, AgentIP},
%% {sub_agent_node, SubAgentNode},
%% {sub_agent_host, SubAgentHost},
%% {sub_agent_ip, SubAgentIP},
{manager_node, ManagerNode},
{manager_host, ManagerHost},
{manager_ip, ManagerIP}|Config]),
%% --
%% Create watchdog
%%
Dog = ?WD_START(?MINS(1)),
[{watchdog, Dog} | Config2];
otp8395({fin, Config}) when is_list(Config) ->
?DBG("otp8395(fin) -> entry with"
"~n Config: ~p", [Config]),
AgentNode = ?config(agent_node, Config),
ManagerNode = ?config(manager_node, Config),
%% -
%% Stop agent (this is the nice way to do it,
%% so logs and files can be closed in the proper way).
%%
AgentSup = ?config(agent_sup, Config),
?DBG("otp8395(fin) -> stop (stand-alone) agent: ~p", [AgentSup]),
stop_stdalone_agent(AgentSup),
%% -
%% Stop mnesia
%%
?DBG("otp8395(fin) -> stop mnesia", []),
mnesia_stop(AgentNode),
%% -
%% Stop the agent node
%%
?DBG("otp8395(fin) -> stop agent node", []),
stop_node(AgentNode),
%% SubAgentNode = ?config(sub_agent_node, Config),
%% stop_node(SubAgentNode),
%% -
%% Stop the manager node
%%
?DBG("otp8395(fin) -> stop manager node", []),
stop_node(ManagerNode),
Dog = ?config(watchdog, Config),
?WD_STOP(Dog),
lists:keydelete(watchdog, 1, Config);
otp8395(doc) ->
"OTP-8395 - ATL with sequence numbering. ";
otp8395(Config) when is_list(Config) ->
?DBG("otp8395 -> entry with"
"~n Config: ~p", [Config]),
?SLEEP(1000),
%% This is just to dirty trick for the ***old*** test-code
put(mgr_node, ?config(manager_node, Config)),
put(mgr_dir, ?config(manager_top_dir, Config)),
put(mib_dir, ?config(mib_dir, Config)),
put(vsn, v1),
put(master_host, ?config(agent_host, Config)),
try_test(simple_standard_test),
?SLEEP(1000),
AgentNode = ?config(agent_node, Config),
AgentLogDir = ?config(agent_log_dir, Config),
OutFile = filename:join([AgentLogDir, "otp8395.txt"]),
{ok, LogInfo} = rpc:call(AgentNode, snmpa, log_info, []),
?DBG("otp8395 -> LogInfo: ~p", [LogInfo]),
%% SyncRes = rpc:call(AgentNode, snmp, log_sync, [?audit_trail_log_name]),
%% ?DBG("otp8395 -> SyncRes: ~p", [SyncRes]),
ok = agent_log_validation(AgentNode),
LTTRes =
rpc:call(AgentNode, snmpa, log_to_txt, [AgentLogDir, [], OutFile]),
?DBG("otp8395 -> LTTRes: ~p", [LTTRes]),
?SLEEP(1000),
?DBG("otp8395 -> done", []),
ok.
agent_log_validation(Node) ->
rpc:call(Node, ?MODULE, agent_log_validation, []).
agent_log_validation() ->
put(sname, otp8308),
put(verbosity, trace),
snmp_log:validate(?audit_trail_log_name, true).
mnesia_init(Node, Dir) ->
rpc:call(Node, ?MODULE, mnesia_init, [Dir]).
mnesia_init(Dir) ->
ok = application:load(mnesia),
application_controller:set_env(mnesia, dir, Dir).
mnesia_create_schema(Node, Nodes) ->
rpc:call(Node, mnesia, create_schema, [Nodes]).
mnesia_start(Node) ->
rpc:call(Node, application, start, [mnesia]).
mnesia_start() ->
application:start(mnesia).
mnesia_stop(Node) ->
rpc:call(Node, application, stop, [mnesia]).
mnesia_stop() ->
application:start(mnesia).
start_agent(Config) ->
start_agent(Config, []).
start_agent(Config, Opts) ->
%% Directories
ConfDir = ?config(agent_conf_dir, Config),
DbDir = ?config(agent_db_dir, Config),
LogDir = ?config(agent_log_dir, Config),
Vsns = [v1],
AgentConfig = process_agent_options(ConfDir, DbDir, LogDir, Vsns, Opts),
%% Nodes
AgentNode = ?config(agent_node, Config),
%% ManagerNode = ?config(manager_node, Config),
process_flag(trap_exit,true),
AgentTopSup = start_stdalone_agent(AgentNode, AgentConfig),
[{agent_sup, AgentTopSup} | Config].
process_agent_options(ConfDir, DbDir, LogDir, Vsns, Opts) ->
Defaults =
[{agent_type, master},
{agent_verbosity, trace},
{priority, normal},
{versions, Vsns},
{db_dir, DbDir},
{mib_storage, ets},
{local_db, [{repair, true},
{auto_save, 5000},
{verbosity, log}]},
{error_report_module, snmpa_error_logger},
{config, [{dir, ConfDir},
{force_load, true},
{verbosity, trace}]},
{multi_threaded, true},
{mib_server, [{mibentry_override, false},
{trapentry_override, false},
{verbosity, info}]},
{target_cache, [{verbosity,info}]},
{symbolic_store, [{verbosity,log}]},
{note_store, [{timeout,30000}, {verbosity,log}]},
{net_if, [{module, snmpa_net_if},
{verbosity, trace},
{options, [{bind_to, false},
{no_reuse, false},
{req_limit, infinity}]}]},
{audit_trail_log, [{type, read_write},
{dir, LogDir},
{size, {10240,20}},
{repair, true},
{seqno, true}]}],
process_options(Defaults, Opts).
process_options(Defaults, _Opts) ->
%% process_options(Defaults, Opts, []).
Defaults.
%% process_options([], _Opts, Acc) ->
%% lists:reverse(Acc);
%% process_options([{Key, DefaultValue}|Defaults], Opts, Acc) ->
%% case lists:keysearch(Key, 1, Opts) of
%% {value, {Key, Value}} when is_list->
snmp_app_env_init(Node, Entity, Conf) ->
rpc:call(Node, snmp_app_env_init, [Entity, Conf]).
snmp_app_env_init(Entity, Conf) ->
application:unload(snmp),
application:load(snmp),
application:set_env(snmp, Entity, Conf).
start_stdalone_agent(Node, Config) ->
rpc:call(Node, ?MODULE, start_stdalone_agent, [Config]).
start_stdalone_agent(Config) ->
case snmpa_supervisor:start_link(normal, Config) of
{ok, AgentTopSup} ->
unlink(AgentTopSup),
AgentTopSup;
{error, {already_started, AgentTopSup}} ->
AgentTopSup
end.
stop_stdalone_agent(Pid) when (node(Pid) =/= node()) ->
MRef = erlang:monitor(process, Pid),
rpc:call(node(Pid), ?MODULE, stop_stdalone_agent, [Pid]),
receive
{'DOWN', MRef, process, Pid, Info} ->
?DBG("received expected DOWN message "
"regarding snmp agent supervisor: "
"~n Info: ~p", [Info]),
ok
after 5000 ->
?DBG("no DOWN message "
"regarding snmp agent supervisor within time", []),
ok
end;
stop_stdalone_agent(Pid) ->
?DBG("attempting to terminate agent top-supervisor: ~p", [Pid]),
nkill(Pid, kill).
nkill(Pid, Reason) ->
nkill(Pid, Reason, 10).
nkill(Pid, Reason, N) when N > 0 ->
case (catch erlang:process_info(Pid)) of
Info when is_list(Info) ->
?DBG("Info for process to kill: "
"~n Info: ~p", [Info]),
exit(Pid, Reason),
?SLEEP(1000),
nkill(Pid, Reason, N-1);
_ ->
?DBG("No process info => already dead?", []),
ok
end.
%%-----------------------------------------------------------------
%% Slogan: info test
%%-----------------------------------------------------------------
info_test(suite) -> [];
info_test(Config) when is_list(Config) ->
?P(info_test),
init_case(Config),
?line load_master("OLD-SNMPEA-MIB"),
?line init_old(),
try_test(info_test1, [node()]),
?line unload_master("OLD-SNMPEA-MIB").
info_test1(MaNode) ->
?line Info = rpc:call(MaNode, snmpa, info, []),
?DBG("info_test1 -> Info: ~n~p", [Info]),
Keys = [vsns,
stats_counters,
{agent, [process_memory, db_memory]},
{net_if, [process_memory, port_info, reqs]},
{note_store, [process_memory, db_memory]},
{symbolic_store, [process_memory, db_memory]},
{local_db, [process_memory, db_memory]},
{mib_server, [process_memory,
loaded_mibs,
subagents,
tree_size_bytes,
db_memory]}],
verify_info(Info, Keys),
OldInfo = snmpa:old_info_format(Info),
?DBG("info_test1 -> OldInfo: ~n~p", [OldInfo]),
verify_old_info(OldInfo),
ok.
verify_info([], []) ->
ok;
verify_info([], Keys) ->
?FAIL({remaining_info_keys, Keys});
verify_info(Info0, [Key|Keys]) ->
Info = verify_info1(Info0, Key),
verify_info(Info, Keys).
verify_info1(Info0, Key) when is_atom(Key) ->
case lists:keydelete(Key, 1, Info0) of
Info0 ->
?FAIL({missing_info, Key});
Info ->
Info
end;
verify_info1(Info0, {Key, SubKeys}) when is_atom(Key) andalso is_list(SubKeys) ->
case lists:keysearch(Key, 1, Info0) of
false ->
?FAIL({missing_info, Key});
{value, {Key, SubInfo}} ->
case verify_subinfo(SubInfo, SubKeys) of
ok ->
lists:keydelete(Key, 1, Info0);
{error, MissingSubKeyOrKeys} ->
?FAIL({missing_info, {Key, MissingSubKeyOrKeys}})
end
end.
verify_subinfo(_, []) ->
ok;
verify_subinfo([], Keys) ->
{error, Keys};
verify_subinfo(Info0, [Key|Keys]) ->
case lists:keydelete(Key, 1, Info0) of
Info0 ->
{error, Key};
Info ->
verify_subinfo(Info, Keys)
end.
verify_old_info(Info) ->
Keys = [vsns, subagents, loaded_mibs,
tree_size_bytes, process_memory, db_memory],
verify_old_info(Keys, Info).
verify_old_info([], _) ->
ok;
verify_old_info([Key|Keys], Info) ->
case lists:keymember(Key, 1, Info) of
true ->
verify_old_info(Keys, Info);
false ->
?FAIL({missing_old_info, Key})
end.
%% string used in index
is(S) -> [length(S) | S].
try_test(Func) ->
?P2("try test ~w...", [Func]),
snmp_agent_test_lib:try_test(?MODULE, Func).
try_test(Func, A) ->
?P2("try test ~w...", [Func]),
snmp_agent_test_lib:try_test(?MODULE, Func, A).
try_test(Func, A, Opts) ->
?P2("try test ~w...", [Func]),
snmp_agent_test_lib:try_test(?MODULE, Func, A, Opts).
%% Test manager wrapperfunctions:
g(Oids) -> snmp_test_mgr:g(Oids).
gn() -> snmp_test_mgr:gn().
gn(OidsOrN) -> snmp_test_mgr:gn(OidsOrN).
gb(NR, MR, Oids) -> snmp_test_mgr:gb(NR, MR, Oids).
s(VAV) -> snmp_test_mgr:s(VAV).
expect(A, B) -> snmp_agent_test_lib:expect(A, B).
expect(A, B, C) -> snmp_agent_test_lib:expect(A, B, C).
expect(A, B, C, D) -> snmp_agent_test_lib:expect(A, B, C, D).
expect(A, B, C, D, E, F) -> snmp_agent_test_lib:expect(A, B, C, D, E, F).
get_req(Id, Vars) ->
snmp_agent_test_lib:get_req(Id, Vars).
get_next_req(Vars) ->
snmp_agent_test_lib:get_next_req(Vars).
start_node(Name) ->
snmp_agent_test_lib:start_node(Name).
stop_node(Node) ->
snmp_agent_test_lib:stop_node(Node).
%%%-----------------------------------------------------------------
%%% Configuration
%%%-----------------------------------------------------------------
delete_files(Config) ->
snmp_agent_test_lib:delete_files(Config).
config(Vsns, MgrDir, AgentDir, MIp, AIp) ->
snmp_agent_test_lib:config(Vsns, MgrDir, AgentDir, MIp, AIp).
update_usm(Vsns, Dir) ->
snmp_agent_test_lib:update_usm(Vsns, Dir).
update_usm_mgr(Vsns, Dir) ->
snmp_agent_test_lib:update_usm_mgr(Vsns, Dir).
rewrite_usm_mgr(Dir, ShaKey, DesKey) ->
snmp_agent_test_lib:rewrite_usm_mgr(Dir, ShaKey, DesKey).
reset_usm_mgr(Dir) ->
snmp_agent_test_lib:reset_usm_mgr(Dir).
update_community(Vsns, DIr) ->
snmp_agent_test_lib:update_community(Vsns, DIr).
update_vacm(Vsn, Dir) ->
snmp_agent_test_lib:update_vacm(Vsn, Dir).
write_community_conf(Dir, Conf) ->
snmp_agent_test_lib:write_community_conf(Dir, Conf).
write_target_addr_conf(Dir, Conf) ->
snmp_agent_test_lib:write_target_addr_conf(Dir, Conf).
write_target_addr_conf(Dir, ManagerIp, UDP, Vsns) ->
snmp_agent_test_lib:write_target_addr_conf(Dir, ManagerIp, UDP, Vsns).
rewrite_target_addr_conf(Dir, NewPort) ->
snmp_agent_test_lib:rewrite_target_addr_conf(Dir, NewPort).
reset_target_addr_conf(Dir) ->
snmp_agent_test_lib:reset_target_addr_conf(Dir).
write_target_params_conf(Dir, Vsns) ->
snmp_agent_test_lib:write_target_params_conf(Dir, Vsns).
rewrite_target_params_conf(Dir, SecName, SecLevel) ->
snmp_agent_test_lib:rewrite_target_params_conf(Dir, SecName, SecLevel).
reset_target_params_conf(Dir) ->
snmp_agent_test_lib:reset_target_params_conf(Dir).
write_notify_conf(Dir) ->
snmp_agent_test_lib:write_notify_conf(Dir).
write_view_conf(Dir) ->
snmp_agent_test_lib:write_view_conf(Dir).
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
copy_file(From, To) ->
snmp_agent_test_lib:copy_file(From, To).
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
display_memory_usage() ->
Info = snmpa:info(snmp_master_agent),
AMU = display_agent_memory_uasge(Info),
NIMU = display_net_if_memory_usage(Info),
NSMU = display_note_store_memory_usage(Info),
SSMU = display_symbolic_store_memory_usage(Info),
LDBMU = display_local_db_memory_usage(Info),
MSMU = display_mib_server_memory_usage(Info),
?INF("Memory usage: ~n" ++
AMU ++ NIMU ++ NSMU ++ SSMU ++ LDBMU ++ MSMU, []),
ok.
display_agent_memory_uasge(Info) ->
AgentInfo = lists_key1search(agent, Info),
ProcMem =
lists_key1search([process_memory,master_agent], AgentInfo),
WProcMem =
lists_key1search([process_memory,worker], AgentInfo),
SWProcMem =
lists_key1search([process_memory,set_worker], AgentInfo),
TabSize =
lists_key1search([db_memory,agent], AgentInfo),
CCSize =
lists_key1search([db_memory,community_cache], AgentInfo),
VacmSize =
lists_key1search([db_memory,vacm], AgentInfo),
lists:flatten(
io_lib:format(" Agent memory usage: "
"~n Master process memory size: ~p"
"~n Worker process memory size: ~p"
"~n Set-worker process memory size: ~p"
"~n Agent tab size: ~p"
"~n Community cache size: ~p"
"~n Vacm tab size: ~p"
"~n",
[ProcMem, WProcMem, SWProcMem,
TabSize, CCSize, VacmSize])).
display_net_if_memory_usage(Info) ->
NiInfo = lists_key1search(net_if, Info),
ProcMem = lists_key1search(process_memory, NiInfo),
lists:flatten(
io_lib:format(" Net if memory usage: "
"~n Process memory size: ~p"
"~n",[ProcMem])).
display_note_store_memory_usage(Info) ->
NsInfo = lists_key1search(note_store, Info),
ProcMem = lists_key1search([process_memory,notes], NsInfo),
ProcTmrMem = lists_key1search([process_memory,timer], NsInfo),
TabSize = lists_key1search([db_memory,notes], NsInfo),
lists:flatten(
io_lib:format(" Note store memory usage: "
"~n Notes process memory size: ~p"
"~n Timer process memory size: ~p"
"~n Notes tab size: ~p"
"~n",
[ProcMem, ProcTmrMem, TabSize])).
display_symbolic_store_memory_usage(Info) ->
SsInfo = lists_key1search(symbolic_store, Info),
ProcMem = lists_key1search(process_memory, SsInfo),
DbMem = lists_key1search(db_memory, SsInfo),
lists:flatten(
io_lib:format(" Symbolic store memory usage: "
"~n Process memory size: ~p"
"~n DB size: ~p"
"~n",
[ProcMem, DbMem])).
display_local_db_memory_usage(Info) ->
LdInfo = lists_key1search(local_db, Info),
ProcMem = lists_key1search(process_memory, LdInfo),
EtsSize = lists_key1search([db_memory,ets], LdInfo),
DetsSize = lists_key1search([db_memory,dets], LdInfo),
lists:flatten(
io_lib:format(" Local DB memory usage: "
"~n Process memory size: ~p"
"~n DB [ets] size: ~p"
"~n DB [dets] size: ~p"
"~n",
[ProcMem, EtsSize, DetsSize])).
display_mib_server_memory_usage(Info) ->
MibInfo = lists_key1search(mib_server, Info),
ProcMem = lists_key1search(process_memory, MibInfo),
TreeSize = lists_key1search(tree_size_bytes, MibInfo),
MibDbSize = lists_key1search([db_memory,mib], MibInfo),
NodeDbSize = lists_key1search([db_memory,node], MibInfo),
TreeDbSize = lists_key1search([db_memory,tree], MibInfo),
lists:flatten(
io_lib:format(" MIB server memory usage: "
"~n Process memory size: ~p"
"~n Tree size: ~p"
"~n Mib db size: ~p"
"~n Node db size: ~p"
"~n Tree db size: ~p"
"~n",
[ProcMem, TreeSize, MibDbSize, NodeDbSize, TreeDbSize])).
lists_key1search([], Res) ->
Res;
lists_key1search([Key|Keys], List) when is_atom(Key) andalso is_list(List) ->
case lists:keysearch(Key, 1, List) of
{value, {Key, Val}} ->
lists_key1search(Keys, Val);
false ->
undefined
end;
lists_key1search(Key, List) when is_atom(Key) ->
case lists:keysearch(Key, 1, List) of
{value, {Key, Val}} ->
Val;
false ->
undefined
end.
regs() ->
lists:sort(registered()).
