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.protocol.pcep.impl;
11 import static java.util.Objects.requireNonNull;
13 import io.netty.channel.Channel;
14 import java.net.InetSocketAddress;
15 import org.opendaylight.protocol.util.StatisticsUtil;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.error.messages.grouping.ErrorMessagesBuilder;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.error.messages.grouping.error.messages.LastReceivedErrorBuilder;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.error.messages.grouping.error.messages.LastSentErrorBuilder;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.LocalPref;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.LocalPrefBuilder;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.Messages;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.MessagesBuilder;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.PeerPref;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.stats.rev171113.pcep.session.state.PeerPrefBuilder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.Message;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.PcerrMessage;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.open.object.Open;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.pcep.error.object.ErrorObject;
29 import org.opendaylight.yangtools.yang.common.Uint16;
30 import org.opendaylight.yangtools.yang.common.Uint32;
32 final class PCEPSessionState {
33 private final Open localOpen;
34 private long sentMsgCount = 0;
35 private long receivedMsgCount = 0;
36 private long sentErrMsgCount = 0;
37 private long receivedErrMsgCount = 0;
38 private long lastSentMsgTimestamp = 0;
39 private final PeerPref peerPref;
40 private final LocalPref localPref;
41 private final LastReceivedErrorBuilder lastReceivedErrorBuilder;
42 private final LastSentErrorBuilder lastSentErrorBuilder;
43 private final ErrorMessagesBuilder errorsBuilder;
44 private final MessagesBuilder msgsBuilder;
46 PCEPSessionState(final Open remoteOpen, final Open localOpen, final Channel channel) {
47 requireNonNull(remoteOpen);
48 requireNonNull(localOpen);
49 requireNonNull(channel);
50 this.localOpen = localOpen;
51 this.peerPref = getRemotePref(remoteOpen, channel);
52 this.localPref = getLocalPref(localOpen, channel);
53 this.lastReceivedErrorBuilder = new LastReceivedErrorBuilder();
54 this.lastSentErrorBuilder = new LastSentErrorBuilder();
55 this.errorsBuilder = new ErrorMessagesBuilder();
56 this.msgsBuilder = new MessagesBuilder();
59 Messages getMessages(final int unknownMessagesCount) {
60 this.errorsBuilder.setReceivedErrorMsgCount(Uint32.valueOf(this.receivedErrMsgCount))
61 .setSentErrorMsgCount(Uint32.valueOf(this.sentErrMsgCount))
62 .setLastReceivedError(this.lastReceivedErrorBuilder.build())
63 .setLastSentError(this.lastSentErrorBuilder.build());
64 this.msgsBuilder.setLastSentMsgTimestamp(Uint32.valueOf(this.lastSentMsgTimestamp))
65 .setReceivedMsgCount(Uint32.valueOf(this.receivedMsgCount))
66 .setSentMsgCount(Uint32.valueOf(this.sentMsgCount))
67 .setUnknownMsgReceived(Uint16.valueOf(unknownMessagesCount))
68 .setErrorMessages(this.errorsBuilder.build());
69 return this.msgsBuilder.build();
72 public LocalPref getLocalPref() {
73 return this.localPref;
76 private static LocalPref getLocalPref(final Open open, final Channel channel) {
77 final LocalPrefBuilder peerBuilder = new LocalPrefBuilder()
78 .setDeadtimer(open.getDeadTimer())
79 .setKeepalive(open.getKeepalive())
80 .setIpAddress(((InetSocketAddress) channel.localAddress()).getAddress().getHostAddress())
81 .setSessionId(Uint16.valueOf(open.getSessionId().intValue()));
82 return peerBuilder.build();
85 PeerPref getPeerPref() {
89 void setLastSentError(final Message msg) {
90 this.sentErrMsgCount++;
91 final ErrorObject errObj = getErrorObject(msg);
92 this.lastSentErrorBuilder.setErrorType(errObj.getType()).setErrorValue(errObj.getValue());
95 void setLastReceivedError(final Message msg) {
96 final ErrorObject errObj = getErrorObject(msg);
97 this.receivedErrMsgCount++;
98 this.lastReceivedErrorBuilder.setErrorType(errObj.getType()).setErrorValue(errObj.getValue());
101 void updateLastReceivedMsg() {
102 this.receivedMsgCount++;
105 void updateLastSentMsg() {
106 this.lastSentMsgTimestamp = StatisticsUtil.getCurrentTimestampInSeconds();
110 private static ErrorObject getErrorObject(final Message msg) {
112 final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.pcerr.message
113 .PcerrMessage errMsg = ((PcerrMessage) msg).getPcerrMessage();
114 return errMsg.getErrors().get(errMsg.getErrors().size() - 1).getErrorObject();
117 private static PeerPref getRemotePref(final Open open, final Channel channel) {
118 final PeerPrefBuilder peerBuilder = new PeerPrefBuilder();
119 peerBuilder.setDeadtimer(open.getDeadTimer())
120 .setKeepalive(open.getKeepalive())
121 .setIpAddress(((InetSocketAddress) channel.remoteAddress()).getAddress().getHostAddress())
122 .setSessionId(Uint16.valueOf(open.getSessionId().intValue()));
123 return peerBuilder.build();
126 public Open getLocalOpen() {