mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

Jean-Noël Rouvignac
29.42.2016 f78f372a776579b6c2fb0a0bbb77b098a535aa20
opendj-server-legacy/src/test/java/org/opends/server/snmp/SNMPTrapManagerTest.java
@@ -12,6 +12,7 @@
 * information: "Portions Copyright [year] [name of copyright owner]".
 *
 * Copyright 2008 Sun Microsystems, Inc.
 * Portions Copyright 2016 ForgeRock AS.
 */
package org.opends.server.snmp;
@@ -36,26 +37,26 @@
    public void setUp() throws Exception {
        super.setUp();
    }
    @Test(enabled = true)
    public void checkTraps() {
        try {
            // Create a taskServer for processing traps.
            // This is an optional step. However using a DaemonTaskServer
            // to process incomming PDUs makes it possible to empty
            // the trap socket faster, thus reducing the hazards
            // of trap loss.
            // We set the priority of the DaemonTaskServer to
            // Thread.NORM_PRIORITY so that emptying the socket takes
            // We set the priority of the DaemonTaskServer to
            // Thread.NORM_PRIORITY so that emptying the socket takes
            // precedence over trap processing.
            //
            final DaemonTaskServer taskServer = new DaemonTaskServer();
            taskServer.start(Thread.NORM_PRIORITY);
            // Create a listener and dispatcher for SNMP traps
            // Create a listener and dispatcher for SNMP traps
            // (SnmpEventReportDispatcher).
            // SnmpEventReportDispatcher is run as a thread and listens
            // SnmpEventReportDispatcher is run as a thread and listens
            // for traps in UDP port = agent port + 1.
            // Add TrapListenerImpl as SnmpTrapListener.
            // TrapListenerImpl will receive a callback when a valid trap
@@ -69,15 +70,15 @@
            final Thread trapThread = new Thread(trapAgent);
            trapThread.setPriority(Thread.MAX_PRIORITY);
            trapThread.start();
            // One Trap
            this.setDown();
            int trapNumbers = trapListener.getNumberV1Traps();
            // Should received 1 traps
            assertEquals(trapNumbers, 1);
            trapAgent.close();
            taskServer.terminate();
@@ -88,13 +89,13 @@
                    "Exception occurred:" + e);
        }
    }
    private class SNMPTrapListenerImpl implements SnmpTrapListener {
        private int numberV1Traps=0;
        private int numberV2Traps=0;
        private int numberV3Traps=0;
        public void processSnmpTrapV1(SnmpPduTrap trap) {
            this.numberV1Traps++;
        }
@@ -106,15 +107,15 @@
        public void processSnmpTrapV3(SnmpScopedPduRequest trap) {
            this.numberV3Traps++;
        }
        public int getNumberV1Traps() {
            return this.numberV1Traps;
        }
        public int getNumberV2Traps() {
            return this.numberV3Traps;
        }
    }
}