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