%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2005-2009. All Rights Reserved.
%%
%% The contents of this file are subject to the Erlang Public License,
%% Version 1.1, (the "License"); you may not use this file except in
%% compliance with the License. You should have received a copy of the
%% Erlang Public License along with this software. If not, it can be
%% retrieved online at http://www.erlang.org/.
%%
%% Software distributed under the License is distributed on an "AS IS"
%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
%% the License for the specific language governing rights and limitations
%% under the License.
%%
%% %CopyrightEnd%
%%
-module(snmp_agent_ms_test).
%% TODO
%% * Test fault-tolerance (kill master etc)
%%
-compile(export_all).
-define(application, snmp).
-include_lib("kernel/include/file.hrl").
-include("test_server.hrl").
-include("snmp_test_lib.hrl").
-define(SNMP_USE_V3, true).
-include_lib("snmp/include/snmp_types.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).
-import(snmp_test_mgr, [gn/1, g/1, s/1, gb/3]).
-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(suite) -> {req,
[mnesia, distribution,
{local_slave_nodes, 2}, {time, 360}],
[{conf, init_all, cases(), finish_all}]}.
init_per_testcase(_Case, Config) when list(Config) ->
Dog = ?t:timetrap(?t:minutes(6)),
[{watchdog, Dog}|Config].
fin_per_testcase(_Case, Config) when list(Config) ->
Dog = ?config(watchdog, Config),
?t:timetrap_cancel(Dog),
Config.
cases() ->
case ?OSTYPE() of
vxworks ->
%% No crypto app, so skip v3 testcases
[
app_info,
test_v1, test_v2, test_v1_v2,
test_multi_threaded,
mib_storage,
tickets];
_Else ->
[
app_info,
test_v1, test_v2, test_v1_v2, test_v3,
test_multi_threaded,
mib_storage,
tickets
]
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(Config0) when list(Config0) ->
?LOG("init_all -> entry with"
"~n Config0: ~p",[Config0]),
%% --
%% Fix config:
%%
DataDir0 = ?config(data_dir, Config0),
DataDir1 = filename:split(filename:absname(DataDir0)),
[_|DataDir2] = lists:reverse(DataDir1),
DataDir3 = filename:join(lists:reverse(DataDir2) ++ [?snmp_test_data]),
Config1 = lists:keydelete(data_dir, 1, Config0),
Config = [{data_dir, DataDir3 ++ "/"}|Config1],
%% --
%% Start nodes
%%
?line {ok, SaNode} = start_node(snmp_sa),
?line {ok, MgrNode} = start_node(snmp_mgr),
%% --
%% Create necessary files
%%
Dir = ?config(priv_dir, Config),
?DBG("init_all -> Dir ~p", [Dir]),
DataDir = ?config(data_dir, Config),
?DBG("init_all -> DataDir ~p", [DataDir]),
file:make_dir(MgrDir = filename:join(Dir, "mgr_dir/")),
?DBG("init_all -> MgrDir ~p", [MgrDir]),
file:make_dir(AgentDir = filename:join(Dir, "agent_dir/")),
?DBG("init_all -> AgentDir ~p", [AgentDir]),
file:make_dir(SaDir = filename:join(Dir, "sa_dir/")),
?DBG("init_all -> SaDir ~p", [SaDir]),
%% --
%% Start and initiate mnesia
%%
?DBG("init_all -> load application mnesia", []),
?line ok = application:load(mnesia),
?DBG("init_all -> load application mnesia on node ~p", [SaNode]),
?line ok = rpc:call(SaNode, application, load, [mnesia]),
?DBG("init_all -> application mnesia: set_env dir",[]),
?line application_controller:set_env(mnesia, dir,
filename:join(Dir, "Mnesia1")),
?DBG("init_all -> application mnesia: set_env dir on node ~p",[SaNode]),
?line rpc:call(SaNode, application_controller, set_env,
[mnesia, dir, filename:join(Dir, "Mnesia2")]),
?DBG("init_all -> create mnesia schema",[]),
?line ok = mnesia:create_schema([SaNode, node()]),
?DBG("init_all -> start application mnesia",[]),
?line ok = application:start(mnesia),
?DBG("init_all -> start application mnesia on ~p",[SaNode]),
?line ok = rpc:call(SaNode, application, start, [mnesia]),
Ip = ?LOCALHOST(),
[{snmp_sa, SaNode},
{snmp_mgr, MgrNode},
{agent_dir, AgentDir ++ "/"},
{mgr_dir, MgrDir ++ "/"},
{sa_dir, SaDir ++ "/"},
{mib_dir, DataDir},
{ip, Ip} |
Config].
finish_all(Config) when list(Config) ->
SaNode = ?config(snmp_sa, Config),
MgrNode = ?config(snmp_mgr, Config),
stop_node(SaNode),
stop_node(MgrNode),
application:stop(mnesia).
start_v1_agent(Config) when list(Config) ->
start_agent(Config, [v1]).
start_v1_agent(Config,Opts) when list(Config), list(Opts) ->
start_agent(Config, [v1], Opts).
start_v2_agent(Config) when list(Config) ->
start_agent(Config, [v2]).
start_v3_agent(Config) when list(Config) ->
start_agent(Config, [v3]).
start_bilingual_agent(Config) when list(Config) ->
start_agent(Config, [v1,v2]).
start_multi_threaded_agent(Config) when list(Config) ->
start_agent(Config, [v2], [{snmp_multi_threaded, true}]).
stop_agent(Config) when list(Config) ->
?LOG("stop_agent -> entry with"
"~n Config: ~p",[Config]),
{Sup, Par} = ?config(snmp_sup, Config),
?DBG("stop_agent -> attempt to stop (sup) ~p"
"~n Sup: ~p"
"~n Par: ~p",
[Sup,
(catch process_info(Sup)),
(catch process_info(Par))]),
stop_sup(Sup, Par),
{Sup2, Par2} = ?config(snmp_sub, Config),
?DBG("stop_agent -> attempt to stop (sub) ~p"
"~n Sup2: ~p"
"~n Par2: ~p",
[Sup2,
(catch process_info(Sup2)),
(catch process_info(Par2))]),
stop_sup(Sup2, Par2),
?DBG("stop_agent -> done - now cleanup config", []),
C1 = lists:keydelete(snmp_sup, 1, Config),
lists:keydelete(snmp_sub, 1, C1).
stop_sup(Pid, _) when node(Pid) == node() ->
case (catch process_info(Pid)) of
PI when list(PI) ->
?LOG("stop_sup -> attempt to stop ~p", [Pid]),
Ref = erlang:monitor(process, Pid),
exit(Pid, kill),
await_stopped(Pid, Ref);
{'EXIT', _Reason} ->
?LOG("stop_sup -> ~p not running", [Pid]),
ok
end;
stop_sup(Pid, _) ->
?LOG("stop_sup -> attempt to stop ~p", [Pid]),
Ref = erlang:monitor(process, Pid),
?LOG("stop_sup -> Ref: ~p", [Ref]),
%% Pid ! {'EXIT', Parent, shutdown}, % usch
exit(Pid, kill),
await_stopped(Pid, Ref).
await_stopped(Pid, Ref) ->
receive
{'DOWN', Ref, process, Pid, _Reason} ->
?DBG("received down message for ~p", [Pid]),
ok
after 10000 ->
?INF("await_stopped -> timeout for ~p",[Pid]),
erlang:demonitor(Ref),
?FAIL({failed_stop,Pid})
end.
start_agent(Config, Vsn) ->
start_agent(Config, Vsn, []).
start_agent(Config, Vsn, Opts) ->
?LOG("start_agent -> entry (~p) with"
"~n Config: ~p"
"~n Vsn: ~p"
"~n Opts: ~p",[node(), Config, Vsn, Opts]),
?line AgentDir = ?config(agent_dir, Config),
?line SaNode = ?config(snmp_sa, Config),
snmp_app_env_init(vsn_init(Vsn) ++
[{audit_trail_log, read_write_log},
{audit_trail_log_dir, AgentDir},
{audit_trail_log_size, {10240, 10}},
{force_config_reload, false},
{snmp_agent_type, master},
{snmp_config_dir, AgentDir},
{snmp_db_dir, AgentDir},
{snmp_local_db_auto_repair, true},
{snmp_master_agent_verbosity, trace},
{snmp_supervisor_verbosity, trace},
{snmp_mibserver_verbosity, trace},
{snmp_symbolic_store_verbosity, trace},
{snmp_note_store_verbosity, trace},
{snmp_net_if_verbosity, trace}],
Opts),
process_flag(trap_exit,true),
{ok, AppSup} = snmp_app_sup:start_link(),
unlink(AppSup),
?DBG("start_agent -> snmp app supervisor: ~p",[AppSup]),
?DBG("start_agent -> start master agent (old style)",[]),
Sup = case (catch snmpa_app:start(normal)) of
{ok, S} ->
?DBG("start_agent -> started, Sup: ~p",[S]),
S;
Else ->
?DBG("start_agent -> unknown result: ~n~p",[Else]),
%% Get info about the apps we depend on
MnesiaInfo = mnesia_running(),
?FAIL({start_failed,Else,MnesiaInfo})
end,
?DBG("start_agent -> unlink from supervisor",[]),
?line unlink(Sup),
?line SaDir = ?config(sa_dir, Config),
?DBG("start_agent -> (rpc) start sub on ~p",[SaNode]),
?line {ok, Sub} = rpc:call(SaNode, ?MODULE, start_sub, [SaDir]),
?DBG("start_agent -> done",[]),
?line [{snmp_sup, {Sup, self()}}, {snmp_sub, Sub} | Config].
vsn_init(Vsn) ->
vsn_init([v1,v2,v3], Vsn, []).
vsn_init([], _Vsn, Acc) ->
Acc;
vsn_init([V|Vsns], Vsn, Acc) ->
case lists:member(V, Vsn) of
true ->
vsn_init(Vsns, Vsn, [{V, true}|Acc]);
false ->
vsn_init(Vsns, Vsn, [{V, false}|Acc])
end.
snmp_app_env_init(Env0, Opts) ->
?DBG("snmp_app_env_init -> unload snmp",[]),
?line application:unload(snmp),
?DBG("snmp_app_env_init -> load snmp",[]),
?line application:load(snmp),
?DBG("snmp_app_env_init -> initiate (snmp) application env",[]),
F1 = fun({Key,Val} = New, Acc0) ->
?DBG("snmp_app_env_init -> "
"updating setting ~p to ~p", [Key, Val]),
case lists:keyreplace(Key, 1, Acc0, New) of
Acc0 ->
[New|Acc0];
Acc ->
Acc
end
end,
Env = lists:foldr(F1, Env0, Opts),
?DBG("snmp_app_env_init -> Env: ~p",[Env]),
F2 = fun({Key,Val}) ->
?DBG("snmp_app_env_init -> setting ~p to ~p",[Key, Val]),
application_controller:set_env(snmp, Key, Val)
end,
lists:foreach(F2, Env).
%% Test if application is running
mnesia_running() -> ?IS_MNESIA_RUNNING().
crypto_running() -> ?IS_CRYPTO_RUNNING().
start_sub(Dir) ->
?DBG("start_sub -> entry",[]),
Opts = [{db_dir, Dir},
{supervisor, [{verbosity, trace}]}],
%% BMK BMK
% {ok, P} = snmp_supervisor:start_sub(Dir),
{ok, P} = snmpa_supervisor:start_sub_sup(Opts),
unlink(P),
{ok, {P, self()}}.
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(suite) -> [
mib_storage_ets,
mib_storage_dets,
mib_storage_mnesia,
mib_storage_size_check_ets,
mib_storage_size_check_dets,
mib_storage_size_check_mnesia,
mib_storage_varm_dets,
mib_storage_varm_mnesia
].
mib_storage_ets(suite) -> {req, [], {conf, init_mib_storage_ets,
mib_storage_ets_cases(),
finish_mib_storage_ets}}.
mib_storage_dets(suite) -> {req, [], {conf, init_mib_storage_dets,
mib_storage_dets_cases(),
finish_mib_storage_dets}}.
mib_storage_mnesia(suite) -> {req, [], {conf, init_mib_storage_mnesia,
mib_storage_mnesia_cases(),
finish_mib_storage_mnesia}}.
mib_storage_size_check_ets(suite) ->
{req, [], {conf,
init_size_check_mse,
mse_size_check_cases(),
finish_size_check_mse}}.
mib_storage_size_check_dets(suite) ->
{req, [], {conf,
init_size_check_msd,
msd_size_check_cases(),
finish_size_check_msd}}.
mib_storage_size_check_mnesia(suite) ->
{req, [], {conf,
init_size_check_msm,
msm_size_check_cases(),
finish_size_check_msm}}.
mib_storage_varm_dets(suite) ->
{req, [], {conf,
init_varm_mib_storage_dets,
varm_mib_storage_dets_cases(),
finish_varm_mib_storage_dets}}.
mib_storage_varm_mnesia(suite) ->
{req, [], {conf,
init_varm_mib_storage_mnesia,
varm_mib_storage_mnesia_cases(),
finish_varm_mib_storage_mnesia}}.
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 list(Config) ->
?LOG("init_mib_storage_ets -> entry", []),
MibStorage = {snmp_mib_storage,ets},
init_ms(Config, [MibStorage]).
init_mib_storage_dets(Config) when 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 list(Config) ->
?LOG("init_mib_storage_ets -> entry", []),
MibStorage = {snmp_mib_storage,{mnesia,[]}},
init_ms(Config, [MibStorage]).
init_ms(Config, Opts) when 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 list(Config) ->
MibStorage = {snmp_mib_storage, ets},
init_size_check_ms(Config, [MibStorage]).
init_size_check_msd(Config) when 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 list(Config) ->
MibStorage = {snmp_mib_storage, {mnesia,[]}},
init_size_check_ms(Config, [MibStorage]).
init_size_check_ms(Config, Opts) when 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_agent(Config, [v3], Opts)].
init_varm_mib_storage_dets(Config) when 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 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 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 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 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 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 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 list(Config) ->
finish_size_check_ms(Config).
finish_size_check_msd(Config) when list(Config) ->
finish_size_check_ms(Config).
finish_size_check_msm(Config) when list(Config) ->
finish_size_check_ms(Config).
finish_size_check_ms(Config) when 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) -> simple(X).
mse_v1_processing(X) -> v1_processing(X).
mse_big(X) -> big(X).
mse_big2(X) -> big2(X).
mse_loop_mib(X) -> loop_mib(X).
mse_api(X) -> api(X).
mse_sa_register(X) -> sa_register(X).
mse_v1_trap(X) -> v1_trap(X).
mse_sa_error(X) -> sa_error(X).
mse_next_across_sa(X) -> next_across_sa(X).
mse_undo(X) -> undo(X).
mse_standard_mib(X) -> snmp_standard_mib(X).
mse_community_mib(X) -> snmp_community_mib(X).
mse_framework_mib(X) -> snmp_framework_mib(X).
mse_target_mib(X) -> snmp_target_mib(X).
mse_notification_mib(X) -> snmp_notification_mib(X).
mse_view_based_acm_mib(X) -> snmp_view_based_acm_mib(X).
mse_sparse_table(X) -> sparse_table(X).
mse_me_of(X) -> ms_me_of(X).
mse_mib_of(X) -> ms_mib_of(X).
msd_simple(X) -> simple(X).
msd_v1_processing(X) -> v1_processing(X).
msd_big(X) -> big(X).
msd_big2(X) -> big2(X).
msd_loop_mib(X) -> loop_mib(X).
msd_api(X) -> api(X).
msd_sa_register(X) -> sa_register(X).
msd_v1_trap(X) -> v1_trap(X).
msd_sa_error(X) -> sa_error(X).
msd_next_across_sa(X) -> next_across_sa(X).
msd_undo(X) -> undo(X).
msd_standard_mib(X) -> snmp_standard_mib(X).
msd_community_mib(X) -> snmp_community_mib(X).
msd_framework_mib(X) -> snmp_framework_mib(X).
msd_target_mib(X) -> snmp_target_mib(X).
msd_notification_mib(X) -> snmp_notification_mib(X).
msd_view_based_acm_mib(X) -> snmp_view_based_acm_mib(X).
msd_sparse_table(X) -> sparse_table(X).
msd_me_of(X) -> ms_me_of(X).
msd_mib_of(X) -> ms_mib_of(X).
msm_simple(X) -> simple(X).
msm_v1_processing(X) -> v1_processing(X).
msm_big(X) -> big(X).
msm_big2(X) -> big2(X).
msm_loop_mib(X) -> loop_mib(X).
msm_api(X) -> api(X).
msm_sa_register(X) -> sa_register(X).
msm_v1_trap(X) -> v1_trap(X).
msm_sa_error(X) -> sa_error(X).
msm_next_across_sa(X) -> next_across_sa(X).
msm_undo(X) -> undo(X).
msm_standard_mib(X) -> snmp_standard_mib(X).
msm_community_mib(X) -> snmp_community_mib(X).
msm_framework_mib(X) -> snmp_framework_mib(X).
msm_target_mib(X) -> snmp_target_mib(X).
msm_notification_mib(X) -> snmp_notification_mib(X).
msm_view_based_acm_mib(X) -> snmp_view_based_acm_mib(X).
msm_sparse_table(X) -> sparse_table(X).
msm_me_of(X) -> ms_me_of(X).
msm_mib_of(X) -> 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) -> p("msm_varm_mib_start..."), varm_mib_start(X).
ms_size_check(suite) -> [];
ms_size_check(Config) when list(Config) ->
p("ms_size_check..."),
{_SaNode, _MgrNode, _MibDir} = 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 list(Config) ->
p("varm_mib_start..."),
?LOG("varm_mib_start -> entry", []),
{_SaNode, _MgrNode, _MibDir} = 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 list(Config) ->
p("ms_me_of..."),
{_SaNode, _MgrNode, _MibDir} = 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 list(Config) ->
p("ms_mib_of..."),
{_SaNode, _MgrNode, _MibDir} = 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.
app_info(suite) -> [];
app_info(Config) when list(Config) ->
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 list(D) ->
filename:basename(D);
{error, _Reason} ->
"undefined"
end.
test_v1(suite) -> {req, [], {conf, init_v1, v1_cases(), finish_v1}}.
%v1_cases() -> [loop_mib];
v1_cases() ->
[simple,
db_notify_client,
v1_processing, big, big2, loop_mib,
api, subagent, mnesia, multiple_reqs,
sa_register, v1_trap, sa_error, next_across_sa, undo, reported_bugs,
standard_mibs, sparse_table, cnt_64,
opaque,
% opaque].
change_target_addr_config].
init_v1(Config) when 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 list(Config) ->
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
lists:keydelete(vsn, 1, C1).
test_v2(suite) -> {req, [], {conf, init_v2, v2_cases(), finish_v2}}.
%v2_cases() -> [loop_mib_2];
v2_cases() ->
[simple_2, v2_processing, big_2, big2_2, loop_mib_2,
api_2, subagent_2, mnesia_2,
multiple_reqs_2, sa_register_2, v2_trap, v2_inform, sa_error_2,
next_across_sa_2, undo_2, reported_bugs_2, standard_mibs_2,
v2_types, implied, sparse_table_2, cnt_64_2, opaque_2, v2_caps].
init_v2(Config) when 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 list(Config) ->
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
lists:keydelete(vsn, 1, C1).
test_v1_v2(suite) -> {req, [], {conf, init_v1_v2, v1_v2_cases(), finish_v1_v2}}.
v1_v2_cases() ->
[simple_bi].
init_v1_v2(Config) when 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 list(Config) ->
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
lists:keydelete(vsn, 1, C1).
test_v3(suite) -> {req, [], {conf, init_v3, v3_cases(), finish_v3}}.
%v3_cases() -> [loop_mib_3];
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, reported_bugs_3, standard_mibs_3,
v3_security,
v2_types_3, implied_3, sparse_table_3, cnt_64_3, opaque_3, v2_caps_3].
init_v3(Config) when 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 list(Config) ->
delete_tables(),
C1 = stop_agent(Config),
delete_files(C1),
lists:keydelete(vsn, 1, C1).
test_multi_threaded(suite) -> {req, [], {conf, init_mt, mt_cases(), finish_mt}}.
mt_cases() ->
[multi_threaded, mt_trap].
init_mt(Config) when 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 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) when list(Config) ->
?DBG("init_case -> entry with"
"~n Config: ~p", [Config]),
SaNode = ?config(snmp_sa, Config),
MgrNode = ?config(snmp_mgr, Config),
MasterNode = node(),
SaHost = ?HOSTNAME(SaNode),
MgrHost = ?HOSTNAME(MgrNode),
MasterHost = ?HOSTNAME(MasterNode),
{ok, MasterIP} = snmp_misc:ip(MasterHost),
{ok, MIP} = snmp_misc:ip(MgrHost),
{ok, SIP} = snmp_misc:ip(SaHost),
put(mgr_node, MgrNode),
put(sa_node, SaNode),
put(master_node, MasterNode),
put(sa_host, SaHost),
put(mgr_host, MgrHost),
put(master_host, MasterHost),
put(mip, tuple_to_list(MIP)),
put(masterip , tuple_to_list(MasterIP)),
put(sip, tuple_to_list(SIP)),
MibDir = ?config(mib_dir, Config),
put(mib_dir, MibDir),
StdM = filename:join(code:priv_dir(snmp), "mibs") ++ "/",
put(std_mib_dir, StdM),
MgrDir = ?config(mgr_dir, Config),
put(mgr_dir, MgrDir),
put(vsn, ?config(vsn, Config)),
?DBG("init_case -> exit with"
"~n MasterNode: ~p"
"~n SaNode: ~p"
"~n MgrNode: ~p"
"~n MibDir: ~p", [MasterNode, SaNode, MgrNode, MibDir]),
{SaNode, MgrNode, MibDir}.
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, {loaded_mibs, Mibs}} = lists:keysearch(loaded_mibs, 1, Info),
[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) ->
?DBG("start_subagent -> entry with"
"~n SaNode: ~p"
"~n RegTree: ~p"
"~n Mib: ~p", [SaNode, RegTree, Mib]),
MA = whereis(snmp_master_agent),
?DBG("start_subagent -> MA: ~p", [MA]),
MibDir = get(mib_dir),
Mib1 = join(MibDir,Mib),
%% BMK BMK
% case rpc:call(SaNode,snmp_supervisor,start_subagent,[MA,RegTree,[Mib1]]) of
case rpc:call(SaNode, snmpa_supervisor,
start_sub_agent, [MA, RegTree, [Mib1]]) of
{ok, SA} ->
?DBG("start_subagent -> SA: ~p", [SA]),
{ok, SA};
Error ->
?FAIL({subagent_start_failed, SaNode, Error, [MA, RegTree, Mib1]})
end.
stop_subagent(SA) ->
?DBG("stop_subagent -> entry with"
"~n SA: ~p", [SA]),
%% BNK BMK
%% rpc:call(node(SA), snmp_supervisor, stop_subagent, [SA]).
rpc:call(node(SA), snmpa_supervisor, stop_sub_agent, [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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
try_test(simple_standard_test).
simple_2(X) -> simple(X).
simple_bi(suite) -> [];
simple_bi(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) ->
simple(X).
big(suite) -> [];
big(Config) when list(Config) ->
?DBG("big -> entry", []),
{SaNode, _MgrNode, _MibDir} = init_case(Config),
p("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(),
try_test(big_test),
?line stop_subagent(SA),
?line unload_master("OLD-SNMPEA-MIB").
big_2(X) -> big(X).
big_3(X) -> big(X).
big2(suite) -> [];
big2(Config) when list(Config) ->
%% This is exactly the same tests as 'big', but with the
%% v2 equivalent of the mibs.
{SaNode, _MgrNode, _MibDir} = init_case(Config),
p("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) -> big2(X).
big2_3(X) -> big2(X).
multi_threaded(suite) -> [];
multi_threaded(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Test1"),
try_test(multi_threaded_test),
?line unload_master("Test1").
mt_trap(suite) -> [];
mt_trap(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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").
v2_types(suite) -> [];
v2_types(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Test1"),
try_test(types_v2_test),
?line unload_master("Test1").
v2_types_3(X) -> v2_types(X).
implied(suite) -> [];
implied(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
MA = whereis(snmp_master_agent),
?line load_master("Test1"),
try_test(implied_test,[MA]),
?line unload_master("Test1").
implied_3(X) -> implied(X).
sparse_table(suite) -> [];
sparse_table(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Test1"),
try_test(sparse_table_test),
?line unload_master("Test1").
sparse_table_2(X) -> sparse_table(X).
sparse_table_3(X) -> sparse_table(X).
cnt_64(suite) -> [];
cnt_64(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> cnt_64(X).
cnt_64_3(X) -> cnt_64(X).
opaque(suite) -> [];
opaque(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Test1"),
try_test(opaque_test),
?line unload_master("Test1").
opaque_2(X) -> opaque(X).
opaque_3(X) -> opaque(X).
change_target_addr_config(suite) -> [];
change_target_addr_config(Config) when list(Config) ->
p("Testing changing target address config..."),
?LOG("change_target_addr_config -> entry",[]),
{_SaNode, _MgrNode, _MibDir} = 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 binary(B) ->
size(B);
dummy_manager_message_sz(L) when 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> api(X).
api_3(X) -> api(X).
subagent(suite) -> [];
subagent(Config) when list(Config) ->
{SaNode, _MgrNode, MibDir} = init_case(Config),
?line {ok, SA} = start_subagent(SaNode, ?klas1, "Klas1"),
try_test(load_test_sa),
p("Testing unregister subagent..."),
MA = whereis(snmp_master_agent),
rpc:call(SaNode, snmp, unregister_subagent, [MA, SA]),
try_test(unreg_test),
p("Loading previous subagent mib in master and testing..."),
?line ok = snmpa:load_mibs(MA, [MibDir ++ "Klas1"]),
try_test(load_test),
p("Unloading previous subagent mib in master and testing..."),
?line ok = snmpa:unload_mibs(MA, [MibDir ++ "Klas1"]),
try_test(unreg_test),
p("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) -> subagent(X).
subagent_3(X) -> subagent(X).
mnesia(suite) -> [];
mnesia(Config) when list(Config) ->
{SaNode, _MgrNode, _MibDir} = init_case(Config),
p("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),
p("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) -> mnesia(X).
mnesia_3(X) -> mnesia(X).
multiple_reqs(suite) ->
{req, [], {conf, init_mul, mul_cases(), finish_mul}}.
mul_cases() ->
[mul_get, mul_get_err, mul_next, mul_next_err, mul_set_err].
multiple_reqs_2(suite) ->
{req, [], {conf, init_mul, mul_cases_2(), finish_mul}}.
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 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
p("Testing multiple get..."),
try_test(do_mul_get).
mul_get_2(X) -> mul_get(X).
mul_get_3(X) -> mul_get(X).
mul_get_err(suite) -> [];
mul_get_err(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
p("Testing multiple get with error..."),
try_test(do_mul_get_err).
mul_get_err_2(X) -> mul_get_err(X).
mul_get_err_3(X) -> mul_get_err(X).
mul_next(suite) -> [];
mul_next(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
p("Testing multiple next..."),
try_test(do_mul_next).
mul_next_2(X) -> mul_next(X).
mul_next_3(X) -> mul_next(X).
mul_next_err(suite) -> [];
mul_next_err(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
p("Testing multiple next..."),
try_test(do_mul_next_err).
mul_next_err_2(X) -> mul_next_err(X).
mul_next_err_3(X) -> mul_next_err(X).
mul_set(suite) -> [];
mul_set(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
p("Testing multiple set..."),
try_test(do_mul_set).
mul_set_2(X) -> mul_set(X).
mul_set_3(X) -> mul_set(X).
mul_set_err(suite) -> [];
mul_set_err(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
p("Testing multiple set with error..."),
try_test(do_mul_set_err).
mul_set_err_2(X) -> mul_set_err(X).
mul_set_err_3(X) -> mul_set_err(X).
sa_register(suite) -> [];
sa_register(Config) when list(Config) ->
?DBG("sa_register -> entry", []),
{SaNode, _MgrNode, MibDir} = init_case(Config),
?DBG("sa_register -> start subagent", []),
?line {ok, SA} = start_subagent(SaNode, ?klas1, "Klas1"),
?DBG("sa_register -> unregister subagent", []),
p("Testing unregister subagent (2)..."),
MA = whereis(snmp_master_agent),
rpc:call(SaNode, snmp, unregister_subagent, [MA, ?klas1]),
try_test(unreg_test),
p("Loading SA-MIB..."),
?DBG("sa_register -> unload mibs", []),
snmpa:unload_mibs(SA, [MibDir ++ "Klas1"]),
?DBG("sa_register -> unload mibs", []),
snmpa:load_mibs(SA, [MibDir ++ "SA-MIB"]),
?DBG("sa_register -> register subagent", []),
rpc:call(SaNode, snmp, register_subagent, [MA,?sa,SA]),
try_test(sa_mib),
?DBG("sa_register -> stop subagent", []),
?line stop_subagent(SA).
sa_register_2(X) -> sa_register(X).
sa_register_3(X) -> sa_register(X).
v1_trap(suite) -> [];
v1_trap(Config) when list(Config) ->
{SaNode, _MgrNode, _MibDir} = init_case(Config),
?line {ok, SA} = start_subagent(SaNode, ?sa, "SA-MIB"),
p("Testing trap sending from master agent..."),
MA = whereis(snmp_master_agent),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
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]),
p("Testing trap sending from subagent..."),
try_test(sa_trap1, [SA]),
try_test(sa_trap2, [SA]),
try_test(sa_trap3, [SA]),
?line unload_master("TestTrap"),
?line unload_master("TestTrapv2"),
?line stop_subagent(SA).
v2_trap(suite) -> [];
v2_trap(Config) when list(Config) ->
{SaNode, _MgrNode, _MibDir} = init_case(Config),
?line {ok, SA} = start_subagent(SaNode, ?sa, "SA-MIB"),
p("Testing trap sending from master agent..."),
MA = whereis(snmp_master_agent),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
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),
p("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]),
?line unload_master("TestTrap"),
?line unload_master("TestTrapv2"),
?line stop_subagent(SA).
v3_trap(X) ->
v2_trap(X).
v2_inform(suite) ->
{req, [], {conf, init_v2_inform, [v2_inform_i], finish_v2_inform}}.
v3_inform(_X) ->
%% v2_inform(X).
{req, [], {conf, init_v3_inform, [v3_inform_i], finish_v3_inform}}.
init_v2_inform(Config) when 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 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
p("Testing inform sending from master agent... NOTE! This test\ntakes a "
"few minutes (5) to complete."),
MA = whereis(snmp_master_agent),
?line load_master("TestTrap"),
?line load_master("TestTrapv2"),
try_test(ma_v2_inform1, [MA]),
?line unload_master("TestTrap"),
?line unload_master("TestTrapv2").
v3_inform_i(X) -> v2_inform_i(X).
sa_error(suite) -> [];
sa_error(Config) when list(Config) ->
{SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("OLD-SNMPEA-MIB"),
?line init_old(),
?line {ok, SA} = start_subagent(SaNode, ?sa, "SA-MIB"),
p("Testing sa bad value (is_set_ok)..."),
try_test(sa_errs_bad_value),
p("Testing sa gen err (set)..."),
try_test(sa_errs_gen_err),
p("Testing too big..."),
try_test(sa_too_big),
?line unload_master("OLD-SNMPEA-MIB"),
stop_subagent(SA).
sa_error_2(X) -> sa_error(X).
sa_error_3(X) -> sa_error(X).
next_across_sa(suite) -> [];
next_across_sa(Config) when list(Config) ->
{SaNode, _MgrNode, MibDir} = init_case(Config),
MA = whereis(snmp_master_agent),
?line {ok, SA} = start_subagent(SaNode, ?sa, "SA-MIB"),
p("Loading another subagent mib..."),
?line ok = snmpa:load_mibs(SA, [MibDir ++ "Klas1"]),
rpc:call(SaNode, snmp, register_subagent, [MA, ?klas1, SA]),
try_test(load_test_sa),
p("Testing next across subagent (endOfMibView from SA)..."),
try_test(next_across_sa),
p("Unloading mib"),
snmpa:unload_mibs(SA, [MibDir ++ "Klas1"]),
rpc:call(SaNode, snmp, unregister_subagent, [MA, ?klas1]),
try_test(unreg_test),
p("Starting another subagent"),
?line {ok, SA2} = start_subagent(SaNode, ?klas1, "Klas1"),
p("Testing next across subagent (wrong prefix from SA)..."),
try_test(next_across_sa),
stop_subagent(SA),
stop_subagent(SA2).
next_across_sa_2(X) -> next_across_sa(X).
next_across_sa_3(X) -> next_across_sa(X).
undo(suite) -> [];
undo(Config) when list(Config) ->
{SaNode, _MgrNode, MibDir} = init_case(Config),
MA = whereis(snmp_master_agent),
?line {ok, SA} = start_subagent(SaNode, ?sa, "SA-MIB"),
p("Testing undo phase at master agent..."),
?line ok = snmpa:load_mibs(MA, [MibDir ++ "Klas3"]),
?line ok = snmpa:load_mibs(MA, [MibDir ++ "Klas4"]),
try_test(undo_test),
try_test(api_test2),
?line ok = snmpa:unload_mibs(MA, [MibDir ++ "Klas3"]),
p("Testing bad return values from instrum. funcs..."),
try_test(bad_return),
?line ok = snmpa:unload_mibs(MA, [MibDir ++ "Klas4"]),
p("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),
p("Testing undo phase across master/subagents..."),
try_test(undo_test),
try_test(api_test3),
stop_subagent(SA).
undo_2(X) -> undo(X).
undo_3(X) -> undo(X).
%% Req. Test2
v1_processing(suite) -> [];
v1_processing(Config) when list(Config) ->
?DBG("v1_processing -> entry", []),
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Test2"),
try_test(v1_proc),
?line unload_master("Test2").
%% Req. Test2
v2_processing(suite) -> [];
v2_processing(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Test2"),
try_test(v2_proc),
?line unload_master("Test2").
%% Req. Test2
v3_processing(suite) -> [];
v3_processing(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Test2"),
try_test(v2_proc), % same as v2!
?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_security(suite) -> [v3_crypto_basic, v3_md5_auth, v3_sha_auth, v3_des_priv].
v3_crypto_basic(suite) -> [];
v3_crypto_basic(_Config) ->
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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
p("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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
p("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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
p("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),
?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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
try_test(v2_caps_i, [node()]).
v2_caps_3(X) -> 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 list(Config) ->
{SaNode, MgrNode, MibDir} = init_case(Config),
?DBG("~n\tSaNode: ~p~n\tMgrNode: ~p~n\tMibDir: ~p",
[SaNode,MgrNode,MibDir]),
snmpa_local_db:register_notify_client(self(),?MODULE),
%% This call (the manager) will issue to set operations, so
%% we expect to receive to notify(insert) calls.
try_test(db_notify_client_test),
?DBG("await first notify",[]),
receive
{db_notify_test_reply,insert} -> ?DBG("first notify received",[]),ok
end,
?DBG("await second notify",[]),
receive
{db_notify_test_reply,insert} -> ?DBG("second notify received",[]),ok
end,
snmpa_local_db:unregister_notify_client(self()).
%% 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() ->
?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() ->
p("Testing simple next/get/set @ master agent (2)..."),
simple_standard_test(),
p("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(),
p("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(),
p("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}]),
p("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() ->
p("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) ->
snmpa:send_trap(MA, testTrapv22, "standard trap"),
?line expect(1, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}]),
snmpa:send_trap(MA, mtTrap, "standard trap"),
Pid = get_multi_pid(),
g([[sysUpTime,0]]),
?line expect(2, [{[sysUpTime,0], any}]),
snmpa:send_trap(MA, testTrapv22, "standard trap"),
?line expect(3, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}]),
Pid ! continue,
?line expect(4, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?testTrap ++ [2]},
{[multiStr,0], "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 pid(Pid) -> Pid;
_ -> get_multi_pid(N-1)
end.
%% Req. Test1
types_v2_test() ->
p("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",[]),
p("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() ->
p("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",[]),
p("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() ->
p("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 list(List), length(List) == 8 -> ok;
List when 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() ->
p("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")],
p("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(1, [{[sa, [2,0]], 3}]),
s([{[sa, [1,0]], s, "sa_test"}]),
?line expect(2, [{[sa, [1,0]], "sa_test"}]).
ma_trap1(MA) ->
snmpa:send_trap(MA, testTrap2, "standard trap"),
?line expect(1, trap, [system], 6, 1, [{[system, [4,0]],
"{mbj,eklas}@erlang.ericsson.se"}]),
snmpa:send_trap(MA, testTrap1, "standard trap"),
?line expect(2, trap, [1,2,3] , 1, 0, [{[system, [4,0]],
"{mbj,eklas}@erlang.ericsson.se"}]).
ma_trap2(MA) ->
snmpa:send_trap(MA,testTrap2,"standard trap",[{sysContact,"pelle"}]),
?line expect(3, trap, [system], 6, 1, [{[system, [4,0]], "pelle"}]).
ma_v2_2_v1_trap(MA) ->
snmpa:send_trap(MA,testTrapv22,"standard trap",[{sysContact,"pelle"}]),
?line expect(3, trap, [system], 6, 1, [{[system, [4,0]], "pelle"}]).
ma_v2_2_v1_trap2(MA) ->
snmpa:send_trap(MA,linkUp,"standard trap",[{ifIndex, [1], 1},
{ifAdminStatus, [1], 1},
{ifOperStatus, [1], 2}]),
?line expect(3, trap, [1,2,3], 3, 0, [{[ifIndex, 1], 1},
{[ifAdminStatus, 1], 1},
{[ifOperStatus, 1], 2}]).
sa_trap1(SA) ->
snmpa:send_trap(SA, saTrap, "standard trap"),
?line expect(4, trap, [ericsson], 6, 1, [{[system, [4,0]],
"{mbj,eklas}@erlang.ericsson.se"},
{[sa, [1,0]], "sa_test"}]).
sa_trap2(SA) ->
snmpa:send_trap(SA, saTrap, "standard trap",[{sysContact,"pelle"}]),
?line expect(5, trap, [ericsson], 6, 1, [{[system, [4,0]],
"pelle"},
{[sa, [1,0]], "sa_test"}]).
sa_trap3(SA) ->
snmpa:send_trap(SA, saTrap2, "standard trap",
[{intViewSubtree, [4], [1,2,3,4]}]),
?line expect(6, trap, [ericsson], 6, 2, [{[system, [4,0]],
"{mbj,eklas}@erlang.ericsson.se"},
{[sa, [1,0]], "sa_test"},
{[intViewSubtree,4],[1,2,3,4]}]).
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]}]).
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_inform -> entry with MA = ~p => "
"send notification: testTrapv22",[MA]),
?line snmpa:send_notification(MA, testTrapv22, no_receiver, "standard inform", []),
?line expect(1, {inform, true},
[{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}]),
?DBG("ma_v2_inform -> send notification: testTrapv22",[]),
snmpa:send_notification(MA, testTrapv22, {tag1, self()},
"standard inform", []),
?line expect(1, {inform, true},
[{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}]),
?DBG("ma_v2_inform -> await targets",[]),
receive
{snmp_targets, tag1, [_]} ->
ok;
{snmp_targets, tag1, Addrs1} ->
?line ?FAIL({bad_addrs, Addrs1})
after
5000 ->
?ERR("ma_v2_inform1 -> awaiting snmp_targets(tag1) timeout",[]),
?line ?FAIL(nothing_at_all)
end,
?DBG("ma_v2_inform -> await notification",[]),
receive
{snmp_notification, tag1, {got_response, _}} ->
ok;
{snmp_notification, tag1, {no_response, _}} ->
?line ?FAIL(no_response)
after
20000 ->
?ERR("ma_v2_inform1 -> "
"awaiting snmp_notification(tag1) timeout",[]),
?line ?FAIL(nothing_at_all)
end,
%%
%% -- The rest is possibly erroneous...
%%
?DBG("ma_v2_inform -> send notification: testTrapv22",[]),
snmpa:send_notification(MA, testTrapv22, {tag2, self()},
"standard inform", []),
?line expect(2, {inform, false},
[{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?system ++ [0,1]}]),
?DBG("ma_v2_inform -> await targets",[]),
receive
{snmp_targets, tag2, [_]} ->
ok;
{snmp_targets, tag2, Addrs2} ->
?ERR("ma_v2_inform1 -> awaiting snmp_targets(tag2) timeout",[]),
?line ?FAIL({bad_addrs, Addrs2})
after
5000 ->
?line ?FAIL(nothing_at_all)
end,
?DBG("ma_v2_inform -> await notification",[]),
receive
{snmp_notification, tag2, {got_response, _}} ->
?line ?FAIL(got_response);
{snmp_notification, tag2, {no_response, _}} ->
ok
after
240000 ->
?ERR("ma_v2_inform1 -> "
"awaiting snmp_notification(tag2) timeout",[]),
?line ?FAIL(nothing_at_all)
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:send_trap(SA, saTrap, "standard trap"),
?line expect(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}]).
sa_v1_2_v2_trap2(SA) ->
snmpa:send_trap(SA, saTrap, "standard trap",[{sysContact,"pelle"}]),
?line expect(4, v2trap, [{[sysUpTime, 0], any},
{[snmpTrapOID, 0], ?ericsson ++ [0, 1]},
{[system, [4,0]], "pelle"},
{[sa, [1,0]], "sa_test"},
{[snmpTrapEnterprise, 0], ?ericsson}]).
sa_v1_2_v2_trap3(SA) ->
snmpa:send_trap(SA, saTrap2, "standard trap",
[{intViewSubtree, [4], [1,2,3,4]}]),
?line expect(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}]).
%% 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.
%%%-----------------------------------------------------------------
standard_mibs(suite) ->
[snmp_standard_mib, snmp_community_mib,
snmp_framework_mib,
snmp_target_mib, snmp_notification_mib,
snmp_view_based_acm_mib].
standard_mibs_2(suite) ->
[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(suite) ->
[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].
%%-----------------------------------------------------------------
%% 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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(1, [{[snmpEnableAuthenTraps, 0], 2}]).
%% Req. SNMP-STANDARD-MIB | SNMPv2-MIB
std_mib_finish() ->
%% enable again
s([{[snmpEnableAuthenTraps,0], 1}]),
?line expect(1, [{[snmpEnableAuthenTraps, 0], 1}]).
%% Req. SNMP-STANDARD-MIB
standard_mib_test_finish() ->
%% force a authenticationFailure
std_mib_write(),
%% check that we got a trap
?line expect(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(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 list(Config) ->
?LOG("snmpv2_mib_2 -> start",[]),
{_SaNode, _MgrNode, _MibDir} = 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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(3, [{[snmpSetSerialNo,0], SetSerial},
{[sysLocation, 0], "val2"}]),
s([{[sysLocation, 0], "val3"}, {[snmpSetSerialNo,0], SetSerial}]),
?line expect(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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> snmp_framework_mib(X).
snmp_framework_mib_3(suite) -> [];
snmp_framework_mib_3(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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]]),
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 integer(Boots) -> ok;
Else -> ?FAIL(Else)
end,
ok.
%%-----------------------------------------------------------------
%% o Test the counters
%%-----------------------------------------------------------------
snmp_mpd_mib_3(suite) -> [];
snmp_mpd_mib_3(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> snmp_target_mib(X).
snmp_target_mib_3(X) -> snmp_target_mib(X).
snmp_target_mib() ->
?INF("NOT YET IMPLEMENTED", []),
nyi.
snmp_notification_mib(suite) -> [];
snmp_notification_mib(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> snmp_notification_mib(X).
snmp_notification_mib_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> snmp_view_based_acm_mib(X).
snmp_view_based_acm_mib_3(X) -> 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(1, Row).
add_row(RowStatus) ->
s([{RowStatus, ?createAndGo}]),
expect(1, [{RowStatus, ?createAndGo}]).
del_row(RowStatus) ->
s([{RowStatus, ?destroy}]),
expect(1, [{RowStatus, ?destroy}]).
use_no_rights() ->
g([[xDescr,0]]),
?v1_2_3(expect(11, noSuchName, 1, any),
expect(12, [{[xDescr,0], noSuchObject}]),
expect(13, authorizationError, 1, any)),
g([[xDescr2,0]]),
?v1_2_3(expect(21, noSuchName, 1, any),
expect(22, [{[xDescr2,0], noSuchObject}]),
expect(23, authorizationError, 1, any)),
gn([[xDescr]]),
?v1_2_3(expect(31, noSuchName, 1, any),
expect(32, [{[xDescr], endOfMibView}]),
expect(33, authorizationError, 1, any)),
s([{[xDescr,0], "tryit"}]),
?v1_2_3(expect(41, noSuchName, 1, any),
expect(42, noAccess, 1, any),
expect(43, authorizationError, 1, any)).
use_rights() ->
g([[xDescr,0]]),
expect(1, [{[xDescr,0], any}]),
g([[xDescr2,0]]),
expect(2, [{[xDescr2,0], any}]),
s([{[xDescr,0], "tryit"}]),
expect(3, noError, 0, any),
g([[xDescr,0]]),
expect(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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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 list(Config) ->
?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 list(Config) ->
?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 list(Config) ->
?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"
"\tNOid: ~p~n"
"\tValue: ~p",[NOid,Value]),
?line [Value2] = get_req(1, [NOid]), % must not be same
?DBG("loop_it_1 -> ~n"
"\tValue2: ~p",[Value2]),
loop_it_1(NOid, N+1);
#pdu{type='get-response', error_status=noSuchName, error_index=1,
varbinds=[_]} ->
?DBG("loop_it_1 -> done",[]),
N;
#pdu{type = Type, error_status = Err, error_index = Idx,
varbinds = Vbs} ->
exit({unexpected_pdu, ?LINE, Type, Err, Idx, Vbs})
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"
"\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 = endOfMibView}]} ->
?DBG("loop_it_2 -> ~n"
"\tNOid: ~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"
"\tNOid: ~p~n"
"\tValue: ~p",[NOid,Value]),
?line [Value2] = get_req(1, [NOid]), % must not be same
?DBG("loop_it_2 -> ~n"
"\tValue2: ~p",[Value2]),
loop_it_2(NOid, N+1)
end.
%%%-----------------------------------------------------------------
%%% Testing of reported bugs and other tickets.
%%%-----------------------------------------------------------------
reported_bugs(suite) ->
[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(suite) ->
[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(suite) ->
[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].
%% These are (ticket) test cases where the initiation has to be done
%% individually.
tickets(suite) ->
[otp_4394].
%%-----------------------------------------------------------------
%% Ticket: OTP-1128
%% Slogan: Bug in handling of createAndWait set-requests.
%%-----------------------------------------------------------------
otp_1128(suite) -> [];
otp_1128(Config) when list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> otp_1128(X).
otp_1128_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Klas3"),
try_test(otp_1129_i, [node()]),
?line unload_master("Klas3").
otp_1129_2(X) -> otp_1129(X).
otp_1129_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Klas1"),
try_test(otp_1131),
?line unload_master("Klas1").
otp_1131_2(X) -> otp_1131(X).
otp_1131_3(X) -> 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 list(Config) ->
{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) -> otp_1162(X).
otp_1162_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> otp_1222(X).
otp_1222_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Klas2"),
try_test(otp_1298),
?line unload_master("Klas2").
otp_1298_2(X) -> otp_1298(X).
otp_1298_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> otp_1331(X).
otp_1331_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Klas2"),
try_test(otp_1338),
?line unload_master("Klas2").
otp_1338_2(X) -> otp_1338(X).
otp_1338_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Klas4"),
try_test(otp_1342),
?line unload_master("Klas4").
otp_1342_2(X) -> otp_1342(X).
otp_1342_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> otp_1366(X).
otp_1366_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
try_test(otp_2776).
otp_2776_2(X) -> otp_2776(X).
otp_2776_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = init_case(Config),
?line load_master("Test1"),
?line init_old(),
try_test(otp_2979),
?line unload_master("Test1").
otp_2979_2(X) -> otp_2979(X).
otp_2979_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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) -> otp_3187(X).
otp_3187_3(X) -> 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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 list(Config) ->
{_SaNode, _MgrNode, _MibDir} = 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
%%-----------------------------------------------------------------
otp_4394(suite) -> {req, [], {conf,
init_otp_4394,
[otp_4394_test],
finish_otp_4394}}.
init_otp_4394(Config) when 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 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) ->
?DBG("otp_4394_test -> entry", []),
{_SaNode, _MgrNode, _MibDir} = 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.
%%%--------------------------------------------------
%%% Used to test the standard mib with our
%%% configuration.
%%%--------------------------------------------------
run(F, A, Opts) ->
M = get(mib_dir),
Dir = get(mgr_dir),
User = snmp_misc:get_option(user, Opts, "all-rights"),
SecLevel = snmp_misc:get_option(sec_level, Opts, noAuthNoPriv),
EngineID = snmp_misc:get_option(engine_id, Opts, "agentEngine"),
CtxEngineID = snmp_misc:get_option(context_engine_id, Opts, EngineID),
Community = snmp_misc:get_option(community, Opts, "all-rights"),
?DBG("run -> start crypto app",[]),
Crypto = case os:type() of
vxworks ->
no_crypto;
_ ->
?CRYPTO_START()
end,
?DBG("run -> Crypto: ~p",[Crypto]),
catch snmp_test_mgr:stop(), % If we had a running mgr from a failed case
StdM = filename:join(code:priv_dir(snmp), "mibs") ++ "/",
?DBG("run -> config:~n"
"\tM: ~p~n"
"\tDir: ~p~n"
"\tUser: ~p~n"
"\tSecLevel: ~p~n"
"\tEngineID: ~p~n"
"\tCtxEngineID: ~p~n"
"\tCommunity: ~p~n"
"\tStdM: ~p",
[M,Dir,User,SecLevel,EngineID,CtxEngineID,Community,StdM]),
case snmp_test_mgr:start([%% {agent, snmp_test_lib:hostname()},
{packet_server_debug,true},
{debug,true},
{agent, get(master_host)},
{agent_udp, 4000},
{trap_udp, 5000},
{recbuf,65535},
quiet,
get(vsn),
{community, Community},
{user, User},
{sec_level, SecLevel},
{engine_id, EngineID},
{context_engine_id, CtxEngineID},
{dir, Dir},
{mibs, mibs(StdM, M)}]) of
{ok, _Pid} ->
Res = apply(?MODULE, F, A),
catch snmp_test_mgr:stop(),
Res;
Err ->
io:format("Error starting manager: ~p\n", [Err]),
catch snmp_test_mgr:stop(),
?line exit({mgr_start, Err})
end.
mibs(StdMibDir,MibDir) ->
[join(StdMibDir, ?v1_2("STANDARD-MIB.bin", "SNMPv2-MIB.bin")),
join(MibDir, "OLD-SNMPEA-MIB.bin"),
join(StdMibDir, "SNMP-FRAMEWORK-MIB"),
join(StdMibDir, "SNMP-MPD-MIB"),
join(StdMibDir, "SNMP-VIEW-BASED-ACM-MIB"),
join(StdMibDir, "SNMP-USER-BASED-SM-MIB"),
join(StdMibDir, "SNMP-TARGET-MIB"),
join(StdMibDir, "SNMP-NOTIFICATION-MIB"),
join(MibDir, "Klas1.bin"),
join(MibDir, "Klas2.bin"),
join(MibDir, "Klas3.bin"),
join(MibDir, "Klas4.bin"),
join(MibDir, "SA-MIB.bin"),
join(MibDir, "TestTrap.bin"),
join(MibDir, "Test1.bin"),
join(MibDir, "Test2.bin"),
join(MibDir, "TestTrapv2.bin")].
join(D,F) ->
filename:join(D,F).
%% string used in index
is(S) -> [length(S) | S].
try_test(Func) ->
call(get(mgr_node), ?MODULE, run, [Func, [], []]).
try_test(Func, A) ->
call(get(mgr_node), ?MODULE, run, [Func, A, []]).
try_test(Func, A, Opts) ->
call(get(mgr_node), ?MODULE, run, [Func, A, Opts]).
call(N,M,F,A) ->
?DBG("call -> entry with~n"
" N: ~p~n"
" M: ~p~n"
" F: ~p~n"
" A: ~p~n"
" when~n"
" get(): ~p",
[N,M,F,A,get()]),
spawn(N, ?MODULE, wait, [self(),get(),M,F,A]),
receive
{done, {'EXIT', Rn}, Loc} ->
?DBG("call -> returned ~p",[{done, {'EXIT', Rn}, Loc}]),
put(test_server_loc, Loc),
exit(Rn);
{done, Ret, Zed} ->
?DBG("call -> returned ~p~n",[{done, Ret, Zed}]),
Ret
end.
wait(From, Env, M, F, A) ->
?DBG("wait -> entry with ~n"
"\tFrom: ~p~n"
"\tEnv: ~p",[From,Env]),
lists:foreach(fun({K,V}) -> put(K,V) end, Env),
Rn = (catch apply(M, F, A)),
?DBG("wait -> Rn: ~n~p", [Rn]),
From ! {done, Rn, get(test_server_loc)},
exit(Rn).
expect(A,B) -> ok = snmp_test_mgr:expect(A,B).
expect(A,B,C) -> ok = snmp_test_mgr:expect(A,B,C).
expect(A,B,C,D) -> ok = snmp_test_mgr:expect(A,B,C,D).
expect(A,B,C,D,E,F) -> ok = snmp_test_mgr:expect(A,B,C,D,E,F).
get_req(Id, Vars) ->
?DBG("get_req -> entry with~n"
"\tId: ~p~n"
"\tVars: ~p",[Id,Vars]),
g(Vars),
?DBG("get_req -> await response",[]),
{ok, Val} = snmp_test_mgr:get_response(Id, Vars),
?DBG("get_req -> response: ~p",[Val]),
Val.
get_next_req(Vars) ->
?DBG("get_next_req -> entry with Vars '~p', send request",[Vars]),
gn(Vars),
?DBG("get_next_req -> await response",[]),
Response = snmp_test_mgr:receive_response(),
?DBG("get_next_req -> response: ~p",[Response]),
Response.
start_node(Name) ->
?LOG("start_node -> entry with Name: ~p",[Name]),
M = list_to_atom(?HOSTNAME(node())),
?DBG("start_node -> M: ~p",[M]),
Pa = filename:dirname(code:which(?MODULE)),
?DBG("start_node -> Pa: ~p",[Pa]),
Args = case init:get_argument('CC_TEST') of
{ok, [[]]} ->
" -pa /clearcase/otp/libraries/snmp/ebin ";
{ok, [[Path]]} ->
" -pa " ++ Path;
error ->
""
end,
%% Do not use start_link!!! (the proc that calls this one is tmp)
?DBG("start_node -> Args: ~p~n",[Args]),
A = Args ++ " -pa " ++ Pa,
case (catch ?START_NODE(Name, A)) of
{ok, Node} ->
%% Tell the test_server to not clean up things it never started.
?DBG("start_node -> Node: ~p",[Node]),
{ok, Node};
Else ->
?ERR("start_node -> failed with(other): Else: ~p",[Else]),
?line ?FAIL(Else)
end.
stop_node(Node) ->
?LOG("stop_node -> Node: ~p",[Node]),
rpc:cast(Node, erlang, halt, []).
p(X) ->
io:format(user, X++"\n", []).
sleep(X) ->
receive
after
X -> ok
end.
%%%-----------------------------------------------------------------
%%% Configuration
%%%-----------------------------------------------------------------
config(Vsns, MgrDir, AgentDir, MIp, AIp) ->
?line snmp_config:write_agent_snmp_files(AgentDir, Vsns, MIp,
?TRAP_UDP, AIp, 4000,
"test"),
?line case update_usm(Vsns, AgentDir) of
true ->
?line copy_file(filename:join(AgentDir, "usm.conf"),
filename:join(MgrDir, "usm.conf")),
?line update_usm_mgr(Vsns, MgrDir);
false ->
?line ok
end,
?line update_community(Vsns, AgentDir),
?line update_vacm(Vsns, AgentDir),
?line write_target_addr_conf(AgentDir, MIp, ?TRAP_UDP, Vsns),
?line write_target_params_conf(AgentDir, Vsns),
?line write_notify_conf(AgentDir),
ok.
delete_files(Config) ->
Dir = ?config(agent_dir, Config),
{ok, List} = file:list_dir(Dir),
lists:foreach(fun(FName) -> file:delete(filename:join(Dir, FName)) end,
List).
update_usm(Vsns, Dir) ->
case lists:member(v3, Vsns) of
true ->
{ok, Fid} = file:open(filename:join(Dir,"usm.conf"),[read,write]),
file:position(Fid, eof),
ok = io:format(Fid, "{\"agentEngine\", \"all-rights\", "
"\"all-rights\", zeroDotZero, "
"usmNoAuthProtocol, \"\", \"\", "
"usmNoPrivProtocol, \"\", \"\", \"\", "
"\"\", \"\"}.\n", []),
ok = io:format(Fid, "{\"agentEngine\", \"no-rights\", "
"\"no-rights\", zeroDotZero, "
"usmNoAuthProtocol, \"\", \"\", "
"usmNoPrivProtocol, \"\", \"\", \"\", "
"\"\", \"\"}.\n", []),
ok = io:format(Fid, "{\"agentEngine\", \"authMD5\", "
"\"authMD5\", zeroDotZero, "
"usmHMACMD5AuthProtocol, \"\", \"\", "
"usmNoPrivProtocol, \"\", \"\", \"\", "
"\"passwd_md5xxxxxx\", \"\"}.\n", []),
ok = io:format(Fid, "{\"agentEngine\", \"authSHA\", "
"\"authSHA\", zeroDotZero, "
"usmHMACSHAAuthProtocol, \"\", \"\", "
"usmNoPrivProtocol, \"\", \"\", \"\", "
"\"passwd_shaxxxxxxxxxx\", \"\"}.\n", []),
ok = io:format(Fid, "{\"agentEngine\", \"privDES\", "
"\"privDES\", zeroDotZero, "
"usmHMACSHAAuthProtocol, \"\", \"\", "
"usmDESPrivProtocol, \"\", \"\", \"\", "
"\"passwd_shaxxxxxxxxxx\", \"passwd_desxxxxxx\"}.\n",
[]),
ok = io:format(Fid, "{\"mgrEngine\", \"all-rights\", "
"\"all-rights\", zeroDotZero, "
"usmNoAuthProtocol, \"\", \"\", "
"usmNoPrivProtocol, \"\", \"\", \"\", "
"\"\", \"\"}.\n", []),
ok = io:format(Fid, "{\"mgrEngine\", \"no-rights\", "
"\"no-rights\", zeroDotZero, "
"usmNoAuthProtocol, \"\", \"\", "
"usmNoPrivProtocol, \"\", \"\", \"\", "
"\"\", \"\"}.\n", []),
ok = io:format(Fid, "{\"mgrEngine\", \"authMD5\", "
"\"authMD5\", zeroDotZero, "
"usmHMACMD5AuthProtocol, \"\", \"\", "
"usmNoPrivProtocol, \"\", \"\", \"\", "
"\"passwd_md5xxxxxx\", \"\"}.\n", []),
ok = io:format(Fid, "{\"mgrEngine\", \"authSHA\", "
"\"authSHA\", zeroDotZero, "
"usmHMACSHAAuthProtocol, \"\", \"\", "
"usmNoPrivProtocol, \"\", \"\", \"\", "
"\"passwd_shaxxxxxxxxxx\", \"\"}.\n", []),
ok = io:format(Fid, "{\"mgrEngine\", \"privDES\", "
"\"privDES\", zeroDotZero, "
"usmHMACSHAAuthProtocol, \"\", \"\", "
"usmDESPrivProtocol, \"\", \"\", \"\", "
"\"passwd_shaxxxxxxxxxx\", \"passwd_desxxxxxx\"}.\n",
[]),
file:close(Fid),
true;
false ->
false
end.
update_usm_mgr(Vsns, Dir) ->
case lists:member(v3, Vsns) of
true ->
{ok, Fid} = file:open(filename:join(Dir,"usm.conf"),[read,write]),
file:position(Fid, eof),
ok = io:format(Fid, "{\"agentEngine\", \"newUser\", "
"\"newUser\", zeroDotZero, "
"usmHMACSHAAuthProtocol, \"\", \"\", "
"usmDESPrivProtocol, \"\", \"\", \"\", "
"\"passwd_shaxxxxxxxxxx\", \"passwd_desxxxxxx\"}.\n",
[]),
ok = io:format(Fid, "{\"mgrEngine\", \"newUser\", "
"\"newUser\", zeroDotZero, "
"usmHMACSHAAuthProtocol, \"\", \"\", "
"usmDESPrivProtocol, \"\", \"\", \"\", "
"\"passwd_shaxxxxxxxxxx\", \"passwd_desxxxxxx\"}.\n",
[]),
file:close(Fid),
true;
false ->
false
end.
rewrite_usm_mgr(Dir, ShaKey, DesKey) ->
?line ok = file:rename(filename:join(Dir,"usm.conf"),
filename:join(Dir,"usm.old")),
?line {ok, Fid} = file:open(filename:join(Dir,"usm.conf"),write),
ok = io:format(Fid, "{\"agentEngine\", \"newUser\", "
"\"newUser\", zeroDotZero, "
"usmHMACSHAAuthProtocol, \"\", \"\", "
"usmDESPrivProtocol, \"\", \"\", \"\", "
"\"~s\", \"~s\"}.\n",
[ShaKey, DesKey]),
ok = io:format(Fid, "{\"mgrEngine\", \"newUser\", "
"\"newUser\", zeroDotZero, "
"usmHMACSHAAuthProtocol, \"\", \"\", "
"usmDESPrivProtocol, \"\", \"\", \"\", "
"\"~s\", \"~s\"}.\n",
[ShaKey, DesKey]),
file:close(Fid).
reset_usm_mgr(Dir) ->
?line ok = file:rename(filename:join(Dir,"usm.old"),
filename:join(Dir,"usm.conf")).
update_community([v3], _Dir) -> ok;
update_community(_, Dir) ->
{ok, Fid} = file:open(filename:join(Dir,"community.conf"),[read,write]),
file:position(Fid, eof),
ok=io:format(Fid,"{\"no-rights\",\"no-rights\",\"no-rights\",\"\",\"\"}.\n",
[]),
file:close(Fid).
-define(tDescr_instance, [1,3,6,1,2,1,16,1,0]).
update_vacm(_Vsn, Dir) ->
{ok, Fid} = file:open(filename:join(Dir,"vacm.conf"),[read,write]),
file:position(Fid, eof),
ok=io:format(Fid,"{vacmSecurityToGroup,usm,\"authMD5\",\"initial\"}.\n",[]),
ok=io:format(Fid,"{vacmSecurityToGroup,usm,\"authSHA\",\"initial\"}.\n",[]),
ok=io:format(Fid,"{vacmSecurityToGroup,usm,\"privDES\",\"initial\"}.\n",[]),
ok=io:format(Fid,"{vacmSecurityToGroup,usm,\"newUser\",\"initial\"}.\n",[]),
ok = io:format(Fid, "{vacmViewTreeFamily, \"internet\", "
"~w, excluded, null}.\n", [?tDescr_instance]),
file:close(Fid).
vacm_ver(v1) -> v1;
vacm_ver(v2) -> v2c;
vacm_ver(v3) -> usm.
write_community_conf(Dir, Confs) ->
{ok, Fid} = file:open(filename:join(Dir,"community.conf"),write),
ok = write_community_conf1(Fid, Confs),
file:close(Fid).
write_community_conf1(_, []) ->
ok;
write_community_conf1(Fid, [{ComIdx, ComName, SecName, CtxName, TransTag}|Confs]) ->
ok = io:format(Fid, "{\"~s\", \"~s\", \"~s\", \"~s\", \"~s\"}.~n",
[ComIdx, ComName, SecName, CtxName, TransTag]),
write_community_conf1(Fid, Confs).
write_target_addr_conf(Dir, Confs) ->
{ok, Fid} = file:open(filename:join(Dir,"target_addr.conf"),write),
ok = write_target_addr_conf1(Fid, Confs),
file:close(Fid).
write_target_addr_conf1(_, []) ->
ok;
write_target_addr_conf1(Fid,
[{Name, Ip, Port, Timeout, Retry, TagList, ParamName,
EngineId, TMask, MaxMsgSz}|Confs]) ->
ok = io:format(Fid, "{\"~s\", ~w, ~w, ~w, ~w, \"~s\", \"~s\", \"~s\", ~w, ~w}.~n",
[Name, Ip, Port, Timeout, Retry, TagList, ParamName,
EngineId, TMask, MaxMsgSz]),
write_target_addr_conf1(Fid, Confs).
write_target_addr_conf(Dir, ManagerIp, UDP, Vsns) ->
{ok, Fid} = file:open(filename:join(Dir,"target_addr.conf"),write),
lists:foreach(fun(Vsn) ->
ok = io:format(Fid,
"{\"~s\", ~w, ~w, 1500, 3, "
"\"std_trap\", \"~s\"}.~n",
[mk_ip(ManagerIp, Vsn),
ManagerIp, UDP, mk_param(Vsn)]),
case Vsn of
v1 -> ok;
v2 ->
ok = io:format(Fid,
"{\"~s.2\",~w,~w,1500,3, "
"\"std_inform\", \"~s\"}.~n",
[mk_ip(ManagerIp, Vsn),
ManagerIp, UDP,
mk_param(Vsn)]);
v3 ->
ok = io:format(Fid,
"{\"~s.3\",~w,~w,1500,3, "
"\"std_inform\", \"~s\", "
"\"mgrEngine\", [], 1024}.~n",
[mk_ip(ManagerIp, Vsn),
ManagerIp, UDP,
mk_param(Vsn)])
end
end,
Vsns),
file:close(Fid).
mk_param(v1) -> "target_v1";
mk_param(v2) -> "target_v2";
mk_param(v3) -> "target_v3".
mk_ip([A,B,C,D], Vsn) ->
io_lib:format("~w.~w.~w.~w ~w", [A,B,C,D,Vsn]).
rewrite_target_addr_conf(Dir,NewPort) ->
TAFile = filename:join(Dir, "target_addr.conf"),
?DBG("rewrite_target_addr_conf -> read target file info of address config file",[]),
case file:read_file_info(TAFile) of
{ok, _} -> ok;
{error, R} -> ?ERR("failure reading file info of "
"target address config file: ~p",[R]),
ok
end,
?line [TrapAddr|Addrs] =
snmp_conf:read(TAFile,fun(R) -> rewrite_target_addr_conf1(R) end),
?DBG("rewrite_target_addr_conf -> TrapAddr: ~p",[TrapAddr]),
NewAddrs = [rewrite_target_addr_conf2(NewPort,TrapAddr)|Addrs],
?DBG("rewrite_target_addr_conf -> NewAddrs: ~p",[NewAddrs]),
?line ok = file:rename(filename:join(Dir,"target_addr.conf"),
filename:join(Dir,"target_addr.old")),
?line {ok, Fid} = file:open(filename:join(Dir,"target_addr.conf"),write),
?line ok = rewrite_target_addr_conf3(Fid,NewAddrs),
file:close(Fid).
rewrite_target_addr_conf1(O) ->
{ok,O}.
rewrite_target_addr_conf2(NewPort,{Name,Ip,_Port,Timeout,Retry,
"std_trap",EngineId}) ->
?LOG("rewrite_target_addr_conf2 -> entry with std_trap",[]),
{Name,Ip,NewPort,Timeout,Retry,"std_trap",EngineId};
rewrite_target_addr_conf2(_NewPort,O) ->
?LOG("rewrite_target_addr_conf2 -> entry with "
"~n O: ~p",[O]),
O.
rewrite_target_addr_conf3(_,[]) -> ok;
rewrite_target_addr_conf3(Fid,[{Name,Ip,Port,Timeout,Retry,
ParamName,EngineId}|T]) ->
?LOG("rewrite_target_addr_conf3 -> write(1) ~s",[ParamName]),
io:format(Fid,
"{\"~s\", " % Name
"~p, " % Ip
"~p, " % Port
"~p, " % Timeout
"~p, " % Retry
"\"~s\", " % ParamsName
"\"~s\"}.", % EngineId
[Name,Ip,Port,Timeout,Retry,ParamName,EngineId]),
rewrite_target_addr_conf3(Fid,T);
rewrite_target_addr_conf3(Fid,[{Name,Ip,Port,Timeout,Retry,TagList,
ParamName,EngineId,TMask,MMS}|T]) ->
?LOG("rewrite_target_addr_conf3 -> write(2) ~s",[ParamName]),
io:format(Fid,
"{\"~s\", " % Name
"~p, " % Ip
"~p, " % Port
"~p, " % Timeout
"~p, " % Retry
"\"~s\", " % TagList
"\"~s\", " % ParamsName
"\"~s\"," % EngineId
"~p, " % TMask
"~p}.", % MMS
[Name,Ip,Port,Timeout,Retry,TagList,ParamName,
EngineId,TMask,MMS]),
rewrite_target_addr_conf3(Fid,T).
reset_target_addr_conf(Dir) ->
?line ok = file:rename(filename:join(Dir,"target_addr.old"),
filename:join(Dir,"target_addr.conf")).
write_target_params_conf(Dir, Vsns) ->
{ok, Fid} = file:open(filename:join(Dir,"target_params.conf"),write),
lists:foreach(fun(Vsn) ->
MP = if Vsn == v1 -> v1;
Vsn == v2 -> v2c;
Vsn == v3 -> v3
end,
SM = if Vsn == v1 -> v1;
Vsn == v2 -> v2c;
Vsn == v3 -> usm
end,
ok = io:format(Fid, "{\"target_~w\", ~w, ~w, "
"\"all-rights\", noAuthNoPriv}.~n",
[Vsn, MP, SM])
end,
Vsns),
file:close(Fid).
rewrite_target_params_conf(Dir, SecName, SecLevel) ->
?line ok = file:rename(filename:join(Dir,"target_params.conf"),
filename:join(Dir,"target_params.old")),
?line {ok, Fid} = file:open(filename:join(Dir,"target_params.conf"),write),
?line ok = io:format(Fid, "{\"target_v3\", v3, usm, \"~s\", ~w}.~n",
[SecName, SecLevel]),
file:close(Fid).
reset_target_params_conf(Dir) ->
?line ok = file:rename(filename:join(Dir,"target_params.old"),
filename:join(Dir,"target_params.conf")).
write_notify_conf(Dir) ->
{ok, Fid} = file:open(filename:join(Dir,"notify.conf"),write),
ok = io:format(Fid, "{\"standard trap\", \"std_trap\", trap}.~n", []),
ok = io:format(Fid, "{\"standard inform\", \"std_inform\",inform}.~n", []),
file:close(Fid).
ver_to_trap_str([v1]) -> "v1";
ver_to_trap_str([v2]) -> "v2";
% default is to use the latest snmp version
ver_to_trap_str([v1,v2]) -> "v2".
write_view_conf(Dir) ->
{ok, Fid} = file:open(a(Dir,"view.conf"),write),
ok = io:format(Fid, "{2, [1,3,6], included, null}.~n", []),
ok = io:format(Fid, "{2, ~w, excluded, null}.~n", [?tDescr_instance]),
file:close(Fid).
a(A,B) -> lists:append(A,B).
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
copy_file(From, To) ->
{ok, Bin} = file:read_file(From),
ok = file:write_file(To, Bin).
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
display_memory_usage() ->
Info = snmpa:info(snmp_master_agent),
TreeSize = lists_key1search(tree_size_bytes, Info),
ProcMem = lists_key1search(process_memory, Info),
MibDbSize = lists_key1search([db_memory,mib], Info),
NodeDbSize = lists_key1search([db_memory,node], Info),
TreeDbSize = lists_key1search([db_memory,tree], Info),
?INF("Memory usage: "
"~n Tree size: ~p"
"~n Process memory size: ~p"
"~n Mib db size: ~p"
"~n Node db size: ~p"
"~n Tree db size: ~p",
[TreeSize, ProcMem, MibDbSize, NodeDbSize, TreeDbSize]).
lists_key1search([], Res) ->
Res;
lists_key1search([Key|Keys], List) when atom(Key), list(List) ->
case lists:keysearch(Key, 1, List) of
{value, {Key, Val}} ->
lists_key1search(Keys, Val);
false ->
undefined
end;
lists_key1search(Key, List) when atom(Key) ->
case lists:keysearch(Key, 1, List) of
{value, {Key, Val}} ->
Val;
false ->
undefined
end.
regs() ->
lists:sort(registered()).
