2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright © 2021 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
17 * ============LICENSE_END=========================================================
20 package org.o.ran.oam.nf.oam.adopter.snmp.manager;
22 import java.io.IOException;
23 import org.o.ran.oam.nf.oam.adopter.api.VesEventNotifier;
24 import org.o.ran.oam.nf.oam.adopter.snmp.manager.api.TimeZoneOffsetService;
25 import org.o.ran.oam.nf.oam.adopter.snmp.manager.mapper.SnmpMapper;
26 import org.slf4j.Logger;
27 import org.slf4j.LoggerFactory;
28 import org.snmp4j.MessageDispatcher;
29 import org.snmp4j.MessageDispatcherImpl;
30 import org.snmp4j.Snmp;
31 import org.snmp4j.mp.MPv2c;
32 import org.snmp4j.smi.UdpAddress;
33 import org.snmp4j.transport.DefaultUdpTransportMapping;
34 import org.snmp4j.util.MultiThreadedMessageDispatcher;
35 import org.snmp4j.util.ThreadPool;
37 final class SnmpTrapListener implements Runnable {
39 private static final Logger LOG = LoggerFactory.getLogger(SnmpTrapListener.class);
40 private static final int THREADS_SIZE = 2;
41 private final String hostPortAddress;
42 private final SnmpCommandResponder commandResponder;
44 public SnmpTrapListener(final String host, final Integer port, final SnmpMapper mapper,
45 final VesEventNotifier vesEventNotifier, final TimeZoneOffsetService timeZoneOffsetService) {
46 LOG.info("SnmpTrapListener listening on {}:{}", host, port);
47 this.hostPortAddress = host + "/" + port;
48 this.commandResponder = new SnmpCommandResponder(timeZoneOffsetService, mapper, vesEventNotifier);
52 public synchronized void run() {
53 try (final var snmpTarget = new DefaultUdpTransportMapping(new UdpAddress(hostPortAddress))) {
54 final var threadPool = ThreadPool.create("SNMP_V2_Listener", THREADS_SIZE);
55 final var dispatcher = new MultiThreadedMessageDispatcher(threadPool, new MessageDispatcherImpl());
56 dispatcher.addMessageProcessingModel(new MPv2c());
57 listenSnmp(dispatcher, snmpTarget);
58 } catch (final IOException e) {
59 LOG.error("Error occurred while listening to SNMP messages: {}", e.getMessage());
63 private synchronized void listenSnmp(final MessageDispatcher dispatcher,
64 final DefaultUdpTransportMapping snmpTarget) {
66 try (final var snmp = new Snmp(dispatcher, snmpTarget)) {
67 snmp.addCommandResponder(commandResponder);
69 LOG.debug("Listening on {}", snmpTarget);
71 } catch (final InterruptedException | IOException ex) {
72 Thread.currentThread().interrupt();
74 } while (snmpTarget.isListening());