private volatile long lastMessageSentAt;
/**
- * System.nanoTime value about when was received the last message
+ * System.nanoTime value about when was received the last message.
*/
private long lastMessageReceivedAt;
private final Channel channel;
- private final Keepalive kaMessage = new KeepaliveBuilder().setKeepaliveMessage(new KeepaliveMessageBuilder().build()).build();
+ private final Keepalive kaMessage =
+ new KeepaliveBuilder().setKeepaliveMessage(new KeepaliveMessageBuilder().build()).build();
private final PCEPSessionState sessionState;
channel.eventLoop().schedule(this::handleKeepaliveTimer, getKeepAliveTimerValue(), TimeUnit.SECONDS);
}
- LOG.info("Session {}[{}] <-> {}[{}] started", channel.localAddress(), localOpen.getSessionId(), channel.remoteAddress(),
- remoteOpen.getSessionId());
+ LOG.info("Session {}[{}] <-> {}[{}] started",
+ channel.localAddress(), localOpen.getSessionId(), channel.remoteAddress(), remoteOpen.getSessionId());
this.sessionState = new PCEPSessionState(remoteOpen, localOpen, channel);
}
if (reason != null) {
LOG.info("Closing PCEP session with reason {}: {}", reason, this);
sendMessage(new CloseBuilder().setCCloseMessage(
- new CCloseMessageBuilder().setCClose(new CCloseBuilder().setReason(reason.getShortValue()).build()).build()).build());
+ new CCloseMessageBuilder().setCClose(new CCloseBuilder()
+ .setReason(reason.getShortValue()).build()).build()).build());
} else {
LOG.info("Closing PCEP session: {}", this);
}
/**
* Sends PCEP Error Message with one PCEPError and Open Object.
*
- * @param value
- * @param open
+ * @param value PCEP errors value
+ * @param open Open Object
*/
private void sendErrorMessage(final PCEPErrors value, final Open open) {
this.sendMessage(Util.createErrorMessage(value, open));