From 91a15eccfd85d9ededc20737c88d4841bf330144 Mon Sep 17 00:00:00 2001 From: Sean Hefty Date: Mon, 26 Jul 2010 16:39:09 -0700 Subject: [PATCH] nd: convert use of SGE to Sge The latest ND spec uses Sge instead of SGE. Update the implementation to match. Signed-off-by: Sean Hefty --- trunk/ulp/netdirect2/user/nd_adapter.cpp | 6 +++--- trunk/ulp/netdirect2/user/nd_qp.cpp | 16 ++++++++-------- trunk/ulp/netdirect2/user/nd_qp.h | 14 +++++++------- trunk/ulp/netdirect2/user/nd_srq.cpp | 4 ++-- trunk/ulp/netdirect2/user/nd_srq.h | 8 ++++---- 5 files changed, 24 insertions(+), 24 deletions(-) diff --git a/trunk/ulp/netdirect2/user/nd_adapter.cpp b/trunk/ulp/netdirect2/user/nd_adapter.cpp index 1e40058f..73941447 100644 --- a/trunk/ulp/netdirect2/user/nd_adapter.cpp +++ b/trunk/ulp/netdirect2/user/nd_adapter.cpp @@ -135,9 +135,9 @@ Query(ND_ADAPTER_INFO* pInfo, SIZE_T* pcbInfo) pInfo->AdapterId = m_DeviceGuid; pInfo->MaxRegistrationSize = attr.MaxMrSize; pInfo->MaxWindowSize = attr.MaxMrSize; - pInfo->MaxReceiveSGE = (DWORD) attr.MaxSge; - pInfo->MaxInitiatorSGE = (DWORD) attr.MaxSge; - pInfo->MaxReadSGE = (DWORD) attr.MaxSge; + pInfo->MaxReceiveSge = (DWORD) attr.MaxSge; + pInfo->MaxInitiatorSge = (DWORD) attr.MaxSge; + pInfo->MaxReadSge = (DWORD) attr.MaxSge; pInfo->MaxTransferLength = 1 << 31; pInfo->MaxInboundReadLimit = (DWORD) attr.MaxQpResponderResources; pInfo->MaxOutboundReadLimit = (DWORD) attr.MaxQpInitiatorDepth; diff --git a/trunk/ulp/netdirect2/user/nd_qp.cpp b/trunk/ulp/netdirect2/user/nd_qp.cpp index 64735404..d045d120 100644 --- a/trunk/ulp/netdirect2/user/nd_qp.cpp +++ b/trunk/ulp/netdirect2/user/nd_qp.cpp @@ -173,21 +173,21 @@ ConvertSendFlags(DWORD Flags) } STDMETHODIMP CNDQueuePair:: -Send(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE, DWORD flags) +Send(VOID* requestContext, const ND_SGE* pSge, DWORD nSge, DWORD flags) { HRESULT hr; - hr = m_pWvQp->Send((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSGE, nSGE, + hr = m_pWvQp->Send((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSge, nSge, ConvertSendFlags(flags), 0); return NDConvertWVStatus(hr); } STDMETHODIMP CNDQueuePair:: -Receive(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE) +Receive(VOID* requestContext, const ND_SGE* pSge, DWORD nSge) { HRESULT hr; - hr = m_pWvQp->PostReceive((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSGE, nSGE); + hr = m_pWvQp->PostReceive((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSge, nSge); return NDConvertWVStatus(hr); } @@ -224,25 +224,25 @@ Invalidate(VOID* requestContext, INDMemoryWindow* pMemoryWindow, DWORD flags) } STDMETHODIMP CNDQueuePair:: -Read(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE, +Read(VOID* requestContext, const ND_SGE* pSge, DWORD nSge, UINT64 remoteAddress, UINT32 remoteToken, DWORD flags) { DWORD opts; HRESULT hr; - hr = m_pWvQp->Read((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSGE, nSGE, + hr = m_pWvQp->Read((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSge, nSge, ConvertSendFlags(flags), htonll(remoteAddress), remoteToken); return NDConvertWVStatus(hr); } STDMETHODIMP CNDQueuePair:: -Write(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE, +Write(VOID* requestContext, const ND_SGE* pSge, DWORD nSge, UINT64 remoteAddress, UINT32 remoteToken, DWORD flags) { DWORD opts; HRESULT hr; - hr = m_pWvQp->Write((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSGE, nSGE, + hr = m_pWvQp->Write((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSge, nSge, ConvertSendFlags(flags), 0, htonll(remoteAddress), remoteToken); return NDConvertWVStatus(hr); } diff --git a/trunk/ulp/netdirect2/user/nd_qp.h b/trunk/ulp/netdirect2/user/nd_qp.h index 3ce320ff..48adc805 100644 --- a/trunk/ulp/netdirect2/user/nd_qp.h +++ b/trunk/ulp/netdirect2/user/nd_qp.h @@ -50,15 +50,15 @@ public: // INDQueuePair methods STDMETHODIMP Flush(); - STDMETHODIMP Send(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE, DWORD flags); - STDMETHODIMP Receive(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE); + STDMETHODIMP Send(VOID* requestContext, const ND_SGE* pSge, DWORD nSge, DWORD flags); + STDMETHODIMP Receive(VOID* requestContext, const ND_SGE* pSge, DWORD nSge); STDMETHODIMP Bind(VOID* requestContext, INDMemoryRegion* pMemoryRegion, INDMemoryWindow* pMemoryWindow, const VOID* pBuffer, SIZE_T cbBuffer, DWORD flags); STDMETHODIMP Invalidate(VOID* requestContext, INDMemoryWindow* pMemoryWindow, DWORD flags); - STDMETHODIMP Read(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE, + STDMETHODIMP Read(VOID* requestContext, const ND_SGE* pSge, DWORD nSge, UINT64 remoteAddress, UINT32 remoteToken, DWORD flags); - STDMETHODIMP Write(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE, + STDMETHODIMP Write(VOID* requestContext, const ND_SGE* pSge, DWORD nSge, UINT64 remoteAddress, UINT32 remoteToken, DWORD flags); CNDQueuePair(CNDAdapter *pAdapter); @@ -70,7 +70,7 @@ public: CNDCompletionQueue* pInitiatorCompletionQueue, CNDSharedReceiveQueue *pSharedReceiveQueue, VOID* context, DWORD receiveQueueDepth, DWORD initiatorQueueDepth, - DWORD maxReceiveRequestSGE, DWORD maxInitiatorRequestSGE, + DWORD maxReceiveRequestSge, DWORD maxInitiatorRequestSge, VOID** ppQueuePair) { HRESULT hr; @@ -84,7 +84,7 @@ public: hr = qp->Init(pReceiveCompletionQueue, pInitiatorCompletionQueue, pSharedReceiveQueue, context, receiveQueueDepth, - initiatorQueueDepth, maxReceiveRequestSGE, maxInitiatorRequestSGE); + initiatorQueueDepth, maxReceiveRequestSge, maxInitiatorRequestSge); if (FAILED(hr)) { goto err2; } @@ -111,7 +111,7 @@ protected: CNDCompletionQueue* pInitiatorCompletionQueue, CNDSharedReceiveQueue *pSharedReceiveQueue, VOID* context, DWORD receiveQueueDepth, DWORD initiatorQueueDepth, - DWORD maxReceiveRequestSge, DWORD maxInitiatorRequestSGE); + DWORD maxReceiveRequestSge, DWORD maxInitiatorRequestSge); STDMETHODIMP_(DWORD) ConvertSendFlags(DWORD Flags); }; diff --git a/trunk/ulp/netdirect2/user/nd_srq.cpp b/trunk/ulp/netdirect2/user/nd_srq.cpp index e4727578..db96979b 100644 --- a/trunk/ulp/netdirect2/user/nd_srq.cpp +++ b/trunk/ulp/netdirect2/user/nd_srq.cpp @@ -119,10 +119,10 @@ Notify(OVERLAPPED* pOverlapped) } STDMETHODIMP CNDSharedReceiveQueue:: -Receive(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE) +Receive(VOID* requestContext, const ND_SGE* pSge, DWORD nSge) { HRESULT hr; - hr = m_pWvSrq->PostReceive((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSGE, nSGE); + hr = m_pWvSrq->PostReceive((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSge, nSge); return NDConvertWVStatus(hr); } diff --git a/trunk/ulp/netdirect2/user/nd_srq.h b/trunk/ulp/netdirect2/user/nd_srq.h index 26938559..b748256f 100644 --- a/trunk/ulp/netdirect2/user/nd_srq.h +++ b/trunk/ulp/netdirect2/user/nd_srq.h @@ -53,13 +53,13 @@ public: // INDSharedReceiveQueue methods STDMETHODIMP Modify(DWORD queueDepth, DWORD notifyThreshold); STDMETHODIMP Notify(OVERLAPPED* pOverlapped); - STDMETHODIMP Receive(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE); + STDMETHODIMP Receive(VOID* requestContext, const ND_SGE* pSge, DWORD nSge); CNDSharedReceiveQueue(CNDAdapter *pAdapter); ~CNDSharedReceiveQueue(); void Delete() {delete this;} static STDMETHODIMP - CreateInstance(CNDAdapter *pAdapter, DWORD queueDepth, DWORD maxSGE, + CreateInstance(CNDAdapter *pAdapter, DWORD queueDepth, DWORD maxSge, DWORD notifyThreshold, GROUP_AFFINITY* pAffinity, VOID** ppSharedReceiveQueue) { @@ -72,7 +72,7 @@ public: goto err1; } - hr = srq->Init(queueDepth, maxSGE, notifyThreshold, pAffinity); + hr = srq->Init(queueDepth, maxSge, notifyThreshold, pAffinity); if (FAILED(hr)) { goto err2; } @@ -92,7 +92,7 @@ public: protected: CNDAdapter *m_pAdapter; - STDMETHODIMP Init(DWORD queueDepth, DWORD maxSGE, DWORD notifyThreshold, + STDMETHODIMP Init(DWORD queueDepth, DWORD maxSge, DWORD notifyThreshold, GROUP_AFFINITY* pAffinity); }; -- 2.46.0