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
   9 package org.opendaylight.protocol.pcep.impl;
  10
  11 import static java.util.Objects.requireNonNull;
  12
  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;
  31
  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;
  45
  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();
  57     }
  58
  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();
  70     }
  71
  72     public LocalPref getLocalPref() {
  73         return this.localPref;
  74     }
  75
  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();
  83     }
  84
  85     PeerPref getPeerPref() {
  86         return this.peerPref;
  87     }
  88
  89     void setLastSentError(final Message msg) {
  90         this.sentErrMsgCount++;
  91         final ErrorObject errObj = getErrorObject(msg);
  92         this.lastSentErrorBuilder.setErrorType(errObj.getType()).setErrorValue(errObj.getValue());
  93     }
  94
  95     void setLastReceivedError(final Message msg) {
  96         final ErrorObject errObj = getErrorObject(msg);
  97         this.receivedErrMsgCount++;
  98         this.lastReceivedErrorBuilder.setErrorType(errObj.getType()).setErrorValue(errObj.getValue());
  99     }
 100
 101     void updateLastReceivedMsg() {
 102         this.receivedMsgCount++;
 103     }
 104
 105     void updateLastSentMsg() {
 106         this.lastSentMsgTimestamp = StatisticsUtil.getCurrentTimestampInSeconds();
 107         this.sentMsgCount++;
 108     }
 109
 110     private static ErrorObject getErrorObject(final Message msg) {
 111         requireNonNull(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();
 115     }
 116
 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();
 124     }
 125
 126     public Open getLocalOpen() {
 127         return localOpen;
 128     }
 129 }