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;
41 public final class SessionStateImpl implements PcepSessionState {
42 private final LongAdder lastReceivedRptMsgTimestamp = new LongAdder();
43 private final LongAdder receivedRptMsgCount = new LongAdder();
44 private final LongAdder sentUpdMsgCount = new LongAdder();
45 private final LongAdder sentInitMsgCount = new LongAdder();
46 private final Stopwatch sessionUpDuration;
48 private final LongAdder minReplyTime = new LongAdder();
49 private final LongAdder maxReplyTime = new LongAdder();
50 private final LongAdder totalTime = new LongAdder();
51 private final LongAdder reqCount = new LongAdder();
52 private final TopologySessionStats topologySessionStats;
53 private LocalPref localPref;
54 private PeerPref peerPref;
55 private PCEPSessionState pcepSessionState;
57 public SessionStateImpl(final TopologySessionStats topologySessionStats) {
58 this.sessionUpDuration = Stopwatch.createUnstarted();
59 this.topologySessionStats = requireNonNull(topologySessionStats);
62 public synchronized void init(final PCEPSessionState session) {
63 requireNonNull(session);
64 this.pcepSessionState = session;
65 final Open localOpen = session.getLocalOpen();
67 if (localOpen.getTlvs() != null && localOpen.getTlvs().augmentation(Tlvs3.class) != null) {
68 final SpeakerEntityId entityId = localOpen.getTlvs().augmentation(Tlvs3.class).getSpeakerEntityId();
69 if (entityId != null) {
70 this.localPref = new LocalPrefBuilder(session.getLocalPref())
71 .addAugmentation(PcepEntityIdStatsAug.class,
72 new PcepEntityIdStatsAugBuilder(entityId).build()).build();
75 this.localPref = session.getLocalPref();
78 this.peerPref = session.getPeerPref();
79 this.sessionUpDuration.start();
82 public synchronized void processRequestStats(final long duration) {
83 if (this.minReplyTime.longValue() == 0) {
84 this.minReplyTime.reset();
85 this.minReplyTime.add(duration);
86 } else if (duration < this.minReplyTime.longValue()) {
87 this.minReplyTime.reset();
88 this.minReplyTime.add(duration);
90 if (duration > this.maxReplyTime.longValue()) {
91 this.maxReplyTime.reset();
92 this.maxReplyTime.add(duration);
94 this.totalTime.add(duration);
95 this.reqCount.increment();
98 public synchronized void updateLastReceivedRptMsg() {
99 this.lastReceivedRptMsgTimestamp.reset();
100 this.lastReceivedRptMsgTimestamp.add(StatisticsUtil.getCurrentTimestampInSeconds());
101 this.receivedRptMsgCount.increment();
104 public synchronized void updateStatefulSentMsg(final Message msg) {
105 if (msg instanceof Pcinitiate) {
106 this.sentInitMsgCount.increment();
107 } else if (msg instanceof Pcupd) {
108 this.sentUpdMsgCount.increment();
112 public synchronized String getSessionDuration() {
113 return StatisticsUtil.formatElapsedTime(this.sessionUpDuration.elapsed(TimeUnit.SECONDS));
117 public synchronized Boolean isSynchronized() {
118 return this.topologySessionStats.isSessionSynchronized();
122 public synchronized PeerCapabilities getPeerCapabilities() {
123 return new PeerCapabilitiesBuilder()
124 .addAugmentation(StatefulCapabilitiesStatsAug.class, createStatefulCapabilities())
128 private StatefulCapabilitiesStatsAug createStatefulCapabilities() {
129 return new StatefulCapabilitiesStatsAugBuilder()
130 .setActive(this.topologySessionStats.isLspUpdateCapability())
131 .setInstantiation(this.topologySessionStats.isInitiationCapability())
132 .setStateful(this.topologySessionStats.isStatefulCapability())
137 public Messages getMessages() {
138 return new MessagesBuilder(this.pcepSessionState.getMessages())
139 .setReplyTime(setReplyTime())
140 .addAugmentation(StatefulMessagesStatsAug.class, createStatefulMessages())
144 private StatefulMessagesStatsAug createStatefulMessages() {
145 return new StatefulMessagesStatsAugBuilder()
146 .setLastReceivedRptMsgTimestamp(this.lastReceivedRptMsgTimestamp.longValue())
147 .setReceivedRptMsgCount(this.receivedRptMsgCount.longValue())
148 .setSentInitMsgCount(this.sentInitMsgCount.longValue())
149 .setSentUpdMsgCount(this.sentUpdMsgCount.longValue())
153 private synchronized ReplyTime setReplyTime() {
155 if (this.reqCount.longValue() != 0) {
156 avg = Math.round((double) this.totalTime.longValue() / this.reqCount.longValue());
158 return new ReplyTimeBuilder()
160 .setMaxTime(this.maxReplyTime.longValue())
161 .setMinTime(this.minReplyTime.longValue())
166 public LocalPref getLocalPref() {
167 return this.localPref;
171 public PeerPref getPeerPref() {
172 return this.peerPref;
176 public Integer getDelegatedLspsCount() {
177 return this.topologySessionStats.getDelegatedLspsCount();
181 public Class<PcepSessionState> implementedInterface() {
182 return PcepSessionState.class;