Port # doesn't make much sense since it has not been computed yet.
Also, get rid of OVS_DEFAULT_PORT_NO and use OVS_DPPORT_NUMBER_INVALID
instead.
Signed-off-by: Nithin Raju <nithin@vmware.com>
Acked-by: Sairam Venugopal <vsairam@vmware.com>
Acked-by: Alin Gabriel Serdean <aserdean@cloudbasesolutions.com>
Signed-off-by: Gurucharan Shetty <guru@ovn.org>
* If the packet will not be encapsulated, consume the tunnel context
* by clearing it.
*/
- if (ovsFwdCtx->srcVportNo != OVS_DEFAULT_PORT_NO) {
+ if (ovsFwdCtx->srcVportNo != OVS_DPPORT_NUMBER_INVALID) {
POVS_VPORT_ENTRY vport = OvsFindVportByPortNo(
ovsFwdCtx->switchContext, ovsFwdCtx->srcVportNo);
#include "Flow.h"
#include "Checksum.h"
#include "PacketParser.h"
+#include "Vport.h"
/*
* --------------------------------------------------------------------------
OvsInitNBLContext(ctx, OVS_BUFFER_FROM_FIX_SIZE_POOL |
OVS_BUFFER_PRIVATE_FORWARD_CONTEXT, size,
- OVS_DEFAULT_PORT_NO);
+ OVS_DPPORT_NUMBER_INVALID);
line = __LINE__;
allocate_done:
OVS_LOG_LOUD("Allocate Fix NBL: %p, line: %d", nbl, line);
OvsInitNBLContext(ctx, OVS_BUFFER_PRIVATE_MDL | OVS_BUFFER_PRIVATE_DATA |
OVS_BUFFER_PRIVATE_FORWARD_CONTEXT |
OVS_BUFFER_FROM_ZERO_SIZE_POOL,
- size, OVS_DEFAULT_PORT_NO);
+ size, OVS_DPPORT_NUMBER_INVALID);
OVS_LOG_LOUD("Allocate variable size NBL: %p", nbl);
return nbl;
* we use first nb to decide whether we need advance or retreat during
* complete.
*/
- OvsInitNBLContext(ctx, flags, NET_BUFFER_DATA_LENGTH(nb), OVS_DEFAULT_PORT_NO);
+ OvsInitNBLContext(ctx, flags, NET_BUFFER_DATA_LENGTH(nb),
+ OVS_DPPORT_NUMBER_INVALID);
return ctx;
}
srcNb = NET_BUFFER_LIST_FIRST_NB(nbl);
OvsInitNBLContext(dstCtx, flags, NET_BUFFER_DATA_LENGTH(srcNb) - copySize,
- OVS_DEFAULT_PORT_NO);
+ OVS_DPPORT_NUMBER_INVALID);
InterlockedIncrement((LONG volatile *)&srcCtx->refCount);
OVS_BUFFER_PRIVATE_FORWARD_CONTEXT;
OvsInitNBLContext(dstCtx, flags, NET_BUFFER_DATA_LENGTH(firstNb),
- OVS_DEFAULT_PORT_NO);
+ OVS_DPPORT_NUMBER_INVALID);
#ifdef DBG
OvsDumpNetBufferList(nbl);
UINT32 type;
} OVS_EVENT_ENTRY, *POVS_EVENT_ENTRY;
-#define OVS_DEFAULT_PORT_NO 0xffffffff
-#define OVS_DEFAULT_EVENT_STATUS 0xffffffff
typedef struct _OVS_EVENT_STATUS {
uint32_t numberEntries;
* queued.
*/
static BOOLEAN ovsInternalIPConfigured;
-static UINT32 ovsInternalPortNo;
+static BOOLEAN ovsInternalAdapterUp;
static GUID ovsInternalNetCfgId;
static MIB_IF_ROW2 ovsInternalRow;
static MIB_IPINTERFACE_ROW ovsInternalIPRow;
OvsInternalAdapterDown(VOID)
{
NdisAcquireSpinLock(&ovsIpHelperLock);
- ovsInternalPortNo = OVS_DEFAULT_PORT_NO;
+ ovsInternalAdapterUp = FALSE;
ovsInternalIPConfigured = FALSE;
NdisReleaseSpinLock(&ovsIpHelperLock);
VOID
-OvsInternalAdapterUp(UINT32 portNo,
- GUID *netCfgInstanceId)
+OvsInternalAdapterUp(GUID *netCfgInstanceId)
{
POVS_IP_HELPER_REQUEST request;
request->command = OVS_IP_HELPER_INTERNAL_ADAPTER_UP;
NdisAcquireSpinLock(&ovsIpHelperLock);
- ovsInternalPortNo = portNo;
+ ovsInternalAdapterUp = TRUE;
InsertHeadList(&ovsIpHelperRequestList, &request->link);
ovsNumIpHelperRequests++;
if (ovsNumIpHelperRequests == 1) {
NdisAcquireSpinLock(&ovsIpHelperLock);
- if (ovsInternalPortNo == OVS_DEFAULT_PORT_NO ||
+ if (ovsInternalAdapterUp == FALSE ||
ovsInternalIPConfigured == FALSE) {
NdisReleaseSpinLock(&ovsIpHelperLock);
OvsFreeMemoryWithTag(request, OVS_IPHELPER_POOL_TAG);
RtlZeroMemory(&ovsInternalIPRow, sizeof (MIB_IPINTERFACE_ROW));
ovsInternalIP = 0;
- ovsInternalPortNo = OVS_DEFAULT_PORT_NO;
+ ovsInternalAdapterUp = FALSE;
InitializeListHead(&ovsSortedIPNeighList);
NTSTATUS OvsInitIpHelper(NDIS_HANDLE ndisFilterHandle);
VOID OvsCleanupIpHelper(VOID);
-VOID OvsInternalAdapterUp(UINT32 portNo, GUID *netCfgInstanceId);
+VOID OvsInternalAdapterUp(GUID *netCfgInstanceId);
VOID OvsInternalAdapterDown(VOID);
NTSTATUS OvsFwdIPHelperRequest(PNET_BUFFER_LIST nbl, UINT32 inPort,
OvsClearAllSwitchVports(switchContext);
goto cleanup;
}
- // OvsPostEvent(OVS_DEFAULT_PORT_NO, OVS_DEFAULT_EVENT_STATUS);
cleanup:
if (status != NDIS_STATUS_SUCCESS) {
NdisAcquireRWLockRead(gOvsSwitchContext->dispatchLock, &lockState, 0);
ndisStatus = OvsActionsExecute(gOvsSwitchContext, NULL, pNbl,
vport ? vport->portNo :
- OVS_DEFAULT_PORT_NO,
+ OVS_DPPORT_NUMBER_INVALID,
NDIS_SEND_FLAGS_SWITCH_DESTINATION_GROUP,
&key, NULL, &layers, actions,
execute->actionsLen);
status = OvsReadDpIoctl(instance->fileObject, usrParamsCtx->outputBuffer,
usrParamsCtx->outputLength, replyLen);
return status;
-}
\ No newline at end of file
+}
NdisReleaseRWLock(switchContext->dispatchLock, &lockState);
if (nicParam->NicType == NdisSwitchNicTypeInternal) {
- OvsInternalAdapterUp(portNo, &nicParam->NetCfgInstanceId);
+ OvsInternalAdapterUp(&nicParam->NetCfgInstanceId);
}
done: