diff options
| author | Minoru TAKAHASHI <takahashi.minoru7@gmail.com> | 2015-07-30 13:39:45 +0900 |
|---|---|---|
| committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2015-07-31 08:31:12 +0900 |
| commit | ebb87b4e0304ee9d119f10842a5b54bfb8faa233 (patch) | |
| tree | 2a11d7885c411e09c39f6cf99490f18218513fd7 | |
| parent | d0733220f391d861c110ea76541d98be8f625fc8 (diff) | |
of1.5: port statistics and port descriptions use a common request format
Signed-off-by: Minoru TAKAHASHI <takahashi.minoru7@gmail.com>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
| -rw-r--r-- | ryu/ofproto/ofproto_v1_5_parser.py | 17 |
1 files changed, 13 insertions, 4 deletions
diff --git a/ryu/ofproto/ofproto_v1_5_parser.py b/ryu/ofproto/ofproto_v1_5_parser.py index 8587e6f7..d8307d7c 100644 --- a/ryu/ofproto/ofproto_v1_5_parser.py +++ b/ryu/ofproto/ofproto_v1_5_parser.py @@ -2744,24 +2744,33 @@ class OFPPortDescStatsRequest(OFPMultipartRequest): """ Port description request message - The controller uses this message to query description of all the ports. + The controller uses this message to query description of one or all the ports. ================ ====================================================== Attribute Description ================ ====================================================== flags Zero or ``OFPMPF_REQ_MORE`` + port_no Port number to read (OFPP_ANY to all ports) ================ ====================================================== Example:: def send_port_desc_stats_request(self, datapath): + ofp = datapath.ofproto ofp_parser = datapath.ofproto_parser - req = ofp_parser.OFPPortDescStatsRequest(datapath, 0) + req = ofp_parser.OFPPortDescStatsRequest(datapath, 0, ofp.OFPP_ANY) datapath.send_msg(req) """ - def __init__(self, datapath, flags=0, type_=None): + def __init__(self, datapath, flags=0, port_no=ofproto.OFPP_ANY, type_=None): super(OFPPortDescStatsRequest, self).__init__(datapath, flags) + self.port_no = port_no + + def _serialize_stats_body(self): + msg_pack_into(ofproto.OFP_PORT_MULTIPART_REQUEST_PACK_STR, + self.buf, + ofproto.OFP_MULTIPART_REQUEST_SIZE, + self.port_no) @OFPMultipartReply.register_stats_type() @@ -4509,7 +4518,7 @@ class OFPPortStatsRequest(OFPMultipartRequest): self.port_no = port_no def _serialize_stats_body(self): - msg_pack_into(ofproto.OFP_PORT_STATS_REQUEST_PACK_STR, + msg_pack_into(ofproto.OFP_PORT_MULTIPART_REQUEST_PACK_STR, self.buf, ofproto.OFP_MULTIPART_REQUEST_SIZE, self.port_no) |