for (final Requests req : init.getRequests()) {
serializeObject(req.getEndpointsObj(), buffer);
serializeObject(req.getLspa(), buffer);
- if (req.getEro() != null) {
- serializeObject(req.getEro(), buffer);
- }
- if (req.getBandwidth() != null) {
- serializeObject(req.getBandwidth(), buffer);
- }
+ serializeObject(req.getEro(), buffer);
+ serializeObject(req.getBandwidth(), buffer);
if (req.getMetrics() != null && !req.getMetrics().isEmpty()) {
for (final Metrics m : req.getMetrics()) {
serializeObject(m.getMetric(), buffer);
if (repMsg.getReplies() == null || repMsg.getReplies().isEmpty()) {
throw new IllegalArgumentException("Replies cannot be null or empty.");
}
- ByteBuf buffer = Unpooled.buffer();
+ final ByteBuf buffer = Unpooled.buffer();
for (final Replies reply : repMsg.getReplies()) {
if (reply.getRp() == null) {
throw new IllegalArgumentException("Reply must contain RP object.");
if (reply.getResult() instanceof FailureCase) {
final FailureCase f = ((FailureCase) reply.getResult());
serializeObject(f.getNoPath(), buffer);
- if (f.getLspa() != null) {
- serializeObject(f.getLspa(), buffer);
- }
- if (f.getBandwidth() != null) {
- serializeObject(f.getBandwidth(), buffer);
- }
+ serializeObject(f.getLspa(), buffer);
+ serializeObject(f.getBandwidth(), buffer);
if (f.getMetrics() != null && !f.getMetrics().isEmpty()) {
for (final Metrics m : f.getMetrics()) {
serializeObject(m.getMetric(), buffer);
}
}
- if (f.getIro() != null) {
- serializeObject(f.getIro(), buffer);
- }
+ serializeObject(f.getIro(), buffer);
} else {
final SuccessCase s = (SuccessCase) reply.getResult();
for (final Paths p : s.getSuccess().getPaths()) {
serializeObject(p.getEro(), buffer);
- if (p.getLspa() != null) {
- serializeObject(p.getLspa(), buffer);
- }
- if (p.getOf() != null) {
- serializeObject(p.getOf(), buffer);
- }
- if (p.getBandwidth() != null) {
- serializeObject(p.getBandwidth(), buffer);
- }
+ serializeObject(p.getLspa(), buffer);
+ serializeObject(p.getOf(), buffer);
+ serializeObject(p.getBandwidth(), buffer);
if (p.getMetrics() != null && !p.getMetrics().isEmpty()) {
for (final Metrics m : p.getMetrics()) {
serializeObject(m.getMetric(), buffer);
}
}
- if (p.getIro() != null) {
- serializeObject(p.getIro(), buffer);
- }
+ serializeObject(p.getIro(), buffer);
}
}
}
Preconditions.checkArgument(message instanceof Pcrpt, "Wrong instance of Message. Passed instance of %s. Need Pcrpt.", message.getClass());
final Pcrpt msg = (Pcrpt) message;
final List<Reports> reports = msg.getPcrptMessage().getReports();
- ByteBuf buffer = Unpooled.buffer();
+ final ByteBuf buffer = Unpooled.buffer();
for (final Reports report : reports) {
serializeObject(report.getLsp(), buffer);
final Path p = report.getPath();
if (p != null) {
- if (p.getEro() != null) {
- serializeObject(p.getEro(), buffer);
- }
- if (p.getLspa() != null) {
- serializeObject(p.getLspa(), buffer);
- }
- if (p.getBandwidth() != null) {
- serializeObject(p.getBandwidth(), buffer);
- }
+ serializeObject(p.getEro(), buffer);
+ serializeObject(p.getLspa(), buffer);
+ serializeObject(p.getBandwidth(), buffer);
if (p.getMetrics() != null && !p.getMetrics().isEmpty()) {
for (final Metrics m : p.getMetrics()) {
serializeObject(m.getMetric(), buffer);
}
}
- if (p.getIro() != null) {
- serializeObject(p.getRro(), buffer);
- }
+ serializeObject(p.getIro(), buffer);
}
}
MessageUtil.formatMessage(TYPE, buffer, out);
@Override
protected void serializeP2P(final ByteBuf buffer, final P2p p2p) {
- if (p2p.getEndpointsObj() != null) {
- serializeObject(p2p.getEndpointsObj(), buffer);
- }
- if (p2p.getAugmentation(P2p1.class) != null && p2p.getAugmentation(P2p1.class).getLsp() != null) {
+ serializeObject(p2p.getEndpointsObj(), buffer);
+ if (p2p.getAugmentation(P2p1.class) != null) {
serializeObject(p2p.getAugmentation(P2p1.class).getLsp(), buffer);
}
- if (p2p.getReportedRoute() != null) {
- final ReportedRoute rr = p2p.getReportedRoute();
- if (rr.getRro() != null) {
- serializeObject(rr.getRro(), buffer);
- }
- if (rr.getBandwidth() != null) {
- serializeObject(rr.getBandwidth(), buffer);
- }
- }
- if (p2p.getLoadBalancing() != null) {
- serializeObject(p2p.getLoadBalancing(), buffer);
- }
- if (p2p.getLspa() != null) {
- serializeObject(p2p.getLspa(), buffer);
- }
- if (p2p.getBandwidth() != null) {
- serializeObject(p2p.getBandwidth(), buffer);
+ final ReportedRoute rr = p2p.getReportedRoute();
+ if (rr != null) {
+ serializeObject(rr.getRro(), buffer);
+ serializeObject(rr.getBandwidth(), buffer);
}
+ serializeObject(p2p.getLoadBalancing(), buffer);
+ serializeObject(p2p.getLspa(), buffer);
+ serializeObject(p2p.getBandwidth(), buffer);
if (p2p.getMetrics() != null) {
for (final Metrics m : p2p.getMetrics()) {
serializeObject(m.getMetric(), buffer);
}
}
- if (p2p.getIro() != null) {
- serializeObject(p2p.getIro(), buffer);
- }
- if (p2p.getRro() != null) {
- serializeObject(p2p.getRro(), buffer);
- }
- if (p2p.getXro() != null) {
- serializeObject(p2p.getXro(), buffer);
- }
- if (p2p.getOf() != null) {
- serializeObject(p2p.getOf(), buffer);
- }
- if (p2p.getClassType() != null) {
- serializeObject(p2p.getClassType(), buffer);
- }
+ serializeObject(p2p.getIro(), buffer);
+ serializeObject(p2p.getRro(), buffer);
+ serializeObject(p2p.getXro(), buffer);
+ serializeObject(p2p.getOf(), buffer);
+ serializeObject(p2p.getClassType(), buffer);
}
@Override
Preconditions.checkArgument(message instanceof Pcupd, "Wrong instance of Message. Passed instance of %s. Need Pcupd.", message.getClass());
final Pcupd msg = (Pcupd) message;
final List<Updates> updates = msg.getPcupdMessage().getUpdates();
- ByteBuf buffer = Unpooled.buffer();
+ final ByteBuf buffer = Unpooled.buffer();
for (final Updates update : updates) {
serializeObject(update.getLsp(), buffer);
final Path p = update.getPath();
if (p != null) {
serializeObject(p.getEro(), buffer);
- if (p.getLspa() != null) {
- serializeObject(p.getLspa(), buffer);
- }
- if (p.getBandwidth() != null) {
- serializeObject(p.getBandwidth(), buffer);
- }
+ serializeObject(p.getLspa(), buffer);
+ serializeObject(p.getBandwidth(), buffer);
if (p.getMetrics() != null && !p.getMetrics().isEmpty()) {
for (final Metrics m : p.getMetrics()) {
serializeObject(m.getMetric(), buffer);
}
}
- if (p.getIro() != null) {
- serializeObject(p.getIro(), buffer);
- }
+ serializeObject(p.getIro(), buffer);
}
}
MessageUtil.formatMessage(TYPE, buffer, out);
protected void serializeRequest(final Requests req, final ByteBuf buffer) {
serializeObject(req.getSrp(), buffer);
serializeObject(req.getLsp(), buffer);
- if (req.getEndpointsObj() != null) {
- serializeObject(req.getEndpointsObj(), buffer);
- }
- if (req.getEro() != null) {
- serializeObject(req.getEro(), buffer);
- }
- if (req.getLspa() != null) {
- serializeObject(req.getLspa(), buffer);
- }
- if (req.getBandwidth() != null) {
- serializeObject(req.getBandwidth(), buffer);
- }
+ serializeObject(req.getEndpointsObj(), buffer);
+ serializeObject(req.getEro(), buffer);
+ serializeObject(req.getLspa(), buffer);
+ serializeObject(req.getBandwidth(), buffer);
if (req.getMetrics() != null && !req.getMetrics().isEmpty()) {
for (final Metrics m : req.getMetrics()) {
serializeObject(m.getMetric(), buffer);
}
}
- if (req.getIro() != null) {
- serializeObject(req.getIro(), buffer);
- }
+ serializeObject(req.getIro(), buffer);
}
@Override
Preconditions.checkArgument(message instanceof Pcrpt, "Wrong instance of Message. Passed instance of %s. Need Pcrpt.", message.getClass());
final Pcrpt msg = (Pcrpt) message;
final List<Reports> reports = msg.getPcrptMessage().getReports();
- ByteBuf buffer = Unpooled.buffer();
+ final ByteBuf buffer = Unpooled.buffer();
for (final Reports report : reports) {
serializeReport(report, buffer);
}
final Path p = report.getPath();
if (p != null) {
serializeObject(p.getEro(), buffer);
- if (p.getLspa() != null) {
- serializeObject(p.getLspa(), buffer);
- }
- if (p.getBandwidth() != null) {
- serializeObject(p.getBandwidth(), buffer);
- }
+ serializeObject(p.getLspa(), buffer);
+ serializeObject(p.getBandwidth(), buffer);
if (p.getMetrics() != null && !p.getMetrics().isEmpty()) {
for (final Metrics m : p.getMetrics()) {
serializeObject(m.getMetric(), buffer);
}
}
- if (p.getIro() != null) {
- serializeObject(p.getIro(), buffer);
- }
- if (p.getRro() != null) {
- serializeObject(p.getRro(), buffer);
- }
+ serializeObject(p.getIro(), buffer);
+ serializeObject(p.getRro(), buffer);
}
}
Preconditions.checkArgument(message instanceof Pcupd, "Wrong instance of Message. Passed instance of %s. Need Pcupd.", message.getClass());
final Pcupd msg = (Pcupd) message;
final List<Updates> updates = msg.getPcupdMessage().getUpdates();
- ByteBuf buffer = Unpooled.buffer();
+ final ByteBuf buffer = Unpooled.buffer();
for (final Updates update : updates) {
serializeUpdate(update, buffer);
}
final Path p = update.getPath();
if (p != null) {
serializeObject(p.getEro(), buffer);
- if (p.getLspa() != null) {
- serializeObject(p.getLspa(), buffer);
- }
- if (p.getBandwidth() != null) {
- serializeObject(p.getBandwidth(), buffer);
- }
+ serializeObject(p.getLspa(), buffer);
+ serializeObject(p.getBandwidth(), buffer);
if (p.getMetrics() != null && !p.getMetrics().isEmpty()) {
for (final Metrics m : p.getMetrics()) {
serializeObject(m.getMetric(), buffer);
}
}
- if (p.getIro() != null) {
- serializeObject(p.getIro(), buffer);
- }
+ serializeObject(p.getIro(), buffer);
}
}
if (repMsg.getReplies() == null || repMsg.getReplies().isEmpty()) {
throw new IllegalArgumentException("Replies cannot be null or empty.");
}
- ByteBuf buffer = Unpooled.buffer();
+ final ByteBuf buffer = Unpooled.buffer();
for (final Replies reply : repMsg.getReplies()) {
if (reply.getRp() == null) {
throw new IllegalArgumentException("Reply must contain RP object.");
if (reply.getResult() != null) {
if (reply.getResult() instanceof FailureCase) {
final FailureCase f = ((FailureCase) reply.getResult());
- serializeObject(f.getNoPath(), buffer);
- if (f.getLspa() != null) {
+ if (f != null) {
+ serializeObject(f.getNoPath(), buffer);
serializeObject(f.getLspa(), buffer);
- }
- if (f.getBandwidth() != null) {
serializeObject(f.getBandwidth(), buffer);
- }
- if (f.getMetrics() != null && !f.getMetrics().isEmpty()) {
- for (final Metrics m : f.getMetrics()) {
- serializeObject(m.getMetric(), buffer);
+ if (f.getMetrics() != null && !f.getMetrics().isEmpty()) {
+ for (final Metrics m : f.getMetrics()) {
+ serializeObject(m.getMetric(), buffer);
+ }
}
- }
- if (f.getIro() != null) {
serializeObject(f.getIro(), buffer);
}
} else {
final SuccessCase s = (SuccessCase) reply.getResult();
- for (final Paths p : s.getSuccess().getPaths()) {
- serializeObject(p.getEro(), buffer);
- if (p.getLspa() != null) {
+ if (s != null) {
+ for (final Paths p : s.getSuccess().getPaths()) {
+ serializeObject(p.getEro(), buffer);
serializeObject(p.getLspa(), buffer);
- }
- if (p.getOf() != null) {
serializeObject(p.getOf(), buffer);
- }
- if (p.getBandwidth() != null) {
serializeObject(p.getBandwidth(), buffer);
- }
- if (p.getMetrics() != null && !p.getMetrics().isEmpty()) {
- for (final Metrics m : p.getMetrics()) {
- serializeObject(m.getMetric(), buffer);
+ if (p.getMetrics() != null && !p.getMetrics().isEmpty()) {
+ for (final Metrics m : p.getMetrics()) {
+ serializeObject(m.getMetric(), buffer);
+ }
}
- }
- if (p.getIro() != null) {
serializeObject(p.getIro(), buffer);
}
}
if (msg.getSvec() != null) {
for (final Svec s : msg.getSvec()) {
serializeObject(s.getSvec(), buffer);
- if (s.getOf() != null) {
- serializeObject(s.getOf(), buffer);
- }
- if (s.getGc() != null) {
- serializeObject(s.getGc(), buffer);
- }
- if (s.getXro() != null) {
- serializeObject(s.getXro(), buffer);
- }
+ serializeObject(s.getOf(), buffer);
+ serializeObject(s.getGc(), buffer);
+ serializeObject(s.getXro(), buffer);
if (s.getMetric() != null) {
for (final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.svec.Metric m : s.getMetric()) {
serializeObject(m.getMetric(), buffer);
}
protected void serializeP2P(final ByteBuf buffer, final P2p p2p) {
- if (p2p.getEndpointsObj() != null) {
- serializeObject(p2p.getEndpointsObj(), buffer);
- }
+ serializeObject(p2p.getEndpointsObj(), buffer);
serializeVendorInformationObjects(p2p.getVendorInformationObject(), buffer);
if (p2p.getReportedRoute() != null) {
final ReportedRoute rr = p2p.getReportedRoute();
- if (rr.getRro() != null) {
+ if (rr != null) {
serializeObject(rr.getRro(), buffer);
- }
- if (rr.getBandwidth() != null) {
serializeObject(rr.getBandwidth(), buffer);
}
}
- if (p2p.getLoadBalancing() != null) {
- serializeObject(p2p.getLoadBalancing(), buffer);
- }
- if (p2p.getLspa() != null) {
- serializeObject(p2p.getLspa(), buffer);
- }
- if (p2p.getBandwidth() != null) {
- serializeObject(p2p.getBandwidth(), buffer);
- }
+ serializeObject(p2p.getLoadBalancing(), buffer);
+ serializeObject(p2p.getLspa(), buffer);
+ serializeObject(p2p.getBandwidth(), buffer);
if (p2p.getMetrics() != null) {
for (final Metrics m : p2p.getMetrics()) {
serializeObject(m.getMetric(), buffer);
}
}
- if (p2p.getIro() != null) {
- serializeObject(p2p.getIro(), buffer);
- }
- if (p2p.getRro() != null) {
- serializeObject(p2p.getRro(), buffer);
- }
- if (p2p.getXro() != null) {
- serializeObject(p2p.getXro(), buffer);
- }
- if (p2p.getOf() != null) {
- serializeObject(p2p.getOf(), buffer);
- }
- if (p2p.getClassType() != null) {
- serializeObject(p2p.getClassType(), buffer);
- }
+ serializeObject(p2p.getIro(), buffer);
+ serializeObject(p2p.getRro(), buffer);
+ serializeObject(p2p.getXro(), buffer);
+ serializeObject(p2p.getOf(), buffer);
+ serializeObject(p2p.getClassType(), buffer);
}
@Override
public class SrPcInitiateMessageParser extends CInitiated00PCInitiateMessageParser {
- public SrPcInitiateMessageParser(ObjectRegistry registry) {
+ public SrPcInitiateMessageParser(final ObjectRegistry registry) {
super(registry);
}
@Override
- protected void serializeRequest(Requests req, ByteBuf buffer) {
+ protected void serializeRequest(final Requests req, final ByteBuf buffer) {
if (SrEroUtil.isSegmentRoutingPath(req.getEro())) {
serializeObject(SrEroUtil.addSRPathSetupTypeTlv(req.getSrp()), buffer);
- if (req.getLsp() != null) {
- serializeObject(req.getLsp(), buffer);
- }
+ serializeObject(req.getLsp(), buffer);
serializeObject(req.getEro(), buffer);
} else {
super.serializeRequest(req, buffer);
}
@Override
- protected Requests getValidRequest(List<Object> objects) {
+ protected Requests getValidRequest(final List<Object> objects) {
final Srp srp = (Srp) objects.get(0);
if (isSegmentRoutingPath(srp)) {
final RequestsBuilder builder = new RequestsBuilder();
public class SrPcUpdMessageParser extends Stateful07PCUpdateRequestMessageParser {
- public SrPcUpdMessageParser(ObjectRegistry registry) {
+ public SrPcUpdMessageParser(final ObjectRegistry registry) {
super(registry);
}
@Override
- protected void serializeUpdate(Updates update, ByteBuf buffer) {
+ protected void serializeUpdate(final Updates update, final ByteBuf buffer) {
if (update.getPath() != null && SrEroUtil.isSegmentRoutingPath(update.getPath().getEro())) {
serializeObject(SrEroUtil.addSRPathSetupTypeTlv(update.getSrp()), buffer);
- if (update.getLsp() != null) {
- serializeObject(update.getLsp(), buffer);
- }
+ serializeObject(update.getLsp(), buffer);
serializeObject(update.getPath().getEro(), buffer);
} else {
super.serializeUpdate(update, buffer);
}
@Override
- protected Updates getValidUpdates(List<Object> objects, List<Message> errors) {
+ protected Updates getValidUpdates(final List<Object> objects, final List<Message> errors) {
if (objects.get(0) instanceof Srp && isSegmentRoutingPath((Srp) objects.get(0))) {
boolean isValid = true;
final Srp srp = (Srp) objects.get(0);
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
-import com.google.common.collect.Lists;
import com.google.common.primitives.UnsignedBytes;
import io.netty.buffer.ByteBuf;
import java.util.ArrayList;
}
protected final List<VendorInformationObject> addVendorInformationObjects(final List<Object> objects) {
- final List<VendorInformationObject> vendorInfo = Lists.newArrayList();
+ final List<VendorInformationObject> vendorInfo = new ArrayList<>();
while (!objects.isEmpty() && objects.get(0) instanceof VendorInformationObject) {
final VendorInformationObject viObject = (VendorInformationObject) objects.get(0);
vendorInfo.add(viObject);