OFDatagramPacketEncoder ofDatagramPacketEncoder = new OFDatagramPacketEncoder();
ofDatagramPacketEncoder.setSerializationFactory(getSerializationFactory());
ch.pipeline().addLast(PipelineHandlers.OF_ENCODER.name(), ofDatagramPacketEncoder);
-// connectionFacade.fireConnectionReadyNotification();
}
}
\ No newline at end of file
}
private void conditionalFlush(final ChannelHandlerContext ctx) {
- Preconditions.checkState(ctx.channel() == channel, "Inconsistent channel %s with context %s", channel, ctx);
+ Preconditions.checkState(ctx.channel().equals(channel), "Inconsistent channel %s with context %s", channel, ctx);
conditionalFlush();
}
private static final Exception QUEUE_FULL_EXCEPTION =
new RejectedExecutionException("Output queue is full");
- private static final String APPLICATION_TAG = "OPENFLOW_LIBRARY";
- private static final String TAG = "OPENFLOW";
private static final RemovalListener<RpcResponseKey, ResponseExpectedRpcListener<?>> REMOVAL_LISTENER =
new RemovalListener<RpcResponseKey, ResponseExpectedRpcListener<?>>() {
@Override
}
} else if (!outputClazz.equals(other.outputClazz)) {
return false;
-// if (xid != other.xid)
-// return false;
}
return true;
}
* Get instance of statistics counters, first created object does not start counting and log reporting
* @return an instance
*/
- public synchronized static StatisticsCounters getInstance() {
+ public static synchronized StatisticsCounters getInstance() {
if (instanceHolder == null) {
instanceHolder = new StatisticsCounters();
}
}
Iterable<String> tmp = Splitter.onPattern(splitPattern)
.omitEmptyStrings().split(hexSrc);
- ArrayList<String> byteChips = Lists.newArrayList(tmp);
+ List<String> byteChips = Lists.newArrayList(tmp);
byte[] result = new byte[byteChips.size()];
int i = 0;
for (String chip : byteChips) {