/**
* Function called by the dependency manager when all the required
* dependencies are satisfied
- *
+ *
*/
void init() {
this.controller.addMessageListener(OFType.PACKET_IN, this);
* Function called by the dependency manager when at least one dependency
* become unsatisfied or when the component is shutting down because for
* example bundle is being stopped.
- *
+ *
*/
void destroy() {
this.controller.removeMessageListener(OFType.PACKET_IN, this);
.get(GlobalConstants.DEFAULT.toString());
if (defaultOutService != null) {
defaultOutService.receiveDataPacket(dataPacket);
- logger.trace(
- "Dispatched to apps a frame of size: {} on container: {}: {}",
- new Object[] {
+ if (logger.isTraceEnabled()) {
+ logger.trace(
+ "Dispatched to apps a frame of size: {} on " +
+ "container: {}: {}", new Object[] {
ofPacket.getPacketData().length,
GlobalConstants.DEFAULT.toString(),
HexEncode.bytesToHexString(dataPacket
.getPacketData()) });
+ }
}
// Now check the mapping between nodeConnector and
// Container and later on optimally filter based on
if (s != null) {
// TODO add filtering on a per-flowSpec base
s.receiveDataPacket(dataPacket);
- logger.trace(
- "Dispatched to apps a frame of size: {} on container: {}: {}",
- new Object[] {
+ if (logger.isTraceEnabled()) {
+ logger.trace(
+ "Dispatched to apps a frame of size: {}" +
+ " on container: {}: {}", new Object[] {
ofPacket.getPacketData().length,
- GlobalConstants.DEFAULT.toString(),
- HexEncode
- .bytesToHexString(dataPacket
- .getPacketData()) });
-
+ container,
+ HexEncode.bytesToHexString(dataPacket
+ .getPacketData()) });
+ }
}
}
}
+ data.length);
po.setPacketData(data);
- sw.asyncSend(po);
+ // send PACKET_OUT at high priority
+ sw.asyncFastSend(po);
logger.trace("Transmitted a frame of size: {}", data.length);
}