这里调用的是 BasicFactory 的 parseMessage 方法,一次处理一个of msg,然后添加到链表中,这里重要的条件就是 openflow header 的长度和消息类型,然后调用枚举类型中个体的newinstance()方法生成对应的OFMessage。
public List< OFMessage>
parseMessage(ChannelBuffer data) throws MessageParseException {
List<OFMessage>
msglist = new ArrayList< OFMessage>();
OFMessage msg = null;
while (data.readableBytes()
>= OFMessage.MINIMUM_LENGTH) {
data.markReaderIndex();
msg = this .parseMessageOne(data);
if (msg
== null ) {
data.resetReaderIndex();
break ;
}
else {
msglist.add(msg);
}
}
if (msglist.size()
== 0) {
return null ;
}
return msglist;
}