* if we don't. */
copy = *packet;
}
- flow_extract(©, in_port, &flow);
+ flow_extract(©, 0, in_port, &flow);
xflow_key_from_flow(&key, &flow);
error = xf_netdev_execute_actions(xf, ©, &key, actions, n_actions);
if (mutates) {
struct xflow_key key;
flow_t f;
- if (flow_extract(packet, port->port_no, &f) && xf->drop_frags) {
+ if (flow_extract(packet, 0, port->port_no, &f) && xf->drop_frags) {
xf->n_frags++;
return;
}
}
msg_size = sizeof *header + packet->size;
- msg = ofpbuf_new(msg_size);
+ msg = ofpbuf_new(msg_size + XFIF_RECV_MSG_PADDING);
header = ofpbuf_put_uninit(msg, sizeof *header);
+ ofpbuf_reserve(msg, XFIF_RECV_MSG_PADDING);
header->type = queue_no;
header->length = msg_size;
header->port = port_no;