From: Sean Hefty Date: Tue, 27 Jul 2010 22:26:12 +0000 (+0000) Subject: nd2: pass affinity information to CQ init X-Git-Url: https://openfabrics.org/gitweb/?a=commitdiff_plain;h=e2f2e830c4c9e11d5c046aed24ceec551285a061;p=~shefty%2Frdma-win.git nd2: pass affinity information to CQ init Carry processor affinity information through to Init call, so it's available when supported by winverbs. Signed-off-by: Sean Hefty git-svn-id: svn://openib.tc.cornell.edu/gen1@2860 ad392aa1-c5ef-ae45-8dd8-e69d62a5ef86 --- diff --git a/trunk/ulp/netdirect2/user/nd_adapter.cpp b/trunk/ulp/netdirect2/user/nd_adapter.cpp index 025ed7fd..cdb10442 100644 --- a/trunk/ulp/netdirect2/user/nd_adapter.cpp +++ b/trunk/ulp/netdirect2/user/nd_adapter.cpp @@ -172,7 +172,8 @@ STDMETHODIMP CNDAdapter:: CreateCompletionQueue(REFIID iid, DWORD queueDepth, USHORT group, KAFFINITY affinity, VOID** ppCompletionQueue) { - return CNDCompletionQueue::CreateInstance(this, queueDepth, ppCompletionQueue); + return CNDCompletionQueue::CreateInstance(this, queueDepth, group, + affinity, ppCompletionQueue); } STDMETHODIMP CNDAdapter:: diff --git a/trunk/ulp/netdirect2/user/nd_cq.cpp b/trunk/ulp/netdirect2/user/nd_cq.cpp index be4b4bd3..2d9d0d63 100644 --- a/trunk/ulp/netdirect2/user/nd_cq.cpp +++ b/trunk/ulp/netdirect2/user/nd_cq.cpp @@ -37,7 +37,7 @@ CNDCompletionQueue::CNDCompletionQueue(CNDAdapter *pAdapter) } STDMETHODIMP CNDCompletionQueue:: -Init(DWORD queueDepth) +Init(DWORD queueDepth, USHORT group, KAFFINITY affinity) { HRESULT hr; diff --git a/trunk/ulp/netdirect2/user/nd_cq.h b/trunk/ulp/netdirect2/user/nd_cq.h index fdadd98f..83568542 100644 --- a/trunk/ulp/netdirect2/user/nd_cq.h +++ b/trunk/ulp/netdirect2/user/nd_cq.h @@ -59,7 +59,8 @@ public: ~CNDCompletionQueue(); void Delete() {delete this;} static STDMETHODIMP - CreateInstance(CNDAdapter *pAdapter, DWORD queueDepth, VOID** ppCq) + CreateInstance(CNDAdapter *pAdapter, DWORD queueDepth, USHORT group, + KAFFINITY affinity, VOID** ppCq) { HRESULT hr; CNDCompletionQueue *cq; @@ -70,7 +71,7 @@ public: goto err1; } - hr = cq->Init(queueDepth); + hr = cq->Init(queueDepth, group, affinity); if (FAILED(hr)) { goto err2; } @@ -89,7 +90,7 @@ public: protected: CNDAdapter *m_pAdapter; - STDMETHODIMP Init(DWORD queueDepth); + STDMETHODIMP Init(DWORD queueDepth, USHORT group, KAFFINITY affinity); STDMETHODIMP_(HRESULT) ConvertStatus(WV_WC_STATUS Status); };