}\r
\r
STDMETHODIMP CNDQueuePair::\r
-Send(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE, DWORD flags)\r
+Send(VOID* requestContext, const ND_SGE* pSge, DWORD nSge, DWORD flags)\r
{\r
HRESULT hr;\r
\r
- hr = m_pWvQp->Send((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSGE, nSGE,\r
+ hr = m_pWvQp->Send((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSge, nSge,\r
ConvertSendFlags(flags), 0);\r
return NDConvertWVStatus(hr);\r
}\r
\r
STDMETHODIMP CNDQueuePair::\r
-Receive(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE)\r
+Receive(VOID* requestContext, const ND_SGE* pSge, DWORD nSge)\r
{\r
HRESULT hr;\r
\r
- hr = m_pWvQp->PostReceive((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSGE, nSGE);\r
+ hr = m_pWvQp->PostReceive((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSge, nSge);\r
return NDConvertWVStatus(hr);\r
}\r
\r
}\r
\r
STDMETHODIMP CNDQueuePair::\r
-Read(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE,\r
+Read(VOID* requestContext, const ND_SGE* pSge, DWORD nSge,\r
UINT64 remoteAddress, UINT32 remoteToken, DWORD flags)\r
{\r
DWORD opts;\r
HRESULT hr;\r
\r
- hr = m_pWvQp->Read((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSGE, nSGE,\r
+ hr = m_pWvQp->Read((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSge, nSge,\r
ConvertSendFlags(flags), htonll(remoteAddress), remoteToken);\r
return NDConvertWVStatus(hr);\r
}\r
\r
STDMETHODIMP CNDQueuePair::\r
-Write(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE,\r
+Write(VOID* requestContext, const ND_SGE* pSge, DWORD nSge,\r
UINT64 remoteAddress, UINT32 remoteToken, DWORD flags)\r
{\r
DWORD opts;\r
HRESULT hr;\r
\r
- hr = m_pWvQp->Write((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSGE, nSGE,\r
+ hr = m_pWvQp->Write((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSge, nSge,\r
ConvertSendFlags(flags), 0, htonll(remoteAddress), remoteToken);\r
return NDConvertWVStatus(hr);\r
}\r
\r
// INDQueuePair methods\r
STDMETHODIMP Flush();\r
- STDMETHODIMP Send(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE, DWORD flags);\r
- STDMETHODIMP Receive(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE);\r
+ STDMETHODIMP Send(VOID* requestContext, const ND_SGE* pSge, DWORD nSge, DWORD flags);\r
+ STDMETHODIMP Receive(VOID* requestContext, const ND_SGE* pSge, DWORD nSge);\r
STDMETHODIMP Bind(VOID* requestContext, IUnknown* pMemoryRegion,\r
IUnknown* pMemoryWindow, const VOID* pBuffer, SIZE_T cbBuffer,\r
DWORD flags);\r
STDMETHODIMP Invalidate(VOID* requestContext, IUnknown* pMemoryWindow, DWORD flags);\r
- STDMETHODIMP Read(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE,\r
+ STDMETHODIMP Read(VOID* requestContext, const ND_SGE* pSge, DWORD nSge,\r
UINT64 remoteAddress, UINT32 remoteToken, DWORD flags);\r
- STDMETHODIMP Write(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE,\r
+ STDMETHODIMP Write(VOID* requestContext, const ND_SGE* pSge, DWORD nSge,\r
UINT64 remoteAddress, UINT32 remoteToken, DWORD flags);\r
\r
CNDQueuePair(CNDAdapter *pAdapter);\r
CNDCompletionQueue* pInitiatorCompletionQueue,\r
CNDSharedReceiveQueue *pSharedReceiveQueue,\r
VOID* context, DWORD receiveQueueDepth, DWORD initiatorQueueDepth,\r
- DWORD maxReceiveRequestSGE, DWORD maxInitiatorRequestSGE,\r
+ DWORD maxReceiveRequestSge, DWORD maxInitiatorRequestSge,\r
VOID** ppQueuePair)\r
{\r
HRESULT hr;\r
\r
hr = qp->Init(pReceiveCompletionQueue, pInitiatorCompletionQueue,\r
pSharedReceiveQueue, context, receiveQueueDepth,\r
- initiatorQueueDepth, maxReceiveRequestSGE, maxInitiatorRequestSGE);\r
+ initiatorQueueDepth, maxReceiveRequestSge, maxInitiatorRequestSge);\r
if (FAILED(hr)) {\r
goto err2;\r
}\r
CNDCompletionQueue* pInitiatorCompletionQueue,\r
CNDSharedReceiveQueue *pSharedReceiveQueue,\r
VOID* context, DWORD receiveQueueDepth, DWORD initiatorQueueDepth,\r
- DWORD maxReceiveRequestSge, DWORD maxInitiatorRequestSGE);\r
+ DWORD maxReceiveRequestSge, DWORD maxInitiatorRequestSge);\r
STDMETHODIMP_(DWORD) ConvertSendFlags(DWORD Flags);\r
};\r
\r
}\r
\r
STDMETHODIMP CNDSharedReceiveQueue::\r
-Receive(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE)\r
+Receive(VOID* requestContext, const ND_SGE* pSge, DWORD nSge)\r
{\r
HRESULT hr;\r
\r
- hr = m_pWvSrq->PostReceive((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSGE, nSGE);\r
+ hr = m_pWvSrq->PostReceive((UINT64) (ULONG_PTR) requestContext, (WV_SGE *) pSge, nSge);\r
return NDConvertWVStatus(hr);\r
}\r
STDMETHODIMP GetNotifyAffinity(USHORT *pGroup, KAFFINITY* pAffinity);\r
STDMETHODIMP Modify(DWORD queueDepth, DWORD notifyThreshold);\r
STDMETHODIMP Notify(OVERLAPPED* pOverlapped);\r
- STDMETHODIMP Receive(VOID* requestContext, const ND_SGE* pSGE, DWORD nSGE);\r
+ STDMETHODIMP Receive(VOID* requestContext, const ND_SGE* pSge, DWORD nSge);\r
\r
CNDSharedReceiveQueue(CNDAdapter *pAdapter);\r
~CNDSharedReceiveQueue();\r
void Delete() {delete this;}\r
static STDMETHODIMP\r
- CreateInstance(CNDAdapter *pAdapter, DWORD queueDepth, DWORD maxSGE,\r
+ CreateInstance(CNDAdapter *pAdapter, DWORD queueDepth, DWORD maxSge,\r
DWORD notifyThreshold, KAFFINITY affinity,\r
VOID** ppSharedReceiveQueue)\r
{\r
goto err1;\r
}\r
\r
- hr = srq->Init(queueDepth, maxSGE, notifyThreshold, affinity);\r
+ hr = srq->Init(queueDepth, maxSge, notifyThreshold, affinity);\r
if (FAILED(hr)) {\r
goto err2;\r
}\r
protected:\r
CNDAdapter *m_pAdapter;\r
\r
- STDMETHODIMP Init(DWORD queueDepth, DWORD maxSGE, DWORD notifyThreshold,\r
+ STDMETHODIMP Init(DWORD queueDepth, DWORD maxSge, DWORD notifyThreshold,\r
KAFFINITY affinity);\r
};\r
\r