pcep/impl/src/main/java/org/opendaylight/protocol/pcep/impl/PCEPSessionState.java

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