if (peerDown.isLocalSystemClosed()) {
if (peerDown.getData() instanceof FsmEventCode) {
ByteBufWriteUtil.writeUnsignedByte(REASON_TWO.getValue(), buffer);
- ByteBufWriteUtil.writeUnsignedShort(((FsmEventCode) peerDown.getData()).getFsmEventCode().intValue(), buffer);
+ ByteBufWriteUtil.writeUnsignedShort(((FsmEventCode) peerDown.getData()).getFsmEventCode(), buffer);
} else if (peerDown.getData() instanceof
org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev150512.peer.down.data.Notification) {
ByteBufWriteUtil.writeUnsignedByte(REASON_ONE.getValue(), buffer);
"The extended community %s is not TrafficMarkingExtendedCommunity type.", extendedCommunity);
final TrafficMarkingExtendedCommunity trafficMarking = ((org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.flowspec.rev150807.TrafficMarkingExtendedCommunity) extendedCommunity).getTrafficMarkingExtendedCommunity();
byteAggregator.writeZero(RESERVED);
- ByteBufWriteUtil.writeUnsignedByte(trafficMarking.getGlobalAdministrator().getValue().shortValue(), byteAggregator);
+ ByteBufWriteUtil.writeUnsignedByte(trafficMarking.getGlobalAdministrator().getValue(), byteAggregator);
}
@Override
private static FlowspecType createLabel() {
final List<FlowLabel> labels = new ArrayList<>(2);
- labels.add(new FlowLabelBuilder().setOp(new NumericOperand(false, false, true, false, false)).setValue(new Long(16777222L)).build());
- labels.add(new FlowLabelBuilder().setOp(new NumericOperand(false, true, true, false, false)).setValue(new Long(258L)).build());
+ labels.add(new FlowLabelBuilder().setOp(new NumericOperand(false, false, true, false, false)).setValue(16777222L).build());
+ labels.add(new FlowLabelBuilder().setOp(new NumericOperand(false, true, true, false, false)).setValue(258L).build());
return new FlowLabelCaseBuilder().setFlowLabel(labels).build();
}
private static FlowspecType createLabel() {
final List<FlowLabel> labels = new ArrayList<>(2);
- labels.add(new FlowLabelBuilder().setOp(new NumericOperand(false, false, true, false, false)).setValue(new Long(16777222L)).build());
- labels.add(new FlowLabelBuilder().setOp(new NumericOperand(false, true, true, false, false)).setValue(new Long(258L)).build());
+ labels.add(new FlowLabelBuilder().setOp(new NumericOperand(false, false, true, false, false)).setValue(16777222L).build());
+ labels.add(new FlowLabelBuilder().setOp(new NumericOperand(false, true, true, false, false)).setValue(258L).build());
return new FlowLabelCaseBuilder().setFlowLabel(labels).build();
}
assertEquals(UNRECOGNIZED_ATTRIBUTE_COUNT, unrecogAttribs.size());
final UnrecognizedAttributes unrecogAttrib = unrecogAttribs.get(FIRST_ATTRIBUTE);
final UnrecognizedAttributesKey expectedAttribKey =
- new UnrecognizedAttributesKey(unrecogAttrib.getType().shortValue());
+ new UnrecognizedAttributesKey(unrecogAttrib.getType());
assertTrue(unrecogAttrib.isPartial());
assertTrue(unrecogAttrib.isTransitive());
final BGPProtocolSessionPromise<?> lock = this;
try {
- LOG.debug("Promise {} attempting connect for {}ms", lock, Integer.valueOf(CONNECT_TIMEOUT));
+ LOG.debug("Promise {} attempting connect for {}ms", lock, CONNECT_TIMEOUT);
if (this.address.isUnresolved()) {
this.address = new InetSocketAddress(this.address.getHostName(), this.address.getPort());
}
assertEquals(BGP_ID.getValue(), state.getLocalPeerPreferences().getBgpId().getValue());
assertEquals(1, state.getLocalPeerPreferences().getAdvertizedTableTypes().size());
assertEquals(HOLD_TIMER, state.getLocalPeerPreferences().getHoldtimer().intValue());
- assertTrue(state.getLocalPeerPreferences().getFourOctetAsCapability().booleanValue());
- assertTrue(state.getLocalPeerPreferences().getBgpExtendedMessageCapability().booleanValue());
+ assertTrue(state.getLocalPeerPreferences().getFourOctetAsCapability());
+ assertTrue(state.getLocalPeerPreferences().getBgpExtendedMessageCapability());
assertTrue(state.getLocalPeerPreferences().getGrCapability());
assertEquals(LOCAL_IP, new String(state.getRemotePeerPreferences().getHost().getValue()));
assertEquals(LOCAL_PORT, state.getRemotePeerPreferences().getPort().getValue().intValue());
final UriBuilder c = new UriBuilder(b, "foo");
assertEquals("bgpls://1:Direct:10/type=foo", c.toString());
- a.add("foo", new Long(25L));
+ a.add("foo", 25L);
assertEquals("bgpls://Direct:10/&foo=25", a.toString());
final LinkCaseBuilder linkB = new LinkCaseBuilder();
assertEquals(Integer.valueOf(22), registry.get("second"));
- registry.register(Character.valueOf('c'), 5);
+ registry.register('c', 5);
assertEquals(Integer.valueOf(5), registry.get('c'));
final MultiRegistry<Object, Number> registry = new MultiRegistry<>();
final String first = "first";
- registry.register(first, new Integer(1));
- assertEquals(Integer.valueOf(1), registry.get("first"));
+ registry.register(first, 1);
+ assertEquals(1, registry.get("first"));
- registry.register(first, new Short((short) 1));
- assertEquals(Integer.valueOf(1), registry.get("first"));
+ registry.register(first, (short) 1);
+ assertEquals(1, registry.get("first"));
- registry.register(first, new Short((short) 2));
- assertEquals(Integer.valueOf(1), registry.get("first"));
+ registry.register(first, (short) 2);
+ assertEquals(1, registry.get("first"));
}
@Test
final String first = "first";
final String second = "second";
- registry.register(first, new Integer(1));
- assertEquals(Integer.valueOf(1), registry.get("first"));
+ registry.register(first, 1);
+ assertEquals(1, registry.get("first"));
- registry.register(first, new Character('1'));
- assertEquals(Integer.valueOf(1), registry.get("first"));
+ registry.register(first, '1');
+ assertEquals(1, registry.get("first"));
- registry.register(second, new Character('2'));
- assertEquals(Character.valueOf('2'), registry.get("second"));
+ registry.register(second, '2');
+ assertEquals('2', registry.get("second"));
- registry.register(second, new Integer(2));
- assertEquals(Character.valueOf('2'), registry.get("second"));
+ registry.register(second, 2);
+ assertEquals('2', registry.get("second"));
registry.register(second, new Object());
- assertEquals(Character.valueOf('2'), registry.get("second"));
+ assertEquals('2', registry.get("second"));
}
}
flags.set(E_FLAG_OFFSET, rpObj.isEroCompression());
final byte[] res = flags.array();
if (rpObj.getPriority() != null) {
- final byte p = UnsignedBytes.checkedCast(rpObj.getPriority().shortValue());
+ final byte p = UnsignedBytes.checkedCast(rpObj.getPriority());
res[res.length -1] = (byte) (res[res.length -1] | p);
}
body.writeBytes(res);
final PCEPProtocolSessionPromise<?> lock = this;
try {
- LOG.debug("Promise {} attempting connect for {}ms", lock, Integer.valueOf(this.connectTimeout));
+ LOG.debug("Promise {} attempting connect for {}ms", lock, this.connectTimeout);
if (this.address.isUnresolved()) {
this.address = new InetSocketAddress(this.address.getHostName(), this.address.getPort());
}
} else if (args[argIdx].equals("--password")) {
password = args[++argIdx];
} else if (args[argIdx].equals("--reconnect")) {
- reconnectTime = Integer.valueOf(args[++argIdx]).intValue();
+ reconnectTime = Integer.valueOf(args[++argIdx]);
} else if (args[argIdx].equals("--redelegation-timeout")) {
redelegationTimeout = Integer.valueOf(args[++argIdx]);
} else if (args[argIdx].equals("--state-timeout")) {
for (final Reports report : pcrt) {
final Lsp lsp = report.getLsp();
if (lsp.getPlspId().getValue() == 0) {
- assertEquals(false, lsp.isSync().booleanValue());
+ assertEquals(false, lsp.isSync());
} else {
- assertEquals(true, lsp.isSync().booleanValue());
+ assertEquals(true, lsp.isSync());
}
final BigInteger actuaLspDBVersion = lsp.getTlvs().getAugmentation(org.opendaylight.yang.gen
.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev150714.Tlvs1.class)
* @return true if setup is via RSVP-TE signaling protocol
*/
public static boolean isDefaultPST(final PathSetupType pst) {
- if (pst != null && pst.getPst() != null && pst.getPst().shortValue() != 0) {
+ if (pst != null && pst.getPst() != null && pst.getPst() != 0) {
return false;
}
return true;
Code Review / bgpcep.git / commitdiff