- LOG.debug("PortStatusMessage: version {} dataPathId {} portNo {}",version, datapathId,portNo);
- list.add(PortTranslatorUtil.translatePort(version, datapathId, portNo, port));
+ if(port.getReason() == PortReason.OFPPRDELETE){
+ LOG.debug("PortStatusMessage: version {} dataPathId {} portNo {} reason {}",version, datapathId,portNo,port.getReason());
+ list.add(PortTranslatorUtil.translatePortRemoved(version, datapathId, portNo, port));
+
+ }else{
+ LOG.debug("PortStatusMessage: version {} dataPathId {} portNo {}",version, datapathId,portNo);
+ list.add(PortTranslatorUtil.translatePort(version, datapathId, portNo, port));
+ }