diff options
| author | OHMURA Kei <ohmura.kei@lab.ntt.co.jp> | 2013-04-17 12:19:12 +0900 |
|---|---|---|
| committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2013-04-18 09:38:35 +0900 |
| commit | fc161ff848645ae9ec9383c22fe1137c2c65805d (patch) | |
| tree | 009e4a2a8dd6c3b38e73eac53642647bd71b23c0 | |
| parent | fd7723eaa1e02b91ff7db07ddd5521bb9bd56d00 (diff) | |
of1.0: add nx_match to NXFlowStatsRequest
Signed-off-by: OHMURA Kei <ohmura.kei@lab.ntt.co.jp>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
| -rw-r--r-- | ryu/ofproto/ofproto_v1_0_parser.py | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/ryu/ofproto/ofproto_v1_0_parser.py b/ryu/ofproto/ofproto_v1_0_parser.py index f9673fba..79458887 100644 --- a/ryu/ofproto/ofproto_v1_0_parser.py +++ b/ryu/ofproto/ofproto_v1_0_parser.py @@ -2194,15 +2194,21 @@ class NXStatsRequest(OFPVendorStatsRequest): class NXFlowStatsRequest(NXStatsRequest): - def __init__(self, datapath, flags, out_port, match_len, - table_id): + def __init__(self, datapath, flags, out_port, table_id, rule=None): super(NXFlowStatsRequest, self).__init__(datapath, flags, ofproto_v1_0.NXST_FLOW) self.out_port = out_port - self.match_len = match_len self.table_id = table_id + self.rule = rule + self.match_len = 0 def _serialize_vendor_stats_body(self): + if self.rule is not None: + offset = ofproto_v1_0.NX_STATS_MSG_SIZE + \ + ofproto_v1_0.NX_FLOW_STATS_REQUEST_SIZE + self.match_len = nx_match.serialize_nxm_match( + self.rule, self.buf, offset) + msg_pack_into( ofproto_v1_0.NX_FLOW_STATS_REQUEST_PACK_STR, self.buf, ofproto_v1_0.NX_STATS_MSG_SIZE, self.out_port, |