2 * Copyright (c) 2016 Cisco Systems and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.dsbenchmark.listener;
10 import static java.util.Objects.requireNonNull;
12 import java.util.ArrayList;
13 import java.util.List;
14 import org.opendaylight.mdsal.binding.api.DataBroker;
15 import org.opendaylight.mdsal.binding.api.DataTreeIdentifier;
16 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.dsbenchmark.rev150105.TestExec;
18 import org.opendaylight.yangtools.concepts.ListenerRegistration;
19 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
20 import org.slf4j.Logger;
21 import org.slf4j.LoggerFactory;
23 public class DsbenchmarkListenerProvider {
24 private static final Logger LOG = LoggerFactory.getLogger(DsbenchmarkListenerProvider.class);
25 private static final InstanceIdentifier<TestExec> TEST_EXEC_IID =
26 InstanceIdentifier.builder(TestExec.class).build();
27 private final List<ListenerRegistration<DsbenchmarkListener>> listeners = new ArrayList<>();
28 private final DataBroker dataBroker;
30 public DsbenchmarkListenerProvider(final DataBroker dataBroker) {
31 this.dataBroker = requireNonNull(dataBroker);
32 LOG.debug("DsbenchmarkListenerProvider created");
35 public void createAndRegisterListeners(final int numListeners) {
36 for (int i = 0; i < numListeners; i++) {
37 DsbenchmarkListener listener = new DsbenchmarkListener();
38 listeners.add(dataBroker.registerDataTreeChangeListener(
39 DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, TEST_EXEC_IID), listener));
40 listeners.add(dataBroker.registerDataTreeChangeListener(
41 DataTreeIdentifier.create(LogicalDatastoreType.OPERATIONAL, TEST_EXEC_IID), listener));
44 LOG.debug("DsbenchmarkListenerProvider created {} listeneres", numListeners);
47 public long getDataChangeCount() {
50 for (ListenerRegistration<DsbenchmarkListener> listenerRegistration : listeners) {
51 dataChanges += listenerRegistration.getInstance().getNumDataChanges();
53 LOG.debug("DsbenchmarkListenerProvider , total data changes {}", dataChanges);
57 public long getEventCountAndDestroyListeners() {
60 for (ListenerRegistration<DsbenchmarkListener> listenerRegistration : listeners) {
61 totalEvents += listenerRegistration.getInstance().getNumEvents();
62 listenerRegistration.close();
65 LOG.debug("DsbenchmarkListenerProvider destroyed listeneres, total events {}", totalEvents);