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.Registration;
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<DsbenchmarkListener> listeners = new ArrayList<>();
28 private final List<Registration> registrations = new ArrayList<>();
29 private final DataBroker dataBroker;
31 public DsbenchmarkListenerProvider(final DataBroker dataBroker) {
32 this.dataBroker = requireNonNull(dataBroker);
33 LOG.debug("DsbenchmarkListenerProvider created");
36 public void createAndRegisterListeners(final int numListeners) {
37 for (int i = 0; i < numListeners; i++) {
38 var listener = new DsbenchmarkListener();
39 listeners.add(listener);
40 registrations.add(dataBroker.registerTreeChangeListener(
41 DataTreeIdentifier.of(LogicalDatastoreType.CONFIGURATION, TEST_EXEC_IID), listener));
42 registrations.add(dataBroker.registerTreeChangeListener(
43 DataTreeIdentifier.of(LogicalDatastoreType.OPERATIONAL, TEST_EXEC_IID), listener));
46 LOG.debug("DsbenchmarkListenerProvider created {} listeneres", numListeners);
49 public long getDataChangeCount() {
52 for (var listener : listeners) {
53 dataChanges += listener.getNumDataChanges();
55 LOG.debug("DsbenchmarkListenerProvider , total data changes {}", dataChanges);
59 public long getEventCountAndDestroyListeners() {
62 registrations.forEach(Registration::close);
63 registrations.clear();
65 for (var listener : listeners) {
66 totalEvents += listener.getNumEvents();
70 LOG.debug("DsbenchmarkListenerProvider destroyed listeneres, total events {}", totalEvents);