uint32_t actionsLen;
PCHAR packetBuf;
PNL_ATTR actions;
+ PNL_ATTR *keyAttrs;
} OvsPacketExecute;
}
}
+NDIS_STATUS
+OvsGetFlowMetadata(OvsFlowKey *key,
+ PNL_ATTR *keyAttrs)
+{
+ NDIS_STATUS status = NDIS_STATUS_SUCCESS;
+
+ if (keyAttrs[OVS_KEY_ATTR_RECIRC_ID]) {
+ key->recircId = NlAttrGetU32(keyAttrs[OVS_KEY_ATTR_RECIRC_ID]);
+ key->l2.keyLen += sizeof(key->recircId);
+ }
+
+ if (keyAttrs[OVS_KEY_ATTR_DP_HASH]) {
+ key->dpHash = NlAttrGetU32(keyAttrs[OVS_KEY_ATTR_DP_HASH]);
+ key->l2.keyLen += sizeof(key->dpHash);
+ }
+
+ return status;
+}
+
/*
*----------------------------------------------------------------------------
* Initializes 'flow' members from 'packet', 'skb_priority', 'tun_id', and
NDIS_STATUS OvsAllocateFlowTable(OVS_DATAPATH *datapath,
POVS_SWITCH_CONTEXT switchContext);
+NDIS_STATUS OvsGetFlowMetadata(OvsFlowKey *key,
+ PNL_ATTR *keyAttrs);
NDIS_STATUS OvsExtractFlow(const NET_BUFFER_LIST *pkt, UINT32 inPort,
OvsFlowKey *flow, POVS_PACKET_HDR_INFO layers,
OvsIPv4TunnelKey *tunKey);
execute->actionsLen = NlAttrGetSize(nlAttrs[OVS_PACKET_ATTR_ACTIONS]);
execute->inPort = NlAttrGetU32(keyAttrs[OVS_KEY_ATTR_IN_PORT]);
+ execute->keyAttrs = keyAttrs;
}
NTSTATUS
}
// XXX: Figure out if any of the other members of fwdDetail need to be set.
+ status = OvsGetFlowMetadata(&key, execute->keyAttrs);
+ if (status != STATUS_SUCCESS) {
+ goto dropit;
+ }
+
ndisStatus = OvsExtractFlow(pNbl, fwdDetail->SourcePortId, &key, &layers,
NULL);
if (ndisStatus == NDIS_STATUS_SUCCESS) {
}
}
+dropit:
if (pNbl) {
OvsCompleteNBL(gOvsSwitchContext, pNbl, TRUE);
}