Ryu 控制器丢包
Ryu Controller Drop Packet
如何使用Ryu 发送流条目来丢弃包裹?我从教程中学习了如何将包发送到流入口:
- 我定义动作:
actions = [ofp_parser.OFPActionOutput(ofp.OFPP_FLOOD)]
- 然后条目本身:
out = ofp_parser.OFPPacketOut(datapath=dp, buffer_id=msg.buffer_id, in_port=msg.in_port,actions=actions)
- 发送消息到交换机:
dp.send_msg(out)
我正在尝试找到使此代码丢弃包而不是泛洪的文档,但没有成功。我想我必须在第一步更改操作,在第二步更改 fp_parser.OFPPacketOut
。我需要一个对 Ryu 更有经验并发展自己的人来为我指明正确的方向。谢谢。
OpenFlow 中数据包的默认处理方式是丢弃数据包。因此,如果您有一个流规则,当它匹配时您想要丢弃数据包,您应该只使用 CLEAR_ACTIONS 的指令,然后没有其他指令,这意味着不会处理其他 tables因为没有处理(转到)另一个 table 的指令,也没有对其执行任何操作。
请记住您的流程优先级。如果您有多个流规则将匹配数据包,则具有最高优先级的规则将生效。因此,您的 "drop packet" 可能隐藏在更高优先级的流规则之后。
这是我的一些代码,假设没有更高优先级的数据包匹配,它将丢弃与给定 EtherType 匹配的所有流量。该函数依赖于几个实例变量,即 datapath、proto 和 parser。 =11=]
def dropEthType(self,
match_eth_type = 0x0800):
parser = self.parser
proto = self.proto
match = parser.OFPMatch(eth_type = match_eth_type)
instruction = [
parser.OFPInstructionActions(proto.OFPIT_CLEAR_ACTIONS, [])
]
msg = parser.OFPFlowMod(self.datapath,
table_id = OFDPA_FLOW_TABLE_ID_ACL_POLICY,
priority = 1,
command = proto.OFPFC_ADD,
match = match,
instructions = instruction
)
self._log("dropEthType : %s" % str(msg))
reply = api.send_msg(self.ryuapp, msg)
if reply:
raise Exception
如何使用Ryu 发送流条目来丢弃包裹?我从教程中学习了如何将包发送到流入口:
- 我定义动作:
actions = [ofp_parser.OFPActionOutput(ofp.OFPP_FLOOD)]
- 然后条目本身:
out = ofp_parser.OFPPacketOut(datapath=dp, buffer_id=msg.buffer_id, in_port=msg.in_port,actions=actions)
- 发送消息到交换机:
dp.send_msg(out)
我正在尝试找到使此代码丢弃包而不是泛洪的文档,但没有成功。我想我必须在第一步更改操作,在第二步更改 fp_parser.OFPPacketOut
。我需要一个对 Ryu 更有经验并发展自己的人来为我指明正确的方向。谢谢。
OpenFlow 中数据包的默认处理方式是丢弃数据包。因此,如果您有一个流规则,当它匹配时您想要丢弃数据包,您应该只使用 CLEAR_ACTIONS 的指令,然后没有其他指令,这意味着不会处理其他 tables因为没有处理(转到)另一个 table 的指令,也没有对其执行任何操作。
请记住您的流程优先级。如果您有多个流规则将匹配数据包,则具有最高优先级的规则将生效。因此,您的 "drop packet" 可能隐藏在更高优先级的流规则之后。
这是我的一些代码,假设没有更高优先级的数据包匹配,它将丢弃与给定 EtherType 匹配的所有流量。该函数依赖于几个实例变量,即 datapath、proto 和 parser。 =11=]
def dropEthType(self,
match_eth_type = 0x0800):
parser = self.parser
proto = self.proto
match = parser.OFPMatch(eth_type = match_eth_type)
instruction = [
parser.OFPInstructionActions(proto.OFPIT_CLEAR_ACTIONS, [])
]
msg = parser.OFPFlowMod(self.datapath,
table_id = OFDPA_FLOW_TABLE_ID_ACL_POLICY,
priority = 1,
command = proto.OFPFC_ADD,
match = match,
instructions = instruction
)
self._log("dropEthType : %s" % str(msg))
reply = api.send_msg(self.ryuapp, msg)
if reply:
raise Exception