| 1163 | } |
| 1164 | |
| 1165 | static void |
| 1166 | dsw_port_ctl_process(struct dsw_evdev *dsw, struct dsw_port *port) |
| 1167 | { |
| 1168 | struct dsw_ctl_msg msg; |
| 1169 | |
| 1170 | if (dsw_port_ctl_dequeue(port, &msg) == 0) { |
| 1171 | switch (msg.type) { |
| 1172 | case DSW_CTL_PAUS_REQ: |
| 1173 | dsw_port_handle_pause_flows(dsw, port, |
| 1174 | msg.originating_port_id, |
| 1175 | msg.qfs, msg.qfs_len); |
| 1176 | break; |
| 1177 | case DSW_CTL_UNPAUS_REQ: |
| 1178 | dsw_port_handle_unpause_flows(dsw, port, |
| 1179 | msg.originating_port_id, |
| 1180 | msg.qfs, msg.qfs_len); |
| 1181 | break; |
| 1182 | case DSW_CTL_CFM: |
| 1183 | dsw_port_handle_confirm(dsw, port); |
| 1184 | break; |
| 1185 | } |
| 1186 | } |
| 1187 | } |
| 1188 | |
| 1189 | static void |
| 1190 | dsw_port_note_op(struct dsw_port *port, uint16_t num_events) |
no test coverage detected