import java.math.BigInteger;
import java.util.function.Supplier;
-import javax.annotation.concurrent.NotThreadSafe;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.qos.rev160613.qos.attributes.qos.policies.QosPolicy;
import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.node.connector.statistics.and.port.number.map.NodeConnectorStatisticsAndPortNumberMap;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-@NotThreadSafe
+/**
+ * This class is ThreadSafe.
+ */
public class QosAlertPortData {
private static final Logger LOG = LoggerFactory.getLogger(QosAlertPortData.class);
private static final BigInteger BIG_HUNDRED = new BigInteger("100");
}
public void updatePortStatistics(NodeConnectorStatisticsAndPortNumberMap statsData) {
- LOG.trace("Port {} rx-packets {} tx-packets {} rx-dropped {} tx-dropped {}", port.getUuid(),
+ LOG.trace("Port {} rx-packets {} tx-packets {} rx-dropped {} tx-dropped {}", port.getUuid().getValue(),
statsData.getPackets().getReceived(), statsData.getPackets().getTransmitted(),
statsData.getReceiveDrops(), statsData.getTransmitDrops());
if (statsDataInit) {
BigInteger rxDroppedDiff = statsData.getReceiveDrops().subtract(rxDroppedPackets);
if ((rxDiff.signum() < 0) || (rxDroppedDiff.signum() < 0)) {
- LOG.debug("Port {} counters reset", port.getUuid());
+ LOG.debug("Port {} counters reset", port.getUuid().getValue());
initPortData(); // counters wrapped. wait for one more poll.
return;
}
BigInteger rxTotalDiff = rxDiff.add(rxDroppedDiff);
- LOG.trace("Port {} rxDiff:{} rxDropped diff:{} total diff:{}", port.getUuid(), rxDiff,
+ LOG.trace("Port {} rxDiff:{} rxDropped diff:{} total diff:{}", port.getUuid().getValue(), rxDiff,
rxDroppedDiff, rxTotalDiff);
QosPolicy qosPolicy = qosNeutronUtils.getQosPolicy(port);