2 * Copyright (c) 2014 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.bgpcep.pcep.topology.provider.session.stats;
11 import static java.util.Objects.requireNonNull;
13 import com.google.common.base.Stopwatch;
14 import java.util.concurrent.TimeUnit;
15 import java.util.concurrent.atomic.LongAdder;
16 import org.opendaylight.protocol.pcep.PCEPSessionState;
17 import org.opendaylight.protocol.util.StatisticsUtil;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.Tlvs3;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev181109.speaker.entity.id.tlv.SpeakerEntityId;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev181109.Pcinitiate;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev181109.Pcupd;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stateful.stats.rev181109.PcepEntityIdStatsAug;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stateful.stats.rev181109.PcepEntityIdStatsAugBuilder;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stateful.stats.rev181109.StatefulCapabilitiesStatsAug;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stateful.stats.rev181109.StatefulCapabilitiesStatsAugBuilder;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stateful.stats.rev181109.StatefulMessagesStatsAug;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stateful.stats.rev181109.StatefulMessagesStatsAugBuilder;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.PcepSessionState;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.LocalPref;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.LocalPrefBuilder;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.Messages;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.MessagesBuilder;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.PeerCapabilities;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.PeerCapabilitiesBuilder;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.PeerPref;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.reply.time.grouping.ReplyTime;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.reply.time.grouping.ReplyTimeBuilder;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.Message;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.open.object.Open;
40 import org.opendaylight.yangtools.yang.binding.DataContainer;
42 public final class SessionStateImpl implements PcepSessionState {
43 private final LongAdder lastReceivedRptMsgTimestamp = new LongAdder();
44 private final LongAdder receivedRptMsgCount = new LongAdder();
45 private final LongAdder sentUpdMsgCount = new LongAdder();
46 private final LongAdder sentInitMsgCount = new LongAdder();
47 private final Stopwatch sessionUpDuration;
49 private final LongAdder minReplyTime = new LongAdder();
50 private final LongAdder maxReplyTime = new LongAdder();
51 private final LongAdder totalTime = new LongAdder();
52 private final LongAdder reqCount = new LongAdder();
53 private final TopologySessionStats topologySessionStats;
54 private LocalPref localPref;
55 private PeerPref peerPref;
56 private PCEPSessionState pcepSessionState;
58 public SessionStateImpl(final TopologySessionStats topologySessionStats) {
59 this.sessionUpDuration = Stopwatch.createUnstarted();
60 this.topologySessionStats = requireNonNull(topologySessionStats);
63 public synchronized void init(final PCEPSessionState session) {
64 requireNonNull(session);
65 this.pcepSessionState = session;
66 final Open localOpen = session.getLocalOpen();
68 if (localOpen.getTlvs() != null && localOpen.getTlvs().augmentation(Tlvs3.class) != null) {
69 final SpeakerEntityId entityId = localOpen.getTlvs().augmentation(Tlvs3.class).getSpeakerEntityId();
70 if (entityId != null) {
71 this.localPref = new LocalPrefBuilder(session.getLocalPref())
72 .addAugmentation(PcepEntityIdStatsAug.class,
73 new PcepEntityIdStatsAugBuilder(entityId).build()).build();
76 this.localPref = session.getLocalPref();
79 this.peerPref = session.getPeerPref();
80 this.sessionUpDuration.start();
83 public synchronized void processRequestStats(final long duration) {
84 if (this.minReplyTime.longValue() == 0) {
85 this.minReplyTime.reset();
86 this.minReplyTime.add(duration);
87 } else if (duration < this.minReplyTime.longValue()) {
88 this.minReplyTime.reset();
89 this.minReplyTime.add(duration);
91 if (duration > this.maxReplyTime.longValue()) {
92 this.maxReplyTime.reset();
93 this.maxReplyTime.add(duration);
95 this.totalTime.add(duration);
96 this.reqCount.increment();
99 public synchronized void updateLastReceivedRptMsg() {
100 this.lastReceivedRptMsgTimestamp.reset();
101 this.lastReceivedRptMsgTimestamp.add(StatisticsUtil.getCurrentTimestampInSeconds());
102 this.receivedRptMsgCount.increment();
105 public synchronized void updateStatefulSentMsg(final Message msg) {
106 if (msg instanceof Pcinitiate) {
107 this.sentInitMsgCount.increment();
108 } else if (msg instanceof Pcupd) {
109 this.sentUpdMsgCount.increment();
113 public synchronized String getSessionDuration() {
114 return StatisticsUtil.formatElapsedTime(this.sessionUpDuration.elapsed(TimeUnit.SECONDS));
118 public synchronized Boolean isSynchronized() {
119 return this.topologySessionStats.isSessionSynchronized();
123 public synchronized PeerCapabilities getPeerCapabilities() {
124 return new PeerCapabilitiesBuilder()
125 .addAugmentation(StatefulCapabilitiesStatsAug.class, createStatefulCapabilities())
129 private StatefulCapabilitiesStatsAug createStatefulCapabilities() {
130 return new StatefulCapabilitiesStatsAugBuilder()
131 .setActive(this.topologySessionStats.isLspUpdateCapability())
132 .setInstantiation(this.topologySessionStats.isInitiationCapability())
133 .setStateful(this.topologySessionStats.isStatefulCapability())
138 public Messages getMessages() {
139 return new MessagesBuilder(this.pcepSessionState.getMessages())
140 .setReplyTime(setReplyTime())
141 .addAugmentation(StatefulMessagesStatsAug.class, createStatefulMessages())
145 private StatefulMessagesStatsAug createStatefulMessages() {
146 return new StatefulMessagesStatsAugBuilder()
147 .setLastReceivedRptMsgTimestamp(this.lastReceivedRptMsgTimestamp.longValue())
148 .setReceivedRptMsgCount(this.receivedRptMsgCount.longValue())
149 .setSentInitMsgCount(this.sentInitMsgCount.longValue())
150 .setSentUpdMsgCount(this.sentUpdMsgCount.longValue())
154 private synchronized ReplyTime setReplyTime() {
156 if (this.reqCount.longValue() != 0) {
157 avg = Math.round((double) this.totalTime.longValue() / this.reqCount.longValue());
159 return new ReplyTimeBuilder()
161 .setMaxTime(this.maxReplyTime.longValue())
162 .setMinTime(this.minReplyTime.longValue())
167 public LocalPref getLocalPref() {
168 return this.localPref;
172 public PeerPref getPeerPref() {
173 return this.peerPref;
177 public Integer getDelegatedLspsCount() {
178 return this.topologySessionStats.getDelegatedLspsCount();
182 public Class<? extends DataContainer> getImplementedInterface() {