*/\r
\r
// Author: Tzachi Dar\r
-\r
#include "Precompile.h"\r
\r
+\r
+#if defined(EVENT_TRACING)\r
+#ifdef offsetof\r
+#undef offsetof\r
+#endif\r
+#include "SdpDriver.tmh"\r
+#endif\r
+\r
+\r
+\r
SdpDriver *g_pSdpDriver = NULL;\r
\r
FAST_IO_DISPATCH FastIoDispatch =\r
IN PDRIVER_OBJECT pDriverObject \r
) \r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("called pDriverObject = 0x%x\n", pDriverObject ));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"called pDriverObject = 0x%x\n", (uint32_t)pDriverObject );\r
ib_api_status_t ib_status;\r
\r
g_pSdpDriver->Shutdown();\r
ib_status = ib_close_al(g_pSdpDriver->m_al_handle);\r
g_pSdpDriver->m_al_handle = NULL;\r
ASSERT( ib_status == IB_SUCCESS);\r
-\r
+#if defined(EVENT_TRACING)\r
+ WPP_CLEANUP(pDriverObject);\r
+#endif\r
UNICODE_STRING LinkName;\r
\r
RtlInitUnicodeString( &LinkName, SDP_LINK_NAME );\r
bool LinkCreated = false;\r
UNICODE_STRING DevName1, LinkName;\r
int i;\r
-\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("called\n" ));\r
+#if defined(EVENT_TRACING)\r
+ WPP_INIT_TRACING(pDriverObject, pRegistryPath);\r
+#endif\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"called\n" );\r
\r
// fill the device functions\r
pDriverObject->DriverUnload = DriverUnload;\r
FALSE,\r
&pDevObj );\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("IoCreateDevice failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"IoCreateDevice failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
}\r
DeviceCreated = true;\r
rc = pSdpDriver->Init(pDevObj, pDriverObject);\r
\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpDriver->Init failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpDriver->Init failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
\r
);\r
\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("IoCreateSymbolicLink failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"IoCreateSymbolicLink failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
LinkCreated = true;\r
ib_status = ib_open_al(&pSdpDriver->m_al_handle);\r
#pragma warning( pop )\r
if ( ib_status != IB_SUCCESS) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("ib_open_al failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"ib_open_al failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
switch (pIrpSp->MajorFunction) {\r
\r
case IRP_MJ_CREATE: {\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("IRP_MJ_CREATE pIrpSp->FileObject = 0x%x\n", \r
- pIrpSp->FileObject ));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER, "IRP_MJ_CREATE pIrpSp->FileObject = 0x%x\n", \r
+ (uint32_t)pIrpSp->FileObject );\r
pSdpUserFile = new SdpUserFile;\r
if (pSdpUserFile == NULL) {\r
rc = STATUS_NO_MEMORY;\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("new SdpUserFile failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"new SdpUserFile failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
} \r
rc = pSdpUserFile->Init();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpUserFile->Init failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpUserFile->Init failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
}\r
// Everything went well, and windows is still using this object.\r
}\r
case IRP_MJ_CLEANUP: {\r
// All IRPs that were associated with this device should be cleaned\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("IRP_MJ_CLEANUP pIrpSp->FileObject = 0x%x\n", \r
- pIrpSp->FileObject ));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"IRP_MJ_CLEANUP pIrpSp->FileObject = 0x%p\n", \r
+ pIrpSp->FileObject );\r
pSdpUserFile = (SdpUserFile *)pIrpSp->FileObject->FsContext;\r
// The object is being shutdown, and it's cleaning should\r
// be started\r
// Receipt of this request indicates that the last handle of the file object \r
// that is associated with the target device object has been closed and \r
//released. All outstanding I/O requests have been completed or canceled.\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("IRP_MJ_CLOSE pIrpSp->FileObject = 0x%x\n", \r
- pIrpSp->FileObject ));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER, "IRP_MJ_CLOSE pIrpSp->FileObject = 0x%p\n", \r
+ pIrpSp->FileObject);\r
pSdpUserFile = (SdpUserFile *)pIrpSp->FileObject->FsContext;\r
// Nothing to do, the referance count will be removed once\r
// we leave the function\r
break;\r
}\r
case IRP_MJ_DEVICE_CONTROL: {\r
- SDP_PRINT(SDP_DEBUG, SDP_DRIVER, ("IRP_MJ_DEVICE_CONTROL pIrpSp->FileObject = 0x%x\n", \r
- pIrpSp->FileObject ));\r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER,"IRP_MJ_DEVICE_CONTROL pIrpSp->FileObject = 0x%p\n", \r
+ pIrpSp->FileObject);\r
\r
// IOCTLs are allowed only for user mode processes\r
if (UserMode != pIrp->RequestorMode) {\r
\r
} __except(EXCEPTION_EXECUTE_HANDLER) {\r
rc = STATUS_ACCESS_VIOLATION;\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("IRP_MJ_DEVICE_CONTROL Access "\r
- "violition when trying to read/write data\n" ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"IRP_MJ_DEVICE_CONTROL Access "\r
+ "violition when trying to read/write data\n");\r
\r
ASSERT(FALSE);\r
goto Cleanup;\r
#define VERIFY_BUFFERS(InputBufferLength, OutputBufferLength, InStruct, OutStruct) \\r
if ((InputBufferLength < sizeof (InStruct)) || \\r
(OutputBufferLength < sizeof (OutStruct))) { \\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, \\r
- ("DispatchDeviceIoControl bad buffer sizes\n" )); \\r
+ /*SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER, "DispatchDeviceIoControl bad buffer sizes\n" ); */ \\r
ASSERT(FALSE); \\r
rc = STATUS_ACCESS_VIOLATION; \\r
goto Cleanup; \\r
m_pDevObj = pDevObj;\r
m_pSdpArp = new SdpArp;\r
if (m_pSdpArp == NULL) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("new SdpArp failed \n")); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"new SdpArp failed \n"); \r
rc = STATUS_NO_MEMORY;\r
goto Cleanup;\r
}\r
rc = m_pSdpArp->Init(DriverObject);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("m_pSdpArp->Init failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"m_pSdpArp->Init failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
}\r
\r
switch (IoControlCode) {\r
case IOCTL_WSP_SOCKET :\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("IOCTL_WSP_SOCKET recieved\n" )); \r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"IOCTL_WSP_SOCKET recieved\n" ); \r
VERIFY_BUFFERS(InputBufferLength, OutputBufferLength, WspSocketIn, WspSocketOut);\r
OutputDataSize = sizeof (WspSocketOut);\r
\r
pSdpSocket = new SdpSocket;\r
if (pSdpSocket == NULL) {\r
rc = STATUS_NO_MEMORY;\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("new SdpSocket failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"new SdpSocket failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
}\r
rc = pSdpSocket->Init(&wspSocketIn, pWspSocketOut, pSdpUserFile);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpSocket->Init failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpSocket->Init failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
rc = pSdpUserFile->AddSocket(pSdpSocket);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpUserFile->AddSocket failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpUserFile->AddSocket failed rc = 0x%x\n", rc );\r
pSdpSocket->Shutdown();\r
goto Cleanup;\r
} \r
\r
case IOCTL_WSP_CONNECT :\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("IOCTL_WSP_CONNECT recieved\n" )); \r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"IOCTL_WSP_CONNECT recieved\n" ); \r
VERIFY_BUFFERS(InputBufferLength, OutputBufferLength, WspConnectIn, WspConnectOut);\r
OutputDataSize = sizeof (WspConnectOut);\r
\r
pSdpUserFile = (SdpUserFile *)pIrpSp->FileObject->FsContext;\r
pSdpSocket = pSdpUserFile->SocketByPointer(wspConnectIn.pSocket);\r
if (pSdpSocket == NULL) {\r
- SDP_PRINT(SDP_DEBUG, SDP_DRIVER, ("IOCTL_WSP_CONNECT socket %x not found\n",wspConnectIn.pSocket)); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER,"IOCTL_WSP_CONNECT socket %p not found\n",wspConnectIn.pSocket); \r
// This is a well defined winsock error\r
pWspConnectOut->Errno = WSAENOTSOCK;\r
goto Cleanup;\r
}\r
rc = pSdpSocket->WSPConnect(&wspConnectIn, pWspConnectOut);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpSocket->WSPConnect failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpSocket->WSPConnect failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
}\r
}\r
\r
case IOCTL_WSP_SEND :\r
{\r
- SDP_PRINT(SDP_DEBUG, SDP_DRIVER, ("IOCTL_WSP_SEND recieved\n" )); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER,"IOCTL_WSP_SEND recieved\n" ); \r
VERIFY_BUFFERS(InputBufferLength, OutputBufferLength, WspSendIn, WspSendOut);\r
OutputDataSize = sizeof (WspSendOut);\r
\r
pSdpUserFile = (SdpUserFile *)pIrpSp->FileObject->FsContext;\r
pSdpSocket = pSdpUserFile->SocketByPointer(wspSendIn.pSocket);\r
if (pSdpSocket == NULL) {\r
- SDP_PRINT(SDP_DEBUG, SDP_DRIVER, ("IOCTL_WSP_SEND socket %x not found\n",wspSendIn.pSocket)); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER,"IOCTL_WSP_SEND socket %p not found\n",wspSendIn.pSocket); \r
// This is a well defined winsock error\r
pWspSendOut->Errno = WSAENOTSOCK;\r
goto Cleanup;\r
}\r
rc = pSdpSocket->WSPSend(&wspSendIn, pWspSendOut, pIrp);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpSocket->WSPSend failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpSocket->WSPSend failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
}\r
}\r
\r
case IOCTL_WSP_RECV :\r
{\r
- SDP_PRINT(SDP_DEBUG, SDP_DRIVER, ("IOCTL_WSP_RECV recieved\n" )); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER,"IOCTL_WSP_RECV recieved\n" ); \r
VERIFY_BUFFERS(InputBufferLength, OutputBufferLength, WspRecvIn, WspRecvOut);\r
OutputDataSize = sizeof (WspRecvOut);\r
\r
pSdpUserFile = (SdpUserFile *)pIrpSp->FileObject->FsContext;\r
pSdpSocket = pSdpUserFile->SocketByPointer(wspRecvIn.pSocket);\r
if (pSdpSocket == NULL) {\r
- SDP_PRINT(SDP_DEBUG, SDP_DRIVER, ("IOCTL_WSP_RECV socket %x not found\n",wspRecvIn.pSocket)); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER,"IOCTL_WSP_RECV socket %p not found\n",wspRecvIn.pSocket); \r
// This is a well defined winsock error\r
pWspRecvOut->Errno = WSAENOTSOCK;\r
goto Cleanup;\r
}\r
rc = pSdpSocket->WSPRecv(&wspRecvIn, pWspRecvOut);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpSocket->WSPRecv failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpSocket->WSPRecv failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
}\r
}\r
\r
case IOCTL_WSP_BIND:\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("IOCTL_WSP_BIND recieved\n" )); \r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"IOCTL_WSP_BIND recieved\n" ); \r
VERIFY_BUFFERS(InputBufferLength, OutputBufferLength, WspBindIn, WspBindOut);\r
OutputDataSize = sizeof (WspBindOut);\r
\r
pSdpUserFile = (SdpUserFile *)pIrpSp->FileObject->FsContext;\r
pSdpSocket = pSdpUserFile->SocketByPointer(wspBindIn.pSocket);\r
if (pSdpSocket == NULL) {\r
- SDP_PRINT(SDP_DEBUG, SDP_DRIVER, ("IOCTL_WSP_BIND socket %x not found\n", wspBindIn.pSocket)); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER,"IOCTL_WSP_BIND socket %p not found\n", wspBindIn.pSocket); \r
// This is a well defined winsock error\r
pWspBindOut->Errno = WSAENOTSOCK;\r
goto Cleanup;\r
}\r
rc = pSdpSocket->WSPBind(&wspBindIn, pWspBindOut);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpSocket->WSPBind failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpSocket->WSPBind failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
}\r
}\r
\r
case IOCTL_WSP_LISTEN:\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("IOCTL_WSP_LISTEN recieved\n" )); \r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"IOCTL_WSP_LISTEN recieved\n" ); \r
VERIFY_BUFFERS(InputBufferLength, OutputBufferLength, WspListenIn, WspListenOut);\r
OutputDataSize = sizeof (WspListenOut);\r
\r
pSdpUserFile = (SdpUserFile *)pIrpSp->FileObject->FsContext;\r
pSdpSocket = pSdpUserFile->SocketByPointer(wspListenIn.pSocket);\r
if (pSdpSocket == NULL) {\r
- SDP_PRINT(SDP_DEBUG, SDP_DRIVER, ("IOCTL_WSP_LISTEN socket %x not found\n",wspListenIn.pSocket)); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER,"IOCTL_WSP_LISTEN socket %p not found\n",wspListenIn.pSocket); \r
// This is a well defined winsock error\r
pWspListenOut->Errno = WSAENOTSOCK;\r
goto Cleanup;\r
}\r
rc = pSdpSocket->WSPListen(&wspListenIn, pWspListenOut);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpSocket->WSPListen failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpSocket->WSPListen failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
}\r
}\r
\r
case IOCTL_WSP_ACCEPT:\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("IOCTL_WSP_ACCEPT recieved\n" )); \r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"IOCTL_WSP_ACCEPT recieved\n" ); \r
VERIFY_BUFFERS(InputBufferLength, OutputBufferLength, WspAcceptIn, WspAcceptOut);\r
OutputDataSize = sizeof (WspAcceptOut);\r
\r
pSdpUserFile = (SdpUserFile *)pIrpSp->FileObject->FsContext;\r
pSdpSocket = pSdpUserFile->SocketByPointer(wspAcceptIn.pSocket);\r
if (pSdpSocket == NULL) {\r
- SDP_PRINT(SDP_DEBUG, SDP_DRIVER, ("IOCTL_WSP_ACCEPT socket %x not found\n",wspAcceptIn.pSocket)); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER,"IOCTL_WSP_ACCEPT socket %p not found\n",wspAcceptIn.pSocket); \r
// This is a well defined winsock error\r
pWspAcceptOut->Errno = WSAENOTSOCK;\r
goto Cleanup;\r
}\r
rc = pSdpSocket->WSPAccept(&wspAcceptIn, pWspAcceptOut);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpSocket->WSPAccept failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpSocket->WSPAccept failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
}\r
if (pWspAcceptOut->pAccaptedSocket != NULL) {\r
pAcceptedSdpSocket = (SdpSocket *) pWspAcceptOut->pAccaptedSocket;\r
rc = pSdpUserFile->AddSocket(pAcceptedSdpSocket);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpUserFile->AddSocket failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpUserFile->AddSocket failed rc = 0x%x\n", rc );\r
pAcceptedSdpSocket->Shutdown();\r
goto Cleanup;\r
} \r
\r
case IOCTL_WSP_GET_XXX_NAME:\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("IOCTL_WSP_GET_XXX_NAME recieved\n" )); \r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"IOCTL_WSP_GET_XXX_NAME recieved\n" ); \r
VERIFY_BUFFERS(InputBufferLength, OutputBufferLength, WspGetSockXXIn, WspGetSockXXOut);\r
OutputDataSize = sizeof (WspGetSockXXOut);\r
\r
pSdpUserFile = (SdpUserFile *)pIrpSp->FileObject->FsContext;\r
pSdpSocket = pSdpUserFile->SocketByPointer(wspGetSockXXin.pSocket);\r
if (pSdpSocket == NULL) {\r
- SDP_PRINT(SDP_DEBUG, SDP_DRIVER, ("IOCTL_WSP_GET_XXX_NAME socket %x not found\n", wspGetSockXXin.pSocket)); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER,"IOCTL_WSP_GET_XXX_NAME socket %p not found\n", wspGetSockXXin.pSocket); \r
// This is a well defined winsock error\r
pWspGetSockXXOut->Errno = WSAENOTSOCK;\r
goto Cleanup;\r
}\r
rc = pSdpSocket->WSPGetXXXName(&wspGetSockXXin, pWspGetSockXXOut);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpSocket->WSPGetXXXName failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpSocket->WSPGetXXXName failed rc = 0x%x\n", rc ); \r
goto Cleanup;\r
}\r
}\r
break;\r
case IOCTL_WSP_CLOSE_SOCKET :\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("IOCTL_WSP_CLOSE_SOCKET recieved\n" )); \r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"IOCTL_WSP_CLOSE_SOCKET recieved\n" ); \r
VERIFY_BUFFERS(InputBufferLength, OutputBufferLength, WspSocketCloseIn, WspSocketCloseOut);\r
OutputDataSize = sizeof (WspSocketCloseOut);\r
\r
pSdpUserFile = (SdpUserFile *)pIrpSp->FileObject->FsContext;\r
pSdpSocket = pSdpUserFile->SocketByPointer(wspSocketCloseIn.pSocket);\r
if (pSdpSocket == NULL) {\r
- SDP_PRINT(SDP_DEBUG, SDP_DRIVER, ("IOCTL_WSP_CLOSE_SOCKET socket %x not found\n",wspSocketCloseIn.pSocket)); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER,"IOCTL_WSP_CLOSE_SOCKET socket %p not found\n",wspSocketCloseIn.pSocket); \r
// This is a well defined winsock error\r
pWspSocketCloseOut->Errno = WSAENOTSOCK;\r
goto Cleanup;\r
}\r
rc = pSdpSocket->WSPCloseSocket(&wspSocketCloseIn, pWspSocketCloseOut);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("pSdpSocket->WSPCloseSocket failed rc = 0x%x\n", rc )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"pSdpSocket->WSPCloseSocket failed rc = 0x%x\n", rc ); \r
goto Cleanup; \r
}\r
}\r
\r
case IOCTL_WSP_USER_THREAD :\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("IOCTL_WSP_USER_THREAD recieved\n" )); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_DRIVER, "IOCTL_WSP_USER_THREAD recieved\n" ); \r
pSdpUserFile = (SdpUserFile *)pIrpSp->FileObject->FsContext;\r
\r
/* Ignore Error = */ pSdpUserFile->UsersThread();\r
default:\r
// This is an unrecgnized IOCTL\r
ASSERT(FALSE);\r
- SDP_PRINT(SDP_ERR, SDP_DRIVER, ("unknow IOCTL code = 0x%x\n", IoControlCode ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_DRIVER,"unknow IOCTL code = 0x%x\n", IoControlCode );\r
rc = STATUS_INVALID_PARAMETER;\r
goto Cleanup;\r
\r
VOID \r
SdpDriver::AddThread(ThreadHandle *pThreadHandle)\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("this = 0x%x\n", this ));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"this = 0x%p\n", this );\r
// Check if there is any next thread that can be removed from the queue\r
LARGE_INTEGER WaitTime;\r
WaitTime.QuadPart = 0; // Don't wait for them to die\r
VOID \r
SdpDriver::WaitForAllThreadsToDie()\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("this = 0x%x\n", this ));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"this = 0x%p\n", this );\r
\r
ExAcquireFastMutex(&m_ThreadsMutex);\r
// Timeout of null will cause a wait forever\r
VOID \r
SdpDriver::WaitForThreadsToDie(LARGE_INTEGER *pWaitTime)\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("this = 0x%x\n", this ));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"this = 0x%p\n", this );\r
// Check if there is any next thread that can be removed from the queue\r
NTSTATUS rc = STATUS_SUCCESS;\r
\r
\r
if (rc == STATUS_TIMEOUT) {\r
// Nothing that we should do, the thread is not ready yet\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("this = 0x%x Former thread is not dead yet\n", this ));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"this = 0x%p Former thread is not dead yet\n", this );\r
break;\r
}\r
// SUCESS means that the thread is dead, we can remove it\r
// from the list\r
- SDP_PRINT(SDP_TRACE, SDP_DRIVER, ("this = 0x%x Former thread is already dead\n", this ));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_DRIVER,"this = 0x%p Former thread is already dead\n", this );\r
\r
m_ShutDownThreads.RemoveHeadList();\r
ObDereferenceObject(pNextThreadHandle->ThreadObject);\r
// Author: Tzachi Dar\r
\r
#include "Precompile.h"\r
+\r
#pragma warning(disable: 4244 ) \r
\r
+#if defined(EVENT_TRACING)\r
+#ifdef offsetof\r
+#undef offsetof\r
+#endif\r
+#include "SdpSocket.tmh"\r
+#endif\r
+\r
+\r
NTSTATUS sdp_cm_hello_ack_check(struct sdp_msg_hello_ack *hello_ack);\r
NTSTATUS sdp_cm_hello_check(struct sdp_msg_hello *msg_hello);\r
static NTSTATUS __send_cb2(SdpSocket * pSdpSocket);\r
static void AL_API\r
cm_rej_callback(IN ib_cm_rej_rec_t *p_cm_rej_rec )\r
{\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("dispatch level = %d\n", KeGetCurrentIrql()));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"dispatch level = %d\n", KeGetCurrentIrql());\r
// BUGBUG: This should be used to return error to the connecting side\r
}\r
\r
cm_mra_callback(\r
IN ib_cm_mra_rec_t *p_cm_mra_rec )\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("cm_mra_callback called"));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"cm_mra_callback called");\r
ASSERT(FALSE);\r
}\r
\r
cm_apr_callback(\r
IN ib_cm_apr_rec_t *p_cm_apr_rec )\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("cm_apr_callback called"));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"cm_apr_callback called");\r
ASSERT(FALSE);\r
}\r
\r
cm_lap_callback(\r
IN ib_cm_lap_rec_t *p_cm_lap_rec )\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("dispatch level = %d\n", KeGetCurrentIrql()));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"dispatch level = %d\n", KeGetCurrentIrql());\r
ASSERT(FALSE);\r
}\r
\r
cm_rtu_callback(\r
IN ib_cm_rtu_rec_t *p_cm_rtu_rec )\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("dispatch level = %d\n", KeGetCurrentIrql()));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"dispatch level = %d\n", KeGetCurrentIrql());\r
// Note - Referance count is not increased here since this is a call\r
// back, and we are gurantied that shuting down ibal will only end\r
// after all callbacks are finished.\r
SdpUserFile *pSdpUserFile)\r
{\r
NTSTATUS rc = STATUS_SUCCESS;\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p\n", this);\r
\r
m_CreationFlags = pSocketInParam->dwFlags;\r
\r
// we won't be in trouble after the thread was created\r
m_pCloseSocketThread = new ThreadHandle;\r
if (m_pCloseSocketThread == NULL) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Failed to allocate new SocketThread this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Failed to allocate new SocketThread this = 0x%p \n",this);\r
rc = STATUS_NO_MEMORY;\r
goto Cleanup;\r
}\r
IRP *pIrp\r
)\r
{ \r
- SDP_PRINT(SDP_DEBUG, SDP_SOCKET, ("this = 0x%p size = %d \n",this, pWspSendIn->BufferSize));\r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_SOCKET,"this = 0x%p size = %d \n",this, pWspSendIn->BufferSize);\r
\r
NTSTATUS rc = STATUS_SUCCESS; \r
BufferDescriptor * pBufferDescriptor = NULL;\r
// For zero bytes send we currently don't do anything and return with status \r
// success\r
if (pWspSendIn->BufferSize == 0) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("this = 0x%p - zero size send \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET,"this = 0x%p - zero size send \n",this);\r
goto Cleanup;\r
}\r
\r
if (!m_Lock.Lock()) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Failed to lock this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET, "Failed to lock this = 0x%p \n",this);\r
rc = STATUS_SHUTDOWN_IN_PROGRESS;\r
goto Cleanup;\r
}\r
\r
if ((m_state != SS_CONNECTED)) {\r
// We can not send now.\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("Can't send now, m_state = %s\n",\r
- SS2String(m_state)\r
- ));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET,"Can't send now, m_state = %s\n",\r
+ SS2String(m_state));\r
rc = STATUS_SHUTDOWN_IN_PROGRESS;\r
pWspSendOut->Errno = WSAENOTCONN;\r
\r
if (!NT_SUCCESS(rc)) {\r
// No need to complete the IRP, as it will be be deleted\r
// when all other IRPs will be\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET, "m_Lock.Unlock() failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
// This IRP will be pending (make sure to change this after the unlock)\r
\r
rc = m_SendBufferPool.GetBuffer(&pBufferDescriptor);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_SendBufferPool.GetBuffer failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_SendBufferPool.GetBuffer failed rc = 0x%x\n", rc );\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
goto Cleanup;\r
}\r
\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
// No need to complete the IRP, as it will be be deleted\r
// when all other IRPs will be\r
goto Cleanup;\r
\r
rc = pBufferDescriptor->WriteData(pWspSendIn->pData + Coppied, CopySize);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("pBufferDescriptor->WriteData failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"pBufferDescriptor->WriteData failed rc = 0x%x\n", rc );\r
// free the buffer that you have\r
rc1 = m_SendBufferPool.ReturnBuffer(pBufferDescriptor);\r
ASSERT(NT_SUCCESS(rc1));\r
pBufferDescriptor->SetMid(SDP_MID_DATA);\r
rc = m_SendBufferPool.AddBufferToQueuedList(pBufferDescriptor);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_SendBufferPool.AddBufferToQueuedList failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_SendBufferPool.AddBufferToQueuedList failed rc = 0x%x\n", rc );\r
// free the buffer that you have\r
rc1 = m_SendBufferPool.ReturnBuffer(pBufferDescriptor);\r
ASSERT(NT_SUCCESS(rc1));\r
\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
goto Cleanup;\r
}\r
\r
// Some default value\r
pWspSendOut->Errno = WSAENOBUFS;\r
}\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("this = 0x%p rc = 0x%x\n",this, rc));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "this = 0x%p rc = 0x%x\n",this, rc);\r
// is indeed the case.\r
}\r
return rc;\r
WspRecvOut *pWspRecvOut\r
)\r
{\r
- SDP_PRINT(SDP_DEBUG, SDP_SOCKET, ("this = 0x%p BufferSize = %d\n",this, pWspRecvIn->BufferSize));\r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_SOCKET,"this = 0x%p BufferSize = %d\n",this, pWspRecvIn->BufferSize);\r
\r
NTSTATUS rc = STATUS_SUCCESS;\r
bool First = true;\r
bool NoMoreData;\r
\r
if (pWspRecvIn->BufferSize == 0) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("this = 0x%p - zero size recv \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET,"this = 0x%p - zero size recv \n",this);\r
goto Cleanup;\r
}\r
\r
while (Coppied < pWspRecvIn->BufferSize) {\r
if ((Locked == false) && !m_Lock.Lock()) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Failed to lock this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Failed to lock this = 0x%p \n",this);\r
rc = STATUS_SHUTDOWN_IN_PROGRESS;\r
goto Cleanup;\r
}\r
\r
if ((m_state != SS_CONNECTED && m_state!= SS_CONNECTED_DREP_SENT ) ) {\r
// We can not recv now.\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("Can't recv now, m_state = %s this = %p\n",\r
- SS2String(m_state), this\r
- ));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "Can't recv now, m_state = %s this = %p\n",\r
+ SS2String(m_state), this);\r
rc = STATUS_SHUTDOWN_IN_PROGRESS;\r
pWspRecvOut->Errno = WSAENOTCONN;\r
\r
&NoMoreData\r
);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_RecvBufferPool.GetData failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_RecvBufferPool.GetData failed rc = 0x%x\n", rc );\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
Locked = false;\r
goto Cleanup;\r
rc = m_Lock.Unlock();\r
Locked = false;\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
goto Cleanup;\r
}\r
\r
if (( rc == STATUS_ALERTED ) ||( rc == STATUS_USER_APC )) {\r
// BUGBUG: Think what to do here, we should be able to stop the\r
// connect, and quit (probably shutdown should be enough)\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("MyKeWaitForSingleObject was alerted rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET,"MyKeWaitForSingleObject was alerted rc = 0x%x\n", rc );\r
rc = STATUS_UNEXPECTED_IO_ERROR;\r
//pWspConnectOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
Shutdown();\r
ASSERT(Locked == true);\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
goto Cleanup;\r
}\r
\r
}\r
// Currently in any case, the flags are not being used:\r
pWspRecvOut->dwFlags = 0;\r
- SDP_PRINT(SDP_DEBUG, SDP_SOCKET, ("this = 0x%p returning %d bytes \n",this, pWspRecvOut->NumberOfBytesRecieved));\r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_SOCKET,"this = 0x%p returning %d bytes \n",this, pWspRecvOut->NumberOfBytesRecieved);\r
return rc;\r
\r
}\r
ib_path_rec_t path_rec;\r
ULONG SrcIp = 0;\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p remote addresses ip=%d.%d.%d.%d:%d\n",\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET, "this = 0x%p remote addresses ip=%d.%d.%d.%d:%d\n",\r
this,\r
(pWspConnectIn->DestIP & 0XFF000000) >> 24,\r
(pWspConnectIn->DestIP & 0XFF0000) >> 16,\r
(pWspConnectIn->DestIP & 0XFF00) >> 8,\r
(pWspConnectIn->DestIP & 0XFF),\r
pWspConnectIn->DestPort\r
- ));\r
+ );\r
\r
if((pWspConnectIn->DestIP == 0) || \r
(pWspConnectIn->DestPort == 0) ||\r
(pWspConnectIn->SrcIP == 0)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Invalid Addresses"));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Invalid Addresses");\r
pWspConnectOut->Errno = WSAEADDRNOTAVAIL;\r
goto Cleanup;\r
}\r
m_Lock.Lock();//??? retval\r
if ((m_state != SS_IDLE)) {\r
// We can not connect in this state \r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("Can't send now, m_state = %s\n",\r
- SS2String(m_state)\r
- ));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "Can't send now, m_state = %s\n",\r
+ SS2String(m_state));\r
rc = STATUS_SHUTDOWN_IN_PROGRESS;\r
pWspConnectOut->Errno = WSAENOTCONN;\r
\r
if (m_SrcPort == 0) {\r
rc = g_pSdpDriver->m_pSdpArp->GetPort(m_SrcIp, &m_SrcPort);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_pSdpArp->GetPort failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_pSdpArp->GetPort failed rc = 0x%x\n", rc );\r
pWspConnectOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
goto Cleanup;\r
\r
rc = g_pSdpDriver->m_pSdpArp->SourcePortGidFromIP(SrcIp, &m_SrcPortGuid, &m_SrcCaGuid);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_pSdpArp->SourcePortGidFromIP failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_pSdpArp->SourcePortGidFromIP failed rc = 0x%x\n", rc );\r
pWspConnectOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
goto Cleanup;\r
\r
rc = g_pSdpDriver->m_pSdpArp->DestPortGidFromMac(m_SrcPortGuid, pWspConnectIn->DestMac, &DestPortGid);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_pSdpArp->DestPortGidFromIP failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_pSdpArp->DestPortGidFromIP failed rc = 0x%x\n", rc );\r
pWspConnectOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
goto Cleanup;\r
\r
rc = g_pSdpDriver->m_pSdpArp->QueryPathRecord( m_SrcPortGuid, DestPortGid, &path_rec );\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_pSdpArp->QueryPathRecord failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_pSdpArp->QueryPathRecord failed rc = 0x%x\n", rc );\r
pWspConnectOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
goto Cleanup;\r
}\r
\r
// Verify that we are in the correct state (just looking - without the lock)\r
if (m_state != SS_CONNECTING_QPR_SENT) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("wrong state after QueryPathRecord\n" ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"wrong state after QueryPathRecord\n" );\r
pWspConnectOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
goto Cleanup;\r
}\r
\r
rc = CreateQp();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("CreateQp failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"CreateQp failed rc = 0x%x\n", rc );\r
pWspConnectOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
goto Cleanup;\r
} \r
\r
ib_status = ib_cm_req( &cm_req );\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_cm_req failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_cm_req failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
pWspConnectOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
goto Cleanup;\r
if (( rc == STATUS_ALERTED ) ||( rc == STATUS_USER_APC )) {\r
// BUGBUG: Think what to do here, we should be able to stop the\r
// connect, and quit (probably shutdown should be enough)\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("MyKeWaitForSingleObject was alerted rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET,"MyKeWaitForSingleObject was alerted rc = 0x%x\n", rc );\r
rc = STATUS_UNEXPECTED_IO_ERROR;\r
pWspConnectOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
Shutdown();\r
\r
rc = CmSendRTU();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("CmSendRTU failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"CmSendRTU failed rc = 0x%x\n", rc );\r
pWspConnectOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
goto Cleanup;\r
} \r
ASSERT(((pWspConnectOut->Errno == 0) && (NT_SUCCESS(rc))) |\r
((pWspConnectOut->Errno != 0) && (!NT_SUCCESS(rc))));\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("connect is returning %s this = 0x%p\n",\r
- NT_SUCCESS(rc) ? "SUCCESS" : "FAILURE", this )); \r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"connect is returning %s this = 0x%p\n",\r
+ NT_SUCCESS(rc) ? "SUCCESS" : "FAILURE", this); \r
return rc;\r
\r
}\r
{\r
NTSTATUS rc = STATUS_SUCCESS;\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p bind address ip=%d.%d.%d.%d:%d\n",\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET, "this = 0x%p bind address ip=%d.%d.%d.%d:%d\n",\r
this,\r
(pWspBindIn->IP & 0XFF000000) >> 24,\r
(pWspBindIn->IP & 0XFF0000) >> 16,\r
(pWspBindIn->IP & 0XFF00) >> 8,\r
(pWspBindIn->IP & 0XFF),\r
pWspBindIn->Port\r
- ));\r
+ );\r
\r
if (!m_Lock.Lock()) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Failed to lock this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Failed to lock this = 0x%p \n",this);\r
rc = STATUS_SHUTDOWN_IN_PROGRESS;\r
goto Cleanup;\r
}\r
\r
/* Verify the state of the socket */\r
if( m_state != SS_IDLE) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("socket is in invalid state %s this = 0x%p \n",\r
- this, \r
- SS2String(m_state)));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET, "socket is in invalid state %s this = 0x%p \n",\r
+ SS2String(m_state),this );\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
rc = STATUS_INVALID_DEVICE_STATE;\r
pWspBindOut->Errno = WSAEINVAL;\r
ASSERT(m_SrcCaGuid == NULL);\r
rc = g_pSdpDriver->m_pSdpArp->SourcePortGidFromIP(pWspBindIn->IP, &m_SrcPortGuid, &m_SrcCaGuid);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_pSdpArp->SourcePortGidFromIP failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_pSdpArp->SourcePortGidFromIP failed rc = 0x%x\n", rc );\r
pWspBindOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
goto Cleanup;\r
/* Time to allocate our IB QP */\r
rc = CreateQp();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("CreateQp failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"CreateQp failed rc = 0x%x\n", rc );\r
pWspBindOut->Errno = WSAENOBUFS;\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
goto Cleanup;\r
m_SrcPort = 0;\r
rc = g_pSdpDriver->m_pSdpArp->GetPort(pWspBindIn->IP, &m_SrcPort);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_pSdpArp->GetPort failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_pSdpArp->GetPort failed rc = 0x%x\n", rc );\r
pWspBindOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
goto Cleanup;\r
m_state = SS_BOUND;\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
goto Cleanup;\r
}\r
\r
ib_cm_listen_t param;\r
ib_api_status_t ib_status;\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p \n",this);\r
if (!m_Lock.Lock()) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Failed to lock this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Failed to lock this = 0x%p \n",this);\r
rc = STATUS_SHUTDOWN_IN_PROGRESS;\r
goto Cleanup;\r
}\r
\r
/* Verify the state of the socket */\r
if( m_state != SS_BOUND) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("socket is in invalid state %s this = 0x%p \n",\r
- this, \r
- SS2String(m_state)));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET, "socket is in invalid state %s this = 0x%p \n",\r
+ SS2String(m_state),this);\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
rc = STATUS_INVALID_DEVICE_STATE;\r
pWspListenOut->Errno = WSAEINVAL;\r
);\r
\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_cm_listen failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_cm_listen failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
pWspListenOut->Errno = IbalToWsaError( ib_status );\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
m_state = SS_LISTENING;\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
goto Cleanup;\r
}\r
\r
SdpSocket *pNewSocket = NULL;\r
PRKEVENT pAcceptEvent = NULL;\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p \n",this);\r
\r
while (true) {\r
if ((Locked == false) && !m_Lock.Lock()) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Failed to lock this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Failed to lock this = 0x%p \n",this);\r
rc = STATUS_SHUTDOWN_IN_PROGRESS;\r
goto Cleanup;\r
}\r
\r
/* Verify the state of the socket */\r
if( m_state != SS_LISTENING) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("socket is in invalid state %s this = 0x%p \n",\r
- this, \r
- SS2String(m_state)));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"socket is in invalid state %s this = 0x%p \n",\r
+ SS2String(m_state),this);\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
Locked = false;\r
rc = STATUS_INVALID_DEVICE_STATE;\r
\r
rc = m_ConnectionList.AcceptAReadyConnection(&pNewSocket, &pAcceptEvent);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_ConnectionList.AcceptAReadyConnection failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_ConnectionList.AcceptAReadyConnection failed rc = 0x%x\n", rc );\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
Locked = false;\r
goto Cleanup;\r
rc = m_Lock.Unlock();\r
Locked = false;\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
goto Cleanup;\r
}\r
\r
if (( rc == STATUS_ALERTED ) ||( rc == STATUS_USER_APC )) {\r
// BUGBUG: Think what to do here, we should be able to stop the\r
// connect, and quit (probably shutdown should be enough)\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("MyKeWaitForSingleObject was alerted = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET,"MyKeWaitForSingleObject was alerted = 0x%x\n", rc );\r
rc = STATUS_UNEXPECTED_IO_ERROR;\r
//pWspConnectOut->Errno = WSAENETUNREACH; // BUGBUG: verify this error\r
Shutdown();\r
rc = m_Lock.Unlock();\r
Locked = false;\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
goto Cleanup;\r
}\r
\r
Cleanup: \r
ASSERT(Locked == false);\r
if (NT_SUCCESS(rc) ) {\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p returning socket 0x%p \n",this, pNewSocket));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p returning socket 0x%p \n",this, pNewSocket);\r
pWspAcceptOut->pAccaptedSocket = pNewSocket;\r
pWspAcceptOut->IP = IP;\r
pWspAcceptOut->Port = Port;\r
NTSTATUS rc = STATUS_SUCCESS;\r
ib_api_status_t ib_status;\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p \n",this);\r
rc = m_Lock.LockRc();\r
if (!NT_SUCCESS(rc)) { \r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Failed to lock this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Failed to lock this = 0x%p \n",this);\r
pWspGetSockXXOut->Errno = WSAENETDOWN;\r
goto Cleanup;\r
}\r
}\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
pWspGetSockXXOut->Errno = WSAENETDOWN; \r
goto Cleanup;\r
}\r
)\r
{\r
NTSTATUS rc = STATUS_SUCCESS;\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p state = %s \n",this, SS2String(m_state)));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p state = %s \n",this, SS2String(m_state));\r
OBJECT_ATTRIBUTES attr;\r
HANDLE ThreadHandle;\r
\r
if (!m_Lock.Lock()) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Failed to lock this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Failed to lock this = 0x%p \n",this);\r
rc = STATUS_SHUTDOWN_IN_PROGRESS;\r
goto Cleanup;\r
}\r
\r
/* Verify the state of the socket */\r
if(m_state == SS_IDLE) {\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("socket is in idle state this = 0x%p \n",\r
- this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"socket is in idle state this = 0x%p \n",\r
+ this);\r
m_Lock.Unlock(); // Error ignored as this is already a Shutdown pass\r
Shutdown();\r
pWspSocketCloseOut->Errno = 0;\r
// Need to send the DisConn message to the remote side and wait\r
rc = m_SendBufferPool.PostDisConn();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_SendBufferPool.PostDisConn failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_SendBufferPool.PostDisConn failed rc = 0x%x\n", rc );\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
goto Cleanup;\r
}\r
);\r
\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("PsCreateSystemThread failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"PsCreateSystemThread failed rc = 0x%x\n", rc );\r
m_Lock.Unlock(); // Error ignored as this is already an error pass\r
// The thread wasn't created so we should remove the refferance\r
Release(); \r
rc = STATUS_SUCCESS;\r
}\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
goto Cleanup;\r
}\r
\r
// In the current model, we call shutdown in any case (to kill the socket)\r
Shutdown(); \r
}\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p returning Errno = %d\n", \r
- this , pWspSocketCloseOut->Errno));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET, "this = 0x%p returning Errno = %d\n", \r
+ this , pWspSocketCloseOut->Errno);\r
\r
\r
return rc;\r
\r
VOID SdpSocket::DisconectSentEvent()\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p\n",this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET, "this = 0x%p\n",this);\r
KeSetEvent( &m_DisconectSentEvent, IO_NO_INCREMENT, FALSE );\r
}\r
\r
VOID SdpSocket::CloseSocketThread()\r
{\r
NTSTATUS rc = STATUS_SUCCESS;\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p\n",this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p\n",this);\r
\r
// wait for the last thread to end.\r
LARGE_INTEGER WaitTime;\r
);\r
\r
if (rc == STATUS_TIMEOUT) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Wait failed with time out this = 0x%p\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Wait failed with time out\n");\r
}\r
\r
ASSERT(NT_SUCCESS(rc));\r
ib_api_status_t ib_status;\r
NTSTATUS rc = STATUS_SUCCESS;\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p \n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p \n", this);\r
\r
if (m_state != SS_CONNECTING_REQ_SENT) {\r
// There was some error, we can release the waiting thread.\r
// The error will be handled there\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("this = 0x%p invalid state %s\n", this, SS2String(m_state)));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET,"this = 0x%p invalid state %s\n", this, SS2String(m_state));\r
rc = STATUS_UNEXPECTED_IO_ERROR;\r
goto Cleanup;\r
} \r
\r
rc = sdp_cm_hello_ack_check(&m_hello_ack);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("sdp_cm_hello_ack_check failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"sdp_cm_hello_ack_check failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
\r
\r
rc = m_SendBufferPool.Init(MAX_SEND_PACKETS, SDP_QP_ATTRIB_SQ_DEPTH, MaxMessageSize, m_pd, m_qp, m_lkey, this);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_SendBufferPool.Init failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_SendBufferPool.Init failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
\r
rc = m_RecvBufferPool.Init(MAX_RECV_PACKETS, QP_ATTRIB_RQ_DEPTH, MaxMessageSize, m_pd, m_qp, m_lkey, this);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_RecvBufferPool.Init failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_RecvBufferPool.Init failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
m_SendBufferPool.SetRemoteRecvBuf(m_hello_ack.bsdh.recv_bufs);\r
\r
ib_status = ib_cm_rtu( m_cm_handle_t, &cm_rtu );\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_cm_rtu failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_cm_rtu failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
// we now arm the CQs\r
ib_status = ib_rearm_cq(m_rcq, FALSE);\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_rearm_cq failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_rearm_cq failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
\r
ib_status = ib_rearm_cq(m_scq, FALSE);\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_rearm_cq failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_rearm_cq failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
\r
rc = m_Lock.LockRc();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Lock failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Lock failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
\r
rc = m_RecvBufferPool.ReceiveIfCan(); //??? error\r
m_Lock.Unlock(); // error ????\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_RecvBufferPool.ReceiveIfCan failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_RecvBufferPool.ReceiveIfCan failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
\r
\r
VOID SdpSocket::CmRepCallback(IN ib_cm_rep_rec_t *p_cm_rep_rec)\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p\n", this);\r
ASSERT(KeGetCurrentIrql() == PASSIVE_LEVEL);\r
\r
if (m_state != SS_CONNECTING_REQ_SENT) {\r
// This is not the state that we waited for, not much that we can\r
// do. (This might happen in shutdown)\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Not the expacted state %s\n", SS2String(m_state)));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Not the expacted state %s\n", SS2String(m_state));\r
ASSERT(FALSE);\r
return;\r
}\r
VOID \r
SdpSocket::CmReqCallback(IN ib_cm_req_rec_t *p_cm_req_rec)\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p\n", this);\r
\r
NTSTATUS rc = STATUS_SUCCESS;\r
ASSERT(KeGetCurrentIrql() == PASSIVE_LEVEL);\r
\r
rc = sdp_cm_hello_check(msg_hello);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("sdp_cm_hello_ack_check failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"sdp_cm_hello_ack_check failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
\r
// Take the lock and verify the state\r
rc = m_Lock.LockRc();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Lock failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Lock failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
\r
if (m_state != SS_LISTENING) {\r
// This is not the state that we waited for, we drop the request\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Not the expacted state %s\n", SS2String(m_state)));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Not the expacted state %s\n", SS2String(m_state));\r
ASSERT(FALSE);\r
goto ErrorLocked;\r
}\r
\r
// Check that we haven't passed the backlog for this connection\r
if (m_ConnectionList.IsFull()) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("Dropping the connection, because of a backlog that is too small\n"));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET,"Dropping the connection, because of a backlog that is too small\n");\r
goto ErrorLocked; \r
}\r
\r
// Create a new socket for this request\r
pNewSocket = new SdpSocket;\r
if (pNewSocket == NULL) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("new pNewSocket failed\n")); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"new pNewSocket failed\n"); \r
goto ErrorLocked;\r
}\r
\r
SocketInParam.dwFlags = 0; \r
rc = pNewSocket->Init(&SocketInParam, &SocketOutParam, m_pSdpUserFile);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("pNewSocket.Init() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"pNewSocket.Init()");\r
goto ErrorLocked;\r
}\r
ASSERT(SocketOutParam.Errno == 0);\r
\r
rc = g_pSdpDriver->m_pSdpArp->SourcePortGidFromIP(pNewSocket->m_SrcIp, &SrcPortGuid, &SrcCaGuid);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_pSdpArp->SourcePortGidFromIP failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_pSdpArp->SourcePortGidFromIP failed rc = 0x%x\n", rc );\r
goto ErrorLocked;\r
} \r
\r
// MAke sure that the port that was recieved muches the one that we\r
// get based on the source IP.\r
if (SrcPortGuid != p_cm_req_rec->primary_path.sgid.unicast.interface_id) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Recieved guid is not what we have expected\n" )); \r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Recieved guid is not what we have expected\n" ); \r
ASSERT(0);\r
goto ErrorLocked;\r
}\r
\r
rc = pNewSocket->CreateQp();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("pNewSocket.CreateQp() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"pNewSocket.CreateQp()");\r
goto ErrorLocked;\r
}\r
\r
\r
rc = pNewSocket->m_SendBufferPool.Init(MAX_SEND_PACKETS, SDP_QP_ATTRIB_SQ_DEPTH, MaxMessageSize, pNewSocket->m_pd, pNewSocket->m_qp, pNewSocket->m_lkey, pNewSocket);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_SendBufferPool.Init failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_SendBufferPool.Init failed rc = 0x%x\n", rc );\r
goto ErrorLocked;\r
}\r
\r
rc = pNewSocket->m_RecvBufferPool.Init(MAX_RECV_PACKETS, QP_ATTRIB_RQ_DEPTH, MaxMessageSize, pNewSocket->m_pd, pNewSocket->m_qp, pNewSocket->m_lkey, pNewSocket);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_RecvBufferPool.Init failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_RecvBufferPool.Init failed rc = 0x%x\n", rc );\r
goto ErrorLocked;\r
}\r
pNewSocket->m_SendBufferPool.SetRemoteRecvBuf(msg_hello->bsdh.recv_bufs);\r
\r
ib_status = ib_cm_rep( p_cm_req_rec->h_cm_req, &cm_rep );\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_cm_rep failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_cm_rep failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto ErrorLocked;\r
}\r
// Add this socket to the list of sockets ?????? should this also be done on errors ????\r
rc = m_ConnectionList.AddConnectionToReplySent(pNewSocket);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("pNewSocket.Init() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"pNewSocket.Init()");\r
goto ErrorLocked;\r
}\r
\r
rc = pNewSocket->m_Lock.LockRc();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("pNewSocket.Init() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"pNewSocket.Init()");\r
goto ErrorLocked;\r
} \r
\r
rc = pNewSocket->m_RecvBufferPool.ReceiveIfCan();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("pNewSocket.Init() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"pNewSocket.Init()");\r
pNewSocket->m_Lock.Unlock(); // Error is ignored, since this is already an error path\r
goto ErrorLocked;\r
}\r
// we now arm the CQs (after that a call back might happen)\r
ib_status = ib_rearm_cq(pNewSocket->m_rcq, FALSE);\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_rearm_cq failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_rearm_cq failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
pNewSocket->m_Lock.Unlock(); // Error is ignored, since this is already an error path\r
goto ErrorLocked;\r
\r
ib_status = ib_rearm_cq(pNewSocket->m_scq, FALSE);\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_rearm_cq failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_rearm_cq failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto ErrorLocked;\r
}\r
\r
rc = pNewSocket->m_Lock.Unlock(); // ???????? Error is ignored, since this is already an error path\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("pNewSocket->m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"pNewSocket->m_Lock.Unlock()");\r
// BUGBUG: who is responsibale for the cleanup ???????\r
goto ErrorLocked;\r
} \r
\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
// BUGBUG: who is responsibale for the cleanup ???????\r
} \r
\r
// Previous rc doesn't mater as this function is void\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
// BUGBUG: who is responsibale for the cleanup ???????\r
}\r
goto Cleanup; \r
ASSERT(KeGetCurrentIrql() == PASSIVE_LEVEL);\r
\r
SdpSocket *pSocket = (SdpSocket *) p_cm_rtu_rec->qp_context;\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p pSocket = 0x%p\n", this, pSocket));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p pSocket = 0x%p\n", this, pSocket);\r
\r
// In order to make our model more consistent we increase the refcount here.\r
// (This is not a must since this is a callback and we are gurantied that the last\r
// Take the lock and verify the state\r
rc = m_Lock.LockRc();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Lock failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Lock failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
\r
if (m_state != SS_LISTENING) {\r
// This is not the state that we waited for, we drop the request\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Not the expacted state %s\n", SS2String(m_state)));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Not the expacted state %s\n", SS2String(m_state));\r
ASSERT(FALSE); // Can this happen on shutdown ?\r
goto ErrorLocked;\r
}\r
// First step is to verify that we have the new socket\r
rc = m_ConnectionList.VerifyConnictionInReplySent(pSocket);\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_ConnectionList.GetConnection failed (got a call back on a not existing connection) rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_ConnectionList.GetConnection failed (got a call back on a not existing connection)");\r
ASSERT(FALSE);\r
goto ErrorLocked;\r
}\r
// Next step is to move the new socket to the SS_CONNECTED state\r
rc = pSocket->m_Lock.LockRc();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Lock failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Lock failed rc = 0x%x\n", rc );\r
goto ErrorLocked;\r
}\r
if (pSocket->m_state != SS_REP_SENT) {\r
m_ConnectionList.MoveConnectionFromReplyToReady(pSocket);\r
rc = pSocket->m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("pSocket->m_Lock.Lock failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"pSocket->m_Lock.Lock failed rc = 0x%x\n", rc );\r
goto ErrorLocked;\r
}\r
\r
m_ConnectionList.FreeWaitingIfCan();\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Lock failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Lock failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
\r
// Previous rc doesn't mater as this function is void\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
// BUGBUG: who is responsibale for the cleanup ???????\r
}\r
goto Cleanup; \r
VOID \r
SdpSocket::CmDreqCallback(IN ib_cm_dreq_rec_t *p_cm_dreq_rec)\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p, dispatch level = %d\n", this, KeGetCurrentIrql()));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p, dispatch level = %d\n", this, KeGetCurrentIrql());\r
ASSERT(KeGetCurrentIrql() == PASSIVE_LEVEL);\r
NTSTATUS rc = STATUS_SUCCESS;\r
ib_cm_drep_t cm_drep;\r
// BUGBUG: It seems that even when the lock fails we should send\r
// drep\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Lock failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Lock failed rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
\r
if (m_state != SS_CONNECTED) {\r
// This is not the state that we waited for, we drop the request\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Not the expacted state %s\n", SS2String(m_state)));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Not the expacted state %s\n", SS2String(m_state));\r
ASSERT(FALSE); // Can this happen on shutdown ?\r
goto ErrorLocked;\r
}\r
\r
ib_status = ib_cm_drep( p_cm_dreq_rec->h_cm_dreq, &cm_drep );\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_cm_drep failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_cm_drep failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto ErrorLocked;\r
}\r
\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
// BUGBUG: who is responsibale for the cleanup ???????\r
} \r
\r
// Previous rc doesn't mater as this function is void\r
rc = m_Lock.Unlock();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock() failed rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_Lock.Unlock()");\r
// BUGBUG: who is responsibale for the cleanup ???????\r
}\r
goto Cleanup; \r
IN const ib_cq_handle_t h_cq,\r
IN void *cq_context )\r
{\r
- SDP_PRINT(SDP_DEBUG, SDP_SOCKET, ("__recv_cb1\n"));\r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_SOCKET,"__recv_cb1\n");\r
\r
SdpSocket *pSocket = (SdpSocket *) cq_context;\r
pSocket->m_Lock.SignalCB(RECV_CB_CALLED);\r
NTSTATUS\r
SdpSocket::recv_cb()\r
{\r
- SDP_PRINT(SDP_DEBUG, SDP_SOCKET, ("this = 0x%p \n", this));\r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_SOCKET,"this = 0x%p \n", this);\r
NTSTATUS rc = STATUS_SUCCESS, rc1 = STATUS_SUCCESS; \r
ib_api_status_t ib_status;\r
ib_wc_t *p_free, *p_wc1;\r
\r
ib_status = ib_poll_cq( m_rcq, &p_free, &p_wc1 );\r
if( (ib_status != IB_SUCCESS) && (ib_status != IB_NOT_FOUND) ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_poll_cq failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_poll_cq failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
if (p_wc->status == IB_WCS_WR_FLUSHED_ERR) {\r
// We have an error, but we still need to return the packet to the caller\r
pBufferDescriptor = (BufferDescriptor *)p_wc->wr_id;\r
- SDP_PRINT(SDP_DEBUG, SDP_SOCKET, ("p_wc->status == IB_WCS_WR_FLUSHED_ERR \n" ));\r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_SOCKET,"p_wc->status == IB_WCS_WR_FLUSHED_ERR \n" );\r
// we can not handle it, but we can and should return it to the pool of recieved buffers\r
rc1 = m_RecvBufferPool.RecievedBuffer(pBufferDescriptor, true);\r
ASSERT(rc1 == STATUS_SUCCESS); // return with error can not fail\r
ASSERT(len >= sizeof msg_hdr_bsdh);\r
if (len < sizeof msg_hdr_bsdh) {\r
// This is a message that is not big enough\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Recieved a message with a buffer that is too short len = %d\n", len ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Recieved a message with a buffer that is too short len = %d\n", len );\r
// we can not handle it, but we can and should return it to the pool of recieved buffers\r
rc1 = m_RecvBufferPool.RecievedBuffer(pBufferDescriptor, true);\r
ASSERT(rc1 == STATUS_SUCCESS); // return with error can not fail\r
ASSERT(pHeader->size >= 0x10);\r
if (len != pHeader->size) {\r
// This is a message that is not formated well\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Recieved a message with a len != pHeader->size = %d : %d\n", len , pHeader->size ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Recieved a message with a len != pHeader->size = %d : %d\n", len , pHeader->size );\r
// we can not handle it, but we can and should return it to the pool of recieved buffers\r
rc1 = m_RecvBufferPool.RecievedBuffer(pBufferDescriptor, true);\r
ASSERT(rc1 == STATUS_SUCCESS); // return with error can not fail\r
rc1 = m_RecvBufferPool.RecievedBuffer(pBufferDescriptor, false);\r
if (!NT_SUCCESS(rc1)) {\r
// We have an error, but we should continue, or we will have a leak\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_RecvBufferPool.RecievedBuffer failed rc = 0x%x\n", rc1 ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"m_RecvBufferPool.RecievedBuffer failed rc = 0x%x\n", rc1 );\r
UpdateRc(&rc, rc1);\r
continue;\r
}\r
if (NT_SUCCESS(rc)) { \r
ib_status = ib_rearm_cq(m_rcq, FALSE );\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_rearm_cq failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_rearm_cq failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
// get out of this function\r
}\r
IN void *cq_context )\r
{\r
SdpSocket *pSocket = (SdpSocket *) cq_context;\r
- SDP_PRINT(SDP_DEBUG, SDP_SOCKET, ("called this = 0x%x\n", pSocket )); \r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_SOCKET,"called this = 0x%p\n", pSocket ); \r
pSocket->m_Lock.SignalCB(SEND_CB_CALLED);\r
}\r
\r
\r
NTSTATUS SdpSocket::send_cb()\r
{\r
- SDP_PRINT(SDP_DEBUG, SDP_SOCKET, ("called this =0x%p\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_VERBOSE, SDP_SOCKET,"called this =0x%p\n", this);\r
NTSTATUS rc = STATUS_SUCCESS, rc1 = STATUS_SUCCESS, rc2 = STATUS_SUCCESS;\r
AssertLocked();\r
ib_api_status_t ib_status;\r
ib_status = ib_poll_cq( m_scq, &p_free, &p_wc );\r
ASSERT( ib_status == IB_SUCCESS || ib_status == IB_NOT_FOUND);\r
if (ib_status == IB_NOT_FOUND) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("ib_poll_cq returned IB_NOT_FOUND, this =0x%p\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET,"ib_poll_cq returned IB_NOT_FOUND, this =0x%p\n", this);\r
break;\r
}\r
if (ib_status != IB_SUCCESS) { \r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_poll_cq failed ib_status=%d, this =0x%p\n", ib_status,this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_poll_cq failed ib_status=%d, this =0x%p\n", ib_status,this);\r
ASSERT(ib_status == IB_INVALID_CQ_HANDLE || ib_status == IB_NOT_FOUND);\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
break;\r
\r
case IB_WCS_WR_FLUSHED_ERR:\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Flushed send completion. this =0x%p\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET, "Flushed send completion. this =0x%p\n", this);\r
// Intentainly fall down\r
default:\r
- SDP_PRINT( SDP_ERR, SDP_SOCKET, ("Send failed with %s\n",\r
- ib_get_wc_status_str( p_wc->status )) );\r
+ SDP_PRINT( TRACE_LEVEL_ERROR, SDP_SOCKET, "Send failed with %s\n",\r
+ ib_get_wc_status_str( p_wc->status ));\r
m_Lock.SignalError(IB2Status(ib_status));\r
}\r
\r
/* If we didn't use up every WC, break out. */\r
} while( !p_free );\r
if (!NT_SUCCESS(rc1)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Error was detected on ReturnBuffer rc1 = 0x%x\n", rc1 ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET, "Error was detected on ReturnBuffer rc1 = 0x%x\n", rc1 );\r
ASSERT(NT_SUCCESS(rc));\r
rc = rc1;\r
goto Cleanup;\r
/* Rearm the CQ. */\r
ib_status = ib_rearm_cq(m_scq, FALSE );\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_rearm_cq failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET, "ib_rearm_cq failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
/* Resume any sends awaiting resources. */\r
rc = m_SendBufferPool.SendBuffersIfCan();\r
if (!NT_SUCCESS(rc)) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_SendBufferPool.Init SendBuffersIfCan rc = 0x%x\n", rc ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET, "m_SendBufferPool.Init SendBuffersIfCan rc = 0x%x\n", rc );\r
goto Cleanup;\r
}\r
\r
UNUSED_PARAM( p_event_rec );\r
ASSERT( p_event_rec->context );\r
/* Place holder for proper error handler. */\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("Async QP event: %d\n", p_event_rec->code));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"Async QP event: %d\n", p_event_rec->code);\r
ASSERT( p_event_rec->code == IB_AE_UNKNOWN );\r
}\r
\r
net32_t rkey;\r
\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p\n", this);\r
ASSERT(m_SrcCaGuid != 0);\r
/* Open the CA. */\r
ib_status = ib_open_ca(\r
&mh_Ca \r
);\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_open_ca failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_open_ca failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
\r
if( ib_status != IB_SUCCESS )\r
{\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_alloc_pd failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_alloc_pd failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
);\r
\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_create_cq failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_create_cq failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
);\r
\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_create_cq failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_create_cq failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
qp_create.sq_signaled = TRUE;\r
ib_status = ib_create_qp( m_pd, &qp_create, this, __qp_event1, &m_qp );\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_create_qp failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_create_qp failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
m_qp, &qp_attr );\r
if( ib_status != IB_SUCCESS )\r
{\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_query_qp failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_query_qp failed ib_status = 0x%d\n", ib_status );\r
// ignore the error, this is only needed for debug\r
}\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET,("QP number is %x\n", CL_NTOH32(qp_attr.num)));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"QP number is %x\n", CL_NTOH32(qp_attr.num));\r
#endif \r
\r
const net64_t MEM_REG_SIZE = 0xFFFFFFFFFFFFFFFF;\r
&rkey, \r
&m_mr );\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_reg_phys failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_reg_phys failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
goto Cleanup;\r
}\r
\r
)\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"this = 0x%p\n", this);\r
ASSERT(DestIp != 0);\r
ASSERT(m_SrcPort != 0);\r
ASSERT(m_SrcIp != 0);\r
sdp_msg_hello_ack* hello_ack_msg\r
)\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("called this = 0x%p\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"called this = 0x%p\n", this);\r
\r
memset(hello_ack_msg, 0, sizeof(struct sdp_msg_hello_ack));\r
hello_ack_msg->bsdh.recv_bufs = QP_ATTRIB_RQ_DEPTH; //????conn->l_advt_bf;\r
NTSTATUS rc = STATUS_SUCCESS;\r
\r
if (!m_Lock.Lock()) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Failed to lock this = 0x%p \n",this));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET, "Failed to lock this = 0x%p \n",this);\r
// Error is ignored, as it is a callback path, socket is already at an error state\r
goto Cleanup;\r
}\r
InitializeListHead(&m_CallBackRequestList);\r
rc = m_SendBufferPool.UsersThreadCallBack();\r
if (!NT_SUCCESS(rc)) { \r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_SendBufferPool.UsersThreadCallBack failed this = 0x%p, rc = 0x%x \n",\r
- this, rc));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET, "m_SendBufferPool.UsersThreadCallBack failed this = 0x%p, rc = 0x%x \n",\r
+ this, rc);\r
m_Lock.Unlock(); // Error is ignored, as this is already an error path\r
Shutdown();\r
goto Cleanup;\r
\r
rc = m_Lock.Unlock(); // Error is ignored, as it is a callback path \r
if (!NT_SUCCESS(rc)) { \r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("m_Lock.Unlock failed this = 0x%p, rc = 0x%x \n",\r
- this, rc));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET, "m_Lock.Unlock failed this = 0x%p, rc = 0x%x \n",\r
+ this, rc);\r
Shutdown();\r
goto Cleanup;\r
}\r
);\r
\r
if (rc == STATUS_TIMEOUT) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("Wait failed with time out \n"));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"Wait failed with time out\n");\r
ASSERT(FALSE);\r
}\r
\r
\r
VOID SdpSocket::DyingProcessDetected()\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("called this = 0x%p\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET, "called this = 0x%p\n", this);\r
m_Lock.Lock(true); //????? verify must succeed\r
if (m_CloseSocketCalled) {\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("this = 0x%p m_CloseSocketCalled, letting it finish his job\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET, "this = 0x%p m_CloseSocketCalled, letting it finish his job\n", this);\r
m_Lock.Unlock(); // Error is ignored since this is already\r
// shutdown call\r
return;\r
\r
VOID SdpSocket::Shutdown()\r
{\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("called this = 0x%p\n", this));\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("this = 0x%p m_NumberOfBytesSent = %d m_NumberOfBytesSentAndAcked = %d "\r
- "m_NumberOfBuffersRecievedSuccessfully = %d, m_NumberOfBuffersRecievedWithError = %d\n", \r
- this, m_SendBufferPool.m_NumberOfBytesSent, m_SendBufferPool.m_NumberOfBytesSentAndAcked, \r
- m_RecvBufferPool.m_NumberOfBuffersRecievedSuccessfully, m_RecvBufferPool.m_NumberOfBuffersRecievedWithError)); \r
-\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET, "called this = 0x%p\n", this);\r
+ \r
NTSTATUS rc = STATUS_SUCCESS;\r
ib_api_status_t ib_status;\r
ib_qp_mod_t qp_mod;\r
if (m_ListenHandle != NULL) {\r
ib_status = ib_cm_cancel( m_ListenHandle, ShutdownCB );\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_cm_cancel failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_cm_cancel failed ib_status = 0x%d\n", ib_status );\r
rc = IB2Status(ib_status);\r
} else {\r
WaitForShutdownEvent(&m_ShutdownCompleteEvent);\r
m_ConnectionList.Shutdown();\r
\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("111111\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"111111%p\n", this);\r
\r
if (m_qp != NULL) {\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("222222\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"222222%p\n", this);\r
\r
cl_memclr( &qp_mod, sizeof(ib_qp_mod_t) );\r
qp_mod.req_state = IB_QPS_ERROR;\r
ib_status = ib_modify_qp( m_qp, &qp_mod );\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_modify_qp failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_modify_qp failed ib_status = 0x%d\n", ib_status );\r
ASSERT(FALSE);\r
// We are probably going to leak, but we have to continue\r
}\r
}\r
}\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("333333\n", this));\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"333333%p\n", this);\r
\r
if (m_scq != NULL) {\r
ib_status = ib_destroy_cq(m_scq, ShutdownCB);\r
}\r
//?????m_scq = NULL;\r
}\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("444444\n", this)); \r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"444444%p\n", this); \r
\r
if (m_rcq != NULL) {\r
ib_status = ib_destroy_cq(m_rcq, ShutdownCB); \r
//??????m_rcq = NULL;\r
\r
}\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("555555\n", this)); \r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"555555%p\n", this); \r
if (m_pd != NULL) {\r
ib_status = ib_dealloc_pd(m_pd, ShutdownCB); \r
//???ASSERT(ib_status == IB_SUCCESS);\r
//?????m_pd = NULL;\r
\r
}\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("666666\n", this)); \r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET,"666666%p\n", this); \r
\r
if (mh_Ca != NULL) {\r
ib_status = ib_close_ca(mh_Ca, ShutdownCB); \r
if (m_mr != NULL) {\r
ib_status = ib_dereg_mr(m_mr);\r
if( ib_status != IB_SUCCESS ) {\r
- SDP_PRINT(SDP_ERR, SDP_SOCKET, ("ib_dereg_mr failed ib_status = 0x%d\n", ib_status ));\r
+ SDP_PRINT(TRACE_LEVEL_ERROR, SDP_SOCKET,"ib_dereg_mr failed ib_status = 0x%d\n", ib_status );\r
ASSERT( ib_status == IB_SUCCESS );\r
}\r
m_mr = NULL;\r
* validation and consistency checks\r
*/\r
if (hello_ack->bsdh.size != sizeof(struct sdp_msg_hello_ack)) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("hello ack, size mismatch. (2) <%d:%d>",\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "hello ack, size mismatch. (2) <%d:%d>",\r
hello_ack->bsdh.size,\r
- sizeof(struct sdp_msg_hello_ack)));\r
+ sizeof(struct sdp_msg_hello_ack));\r
return STATUS_UNEXPECTED_IO_ERROR;\r
}\r
\r
if (SDP_MID_HELLO_ACK != hello_ack->bsdh.mid) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("hello ack, unexpected message. <%d>",\r
- hello_ack->bsdh.mid\r
- ));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "hello ack, unexpected message. <%d>",\r
+ hello_ack->bsdh.mid);\r
return STATUS_UNEXPECTED_IO_ERROR; \r
}\r
\r
if (hello_ack->hah.max_adv <= 0) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("hello ack, bad zcopy advertisment. <%d>",\r
- hello_ack->hah.max_adv\r
- ));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "hello ack, bad zcopy advertisment. <%d>",\r
+ hello_ack->hah.max_adv);\r
return STATUS_UNEXPECTED_IO_ERROR; \r
}\r
\r
if ((0xF0 & hello_ack->hah.version) != (0xF0 & SDP_MSG_VERSION)) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET, ("hello ack, version mismatch. <%d:%d>",\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "hello ack, version mismatch. <%d:%d>",\r
((0xF0 & hello_ack->hah.version) >> 4),\r
- ((0xF0 & SDP_MSG_VERSION) >> 4)));\r
+ ((0xF0 & SDP_MSG_VERSION) >> 4));\r
return STATUS_UNEXPECTED_IO_ERROR; \r
}\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("Hello Ack BSDH <%04x:%02x:%02x:%08x:%08x:%08x>",\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET, "Hello Ack BSDH <%04x:%02x:%02x:%08x:%08x:%08x>",\r
hello_ack->bsdh.recv_bufs,\r
hello_ack->bsdh.flags,\r
hello_ack->bsdh.mid,\r
hello_ack->bsdh.size,\r
hello_ack->bsdh.seq_num,\r
- hello_ack->bsdh.seq_ack));\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET, ("Hello Ack HAH <%02x:%02x:%08x",\r
+ hello_ack->bsdh.seq_ack);\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET, "Hello Ack HAH <%02x:%02x:%08x",\r
hello_ack->hah.max_adv,\r
hello_ack->hah.version, \r
- hello_ack->hah.l_rcv_size));\r
+ hello_ack->hah.l_rcv_size);\r
\r
return STATUS_SUCCESS;\r
}\r
*/\r
\r
if (msg_hello->bsdh.size != sizeof(struct sdp_msg_hello)) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET,( "hello msg size mismatch. (2) <%d:%Zu>",\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "hello msg size mismatch. (2) <%d:%d>",\r
msg_hello->bsdh.size,\r
- sizeof(struct sdp_msg_hello)));\r
+ sizeof(struct sdp_msg_hello));\r
return STATUS_UNEXPECTED_IO_ERROR;\r
}\r
\r
if (SDP_MID_HELLO != msg_hello->bsdh.mid) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET,("hello msg unexpected ID. <%d>",\r
- msg_hello->bsdh.mid));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "hello msg unexpected ID. <%d>",\r
+ msg_hello->bsdh.mid);\r
return STATUS_UNEXPECTED_IO_ERROR;\r
}\r
\r
if (msg_hello->hh.max_adv <= 0) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET,("hello msg, bad zcopy count <%d>",\r
- msg_hello->hh.max_adv));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "hello msg, bad zcopy count <%d>",\r
+ msg_hello->hh.max_adv);\r
return STATUS_UNEXPECTED_IO_ERROR;\r
}\r
\r
if ((0xF0 & msg_hello->hh.version) != (0xF0 & SDP_MSG_VERSION)) {\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET,("hello msg, version mismatch. <%d:%d>",\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "hello msg, version mismatch. <%d:%d>",\r
((0xF0 & msg_hello->hh.version) >> 4),\r
- ((0xF0 & SDP_MSG_VERSION) >> 4)));\r
+ ((0xF0 & SDP_MSG_VERSION) >> 4));\r
return STATUS_UNEXPECTED_IO_ERROR;\r
}\r
#ifdef _SDP_MS_APRIL_ERROR_COMPAT\r
#else\r
if ((SDP_MSG_IPVER & 0xF0) != (msg_hello->hh.ip_ver & 0xF0)) {\r
#endif\r
- SDP_PRINT(SDP_WARN, SDP_SOCKET,( "hello msg, ip version mismatch. <%d:%d>",\r
- msg_hello->hh.ip_ver, SDP_MSG_IPVER));\r
+ SDP_PRINT(TRACE_LEVEL_WARNING, SDP_SOCKET, "hello msg, ip version mismatch. <%d:%d>",\r
+ msg_hello->hh.ip_ver, SDP_MSG_IPVER);\r
return STATUS_UNEXPECTED_IO_ERROR;\r
}\r
\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET,("Hello BSDH <%04x:%02x:%02x:%08x:%08x:%08x>",\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET, "Hello BSDH <%04x:%02x:%02x:%08x:%08x:%08x>",\r
msg_hello->bsdh.recv_bufs,\r
msg_hello->bsdh.flags,\r
msg_hello->bsdh.mid,\r
msg_hello->bsdh.size,\r
msg_hello->bsdh.seq_num,\r
- msg_hello->bsdh.seq_ack));\r
- SDP_PRINT(SDP_TRACE, SDP_SOCKET,(\r
- "Hello HH <%02x:%02x:%02x:%08x:%08x:%04x:%08x:%08x>",\r
+ msg_hello->bsdh.seq_ack);\r
+ SDP_PRINT(TRACE_LEVEL_INFORMATION, SDP_SOCKET, "Hello HH <%02x:%02x:%02x:%08x:%08x:%04x:%08x:%08x>",\r
msg_hello->hh.max_adv,\r
msg_hello->hh.ip_ver,\r
msg_hello->hh.version,\r
msg_hello->hh.l_rcv_size,\r
msg_hello->hh.port,\r
msg_hello->hh.src.ipv4.addr,\r
- msg_hello->hh.dst.ipv4.addr));\r
+ msg_hello->hh.dst.ipv4.addr);\r
\r
return STATUS_SUCCESS;\r
}\r
projects / ~shefty / rdma-win.git / commitdiff