| @@ 168-184 (lines=17) @@ | ||
| 165 | return message |
|
| 166 | ||
| 167 | ||
| 168 | def unpack_message(buffer): |
|
| 169 | """Unpack the whole buffer, including header pack. |
|
| 170 | ||
| 171 | Args: |
|
| 172 | buffer (bytes): Bytes representation of a openflow message. |
|
| 173 | ||
| 174 | Returns: |
|
| 175 | object: Instance of openflow message. |
|
| 176 | ||
| 177 | """ |
|
| 178 | hdr_size = Header().get_size() |
|
| 179 | hdr_buff, msg_buff = buffer[:hdr_size], buffer[hdr_size:] |
|
| 180 | header = Header() |
|
| 181 | header.unpack(hdr_buff) |
|
| 182 | message = new_message_from_header(header) |
|
| 183 | message.unpack(msg_buff) |
|
| 184 | return message |
|
| 185 | ||
| @@ 123-139 (lines=17) @@ | ||
| 120 | return message |
|
| 121 | ||
| 122 | ||
| 123 | def unpack_message(buffer): |
|
| 124 | """Unpack the whole buffer, including header pack. |
|
| 125 | ||
| 126 | Args: |
|
| 127 | buffer (bytes): Bytes representation of a openflow message. |
|
| 128 | ||
| 129 | Returns: |
|
| 130 | object: Instance of openflow message. |
|
| 131 | ||
| 132 | """ |
|
| 133 | hdr_size = Header().get_size() |
|
| 134 | hdr_buff, msg_buff = buffer[:hdr_size], buffer[hdr_size:] |
|
| 135 | header = Header() |
|
| 136 | header.unpack(hdr_buff) |
|
| 137 | message = new_message_from_header(header) |
|
| 138 | message.unpack(msg_buff) |
|
| 139 | return message |
|
| 140 | ||