2 * Copyright (c) 2015 Cisco Systems, Inc. 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
9 package org.opendaylight.openflowplugin.impl.device;
11 import com.google.common.base.Preconditions;
12 import javax.annotation.CheckForNull;
13 import javax.annotation.Nonnull;
14 import org.opendaylight.openflowplugin.api.openflow.device.DeviceState;
15 import org.opendaylight.openflowplugin.impl.util.DeviceStateUtil;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FeaturesReply;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetFeaturesOutput;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetFeaturesOutputBuilder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.role.service.rev150727.OfpRole;
23 import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
27 * org.opendaylight.openflowplugin.impl.device
29 * DeviceState is builded from {@link FeaturesReply} and {@link NodeId}. Both values are inside
30 * {@link org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext}
32 * @author <a href="mailto:vdemcak@cisco.com">Vaclav Demcak</a>
34 * Created: Mar 29, 2015
36 class DeviceStateImpl implements DeviceState {
38 private final GetFeaturesOutput featuresOutput;
39 private final NodeId nodeId;
40 private final KeyedInstanceIdentifier<Node, NodeKey> nodeII;
41 private final short version;
42 private boolean valid;
43 private boolean meterIsAvailable;
44 private boolean groupIsAvailable;
45 private boolean deviceSynchronized;
46 private boolean flowStatisticsAvailable;
47 private boolean tableStatisticsAvailable;
48 private boolean portStatisticsAvailable;
49 private boolean statPollEnabled;
50 private boolean queueStatisticsAvailable;
51 private volatile OfpRole role;
53 public DeviceStateImpl(@CheckForNull final FeaturesReply featuresReply, @Nonnull final NodeId nodeId) {
54 Preconditions.checkArgument(featuresReply != null);
55 featuresOutput = new GetFeaturesOutputBuilder(featuresReply).build();
56 this.nodeId = Preconditions.checkNotNull(nodeId);
57 nodeII = DeviceStateUtil.createNodeInstanceIdentifier(nodeId);
58 version = featuresReply.getVersion();
59 statPollEnabled = false;
60 deviceSynchronized = false;
61 role = OfpRole.BECOMESLAVE;
65 public NodeId getNodeId() {
70 public KeyedInstanceIdentifier<Node, NodeKey> getNodeInstanceIdentifier() {
75 public GetFeaturesOutput getFeatures() {
76 return featuresOutput;
80 public boolean isValid() {
85 public void setValid(final boolean valid) {
90 public short getVersion() {
95 public boolean isMetersAvailable() {
96 return meterIsAvailable;
100 public void setMeterAvailable(final boolean available) {
101 meterIsAvailable = available;
105 public boolean isGroupAvailable() {
106 return groupIsAvailable;
110 public void setGroupAvailable(final boolean available) {
111 groupIsAvailable = available;
115 public boolean deviceSynchronized() {
116 return deviceSynchronized;
120 public boolean isFlowStatisticsAvailable() {
121 return flowStatisticsAvailable;
125 public void setFlowStatisticsAvailable(final boolean available) {
126 flowStatisticsAvailable = available;
130 public boolean isTableStatisticsAvailable() {
131 return tableStatisticsAvailable;
135 public void setTableStatisticsAvailable(final boolean available) {
136 tableStatisticsAvailable = available;
140 public boolean isPortStatisticsAvailable() {
141 return portStatisticsAvailable;
145 public void setPortStatisticsAvailable(final boolean available) {
146 portStatisticsAvailable = available;
150 public boolean isQueueStatisticsAvailable() {
151 return queueStatisticsAvailable;
155 public void setQueueStatisticsAvailable(final boolean available) {
156 queueStatisticsAvailable = available;
161 public void setDeviceSynchronized(final boolean _deviceSynchronized) {
162 deviceSynchronized = _deviceSynchronized;
166 public OfpRole getRole() {
171 public void setRole(OfpRole role) {
176 public boolean isStatisticsPollingEnabled() {
177 return statPollEnabled;
181 public void setStatisticsPollingEnabledProp(final boolean statPollEnabled) {
182 this.statPollEnabled = statPollEnabled;