{NDIS_STRING_CONST("BCJoinRetry"), 1, IPOIB_OFFSET(bc_join_retry), IPOIB_SIZE(bc_join_retry), 50, 0, 1000},\r
{NDIS_STRING_CONST("CmEnabled"), 0, IPOIB_OFFSET(cm_enabled), IPOIB_SIZE(cm_enabled), FALSE, FALSE, TRUE},\r
{NDIS_STRING_CONST("CmPayloadMtu"), 1, IPOIB_OFFSET(cm_payload_mtu), IPOIB_SIZE(cm_payload_mtu), MAX_CM_PAYLOAD_MTU, 512, MAX_CM_PAYLOAD_MTU}\r
-\r
-}; \r
+}; \r
\r
#define IPOIB_NUM_REG_PARAMS (sizeof (HCARegTable) / sizeof(IPOIB_REG_ENTRY))\r
\r
p_param->ParameterData.IntegerData > pRegEntry[i].Max)\r
{\r
value = pRegEntry[i].Default;\r
- ipoib_create_log(p_adapter->h_adapter, i, EVENT_IPOIB_WRONG_PARAMETER_WRN);\r
- IPOIB_PRINT(TRACE_LEVEL_VERBOSE, IPOIB_DBG_INIT, ("Read configuration.Registry %S value is out of range, setting default value= 0x%x\n", pRegEntry[i].RegName.Buffer, value)); \r
-\r
+ ipoib_create_log(p_adapter->h_adapter, i,\r
+ EVENT_IPOIB_WRONG_PARAMETER_WRN);\r
+ IPOIB_PRINT(TRACE_LEVEL_VERBOSE, IPOIB_DBG_INIT,\r
+ ("Read configuration.Registry %S value is out of range, "\r
+ "setting default value= 0x%x\n",\r
+ pRegEntry[i].RegName.Buffer, value));\r
}\r
else\r
{\r
value = p_param->ParameterData.IntegerData;\r
- IPOIB_PRINT(TRACE_LEVEL_VERBOSE, IPOIB_DBG_INIT, ("Read configuration. Registry %S, Value= 0x%x\n", pRegEntry[i].RegName.Buffer, value));\r
+ IPOIB_PRINT(TRACE_LEVEL_VERBOSE, IPOIB_DBG_INIT,\r
+ ("Read configuration. Registry %S, Value= 0x%x\n",\r
+ pRegEntry[i].RegName.Buffer, value));\r
}\r
}\r
-\r
else\r
{\r
value = pRegEntry[i].Default;\r
status = NDIS_STATUS_SUCCESS;\r
if (pRegEntry[i].bRequired)\r
{\r
- ipoib_create_log(p_adapter->h_adapter, i, EVENT_IPOIB_WRONG_PARAMETER_ERR);\r
- IPOIB_PRINT(TRACE_LEVEL_ERROR, IPOIB_DBG_INIT, ("Read configuration.Registry %S value not found, setting default value= 0x%x\n", pRegEntry[i].RegName.Buffer, value));\r
+ ipoib_create_log(p_adapter->h_adapter, i,\r
+ EVENT_IPOIB_WRONG_PARAMETER_ERR);\r
+ IPOIB_PRINT(TRACE_LEVEL_ERROR, IPOIB_DBG_INIT,\r
+ ("Read configuration.Registry %S value not found, setting "\r
+ "default value= 0x%x\n",\r
+ pRegEntry[i].RegName.Buffer, value));\r
}\r
else\r
{\r
break;\r
\r
default:\r
- IPOIB_PRINT(TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR, ("Bogus field size %d\n", pRegEntry[i].FieldSize));\r
+ IPOIB_PRINT(TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
+ ("Bogus field size %d\n", pRegEntry[i].FieldSize));\r
break;\r
}\r
}\r
\r
if (p_adapter->params.sq_depth % sq_depth_step) {\r
static const c_sq_ind = 2;\r
- p_adapter->params.sq_depth = sq_depth_step *(\r
- p_adapter->params.sq_depth / sq_depth_step + !!( (p_adapter->params.sq_depth % sq_depth_step) > (sq_depth_step/2) ));\r
- ipoib_create_log(p_adapter->h_adapter, c_sq_ind, EVENT_IPOIB_WRONG_PARAMETER_WRN);\r
- IPOIB_PRINT(TRACE_LEVEL_VERBOSE, IPOIB_DBG_INIT, ("SQ DEPTH value was rounded to the closest acceptable value of 0x%x\n", p_adapter->params.sq_depth ));\r
-\r
+ p_adapter->params.sq_depth = sq_depth_step *\r
+ (p_adapter->params.sq_depth / sq_depth_step +\r
+ !!((p_adapter->params.sq_depth % sq_depth_step) > (sq_depth_step/2)));\r
+ ipoib_create_log(p_adapter->h_adapter, c_sq_ind,\r
+ EVENT_IPOIB_WRONG_PARAMETER_WRN);\r
+ IPOIB_PRINT(TRACE_LEVEL_VERBOSE, IPOIB_DBG_INIT,\r
+ ("SQ DEPTH value was rounded to the closest acceptable value "\r
+ "of 0x%x\n", p_adapter->params.sq_depth ));\r
}\r
\r
// Adjusting the low watermark parameter\r
if (len != NDIS_SIZEOF_OFFLOAD_PARAMETERS_REVISION_2)\r
{\r
ASSERT(FALSE);\r
- IPOIB_PRINT(TRACE_LEVEL_ERROR, IPOIB_DBG_OID, ("Buffer is too small. offloading task requirs %d but the buffer size is: %d \n", NDIS_SIZEOF_OFFLOAD_PARAMETERS_REVISION_2, len));\r
+ IPOIB_PRINT(TRACE_LEVEL_ERROR, IPOIB_DBG_OID,\r
+ ("Buffer is too small. offloading task requirs %d but the buffer "\r
+ "size is: %d \n", NDIS_SIZEOF_OFFLOAD_PARAMETERS_REVISION_2, len));\r
Status = NDIS_STATUS_INVALID_LENGTH;\r
goto Exit;\r
}\r
\r
- IPOIB_PRINT(TRACE_LEVEL_VERBOSE, IPOIB_DBG_OID, ("received set for OID_TCP_TASK_OFFLOAD\n"));\r
+ IPOIB_PRINT(TRACE_LEVEL_VERBOSE, IPOIB_DBG_OID,\r
+ ("received set for OID_TCP_TASK_OFFLOAD\n"));\r
\r
pOffloadParam = (PNDIS_OFFLOAD_PARAMETERS) pBuf;\r
pOffloadHeader = &(pOffloadParam->Header);\r
(pOffloadHeader->Size != NDIS_SIZEOF_OFFLOAD_PARAMETERS_REVISION_2))\r
{ \r
ASSERT(FALSE);\r
- IPOIB_PRINT(TRACE_LEVEL_ERROR, IPOIB_DBG_OID, ("Set offloading task Illegal header\n"));\r
+ IPOIB_PRINT(TRACE_LEVEL_ERROR, IPOIB_DBG_OID,\r
+ ("Set offloading task Illegal header\n"));\r
Status = NDIS_STATUS_INVALID_DATA;\r
goto Exit;\r
}\r
status = NdisMRegisterScatterGatherDma(\r
h_adapter,\r
&DmaDescription,\r
- &p_adapter->NdisMiniportDmaHandle);\r
+ &p_adapter->NdisMiniportDmaHandle );\r
\r
if( status != NDIS_STATUS_SUCCESS )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- ("NdisMRegisterScatterGatherDma returned 0x%.8x.\n", status) );\r
+ ("NdisMRegisterScatterGatherDma returned 0x%.8x.\n", status) );\r
return status;\r
\r
}\r
- //NDIS sets this value before it returns from NdisMRegisterScatterGatherDma. \r
- //Miniport drivers should use this size to preallocate memory for each scatter/gather list. \r
+ //NDIS sets this value before it returns from NdisMRegisterScatterGatherDma.\r
+ //Miniport drivers should use this size to preallocate memory for each\r
+ // scatter/gather list. \r
p_adapter->sg_list_size = DmaDescription.ScatterGatherListSize ;\r
\r
return status;\r
++(p_adapter->p_port->n_no_progress);\r
if (p_adapter->p_port->n_no_progress >= 4)\r
{\r
- IPOIB_PRINT( TRACE_LEVEL_ERROR,IPOIB_DBG_ERROR, ("port got stuck, reseting it !!!\n"));\r
+ IPOIB_PRINT( TRACE_LEVEL_ERROR,IPOIB_DBG_ERROR,\r
+ ("port got stuck, reseting it !!!\n"));\r
//CL_ASSERT(FALSE); //?????\r
p_adapter->hung = TRUE;\r
}\r
\r
case OID_GEN_TRANSMIT_BUFFER_SPACE:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received query for OID_GEN_TRANSMIT_BUFFER_SPACE\n", port_num) );\r
+ ("Port %d received query for OID_GEN_TRANSMIT_BUFFER_SPACE\n",\r
+ port_num) );\r
if( p_adapter->params.cm_enabled )\r
- info = p_adapter->params.sq_depth * p_adapter->params.cm_xfer_block_size;\r
+ info = p_adapter->params.sq_depth\r
+ * p_adapter->params.cm_xfer_block_size;\r
else\r
- info = p_adapter->params.sq_depth * p_adapter->params.xfer_block_size;\r
+ info = p_adapter->params.sq_depth\r
+ * p_adapter->params.xfer_block_size;\r
break;\r
\r
case OID_GEN_RECEIVE_BUFFER_SPACE:\r
("Port %d received query for OID_GEN_TRANSMIT_BUFFER_SPACE "\r
"or OID_GEN_RECEIVE_BUFFER_SPACE\n", port_num) );\r
if( p_adapter->params.cm_enabled )\r
- info = p_adapter->params.rq_depth * p_adapter->params.cm_xfer_block_size;\r
+ info = p_adapter->params.rq_depth\r
+ * p_adapter->params.cm_xfer_block_size;\r
else\r
- info = p_adapter->params.rq_depth * p_adapter->params.xfer_block_size;\r
+ info = p_adapter->params.rq_depth\r
+ * p_adapter->params.xfer_block_size;\r
break;\r
\r
case OID_GEN_MAXIMUM_LOOKAHEAD:\r
case OID_GEN_TRANSMIT_BLOCK_SIZE:\r
case OID_GEN_RECEIVE_BLOCK_SIZE:\r
case OID_GEN_MAXIMUM_TOTAL_SIZE:\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received query for OID_GEN_MAXIMUM_LOOKAHEAD "\r
- "or OID_GEN_CURRENT_LOOKAHEAD or "\r
- "OID_GEN_TRANSMIT_BLOCK_SIZE or "\r
- "OID_GEN_RECEIVE_BLOCK_SIZE or "\r
- "OID_GEN_MAXIMUM_TOTAL_SIZE\n", port_num) );\r
if( p_adapter->params.cm_enabled )\r
info = p_adapter->params.cm_xfer_block_size;\r
else\r
info = p_adapter->params.xfer_block_size;\r
+\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
+ ("Port %d received query for 1 of OID_GEN_MAXIMUM_LOOKAHEAD, "\r
+ "_CURRENT_LOOKAHEAD, "\r
+ "_TRANSMIT_BLOCK_SIZE, "\r
+ "_RECEIVE_BLOCK_SIZE, "\r
+ "_GEN_MAXIMUM_TOTAL_SIZE = %d\n", port_num, info) );\r
break;\r
\r
case OID_GEN_VENDOR_ID:\r
\r
case OID_GEN_VENDOR_DESCRIPTION:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID, \r
- ("Port %d received query for OID_GEN_VENDOR_DESCRIPTION\n", port_num) );\r
+ ("Port %d received query for OID_GEN_VENDOR_DESCRIPTION\n",\r
+ port_num) );\r
src_buf = VENDOR_DESCRIPTION;\r
buf_len = sizeof(VENDOR_DESCRIPTION);\r
break;\r
\r
case OID_GEN_VENDOR_DRIVER_VERSION:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received query for OID_GEN_VENDOR_DRIVER_VERSION\n", port_num) );\r
+ ("Port %d received query for OID_GEN_VENDOR_DRIVER_VERSION\n",\r
+ port_num) );\r
src_buf = &version;\r
buf_len = sizeof(version);\r
//TODO: Figure out what the right version is.\r
\r
case OID_GEN_PHYSICAL_MEDIUM:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received query for OID_GEN_PHYSICAL_MEDIUM\n", port_num) );\r
+ ("Port %d received query for OID_GEN_PHYSICAL_MEDIUM\n",\r
+ port_num) );\r
info = NdisPhysicalMediumUnspecified;\r
break;\r
\r
case OID_GEN_CURRENT_PACKET_FILTER:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received query for OID_GEN_CURRENT_PACKET_FILTER\n", port_num) );\r
+ ("Port %d received query for OID_GEN_CURRENT_PACKET_FILTER\n",\r
+ port_num) );\r
info = p_adapter->packet_filter;\r
break;\r
\r
case OID_GEN_DRIVER_VERSION:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received query for OID_GEN_DRIVER_VERSION\n", port_num) );\r
+ ("Port %d received query for OID_GEN_DRIVER_VERSION\n",\r
+ port_num) );\r
src_buf = &version;\r
buf_len = sizeof(version);\r
version = MAJOR_NDIS_VERSION << 8 | MINOR_NDIS_VERSION;\r
\r
case OID_GEN_MEDIA_CONNECT_STATUS:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received query for OID_GEN_MEDIA_CONNECT_STATUS\n", port_num) );\r
+ ("Port %d received query for OID_GEN_MEDIA_CONNECT_STATUS\n",\r
+ port_num) );\r
cl_obj_lock( &p_adapter->obj );\r
switch( p_adapter->state )\r
{\r
\r
case OID_GEN_MAXIMUM_SEND_PACKETS:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received query for OID_GEN_MAXIMUM_SEND_PACKETS\n", port_num) );\r
+ ("Port %d received query for OID_GEN_MAXIMUM_SEND_PACKETS\n",\r
+ port_num) );\r
info = MINIPORT_MAX_SEND_PACKETS;\r
break;\r
\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
("Port %d received query for OID_802_3_PERMANENT_ADDRESS\n", port_num) );\r
src_buf = &p_adapter->mac;\r
- buf_len = sizeof(p_adapter->mac);\r
+ buf_len = sizeof(p_adapter->mac);\r
break;\r
\r
case OID_802_3_CURRENT_ADDRESS:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
("Port %d received query for OID_802_3_CURRENT_ADDRESS\n", port_num) );\r
src_buf = &p_adapter->params.conf_mac;\r
- buf_len = sizeof(p_adapter->params.conf_mac);\r
+ buf_len = sizeof(p_adapter->params.conf_mac);\r
break;\r
\r
case OID_802_3_MULTICAST_LIST:\r
break; \r
case OID_GEN_INTERRUPT_MODERATION:\r
InterruptModerationParam.Header.Type = NDIS_OBJECT_TYPE_DEFAULT;\r
- InterruptModerationParam.Header.Revision = NDIS_INTERRUPT_MODERATION_PARAMETERS_REVISION_1;\r
- InterruptModerationParam.Header.Size = NDIS_SIZEOF_INTERRUPT_MODERATION_PARAMETERS_REVISION_1;\r
- InterruptModerationParam.Flags = NDIS_INTERRUPT_MODERATION_CHANGE_NEEDS_RESET ;\r
- InterruptModerationParam.InterruptModeration = NdisInterruptModerationNotSupported ; \r
+ InterruptModerationParam.Header.Revision =\r
+ NDIS_INTERRUPT_MODERATION_PARAMETERS_REVISION_1;\r
+ InterruptModerationParam.Header.Size =\r
+ NDIS_SIZEOF_INTERRUPT_MODERATION_PARAMETERS_REVISION_1;\r
+ InterruptModerationParam.Flags =\r
+ NDIS_INTERRUPT_MODERATION_CHANGE_NEEDS_RESET;\r
+ InterruptModerationParam.InterruptModeration =\r
+ NdisInterruptModerationNotSupported;\r
buf_len = sizeof(NDIS_INTERRUPT_MODERATION_PARAMETERS);\r
src_buf = (PVOID) &InterruptModerationParam; \r
break;\r
case OID_PNP_CAPABILITIES:\r
status = NDIS_STATUS_NOT_SUPPORTED;\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received an unsupported oid of 0x%.8X!\n", port_num, oid_info.oid) );\r
+ ("Port %d received an unsupported Optional oid of 0x%.8X!\n",\r
+ port_num, oid_info.oid) );\r
break;\r
\r
case OID_GEN_PROTOCOL_OPTIONS:\r
case OID_GEN_TRANSPORT_HEADER_OFFSET:\r
case OID_PNP_ENABLE_WAKE_UP:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received query for OID_GEN_PROTOCOL_OPTIONS or OID_GEN_NETWORK_LAYER_ADDRESSES or OID_GEN_TRANSPORT_HEADER_OFFSET OID_PNP_ENABLE_WAKE_UPn", port_num) );\r
+ ("Port %d received query for OID_GEN_PROTOCOL_OPTIONS or "\r
+ "OID_GEN_NETWORK_LAYER_ADDRESSES or "\r
+ "OID_GEN_TRANSPORT_HEADER_OFFSET OID_PNP_ENABLE_WAKE_UP\n",\r
+ port_num) );\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
("Number of OID: 0x%.8X!\n", oid_info.oid) );\r
status = NDIS_STATUS_SUCCESS; \r
\r
case OID_TCP_OFFLOAD_CURRENT_CONFIG:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received query for OID_PNP_QUERY_POWER\n", port_num) );\r
+ ("Port %d received query for OID_TCP_OFFLOAD_CURRENT_CONFIG\n",\r
+ port_num) );\r
//ulBytesAvailable = ulInfoLen = sizeof(NDIS_OFFLOAD);\r
if (oid_info.buf_len < sizeof(NDIS_OFFLOAD))\r
{\r
OffloadConfig( p_adapter, &offload);\r
src_buf = &offload;\r
break;\r
+\r
case OID_IP6_OFFLOAD_STATS:\r
case OID_IP4_OFFLOAD_STATS:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
- ("Port %d received query for UNSUPPORTED OID_IP[4,6]_OFFLOAD_STATS\n", port_num) );\r
+ ("Port %d received query for UNSUPPORTED "\r
+ "OID_IP[4,6]_OFFLOAD_STATS\n", port_num) );\r
+ status = NDIS_STATUS_NOT_SUPPORTED;\r
+ break;\r
+\r
+ case OID_GEN_MACHINE_NAME:\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION,IPOIB_DBG_OID,\r
+ ("Port %d received query OID_GEN_MACHINE_NAME\n", port_num) );\r
status = NDIS_STATUS_NOT_SUPPORTED;\r
break;\r
+\r
default:\r
status = NDIS_STATUS_INVALID_OID;\r
IPOIB_PRINT( TRACE_LEVEL_ERROR,IPOIB_DBG_ERROR,\r
- ("Port %d received an invalid oid of 0x%.8X!\n", port_num, oid_info.oid) );\r
+ ("Port %d received an invalid oid of 0x%.8X!\n",\r
+ port_num, oid_info.oid) );\r
break;\r
}\r
\r
*/\r
if( status != NDIS_STATUS_PENDING )\r
{\r
- return ipoib_complete_query(\r
- p_adapter, &oid_info, status, src_buf, buf_len );\r
+ return ipoib_complete_query( p_adapter,\r
+ &oid_info,\r
+ status,\r
+ src_buf,\r
+ buf_len );\r
}\r
\r
IPOIB_EXIT( IPOIB_DBG_OID );\r
p_adapter->pending_query = FALSE;\r
IPOIB_EXIT( IPOIB_DBG_OID );\r
return oid_status;\r
-\r
- \r
}\r
\r
static\r
}\r
else\r
{\r
- ipoib_refresh_mcast( p_adapter, (mac_addr_t*)info_buf,\r
- (uint8_t)(info_buf_len / sizeof(mac_addr_t)) );\r
+ ipoib_refresh_mcast( p_adapter,\r
+ (mac_addr_t*)info_buf,\r
+ (uint8_t)(info_buf_len / sizeof(mac_addr_t)) );\r
\r
buf_len = info_buf_len;\r
/*\r
return status;\r
}\r
\r
-//! Transfers some number of packets, specified as an array of packet pointers,\r
-// over the network. \r
-/* For a deserialized driver, these packets are completed asynchronously\r
-using NdisMSendComplete.\r
-IRQL <= DISPATCH_LEVEL\r
+/* Transfers some number of packets, specified as an array of packet pointers,\r
+ * over the network. \r
+ * For a deserialized driver, these packets are completed asynchronously\r
+ * using NdisMSendComplete.\r
+ * IRQL <= DISPATCH_LEVEL\r
\r
-@param adapter_context Pointer to ipoib_adapter_t structure with per NIC state\r
-@param packet_array Array of packets to send\r
-@param numPackets Number of packets in the array\r
+ @param adapter_context - Pointer to ipoib_adapter_t structure with per NIC state\r
+ @param net_buffer_list - Array of packets to send\r
+ @param port_num - miniport number.\r
+ @param send_flags - NDIS send flags.\r
*/\r
void\r
ipoib_send_net_buffer_list(\r
IN NDIS_HANDLE adapter_context,\r
IN PNET_BUFFER_LIST net_buffer_list,\r
IN NDIS_PORT_NUMBER port_num,\r
- IN ULONG send_flags\r
- )\r
+ IN ULONG send_flags )\r
{\r
ipoib_adapter_t *p_adapter;\r
ipoib_port_t *p_port;\r
NET_BUFFER_LIST_NEXT_NBL(curr_net_buffer_list) = NULL;\r
\r
cl_perf_start( PortSend );\r
- IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND,\r
- ("Sending NBL=%p, g_NBL=%d, g_NBL_completed=%d \n", curr_net_buffer_list, g_NBL, g_NBL_complete) );\r
+ IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_BUF,\r
+ ("Sending NBL=%p, g_NBL=%d, g_NBL_completed=%d \n",\r
+ curr_net_buffer_list, g_NBL, g_NBL_complete) );\r
+\r
ipoib_port_send( p_port, curr_net_buffer_list, send_flags);\r
+\r
cl_perf_stop( &p_adapter->perf, PortSend );\r
}\r
ipoib_port_deref( p_port, ref_send_packets );\r
{\r
\r
IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- ("Got bad status, g_NBL=%d, g_NBL_completed=%d \n", g_NBL, g_NBL_complete) );\r
+ ("Got bad status, g_NBL=%d, g_NBL_completed=%d \n",\r
+ g_NBL, g_NBL_complete) );\r
send_complete_flags = 0;\r
\r
for (curr_net_buffer_list = net_buffer_list;\r
if (NDIS_TEST_SEND_AT_DISPATCH_LEVEL(send_flags))\r
{\r
ASSERT(KeGetCurrentIrql() == DISPATCH_LEVEL);\r
- NDIS_SET_SEND_COMPLETE_FLAG(send_complete_flags, NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL);\r
+ NDIS_SET_SEND_COMPLETE_FLAG(send_complete_flags,\r
+ NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL);\r
}\r
- NdisMSendNetBufferListsCompleteX(\r
- p_adapter,\r
- net_buffer_list,\r
- send_complete_flags); \r
+ NdisMSendNetBufferListsCompleteX( p_adapter,\r
+ net_buffer_list,\r
+ send_complete_flags); \r
}\r
IPOIB_EXIT( IPOIB_DBG_SEND );\r
}\r
\r
+\r
void\r
ipoib_pnp_notify(\r
IN NDIS_HANDLE adapter_context,\r
/* Take a reference for each service request. */\r
cl_obj_ref(&p_adapter->obj);\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_OBJ,\r
- ("[%p] Adapter refcount raised to %d\n", p_adapter, p_adapter->obj.ref_cnt));\r
+ ("[%p] Adapter refcount raised to %d\n",\r
+ p_adapter, p_adapter->obj.ref_cnt));\r
ib_status = p_adapter->p_ifc->reg_svc(\r
p_adapter->h_al, &ib_service, &p_addr_item->p_reg->h_reg_svc );\r
if( ib_status != IB_SUCCESS )\r
{\r
/* Fatal error. */\r
IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- ("Port %d OID_GEN_NETWORK_LAYER_ADDRESSES - Failed to register IP Address "\r
- "of %d.%d.%d.%d with error %s\n",\r
+ ("Port %d OID_GEN_NETWORK_LAYER_ADDRESSES - Failed to "\r
+ "register IP Address of %d.%d.%d.%d with error %s\n",\r
port_num,\r
p_addr_item->address.as_bytes[0],\r
p_addr_item->address.as_bytes[1],\r
cl_obj_unlock( &p_reg->p_adapter->obj );\r
cl_obj_deref(&p_reg->p_adapter->obj);\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_OBJ,\r
- ("Adapter[%p] refcnt decremented to %d\n", p_reg->p_adapter, p_reg->p_adapter->obj.ref_cnt));\r
+ ("Adapter[%p] refcnt decremented to %d\n",\r
+ p_reg->p_adapter, p_reg->p_adapter->obj.ref_cnt));\r
\r
IPOIB_EXIT( IPOIB_DBG_OID );\r
}\r
#if DBG\r
cl_atomic_inc( &p_port->ref[type % ref_mask] );\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_OBJ,\r
- ("Port[%d] refcount raised to %d\n", p_port->port_num, p_port->obj.ref_cnt));\r
+ ("Port[%d] refcount raised to %d\n", p_port->port_num, p_port->obj.ref_cnt));\r
\r
if ((p_port->obj.ref_cnt % 20)==0)\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_OBJ,\r
#if DBG\r
cl_atomic_dec( &p_port->ref[type % ref_mask] );\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_OBJ,\r
- ("Port[%d] refcount decremented to %d\n", p_port->port_num, p_port->obj.ref_cnt));\r
+ ("Port[%d] refcount-- to %d\n", p_port->port_num, p_port->obj.ref_cnt));\r
+\r
if ((p_port->obj.ref_cnt % 20) == 0)\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_OBJ,\r
("deref type %d ref_cnt %d\n", type, p_port->obj.ref_cnt) );\r
__ib_mgr_construct(\r
IN ipoib_port_t* const p_port )\r
{\r
- IPOIB_ENTER( IPOIB_DBG_INIT );\r
-\r
cl_memclr( &p_port->ib_mgr, sizeof(ipoib_ib_mgr_t) );\r
-\r
- IPOIB_EXIT( IPOIB_DBG_INIT );\r
}\r
\r
\r
IPOIB_ENTER( IPOIB_DBG_INIT );\r
\r
/* Open the CA. */\r
- status = p_port->p_adapter->p_ifc->open_ca(\r
- p_port->p_adapter->h_al, p_port->p_adapter->guids.ca_guid,\r
- NULL, p_port, &p_port->ib_mgr.h_ca );\r
+ status = p_port->p_adapter->p_ifc->open_ca( p_port->p_adapter->h_al,\r
+ p_port->p_adapter->guids.ca_guid,\r
+ NULL,\r
+ p_port,\r
+ &p_port->ib_mgr.h_ca );\r
if( status != IB_SUCCESS )\r
{\r
NdisWriteErrorLogEntry( p_port->p_adapter->h_adapter,\r
EVENT_IPOIB_OPEN_CA, 1, status );\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- ("ib_open_ca returned %s\n", \r
- p_port->p_adapter->p_ifc->get_err_str( status )) );\r
+ ("ib_open_ca(port %p) returns %s\n", \r
+ p_port, p_port->p_adapter->p_ifc->get_err_str( status )) );\r
return status;\r
}\r
\r
if( p_port->p_adapter->params.cm_enabled )\r
{\r
uint32_t payload_mtu = __port_attr_to_mtu_size( \r
- p_port->p_ca_attrs->p_port_attr[p_port->port_num - 1].mtu )\r
- - sizeof(ipoib_hdr_t);\r
+ p_port->p_ca_attrs->p_port_attr[p_port->port_num - 1].mtu )\r
+ - sizeof(ipoib_hdr_t);\r
+\r
/* adjust ipoib UD payload MTU to actual port MTU size. */\r
p_port->p_adapter->params.payload_mtu = \r
- max( DEFAULT_PAYLOAD_MTU, payload_mtu );\r
+ max( DEFAULT_PAYLOAD_MTU, payload_mtu );\r
p_port->p_adapter->params.xfer_block_size = \r
(sizeof(eth_hdr_t) + p_port->p_adapter->params.payload_mtu);\r
}\r
#endif\r
+\r
#if IPOIB_USE_DMA\r
/* init DMA only once while running MiniportInitialize */\r
if ( !p_port->p_adapter->reset )\r
{\r
ULONG max_phys_mapping;\r
+\r
if( p_port->p_adapter->params.cm_enabled )\r
{\r
max_phys_mapping = p_port->p_adapter->params.cm_xfer_block_size;\r
else \r
{\r
if ( p_port->p_adapter->params.send_chksum_offload )\r
- p_port->p_adapter->params.send_chksum_offload = CSUM_DISABLED;\r
+ p_port->p_adapter->params.send_chksum_offload = CSUM_DISABLED;\r
}\r
}\r
#endif\r
__buf_mgr_construct(\r
IN ipoib_port_t* const p_port )\r
{\r
- IPOIB_ENTER( IPOIB_DBG_INIT );\r
-\r
cl_qpool_construct( &p_port->buf_mgr.recv_pool );\r
\r
p_port->buf_mgr.h_packet_pool = NULL;\r
NULL, NULL, 0, MAX_LSO_PAYLOAD_MTU, 'bipi', 0 );\r
\r
p_port->buf_mgr.h_send_pkt_pool = NULL;\r
-\r
- IPOIB_EXIT( IPOIB_DBG_INIT );\r
}\r
\r
\r
\r
/* Allocate the receive descriptor pool */\r
cl_status = cl_qpool_init( &p_port->buf_mgr.recv_pool,\r
- p_params->rq_depth * p_params->recv_pool_ratio,\r
+ p_params->rq_depth * p_params->recv_pool_ratio,\r
#if IPOIB_INLINE_RECV\r
0, 0, sizeof(ipoib_recv_desc_t), __recv_ctor, NULL, p_port );\r
#else /* IPOIB_INLINE_RECV */\r
pool_parameters.DataSize = 0;\r
\r
p_port->buf_mgr.h_packet_pool = NdisAllocateNetBufferListPool(\r
- p_port->p_adapter->h_adapter,\r
- &pool_parameters); \r
+ p_port->p_adapter->h_adapter,\r
+ &pool_parameters ); \r
\r
if( !p_port->buf_mgr.h_packet_pool )\r
{\r
pool_parameters.PoolTag = 'XTPI';\r
\r
p_port->buf_mgr.h_send_pkt_pool = NdisAllocateNetBufferListPool(\r
- p_port->p_adapter->h_adapter,\r
- &pool_parameters); \r
+ p_port->p_adapter->h_adapter,\r
+ &pool_parameters ); \r
if( !p_port->buf_mgr.h_send_pkt_pool)\r
{\r
NdisWriteErrorLogEntry( p_port->p_adapter->h_adapter,\r
{\r
/* The buffer crosses page boundaries. */\r
p_desc->local_ds[0].length = ds0_len;\r
- p_desc->local_ds[1].vaddr = cl_get_physaddr( \r
- ((uint8_t*)&p_desc->buf) + ds0_len );\r
+ p_desc->local_ds[1].vaddr =\r
+ cl_get_physaddr( ((uint8_t*)&p_desc->buf) + ds0_len );\r
p_desc->local_ds[1].lkey = p_port->ib_mgr.lkey;\r
p_desc->local_ds[1].length = sizeof(recv_buf_t) - ds0_len;\r
p_desc->wr.num_ds = 2;\r
ipoib_recv_desc_t *p_desc;\r
IPOIB_ENTER( IPOIB_DBG_RECV );\r
p_desc = (ipoib_recv_desc_t*)cl_qpool_get( &p_port->buf_mgr.recv_pool );\r
+\r
/* Reference the port object for the send. */\r
if( p_desc )\r
{\r
IN ipoib_port_t* const p_port,\r
IN cl_qlist_t* const p_list )\r
{\r
- //IPOIB_ENTER( IPOIB_DBG_RECV );\r
cl_qpool_put_list( &p_port->buf_mgr.recv_pool, p_list );\r
- //IPOIB_EXIT( IPOIB_DBG_RECV );\r
}\r
\r
\r
__recv_mgr_construct(\r
IN ipoib_port_t* const p_port )\r
{\r
- IPOIB_ENTER( IPOIB_DBG_INIT );\r
-\r
cl_qlist_init( &p_port->recv_mgr.done_list );\r
-\r
p_port->recv_mgr.recv_NBL_array = NULL;\r
-\r
- IPOIB_EXIT( IPOIB_DBG_INIT );\r
}\r
\r
\r
if ( !p_port ) {\r
ASSERT(p_port);\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- ("return_NBL callback called when port pointer was already cleared\n") );\r
+ ("<NULL> port pointer; already cleared?\n") );\r
return;\r
}\r
\r
cl_perf_start( ReturnPacket );\r
cl_spinlock_acquire( &p_port->recv_lock );\r
+\r
NBL_cnt = __free_received_NBL( p_port, p_net_buffer_lists );\r
\r
shutter_sub( &p_port->p_adapter->recv_shutter, -NBL_cnt );\r
p_free = wc;\r
\r
cl_perf_start( PollRecv );\r
- status = p_port->p_adapter->p_ifc->poll_cq(\r
- p_port->ib_mgr.h_recv_cq, &p_free, &p_wc );\r
+ status = p_port->p_adapter->p_ifc->poll_cq( p_port->ib_mgr.h_recv_cq,\r
+ &p_free,\r
+ &p_wc );\r
cl_perf_stop( &p_port->p_adapter->perf, PollRecv );\r
CL_ASSERT( status == IB_SUCCESS || status == IB_NOT_FOUND );\r
\r
\r
cl_perf_start( BuildNBLArray );\r
/* Notify NDIS of any and all possible receive buffers. */\r
- NBL_cnt = __recv_mgr_build_NBL_array(\r
- p_port, &done_list, &discarded);\r
+ NBL_cnt = __recv_mgr_build_NBL_array( p_port, &done_list, &discarded);\r
cl_perf_stop( &p_port->p_adapter->perf, BuildNBLArray );\r
\r
/* Only indicate receives if we actually had any. */\r
if (shortage <= 0) {\r
\r
res = shutter_add( &p_port->p_adapter->recv_shutter, NBL_cnt );\r
- if (res) {\r
+ if (res)\r
+ {\r
NdisMIndicateReceiveNetBufferLists(\r
- p_port->p_adapter->h_adapter,\r
- p_port->recv_mgr.recv_NBL_array[0],\r
- NDIS_DEFAULT_PORT_NUMBER,\r
- NBL_cnt,\r
- recv_complete_flags);\r
+ p_port->p_adapter->h_adapter,\r
+ p_port->recv_mgr.recv_NBL_array[0],\r
+ NDIS_DEFAULT_PORT_NUMBER,\r
+ NBL_cnt,\r
+ recv_complete_flags );\r
}\r
else {\r
- __free_received_NBL (p_port, p_port->recv_mgr.recv_NBL_array[0]);\r
+ __free_received_NBL( p_port, p_port->recv_mgr.recv_NBL_array[0] );\r
}\r
\r
} else {\r
- \r
- // If shortage >0, we already set the status to NDIS_RECEIVE_FLAGS_RESOURCES\r
- // That is, IPoIB driver regain ownership of the NET_BUFFER_LIST structures immediately\r
+ /* If shortage >0, we already set the status to\r
+ NDIS_RECEIVE_FLAGS_RESOURCES. That is, IPoIB driver regain\r
+ ownership of the NET_BUFFER_LIST structures immediately.\r
+ */\r
res = shutter_add( &p_port->p_adapter->recv_shutter, 1 );\r
if (res) {\r
NdisMIndicateReceiveNetBufferLists(\r
- p_port->p_adapter->h_adapter,\r
- p_port->recv_mgr.recv_NBL_array[0],\r
- NDIS_DEFAULT_PORT_NUMBER,\r
- NBL_cnt,\r
- recv_complete_flags);\r
+ p_port->p_adapter->h_adapter,\r
+ p_port->recv_mgr.recv_NBL_array[0],\r
+ NDIS_DEFAULT_PORT_NUMBER,\r
+ NBL_cnt,\r
+ recv_complete_flags );\r
shutter_sub( &p_port->p_adapter->recv_shutter, -1 );\r
}\r
- \r
}\r
- \r
- \r
\r
cl_perf_stop( &p_port->p_adapter->perf, RecvNdisIndicate );\r
\r
*/\r
if( shortage > 0 )\r
{\r
-\r
cl_dbg_out("GOT SHORTAGE <===============\n");\r
/* Return all but the last packet to the pool. */\r
cl_spinlock_acquire( &p_port->recv_lock );\r
//while( shortage-- > 1 )\r
while ( NBL_cnt-- > 0)\r
{\r
- __buf_mgr_put_recv( p_port,\r
- (ipoib_recv_desc_t *)IPOIB_RECV_FROM_NBL( p_port->recv_mgr.recv_NBL_array[NBL_cnt] ),\r
+ __buf_mgr_put_recv(\r
+ p_port,\r
+ (ipoib_recv_desc_t *)\r
+ IPOIB_RECV_FROM_NBL( p_port->recv_mgr.recv_NBL_array[NBL_cnt] ),\r
p_port->recv_mgr.recv_NBL_array[NBL_cnt] );\r
}\r
__recv_mgr_repost( p_port );\r
* __endpt_mgr_insert find a duplicate.\r
*/\r
cl_perf_start( RearmRecv );\r
- status = p_port->p_adapter->p_ifc->rearm_cq(\r
- p_port->ib_mgr.h_recv_cq, FALSE );\r
+\r
+ status =\r
+ p_port->p_adapter->p_ifc->rearm_cq( p_port->ib_mgr.h_recv_cq, FALSE );\r
+\r
cl_perf_stop( &p_port->p_adapter->perf, RearmRecv );\r
CL_ASSERT( status == IB_SUCCESS );\r
\r
// Please note the reference is still up\r
KeInsertQueueDpc(&p_port->recv_dpc, NULL, NULL);\r
}\r
-\r
cl_perf_stop( &p_port->p_adapter->perf, RecvCb );\r
\r
IPOIB_EXIT( IPOIB_DBG_RECV );\r
break;\r
}\r
if ((p_ipoib->type.ip.hdr.ver_hl & 0x0f) != 5 ) {\r
- // If there are IP options in this message, we are in trouble in any case\r
+ // If there are IP options in this message, we are in\r
+ // trouble in any case\r
status = IB_INVALID_SETTING;\r
break; \r
}\r
else\r
{\r
ip_stat_sel_t ip_stat;\r
- p_desc->len =\r
- len + sizeof(eth_hdr_t) - sizeof(ipoib_hdr_t);\r
+ p_desc->len = len + sizeof(eth_hdr_t) - sizeof(ipoib_hdr_t);\r
if( p_dst->h_mcast)\r
{\r
if( p_dst->dgid.multicast.raw_group_id[10] == 0xFF &&\r
if( p_ib_arp->prot_type != ETH_PROT_TYPE_IP )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- ("ARP protocal type not IP\n") );\r
+ ("ARP protocal type not IP?\n") );\r
return IB_INVALID_SETTING;\r
}\r
\r
*/\r
if( *pp_src )\r
{\r
- if( cl_memcmp( &(*pp_src)->dgid, &p_ib_arp->src_hw.gid,\r
- sizeof(ib_gid_t) ) )\r
+ if( cl_memcmp( &(*pp_src)->dgid, &p_ib_arp->src_hw.gid, sizeof(ib_gid_t) ) )\r
{\r
/*\r
* GIDs for the endpoint are different. The ARP must\r
*/\r
*pp_src = NULL;\r
}\r
- else if( (*pp_src)->dlid &&\r
- (*pp_src)->dlid != p_wc->recv.ud.remote_lid )\r
+ else if( (*pp_src)->dlid && (*pp_src)->dlid != p_wc->recv.ud.remote_lid )\r
{\r
/* Out of date! Destroy the endpoint and replace it. */\r
__endpt_mgr_remove( p_port, *pp_src );\r
*pp_src = NULL;\r
}\r
- else if ( ! ((*pp_src)->dlid)) {\r
+ else if ( ! ((*pp_src)->dlid))\r
+ {\r
/* Out of date! Destroy the endpoint and replace it. */\r
__endpt_mgr_remove( p_port, *pp_src );\r
*pp_src = NULL;\r
else if( ipoib_is_voltaire_router_gid( &(*pp_src)->dgid ) )\r
{\r
if( (*pp_src)->qpn != ipoib_addr_get_qpn( &p_ib_arp->src_hw ) &&\r
- p_wc->recv.ud.remote_qp != ipoib_addr_get_qpn( &p_ib_arp->src_hw ) )\r
+ p_wc->recv.ud.remote_qp != ipoib_addr_get_qpn( &p_ib_arp->src_hw ) )\r
{\r
/* Out of date! Destroy the endpoint and replace it. */\r
__endpt_mgr_remove( p_port, *pp_src );\r
{\r
/* Copy the src GID to allow aligned access */\r
cl_memcpy( &gid, &p_ib_arp->src_hw.gid, sizeof(ib_gid_t) );\r
- status = ipoib_mac_from_guid( gid.unicast.interface_id, p_port->p_adapter->params.guid_mask, &mac );\r
+ status = ipoib_mac_from_guid( gid.unicast.interface_id,\r
+ p_port->p_adapter->params.guid_mask,\r
+ &mac );\r
if (status == IB_INVALID_GUID_MASK)\r
{\r
IPOIB_PRINT( TRACE_LEVEL_WARNING, IPOIB_DBG_ERROR,\r
("Invalid GUID mask received, rejecting it") );\r
- ipoib_create_log(p_port->p_adapter->h_adapter, GUID_MASK_LOG_INDEX, EVENT_IPOIB_WRONG_PARAMETER_WRN);\r
+ ipoib_create_log( p_port->p_adapter->h_adapter,\r
+ GUID_MASK_LOG_INDEX,\r
+ EVENT_IPOIB_WRONG_PARAMETER_WRN );\r
+ return status;\r
}\r
else if( status != IB_SUCCESS )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
("ipoib_mac_from_guid returned %s\n",\r
- p_port->p_adapter->p_ifc->get_err_str( status )) );\r
+ p_port->p_adapter->p_ifc->get_err_str( status )) );\r
return status;\r
}\r
+\r
/*\r
* Create the endpoint.\r
*/\r
*pp_src = ipoib_endpt_create( &p_ib_arp->src_hw.gid,\r
- p_wc->recv.ud.remote_lid, ipoib_addr_get_qpn( &p_ib_arp->src_hw ) );\r
+ p_wc->recv.ud.remote_lid, ipoib_addr_get_qpn( &p_ib_arp->src_hw ) );\r
\r
if( !*pp_src )\r
{\r
p_port->p_adapter->p_ifc->get_err_str( status )) );\r
return status;\r
}\r
-\r
cl_obj_unlock( &p_port->obj );\r
}\r
\r
if( cl_memcmp( &p_dst->dgid, &p_ib_arp->dst_hw.gid, sizeof(ib_gid_t) ) )\r
{\r
/*\r
- * We received bcast ARP packet that means\r
- * remote port lets everyone know it was changed IP/MAC\r
- * or just activated\r
+ * We received bcast ARP packet that means the remote port\r
+ * lets everyone know it was changed IP/MAC or just activated\r
*/\r
\r
/* Guy: TODO: Check why this check fails in case of Voltaire IPR */\r
CL_ASSERT( p_dst->qpn == ipoib_addr_get_qpn( &p_ib_arp->dst_hw ) );\r
}\r
}\r
- else /* we got ARP reqeust */\r
+ else /* we got ARP request */\r
{\r
cl_memclr( &p_arp->dst_hw, sizeof(mac_addr_t) );\r
p_arp->dst_ip = p_ib_arp->dst_ip;\r
* we have a chance to create a new endpoint.\r
*/\r
status = __recv_gen( p_ipoib, p_eth, *pp_src, p_dst );\r
+\r
if( status != IB_SUCCESS )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
{\r
NDIS_STATUS status;\r
uint32_t pkt_filter;\r
- //NDIS60\r
NDIS_TCP_IP_CHECKSUM_NET_BUFFER_LIST_INFO chksum;\r
- //NDIS_TCP_IP_CHECKSUM_PACKET_INFO chksum;\r
\r
PERF_DECLARE( GetNdisPkt );\r
\r
{\r
/* OK to report. */\r
status = NDIS_STATUS_SUCCESS;\r
- IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_ERROR,\r
+ IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_RECV,\r
("Received UCAST PKT.\n"));\r
}\r
else\r
{\r
status = NDIS_STATUS_FAILURE;\r
IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- ("Received BCAST PKT with ERROR !!!!\n"));\r
+ ("Received BCAST PKT with ERROR!!!! pkt_filter 0x%x\n",pkt_filter));\r
}\r
break;\r
case PKT_TYPE_MCAST:\r
(void*)(uintn_t)chksum.Value;\r
break;\r
case CSUM_ENABLED:\r
- /* Get the checksums directly from packet information. */\r
- /* In this case, no one of cheksum's cat get false value */\r
- /* If hardware checksum failed or wasn't calculated, NDIS will recalculate it again */\r
+ /* Get the checksums directly from packet information.\r
+ * In this case, no one of cheksum's cat get false value\r
+ * If hardware checksum failed or wasn't calculated, NDIS will recalculate\r
+ * it again\r
+ */\r
NET_BUFFER_LIST_INFO(*pp_net_buffer_list, TcpIpChecksumNetBufferListInfo) =\r
(void*)(uintn_t)(p_desc->ndis_csum.Value);\r
break;\r
\r
static uint32_t\r
__recv_mgr_build_NBL_array(\r
- IN ipoib_port_t* const p_port,\r
- OUT cl_qlist_t* p_done_list OPTIONAL,\r
- OUT int32_t* const p_discarded)\r
+ IN ipoib_port_t* const p_port,\r
+ OUT cl_qlist_t* p_done_list OPTIONAL,\r
+ OUT int32_t* const p_discarded )\r
{\r
cl_list_item_t *p_item;\r
ipoib_recv_desc_t *p_desc;\r
\r
*p_discarded = 0;\r
\r
- /* Move any existing receives to the head of p_done_list to preserve ordering. */\r
+ /* to preserve ordering move existing receives to the head of p_done_list */\r
if ( p_done_list ) {\r
cl_qlist_insert_list_head( p_done_list, &p_port->recv_mgr.done_list );\r
} else {\r
{\r
CL_ASSERT( p_port->recv_mgr.recv_NBL_array[i] );\r
\r
- if (i) {\r
- // Link NBLs together\r
+ if (i)\r
+ { // Link NBLs together\r
NET_BUFFER_LIST_NEXT_NBL(p_port->recv_mgr.recv_NBL_array[i-1]) = \r
p_port->recv_mgr.recv_NBL_array[i];\r
- }\r
+ }\r
i++;\r
}\r
else if( status == IB_NOT_DONE )\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
("cl_qpool_init for sends returned %#x\n",\r
cl_status) );\r
+ IPOIB_EXIT(IPOIB_DBG_SEND );\r
return IB_INSUFFICIENT_MEMORY;\r
}\r
\r
NdisWriteErrorLogEntry( p_port->p_adapter->h_adapter,\r
EVENT_IPOIB_RECV_POOL, 1, cl_status ); //TODO EVENT_IPOIB_SEND_POOL\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- ("cl_qpool_init for sends returned %#x\n",\r
- cl_status) );\r
+ ("cl_qpool_init for sends returned %#x\n", cl_status) );\r
cl_qpool_destroy(&p_port->send_mgr.sg_pool);\r
return IB_INSUFFICIENT_MEMORY;\r
}\r
\r
- //This send descriptor can't be allocated on the stack because of boundary violation !!!\r
- p_port->p_desc = \r
- (ipoib_send_desc_t *)ExAllocatePoolWithTag(NonPagedPool ,sizeof (ipoib_send_desc_t), 'XMXA');\r
+ //This send descriptor can't be allocated on the stack because of boundary\r
+ // violation !!!\r
+ p_port->p_desc = (ipoib_send_desc_t *)\r
+ ExAllocatePoolWithTag(NonPagedPool ,sizeof (ipoib_send_desc_t), 'XMXA');\r
if (!p_port->p_desc) {\r
NdisWriteErrorLogEntry( p_port->p_adapter->h_adapter,\r
EVENT_IPOIB_RECV_POOL, 1, CL_INSUFFICIENT_MEMORY); //TODO EVENT_IPOIB_SEND_POOL\r
IN const eth_hdr_t* const p_eth_hdr,\r
IN MDL* const p_mdl,\r
IN size_t buf_len,\r
- IN OUT ipoib_send_NB_SG *s_buf)\r
+ IN OUT ipoib_send_NB_SG *s_buf )\r
{\r
NDIS_STATUS status;\r
\r
if( *p_mdl_len < sizeof(eth_hdr_t) )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- ("First buffer in packet smaller than eth_hdr_t: %d.\n",\r
- *p_mdl_len) );\r
+ ("First buffer in packet smaller than eth_hdr_t: %d.\n", *p_mdl_len) );\r
return NDIS_STATUS_BUFFER_TOO_SHORT;\r
}\r
\r
\r
\r
#if !IPOIB_USE_DMA\r
+\r
/* Send using the MDL's page information rather than the SGL. */\r
static ib_api_status_t\r
__send_gen(\r
\r
ULONG g_ipoib_send_mcast = 0;\r
\r
-\r
// returns true if buffer was sent\r
\r
bool \r
IN PVOID pIrp,\r
IN PSCATTER_GATHER_LIST p_sgl,\r
IN PVOID context )\r
-{ \r
+{\r
NDIS_STATUS status;\r
ipoib_port_t *p_port;\r
MDL *p_mdl;\r
boolean_t from_queue;\r
ib_api_status_t ib_status;\r
ULONG complete_flags = 0;\r
+ ipoib_send_NB_SG *s_buf;\r
+ ipoib_send_desc_t *p_desc;\r
\r
IPOIB_ENTER( IPOIB_DBG_SEND );\r
\r
++g_ipoib_send_SG_real;\r
\r
//Read Data from the buffer passed as a context\r
- ipoib_send_NB_SG * s_buf = (ipoib_send_NB_SG *)context;\r
+ s_buf = (ipoib_send_NB_SG *)context;\r
p_net_buffer_list = s_buf->p_nbl;\r
p_netbuf = s_buf->p_curr_nb;\r
p_port = s_buf->p_port;\r
+ p_desc = p_port->p_desc;\r
\r
-\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_SEND,\r
- ("Processing netbuffer list: %p \n", p_net_buffer_list) );\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_BUF,\r
+ ("Processing netbuffer list %p s_buf %p\n", p_net_buffer_list, s_buf) );\r
\r
//TODO Define this function as void if we are not in DBG mode\r
//cl_qlist_check_validity(&p_port->send_mgr.pending_list);\r
- NDIS_SET_SEND_COMPLETE_FLAG(complete_flags, NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL);\r
+\r
+ NDIS_SET_SEND_COMPLETE_FLAG(complete_flags,\r
+ NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL);\r
+\r
CL_ASSERT(KeGetCurrentIrql() == DISPATCH_LEVEL);\r
\r
p_port->p_desc->p_netbuf_list = p_net_buffer_list;\r
ret = true;\r
goto send_end;\r
}\r
+\r
from_queue = (boolean_t)(s_buf->p_sgl != NULL);\r
\r
if (from_queue)\r
{\r
cl_perf_start( GetEndpt );\r
- status = __endpt_mgr_ref( p_port, p_eth_hdr->dst, &(p_port->p_desc->p_endpt) );\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,("__endpt_mgr_ref called for %p\n", p_port->p_desc->p_endpt));\r
+ status = __endpt_mgr_ref( p_port,\r
+ p_eth_hdr->dst,\r
+ &(p_port->p_desc->p_endpt) );\r
+\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,\r
+ ("__endpt_mgr_ref called on EP %p\n", p_port->p_desc->p_endpt));\r
+\r
cl_perf_stop( &p_port->p_adapter->perf, GetEndpt );\r
if( status == NDIS_STATUS_PENDING )\r
{\r
\r
if( ETH_IS_MULTICAST( p_eth_hdr->dst.addr ) )\r
{\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST, ("recived a mc packet (from the queue) %p\n", p_net_buffer_list));\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,\r
+ ("recived a mc packet (from the queue) %p\n",\r
+ p_net_buffer_list));\r
if( ipoib_port_join_mcast( p_port, p_eth_hdr->dst,\r
IB_MC_REC_STATE_FULL_MEMBER) == IB_SUCCESS )\r
{\r
s_buf->p_sgl = p_sgl;\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,("We insert this MULTICAST item back to the pending list: %p \n", p_net_buffer_list)); \r
- cl_qlist_insert_head( &p_port->send_mgr.pending_list, (cl_list_item_t*) s_buf );\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,\r
+ ("Insert MULTICAST item back to the pending list %p\n",\r
+ p_net_buffer_list)); \r
+ cl_qlist_insert_head( &p_port->send_mgr.pending_list,\r
+ (cl_list_item_t*) s_buf );\r
ret = false;\r
++g_ipoib_send_SG_pending;\r
goto send_end;\r
}\r
}\r
+\r
/*\r
* Complete the send as if we sent it - WHQL tests don't like the\r
* sends to fail.\r
*/\r
- IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,("We got bad status and the packet had not been sent\n"));\r
+ IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
+ ("Bad status: packet has not been sent\n"));\r
cl_perf_start( ProcessFailedSends );\r
\r
- __send_complete_net_buffer(s_buf, NDIS_STATUS_SUCCESS, complete_flags, TRUE);\r
+ __send_complete_net_buffer( s_buf,\r
+ NDIS_STATUS_SUCCESS,\r
+ complete_flags,\r
+ TRUE );\r
ret = true;\r
goto send_end;\r
}\r
}\r
else //We got this Net Buffer and its SG list directly from NDIS\r
{\r
- ASSERT(s_buf->p_sgl ==NULL);\r
+ ASSERT(s_buf->p_sgl == NULL);\r
s_buf->p_sgl = p_sgl;\r
\r
cl_perf_start( SendMgrQueue );\r
p_eth_hdr->type == ETH_PROT_TYPE_IP &&\r
!ETH_IS_BROADCAST( p_eth_hdr->dst.addr ) ) \r
{\r
-\r
- IPOIB_PRINT_EXIT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,\r
- ("recived a Multicast NBL= %p\n", p_net_buffer_list) );\r
-\r
- \r
- \r
ip_hdr_t *p_ip_hdr;\r
uint8_t *p_tmp;\r
MDL *p_ip_hdr_mdl;\r
UINT ip_hdr_mdl_len;\r
\r
+ IPOIB_PRINT_EXIT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,\r
+ ("Sent a Multicast NBL=%p\n", p_net_buffer_list) );\r
+ \r
g_ipoib_send_mcast++;\r
\r
if(mdl_len >= sizeof(ip_hdr_t) + sizeof(eth_hdr_t))\r
p_ip_hdr = (ip_hdr_t*)(p_tmp + NET_BUFFER_CURRENT_MDL_OFFSET(p_netbuf));\r
\r
}\r
- \r
p_eth_hdr->dst.addr[1] = ((unsigned char*)&p_ip_hdr->dst_ip)[0] & 0x0f;\r
p_eth_hdr->dst.addr[3] = ((unsigned char*)&p_ip_hdr->dst_ip)[1];\r
\r
mc_end:\r
ASSERT(s_buf->p_sgl);\r
\r
- status = __send_mgr_queue( p_port,\r
- p_eth_hdr,\r
- &(p_port->p_desc->p_endpt) );\r
+ status = __send_mgr_queue( p_port, p_eth_hdr, &(p_port->p_desc->p_endpt) );\r
\r
cl_perf_stop( &p_port->p_adapter->perf, SendMgrQueue );\r
if( status == NDIS_STATUS_PENDING )\r
*/\r
//TODO - check previous comment !\r
cl_perf_start( ProcessFailedSends );\r
- __send_complete_net_buffer( s_buf, NDIS_STATUS_SUCCESS,\r
- complete_flags, TRUE);\r
+ __send_complete_net_buffer( s_buf,\r
+ NDIS_STATUS_SUCCESS,\r
+ complete_flags,\r
+ TRUE );\r
cl_perf_stop( &p_port->p_adapter->perf, ProcessFailedSends );\r
ret = true;\r
goto send_end;\r
}\r
\r
\r
+// This routine called during execution of NdisMAllocateNetBufferSGList().\r
+\r
void \r
ipoib_process_sg_list(\r
IN PDEVICE_OBJECT pDO,\r
//ASSERT(g_ipoib_send_SG-2 <= g_ipoib_send + g_ipoib_send_mcast+p_port->send_mgr.pending_list.count+ g_ipoib_send_SG_failed);\r
}\r
\r
- ipoib_process_sg_list_real(pDO, pIrp, p_sgl, context);\r
+ ipoib_process_sg_list_real( pDO, pIrp, p_sgl, context );\r
\r
if (g_ipoib_send_SG > 1) {\r
//ASSERT(g_ipoib_send_SG-1 <= g_ipoib_send + g_ipoib_send_mcast+p_port->send_mgr.pending_list.count + g_ipoib_send_SG_failed);\r
return NDIS_STATUS_FAILURE;\r
}\r
ipoib_send_desc_t *p_desc = s_buf->p_port->p_desc;\r
- //TODO: Copy only essential data\r
- // That is, copy only 2 chunks of ETH header if it contained in several first SG elements\r
- // Copy only N+1-MAX_SEND_SGE, where N is a lenght of SG List\r
- /* Remember that one of the DS entries is reserved for the IPoIB header. */\r
+\r
+ /* TODO: Copy only essential data\r
+ That is, copy only 2 chunks of ETH header if it contained in several\r
+ first SG elements.\r
+ Copy only N+1-MAX_SEND_SGE, where N is a lenght of SG List\r
+ Remember that one of the DS entries is reserved for the IPoIB header.\r
+ */\r
if( ( p_sgl->NumberOfElements >= MAX_SEND_SGE ||\r
p_sgl->Elements[0].Length < sizeof(eth_hdr_t)) )\r
{\r
-\r
IPOIB_PRINT( TRACE_LEVEL_WARNING, IPOIB_DBG_SEND,\r
("Too many buffers %d to fit in WR ds_array[%d] \\r
Or buffer[0] length %d < Eth header. Copying data.\n",\r
- p_sgl->NumberOfElements, MAX_SEND_SGE, p_sgl->Elements[0].Length ) );\r
- status = NDIS_STATUS_RESOURCES;\r
+ p_sgl->NumberOfElements, MAX_SEND_SGE, p_sgl->Elements[0].Length ) );\r
+\r
if( !s_buf->p_port->p_adapter->params.cm_enabled )\r
{\r
cl_perf_start( SendCopy );\r
status = __send_copy( s_buf->p_port, s_buf, lso_header_size );\r
cl_perf_stop( &s_buf->p_port->p_adapter->perf, SendCopy );\r
}\r
+\r
+ status = NDIS_STATUS_RESOURCES;\r
IPOIB_EXIT( IPOIB_DBG_SEND );\r
return status;\r
}\r
{\r
p_ip_hdr = (ip_hdr_t*)(p_eth_hdr + 1);\r
}\r
+\r
if( buf_len < sizeof(ip_hdr_t) )\r
{\r
/* This buffer is done for. Get the next buffer. */\r
switch( p_ip_hdr->prot )\r
{\r
case IP_PROT_UDP:\r
-\r
cl_perf_start( FilterUdp );\r
- status = __send_mgr_filter_udp( p_ip_hdr, p_mdl, (buf_len - sizeof(ip_hdr_t)), s_buf );\r
+ status = __send_mgr_filter_udp( p_ip_hdr, p_mdl,\r
+ (buf_len - sizeof(ip_hdr_t)), s_buf );\r
cl_perf_stop( &p_port->p_adapter->perf, FilterUdp );\r
if( status == NDIS_STATUS_PENDING )\r
{ /* not DHCP packet, keep going */\r
In igmp packet I saw that iph arrive in 2 NDIS_BUFFERs:\r
1. iph\r
2. ip options\r
- So to get the IGMP packet we need to skip the ip options NDIS_BUFFER\r
- */\r
+ So to get the IGMP packet we need to skip the ip options NDIS_BUFFER\r
+ */\r
iph_size_in_bytes = (p_ip_hdr->ver_hl & 0xf) * 4;\r
iph_options_size = iph_size_in_bytes - buf_len;\r
buf_len -= sizeof(ip_hdr_t);//without ipheader\r
\r
- /*\r
+ /*\r
Could be a case that arrived igmp packet not from type IGMPv2 ,\r
but IGMPv1 or IGMPv3.\r
We anyway pass it to __send_mgr_filter_igmp_v2().\r
*/\r
- status =\r
- __send_mgr_filter_igmp_v2( s_buf->p_port, p_ip_hdr, iph_options_size, p_mdl, buf_len );\r
+ status = __send_mgr_filter_igmp_v2( s_buf->p_port,\r
+ p_ip_hdr,\r
+ iph_options_size,\r
+ p_mdl,\r
+ buf_len );\r
if( status != NDIS_STATUS_SUCCESS )\r
return status;\r
\r
{\r
//TODO: NDIS60\r
#if 0\r
- status = __send_fragments( p_port, p_desc, (eth_hdr_t* const)p_eth_hdr,\r
- (ip_hdr_t* const)p_ip_hdr, (uint32_t)buf_len, p_mdl );\r
+ status = __send_fragments( p_port,\r
+ p_desc,\r
+ (eth_hdr_t* const)p_eth_hdr,\r
+ (ip_hdr_t* const)p_ip_hdr,\r
+ (uint32_t)buf_len,\r
+ p_mdl );\r
return status;\r
#endif\r
+ IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
+ ("TODO NDIS6 SEND_UD_QP fragments @ line #%d file %s\n",\r
+ __LINE__,__FILE__) );\r
ASSERT(FALSE);\r
}\r
}\r
IPOIB_ENTER( IPOIB_DBG_SEND );\r
\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,\r
- ("buf_len = %d,iph_options_size = %d\n",(int)buf_len,(int)iph_options_size ) );\r
+ ("buf_len = %d,iph_options_size = %d\n",\r
+ (int)buf_len, (int)iph_options_size) );\r
\r
if( !buf_len )\r
{\r
- // To get the IGMP packet we need to skip the ip options NDIS_BUFFER (if exists)\r
+ // To get the IGMP packet we need to skip the ip options NDIS_BUFFER\r
+ // (if exists)\r
while ( iph_options_size )\r
{\r
NdisGetNextMdl( p_mdl, &p_mdl );\r
collector will not delete this mcast endpt.\r
*/\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,\r
- ("Catched IGMP_V2_MEMBERSHIP_REPORT message\n") );\r
+ ("Received IGMP_V2_MEMBERSHIP_REPORT message\n") );\r
endpt_status = __endpt_mgr_ref( p_port, fake_mcast_mac, &p_endpt );\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,("__endpt_mgr_ref called for %p\n", p_endpt));\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,\r
+ ("__endpt_mgr_ref called for %p\n", p_endpt));\r
if ( p_endpt )\r
{\r
cl_obj_lock( &p_port->obj );\r
garbage collector will delete this mcast endpt next time.\r
*/\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,\r
- ("Catched IGMP_V2_LEAVE_GROUP message\n") );\r
+ ("Received IGMP_V2_LEAVE_GROUP message\n") );\r
endpt_status = __endpt_mgr_ref( p_port, fake_mcast_mac, &p_endpt );\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,("__endpt_mgr_ref called for %p\n", p_endpt));\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,\r
+ ("__endpt_mgr_ref called for %p\n", p_endpt));\r
if ( p_endpt )\r
{\r
cl_obj_lock( &p_port->obj );\r
/* no chksum for udp */\r
s_buf->p_send_buf->ip.prot.udp.hdr.chksum = 0;\r
p_desc->send_wr[0].local_ds[1].vaddr = cl_get_physaddr( s_buf->p_send_buf );\r
- p_desc->send_wr[0].local_ds[1].length = sizeof(ip_hdr_t) + sizeof(udp_hdr_t) + sizeof(dhcp_pkt_t);\r
+ p_desc->send_wr[0].local_ds[1].length = sizeof(ip_hdr_t)\r
+ + sizeof(udp_hdr_t)\r
+ + sizeof(dhcp_pkt_t);\r
p_desc->send_wr[0].local_ds[1].lkey = s_buf->p_port->ib_mgr.lkey;\r
p_desc->send_wr[0].wr.num_ds = 2;\r
p_desc->send_dir = SEND_UD_QP;\r
}\r
}\r
else\r
- {\r
p_arp = (arp_pkt_t*)(p_eth_hdr + 1);\r
- }\r
\r
/* Single buffer ARP packet. */\r
if( buf_len < sizeof(arp_pkt_t) )\r
/* Allocate our scratch buffer. */\r
ASSERT(s_buf->p_send_buf == NULL);\r
s_buf->p_send_buf = (send_buf_t*)\r
- NdisAllocateFromNPagedLookasideList( &s_buf->p_port->buf_mgr.send_buf_list );\r
+ NdisAllocateFromNPagedLookasideList(\r
+ &s_buf->p_port->buf_mgr.send_buf_list );\r
if( !s_buf->p_send_buf )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
#endif\r
\r
ib_gid_set_default( &p_ib_arp->src_hw.gid,\r
- s_buf->p_port->p_adapter->guids.port_guid.guid );\r
+ s_buf->p_port->p_adapter->guids.port_guid.guid );\r
+\r
p_ib_arp->src_ip = p_arp->src_ip;\r
+\r
if( cl_memcmp( &p_arp->dst_hw, &null_hw, sizeof(mac_addr_t) ) )\r
{\r
/* Get the endpoint referenced by the dst_hw address. */\r
net32_t qpn = 0;\r
- status = __endpt_mgr_get_gid_qpn( s_buf->p_port, p_arp->dst_hw,\r
- &p_ib_arp->dst_hw.gid, &qpn );\r
+ status = __endpt_mgr_get_gid_qpn( s_buf->p_port,\r
+ p_arp->dst_hw,\r
+ &p_ib_arp->dst_hw.gid,\r
+ &qpn );\r
if( status != NDIS_STATUS_SUCCESS )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
\r
case IPOIB_CM_CONNECT:\r
/* queue ARP REP packet until connected */\r
- NdisFreeToNPagedLookasideList(\r
+ NdisFreeToNPagedLookasideList(\r
&p_port->buf_mgr.send_buf_list, s_buf->p_send_buf );\r
- cl_qlist_insert_tail( &p_port->send_mgr.pending_list,\r
- IPOIB_LIST_ITEM_FROM_NBL( p_desc->p_pkt ) );\r
- return NDIS_STATUS_PENDING;\r
+ cl_qlist_insert_tail( &p_port->send_mgr.pending_list,\r
+ IPOIB_LIST_ITEM_FROM_NBL( s_buf->p_nbl ) );\r
+\r
+ return NDIS_STATUS_PENDING;\r
default:\r
break;\r
}\r
if( cl_qlist_count( &p_port->send_mgr.pending_list ) )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_WARNING, IPOIB_DBG_SEND,\r
- ("Pending list not empty.\n") );\r
+ ("Pending list not empty p_eth_hdr %p\n",p_eth_hdr) );\r
return NDIS_STATUS_PENDING;\r
}\r
\r
if( status == NDIS_STATUS_NO_ROUTE_TO_DESTINATION &&\r
ETH_IS_MULTICAST( p_eth_hdr->dst.addr ) )\r
{\r
- IPOIB_PRINT_EXIT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,("Calling join mcast from send_mgr_queue\n"));\r
+ IPOIB_PRINT_EXIT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,\r
+ ("Calling join mcast from send_mgr_queue\n"));\r
if( ipoib_port_join_mcast( p_port, p_eth_hdr->dst, \r
IB_MC_REC_STATE_FULL_MEMBER) == IB_SUCCESS )\r
{\r
hdr_idx = cl_atomic_inc( &s_buf->p_port->hdr_idx );\r
hdr_idx &= (s_buf->p_port->p_adapter->params.sq_depth - 1);\r
ASSERT( hdr_idx < s_buf->p_port->p_adapter->params.sq_depth );\r
+\r
s_buf->p_port->hdr[hdr_idx].type = p_eth_hdr->type;\r
s_buf->p_port->hdr[hdr_idx].resv = 0;\r
\r
- //TODO why we enter this block for LSO ???\r
- p_desc->send_wr[0].local_ds[0].vaddr = cl_get_physaddr( &s_buf->p_port->hdr[hdr_idx] );\r
+ //TODO why enter this block for LSO ???\r
+ p_desc->send_wr[0].local_ds[0].vaddr =\r
+ cl_get_physaddr( &s_buf->p_port->hdr[hdr_idx] );\r
p_desc->send_wr[0].local_ds[0].length = sizeof(ipoib_hdr_t);\r
p_desc->send_wr[0].local_ds[0].lkey = s_buf->p_port->ib_mgr.lkey;\r
p_desc->send_wr[0].wr.send_opt = 0;\r
+\r
//Init send buffer to 0\r
s_buf->p_send_buf = NULL;\r
\r
\r
ASSERT( mss == (p_lso_info->LsoV1Transmit.MSS & p_lso_info->LsoV2Transmit.MSS));\r
//ASSERT ( (mss & (1<<20)) == mss);\r
- status = __build_lso_desc( s_buf->p_port, mss, hdr_idx, p_lso_info, s_buf->p_curr_nb);\r
+ status = __build_lso_desc( s_buf->p_port,\r
+ mss,\r
+ hdr_idx,\r
+ p_lso_info,\r
+ s_buf->p_curr_nb );\r
+\r
if( status != NDIS_STATUS_SUCCESS )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
CL_ASSERT( p_desc->send_dir == SEND_RC_QP );\r
p_desc->send_qp = p_desc->p_endpt->conn.h_work_qp;\r
}\r
+\r
for( i = 0; i < p_desc->num_wrs; i++ )\r
{\r
p_desc->send_wr[i].wr.wr_type = WR_SEND;\r
return NDIS_STATUS_SUCCESS;\r
}\r
\r
+\r
static NDIS_STATUS\r
__build_lso_desc(\r
IN ipoib_port_t* const p_port,\r
ULONG PhysBufCount,\r
PNET_BUFFER NetBuff,\r
ULONG PacketLength,\r
- PMP_FRAG_LIST pFragList\r
- )\r
+ PMP_FRAG_LIST pFragList )\r
{\r
-\r
-\r
ULONG i = 0;\r
int j=0;\r
\r
ULONG CurrentMdlDataOffset = NET_BUFFER_CURRENT_MDL_OFFSET(NetBuff);\r
ASSERT(MmGetMdlByteCount(pMdl) >= CurrentMdlDataOffset);\r
\r
- \r
ASSERT(NetBuff != NULL);\r
#ifdef DBG\r
ASSERT(PhysBufCount <= MAX_PHYS_BUF_FRAG_ELEMENTS);\r
UNREFERENCED_PARAMETER(PacketLength);\r
\r
\r
- IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND, ("CreateFragList: NetBuff %p, Length =0x%x\n", NetBuff, buf_len));\r
+ IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND,\r
+ ("CreateFragList: NetBuff %p, Length =0x%x\n", NetBuff, buf_len));\r
\r
while ( (pMdl != NULL) && (buf_len != 0) )\r
{\r
\r
ASSERT( (buf_len > 0) && (MdlBytesCount > 0) );\r
\r
- IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND, ("CreateFragList: pMdl=%p, MdlBytesCount=x%x, MdlBufCount=0x%x\n", pMdl, MdlBytesCount, MdlBufCount));\r
+ IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND,\r
+ ("CreateFragList: pMdl=%p, MdlBytesCount=x%x, MdlBufCount=0x%x\n",\r
+ pMdl, MdlBytesCount, MdlBufCount));\r
\r
if (MdlBytesCount > 0)\r
{\r
buf_len = 0; \r
} \r
//\r
- // In some cases the mdlcount is greater than needed and in the last page\r
- // there is 0 bytes\r
+ // In some cases the mdlcount is greater than needed and in the last\r
+ // page there is 0 bytes\r
//\r
for (j=0; ((j< MdlBufCount) && (MdlBytesCount > 0)); j++) \r
{\r
ASSERT(MdlBytesCount > 0);\r
if (j ==0 ) \r
{\r
- //\r
// First page\r
//\r
ULONG64 ul64PageNum = page_array[j];\r
- pFragList->Elements[i].Address.QuadPart = (ul64PageNum << PAGE_SHIFT)+ offset;\r
+ pFragList->Elements[i].Address.QuadPart =\r
+ (ul64PageNum << PAGE_SHIFT)+ offset;\r
if( offset + MdlBytesCount > PAGE_SIZE )\r
{\r
- //\r
// the data slides behind the page boundry\r
//\r
ASSERT(PAGE_SIZE > offset);\r
}\r
else\r
{\r
- //\r
// All the data is hold in one page\r
// \r
pFragList->Elements[i].Length = MdlBytesCount;\r
MdlBytesCount = 0;\r
}\r
\r
- IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND, ( "CreateFragList: j == 0, MdlBytesCount=x%x, i = %d, element.length=0x%x \n", MdlBytesCount, i, pFragList->Elements[i].Length)); \r
+ IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND,\r
+ ("CreateFragList: j == 0, MdlBytesCount=x%x, i = %d, "\r
+ "element.length=0x%x \n",\r
+ MdlBytesCount, i, pFragList->Elements[i].Length));\r
} \r
else \r
{\r
}\r
else \r
{\r
- //\r
- // Not first page. so the data always start at the begining of the page\r
+ // Not first page. so the data always start at the\r
+ // begining of the page\r
//\r
ULONG64 ul64PageNum = page_array[j];\r
pFragList->Elements[i].Address.QuadPart = (ul64PageNum << PAGE_SHIFT);\r
MdlBytesCount -= pFragList->Elements[i].Length;\r
}\r
\r
- IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND, ( "CreateFragList: j != 0, MdlBytesCount=x%x, i = %d, element.length=0x%x \n", MdlBytesCount, i, pFragList->Elements[i].Length)); \r
+ IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND,\r
+ ( "CreateFragList: j != 0, MdlBytesCount=x%x, i = %d, "\r
+ "element.length=0x%x \n",\r
+ MdlBytesCount, i, pFragList->Elements[i].Length));\r
} \r
i++;\r
ASSERT(i <= MAX_PHYS_BUF_FRAG_ELEMENTS);\r
}\r
}\r
-\r
pMdl = pMdl->Next;\r
}\r
\r
if (buf_len != 0)\r
{\r
- //\r
- // In some cases the size in MDL isn't equal to the buffer size. In such \r
- // a case we need to add the rest of packet to last chunk\r
+ // In some cases the size in MDL isn't equal to the buffer size.\r
+ // In such a case we need to add the rest of packet to last chunk\r
//\r
ASSERT(i > 0); // To prevent array underflow\r
pFragList->Elements[i-1].Length += buf_len;\r
- IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND, ( "CreateFragList: buf_len != 0, i = %d, element.length=0x%x \n", i -1, pFragList->Elements[i-1].Length)); \r
+ IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND,\r
+ ( "CreateFragList: buf_len != 0, i = %d, element.length=0x%x \n",\r
+ i-1, pFragList->Elements[i-1].Length));\r
}\r
\r
ASSERT(i <= PhysBufCount);\r
pFragList->NumberOfElements = i;\r
\r
#ifdef DBG\r
-{\r
- ULONG size = 0;\r
- for (i = 0; i < pFragList->NumberOfElements; ++i)\r
- {\r
- size += pFragList->Elements[i].Length;\r
- }\r
- ASSERT(size == PacketLength);\r
-}\r
+ {\r
+ ULONG size = 0;\r
+ for (i = 0; i < pFragList->NumberOfElements; ++i)\r
+ {\r
+ size += pFragList->Elements[i].Length;\r
+ }\r
+ ASSERT(size == PacketLength);\r
+ }\r
#endif\r
-\r
}\r
\r
\r
void\r
ipoib_port_send(\r
- IN ipoib_port_t* const p_port,\r
- IN NET_BUFFER_LIST *p_net_buffer_list,\r
- IN ULONG send_flags)\r
+ IN ipoib_port_t* const p_port,\r
+ IN NET_BUFFER_LIST *p_net_buffer_list,\r
+ IN ULONG send_flags )\r
{\r
NDIS_STATUS status;\r
PNET_BUFFER p_netbuf, p_next_netbuf = NULL;\r
NDIS_RAISE_IRQL_TO_DISPATCH(&old_irql);\r
//ASSERT (KeGetCurrentIrql() == PASSIVE_LEVEL); // Happens\r
}\r
- NDIS_SET_SEND_COMPLETE_FLAG(send_complete_flags, NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL);\r
- \r
+ NDIS_SET_SEND_COMPLETE_FLAG( send_complete_flags,\r
+ NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL );\r
cl_obj_lock( &p_port->obj );\r
if( p_port->state != IB_QPS_RTS )\r
{\r
cl_obj_unlock( &p_port->obj );\r
\r
IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND,\r
- ("QP state isnt RTS, exiting from port_send\n"));\r
+ ("Invalid QP state: not RTS, exiting from port_send\n"));\r
NET_BUFFER_LIST_STATUS(p_net_buffer_list) = NDIS_STATUS_FAILURE;\r
ipoib_inc_send_stat( p_port->p_adapter, IP_STAT_DROPPED, 0 );\r
\r
- NdisMSendNetBufferListsCompleteX(\r
- p_port->p_adapter,\r
- p_net_buffer_list,\r
- send_complete_flags); \r
- \r
+ NdisMSendNetBufferListsCompleteX( p_port->p_adapter,\r
+ p_net_buffer_list,\r
+ send_complete_flags ); \r
return;\r
}\r
cl_obj_unlock( &p_port->obj );\r
// You are already here at dispatch\r
\r
// We need to init the status here\r
- // When completing the send, we will set the status NDIS_STATUS_FAILURE if AT LEAST\r
- // one of NBs will fail.\r
- // That is, status can't be updated back to SUCCESS if it previosly was set to FAILURE\r
+ // When completing the send, we will set the status NDIS_STATUS_FAILURE if\r
+ // AT LEAST one of NBs will fail.\r
+ // That is, status can't be updated back to SUCCESS if it previosly was set\r
+ // to FAILURE.\r
NET_BUFFER_LIST_STATUS(p_net_buffer_list) = NDIS_STATUS_SUCCESS;\r
\r
for (p_netbuf = NET_BUFFER_LIST_FIRST_NB(p_net_buffer_list);\r
ASSERT(buf_cnt);\r
\r
// Raise reference count of the NBL to the number of its NBs\r
- IPOIB_GET_NET_BUFFER_LIST_REF_COUNT(p_net_buffer_list) = (PVOID)(ULONG_PTR)buf_cnt;\r
+ IPOIB_GET_NET_BUFFER_LIST_REF_COUNT(p_net_buffer_list) =\r
+ (PVOID)(ULONG_PTR)buf_cnt;\r
\r
for (p_netbuf = NET_BUFFER_LIST_FIRST_NB(p_net_buffer_list);\r
p_netbuf != NULL; \r
{\r
p_next_netbuf = NET_BUFFER_NEXT_NB(p_netbuf);\r
\r
- ipoib_send_NB_SG * s_buf = (ipoib_send_NB_SG*) (PVOID) (cl_qpool_get(&p_port->send_mgr.send_pool));\r
- if (s_buf == NULL) {\r
+ ipoib_send_NB_SG * s_buf = (ipoib_send_NB_SG*) (PVOID)\r
+ (cl_qpool_get(&p_port->send_mgr.send_pool));\r
+ if (s_buf == NULL)\r
+ {\r
ASSERT(FALSE);\r
NET_BUFFER_LIST_STATUS(p_net_buffer_list) = NDIS_STATUS_RESOURCES;\r
- NdisMSendNetBufferListsCompleteX(\r
- p_port->p_adapter,\r
- p_net_buffer_list,\r
- send_complete_flags); \r
- break;\r
+ NdisMSendNetBufferListsCompleteX( p_port->p_adapter,\r
+ p_net_buffer_list,\r
+ send_complete_flags ); \r
+ break;\r
}\r
\r
//Set all the data needed for process_sg_list\r
\r
++g_ipoib_send_SW_in_loop;\r
\r
- ASSERT(s_buf->p_sg_buf);\r
- status = NdisMAllocateNetBufferSGList(\r
- p_port->p_adapter->NdisMiniportDmaHandle,\r
- p_netbuf,\r
- s_buf,\r
- NDIS_SG_LIST_WRITE_TO_DEVICE,\r
- (PUCHAR )s_buf->p_sg_buf + sizeof(cl_pool_item_t),\r
- p_port->p_adapter->sg_list_size);\r
+ status = NdisMAllocateNetBufferSGList(\r
+ p_port->p_adapter->NdisMiniportDmaHandle,\r
+ p_netbuf,\r
+ s_buf,\r
+ NDIS_SG_LIST_WRITE_TO_DEVICE,\r
+ (PUCHAR )s_buf->p_sg_buf + sizeof(cl_pool_item_t),\r
+ p_port->p_adapter->sg_list_size);\r
\r
- \r
- cl_spinlock_acquire( &p_port->send_lock ); \r
+ cl_spinlock_acquire( &p_port->send_lock ); \r
#endif\r
-// }\r
- \r
+\r
if( status != NDIS_STATUS_SUCCESS )\r
{\r
-\r
+ IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
+ ("Partial Send @ line #%d\n %s\n",__LINE__,__FILE__) );\r
ASSERT(FALSE);\r
- // TODOD: There is a bug here if we have succeeded in sending some and failed\r
- // with the otheres.\r
-\r
+ // TODOD: There is a bug here if we have succeeded in sending some\r
+ // and failed with the others.\r
\r
/* fail net buffer list */\r
NET_BUFFER_LIST_STATUS(p_net_buffer_list) = status;\r
- NdisMSendNetBufferListsCompleteX(\r
- p_port->p_adapter,\r
- p_net_buffer_list,\r
- send_complete_flags); \r
- break;\r
+ NdisMSendNetBufferListsCompleteX( p_port->p_adapter,\r
+ p_net_buffer_list,\r
+ send_complete_flags ); \r
+ break;\r
}\r
}\r
\r
IN ipoib_send_NB_SG *s_buf, \r
IN NDIS_STATUS status,\r
IN ULONG compl_flags,\r
- IN boolean_t bLock ) \r
+ IN boolean_t bLock ) \r
{\r
CL_ASSERT( s_buf );\r
\r
- IPOIB_PRINT(TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND,\r
- ("Processing send completion for NBL=0x%p .\n", s_buf->p_nbl ));\r
+ IPOIB_PRINT(TRACE_LEVEL_VERBOSE, IPOIB_DBG_BUF,\r
+ ("Processing send completion for NBL %p s_buf %p\n",\r
+ s_buf->p_nbl, s_buf));\r
\r
// Free SGL element allocated by NDIS\r
// We should do it before freeing the whole NBL\r
- NdisMFreeNetBufferSGList(\r
- s_buf->p_port->p_adapter->NdisMiniportDmaHandle,\r
- s_buf->p_sgl,\r
- s_buf->p_curr_nb);\r
+ NdisMFreeNetBufferSGList( s_buf->p_port->p_adapter->NdisMiniportDmaHandle,\r
+ s_buf->p_sgl,\r
+ s_buf->p_curr_nb );\r
\r
// No need to delete p_sg_buf at this state, we will destroy the whole list\r
// at the end of the execution\r
case NDIS_STATUS_RESOURCES:\r
default:\r
ASSERT(FALSE);\r
- \r
}\r
\r
IPOIB_DEC_NET_BUFFER_LIST_REF_COUNT(s_buf->p_nbl);\r
/* Complete the NBL */\r
- if (IPOIB_GET_NET_BUFFER_LIST_REF_COUNT(s_buf->p_nbl) == 0) {\r
+ if (IPOIB_GET_NET_BUFFER_LIST_REF_COUNT(s_buf->p_nbl) == 0)\r
+ {\r
NET_BUFFER_LIST_STATUS(s_buf->p_nbl) = status;\r
PNDIS_TCP_LARGE_SEND_OFFLOAD_NET_BUFFER_LIST_INFO pLsoInfo = \r
- (PNDIS_TCP_LARGE_SEND_OFFLOAD_NET_BUFFER_LIST_INFO) (PULONG)&NET_BUFFER_LIST_INFO(s_buf->p_nbl, TcpLargeSendNetBufferListInfo);\r
+ (PNDIS_TCP_LARGE_SEND_OFFLOAD_NET_BUFFER_LIST_INFO)\r
+ (PULONG)&NET_BUFFER_LIST_INFO(s_buf->p_nbl, TcpLargeSendNetBufferListInfo);\r
if(pLsoInfo->Transmit.Type == NDIS_TCP_LARGE_SEND_OFFLOAD_V1_TYPE)\r
{ \r
UINT TcpPayLoad = 0;\r
if( p_port->state != IB_QPS_RTS )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_SEND,\r
- ("Invalid port state =%d - Flushing the penging list\n", p_port->state) );\r
+ ("Invalid port state =%d - Flush pending list\n", p_port->state) );\r
b_good_port_state = FALSE;\r
-\r
}\r
cl_obj_unlock( &p_port->obj );\r
\r
p_item = cl_qlist_remove_head( &p_port->send_mgr.pending_list );\r
while (p_item != cl_qlist_end(&p_port->send_mgr.pending_list))\r
{\r
-\r
s_buf = (ipoib_send_NB_SG*) (PVOID) p_item; // TODO: Check this casting\r
\r
if (!b_good_port_state) {\r
// Port is in error state, flush the list\r
ipoib_inc_send_stat( p_port->p_adapter, IP_STAT_DROPPED, 0 );\r
- __send_complete_net_buffer(\r
- s_buf, NDIS_STATUS_FAILURE, NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL, FALSE);\r
+ __send_complete_net_buffer( s_buf, NDIS_STATUS_FAILURE,\r
+ NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL, FALSE);\r
} else {\r
-\r
/* Check the send queue and pend the request if not empty. */\r
if( p_port->send_mgr.depth == p_port->p_adapter->params.sq_depth )\r
{\r
//cl_qlist_check_validity(&p_port->send_mgr.pending_list);\r
\r
if (!continue_sending) {\r
- ASSERT (cl_is_item_in_qlist(&p_port->send_mgr.pending_list, (cl_list_item_t*)(PVOID)s_buf));\r
+ ASSERT( cl_is_item_in_qlist(&p_port->send_mgr.pending_list,\r
+ (cl_list_item_t*)(PVOID)s_buf) );\r
goto Cleanup;\r
}\r
}\r
- \r
p_item = cl_qlist_remove_head( &p_port->send_mgr.pending_list );\r
}\r
+\r
Cleanup:\r
IPOIB_EXIT( IPOIB_DBG_SEND );\r
}\r
\r
+\r
//TODO: use s_buf-><data_member> directly, instead of useless copies\r
\r
static void\r
{\r
p_free = wc;\r
cl_perf_start( PollSend );\r
- status = p_port->p_adapter->p_ifc->poll_cq( p_port->ib_mgr.h_send_cq, &p_free, &p_wc );\r
+ status = p_port->p_adapter->p_ifc->poll_cq( p_port->ib_mgr.h_send_cq,\r
+ &p_free,\r
+ &p_wc );\r
cl_perf_stop( &p_port->p_adapter->perf, PollSend );\r
CL_ASSERT( status == IB_SUCCESS || status == IB_NOT_FOUND );\r
\r
while( p_wc )\r
{\r
cl_perf_start( SendComp );\r
- CL_ASSERT( p_wc->status != IB_WCS_SUCCESS || p_wc->wc_type == IB_WC_SEND || p_wc->wc_type == IB_WC_LSO);\r
+ CL_ASSERT( p_wc->status != IB_WCS_SUCCESS ||\r
+ p_wc->wc_type == IB_WC_SEND || p_wc->wc_type == IB_WC_LSO);\r
+\r
s_buf = (ipoib_send_NB_SG*)(uintn_t)p_wc->wr_id;\r
IPOIB_PRINT(TRACE_LEVEL_VERBOSE, IPOIB_DBG_SEND,\r
("Successfull send completion for NBL=0x%p .\n", s_buf->p_nbl ));\r
}\r
\r
p_netbuffer = s_buf->p_curr_nb;\r
- ipoib_inc_send_stat( p_port->p_adapter, type, NET_BUFFER_DATA_LENGTH(p_netbuffer) ); \r
+ ipoib_inc_send_stat( p_port->p_adapter, type,\r
+ NET_BUFFER_DATA_LENGTH(p_netbuffer) ); \r
status = NDIS_STATUS_SUCCESS;\r
break;\r
\r
case IB_WCS_WR_FLUSHED_ERR:\r
IPOIB_PRINT(TRACE_LEVEL_INFORMATION, IPOIB_DBG_SEND,\r
("Flushed send completion.\n") );\r
- ipoib_inc_send_stat( p_port->p_adapter, IP_STAT_DROPPED, 0 );\r
+ ipoib_inc_send_stat( p_port->p_adapter, IP_STAT_DROPPED, 0 );\r
status = NDIS_STATUS_RESET_IN_PROGRESS;\r
\r
break;\r
("Send failed with %s (vendor specific %#x)\n",\r
p_port->p_adapter->p_ifc->get_wc_status_str( p_wc->status ),\r
(int)p_wc->vendor_specific) );\r
- ipoib_inc_send_stat( p_port->p_adapter, IP_STAT_ERROR, 0 );\r
+ ipoib_inc_send_stat( p_port->p_adapter, IP_STAT_ERROR, 0 );\r
status = NDIS_STATUS_FAILURE;\r
\r
break;\r
}\r
\r
- __send_complete_net_buffer(s_buf, status, NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL, FALSE);\r
+ __send_complete_net_buffer( s_buf,\r
+ status,\r
+ NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL,\r
+ FALSE );\r
\r
cl_atomic_dec( &p_port->send_mgr.depth );\r
\r
__endpt_mgr_construct(\r
IN ipoib_port_t* const p_port )\r
{\r
- IPOIB_ENTER( IPOIB_DBG_INIT );\r
cl_qmap_init( &p_port->endpt_mgr.mac_endpts );\r
cl_qmap_init( &p_port->endpt_mgr.lid_endpts );\r
cl_fmap_init( &p_port->endpt_mgr.gid_endpts, __gid_cmp );\r
- IPOIB_EXIT( IPOIB_DBG_INIT );\r
}\r
\r
//TODO Restore CM\r
\r
if( !p_endpt->conn.h_send_qp )\r
{\r
- ib_status = endpt_cm_create_qp( p_endpt, &p_endpt->conn.h_send_qp );\r
+ ib_status = endpt_cm_create_qp( p_endpt,\r
+ &p_endpt->conn.h_send_qp );\r
if( ib_status != IB_SUCCESS )\r
{\r
IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- ("Endpt [%p ] CM create QP failed status %#x\n", p_endpt, ib_status ) );\r
+ ("Endpt %p CM create QP failed status %#x\n",\r
+ p_endpt, ib_status ) );\r
}\r
else\r
{\r
ib_status = ipoib_endpt_connect( p_endpt );\r
if( ib_status != IB_SUCCESS && ib_status != IB_PENDING )\r
{\r
- IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- ("Endpt [ %p ] conn REQ failed status %#x\n", p_endpt, ib_status ) );\r
+ IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
+ ("Endpt %p conn REQ failed status %#x\n",\r
+ p_endpt, ib_status ) );\r
}\r
}\r
if( ib_status != IB_SUCCESS && ib_status != IB_PENDING )\r
NdisFreeSpinLock( &p_port->endpt_mgr.conn_lock );\r
\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_INIT, \r
- (" Port [%d] Endpt thread is done\n", p_port->port_num ) );\r
+ (" Port [%d] Endpt_mgr thread is done\n", p_port->port_num ) );\r
}\r
#endif\r
\r
link_state.MediaConnectState = MediaConnectStateDisconnected;\r
link_state.MediaDuplexState = MediaDuplexStateFull;\r
link_state.XmitLinkSpeed =\r
- link_state.RcvLinkSpeed = link_state.RcvLinkSpeed = SET_PORT_RATE_BPS( p_port->p_adapter->port_rate );\r
+ link_state.RcvLinkSpeed =\r
+ link_state.RcvLinkSpeed =\r
+ SET_PORT_RATE_BPS( p_port->p_adapter->port_rate );\r
\r
IPOIB_INIT_NDIS_STATUS_INDICATION(&status_indication,\r
p_port->p_adapter->h_adapter,\r
NDIS_STATUS_LINK_STATE,\r
(PVOID)&link_state,\r
sizeof(link_state));\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_INIT, ("Indicate DISCONNECT!\n") );\r
- NdisMIndicateStatusEx(p_port->p_adapter->h_adapter,&status_indication);\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_INIT,\r
+ ("Indicate DISCONNECT!\n") );\r
+ NdisMIndicateStatusEx( p_port->p_adapter->h_adapter,\r
+ &status_indication );\r
\r
link_state.MediaConnectState = MediaConnectStateConnected;\r
IPOIB_INIT_NDIS_STATUS_INDICATION(&status_indication,\r
NDIS_STATUS_LINK_STATE,\r
(PVOID)&link_state,\r
sizeof(link_state));\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_INIT, ("Indicate Connect\n") );\r
- NdisMIndicateStatusEx(p_port->p_adapter->h_adapter,&status_indication);\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_INIT,\r
+ ("Indicate Connect\n") );\r
+ NdisMIndicateStatusEx( p_port->p_adapter->h_adapter,\r
+ &status_indication );\r
\r
\r
// IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_INIT,\r
KeSetEvent( &p_port->leave_mcast_event, EVENT_INCREMENT, FALSE );\r
} \r
\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,("p_port->mcast_cnt = %d\n", p_port->mcast_cnt - local_exist));\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,\r
+ ("p_port->mcast_cnt = %d\n", p_port->mcast_cnt - local_exist));\r
\r
/* Destroy all multicast endpoints now that we have released the lock. */\r
while( cl_qlist_count( &mc_list ) )\r
{\r
cl_list_item_t *p_item;\r
p_item = cl_qlist_remove_head( &mc_list );\r
- p_endpt = PARENT_STRUCT(p_item, ipoib_endpt_t, mac_item.pool_item.list_item);\r
+ p_endpt = PARENT_STRUCT(p_item, ipoib_endpt_t,\r
+ mac_item.pool_item.list_item);\r
cl_obj_destroy( &p_endpt->obj);\r
}\r
\r
if( p_fmap_item != cl_fmap_end( &p_port->endpt_mgr.conn_endpts ) )\r
{\r
cl_fmap_remove_item( &p_port->endpt_mgr.conn_endpts, \r
- &p_endpt->conn_item );\r
+ &p_endpt->conn_item );\r
}\r
}\r
#endif \r
if( p_endpt->dlid )\r
{\r
- cl_qmap_remove_item( &p_port->endpt_mgr.lid_endpts,\r
- &p_endpt->lid_item );\r
+ cl_qmap_remove_item( &p_port->endpt_mgr.lid_endpts, &p_endpt->lid_item );\r
}\r
\r
cl_obj_unlock( &p_port->obj );\r
cl_obj_unlock( &p_port->obj );\r
cl_obj_lock( &p_port->obj );\r
}\r
- /* __endpt_mgr_insert expects *one* reference to be held when being called. */\r
+ /* __endpt_mgr_insert expects *1* reference to be held when being called */\r
cl_atomic_inc( &p_port->endpt_rdr );\r
status= __endpt_mgr_insert( p_port, mac, p_endpt );\r
cl_atomic_dec( &p_port->endpt_rdr );\r
p_endpt->mac = mac;\r
key = 0;\r
cl_memcpy( &key, &mac, sizeof(mac_addr_t) );\r
- p_qitem = cl_qmap_insert(\r
- &p_port->endpt_mgr.mac_endpts, key, &p_endpt->mac_item );\r
+ p_qitem = cl_qmap_insert( &p_port->endpt_mgr.mac_endpts,\r
+ key,\r
+ &p_endpt->mac_item );\r
CL_ASSERT( p_qitem == &p_endpt->mac_item );\r
- p_fitem = cl_fmap_insert(\r
- &p_port->endpt_mgr.gid_endpts, &p_endpt->dgid, &p_endpt->gid_item );\r
+\r
+ p_fitem = cl_fmap_insert( &p_port->endpt_mgr.gid_endpts,\r
+ &p_endpt->dgid,\r
+ &p_endpt->gid_item );\r
CL_ASSERT( p_fitem == &p_endpt->gid_item );\r
+\r
if( p_endpt->dlid )\r
{\r
- p_qitem = cl_qmap_insert(\r
- &p_port->endpt_mgr.lid_endpts, p_endpt->dlid, &p_endpt->lid_item );\r
+ p_qitem = cl_qmap_insert( &p_port->endpt_mgr.lid_endpts,\r
+ p_endpt->dlid,\r
+ &p_endpt->lid_item );\r
CL_ASSERT( p_qitem == &p_endpt->lid_item );\r
if (p_qitem != &p_endpt->lid_item) {\r
// Since we failed to insert into the list, make sure it is not removed\r
\r
/* Allocate the broadcast endpoint. */\r
p_endpt = ipoib_endpt_create( &p_mcast_rec->p_member_rec->mgid,\r
- 0 , CL_HTON32(0x00FFFFFF) );\r
+ 0,\r
+ CL_HTON32(0x00FFFFFF) );\r
if( !p_endpt )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
/* set reference to transport to be used while is not attached to the port */\r
p_endpt->is_mcast_listener = TRUE;\r
p_endpt->p_ifc = p_port->p_adapter->p_ifc;\r
- status = ipoib_endpt_set_mcast( p_endpt, p_port->ib_mgr.h_pd,\r
- p_port->port_num, p_mcast_rec );\r
+ status = ipoib_endpt_set_mcast( p_endpt,\r
+ p_port->ib_mgr.h_pd,\r
+ p_port->port_num,\r
+ p_mcast_rec );\r
if( status != IB_SUCCESS )\r
{\r
cl_obj_destroy( &p_endpt->obj );\r
\r
/* Remove the endpoint from the maps so further requests don't find it. */\r
cl_obj_lock( &p_port->obj );\r
+\r
/* Wait for all readers to finish */\r
while( p_port->endpt_rdr )\r
;\r
{\r
p_endpt = PARENT_STRUCT( p_item, ipoib_endpt_t, mac_item );\r
/*\r
- * The enpoints are *ALWAYS* in both the MAC and GID maps. They are only\r
+ * The enpoints are *ALWAYS* in both the MAC and GID maps. They are only\r
* in the LID map if the GID has the same subnet prefix as us.\r
*/\r
cl_fmap_remove_item(\r
#if 0\r
if( p_port->p_adapter->params.cm_enabled )\r
{\r
- p_fmap_item = cl_fmap_get( &p_port->endpt_mgr.conn_endpts, &p_endpt->dgid );\r
+ p_fmap_item = cl_fmap_get( &p_port->endpt_mgr.conn_endpts,\r
+ &p_endpt->dgid );\r
\r
if( p_fmap_item != cl_fmap_end( &p_port->endpt_mgr.conn_endpts ) )\r
{\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,\r
("ref type %d ref_cnt %d\n", ref_endpt_track, p_port->obj.ref_cnt) );\r
#endif\r
-\r
}\r
else\r
- {\r
cl_obj_unlock( &p_port->obj );\r
- }\r
\r
IPOIB_EXIT( IPOIB_DBG_ENDPT );\r
}\r
mad_in->class_ver =1;\r
mad_in->mgmt_class = IB_MCLASS_SUBN_LID;\r
\r
- status = p_port->p_adapter->p_ifc->local_mad(\r
- p_port->ib_mgr.h_ca ,p_port->port_num ,mad_in ,mad_out);\r
-\r
+ status = p_port->p_adapter->p_ifc->local_mad( p_port->ib_mgr.h_ca,\r
+ p_port->port_num,\r
+ mad_in,\r
+ mad_out );\r
if( status != IB_SUCCESS )\r
{\r
ipoib_set_inactive( p_port->p_adapter );\r
p_port_info = (ib_port_info_t*)(((ib_smp_t*)mad_out)->data);\r
p_port->base_lid = p_pnp_rec->p_port_attr->lid;\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_INIT,\r
- ("Received port info: link width = %d.\n",\r
+ ("Received port info: link width = %d.\n",\r
p_port_info->link_width_active) );\r
- p_port->ib_mgr.rate =\r
- ib_port_info_compute_rate( p_port_info );\r
+ p_port->ib_mgr.rate = ib_port_info_compute_rate( p_port_info );\r
\r
ipoib_set_rate( p_port->p_adapter,\r
- p_port_info->link_width_active,\r
- ib_port_info_get_link_speed_active( p_port_info ) );\r
+ p_port_info->link_width_active,\r
+ ib_port_info_get_link_speed_active( p_port_info ) );\r
\r
status = __port_get_bcast( p_port );\r
if (status != IB_SUCCESS)\r
+ {\r
IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
- (" __port_get_bcast returned %s\n",p_port->p_adapter->p_ifc->get_err_str( status )));\r
+ (" __port_get_bcast returned %s\n",\r
+ p_port->p_adapter->p_ifc->get_err_str( status )));\r
+ }\r
\r
up_done:\r
if( status != IB_SUCCESS )\r
IPOIB_ENTER( IPOIB_DBG_INIT );\r
\r
ib_gid_set_default( &gid, p_port->p_adapter->guids.port_guid.guid );\r
- p_endpt = ipoib_endpt_create(\r
- &gid, p_port_info->base_lid, p_port->ib_mgr.qpn );\r
+ p_endpt = ipoib_endpt_create( &gid, p_port_info->base_lid, p_port->ib_mgr.qpn );\r
if( !p_endpt )\r
{\r
p_port->p_adapter->hung = TRUE;\r
av_attr.port_num = p_port->port_num;\r
av_attr.sl = 0;\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,\r
- (" av_attr.dlid = p_port_info->base_lid = %d\n", cl_ntoh16( p_port_info->base_lid ) ));\r
+ (" av_attr.dlid = p_port_info->base_lid = %d\n",\r
+ cl_ntoh16( p_port_info->base_lid ) ));\r
av_attr.dlid = p_port_info->base_lid;\r
av_attr.static_rate = p_port->ib_mgr.rate;\r
av_attr.path_bits = 0;\r
cl_obj_destroy( &p_endpt->obj );\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
("ib_create_av for local endpoint returned %s\n",\r
- p_port->p_adapter->p_ifc->get_err_str( status )) );\r
+ p_port->p_adapter->p_ifc->get_err_str( status )) );\r
return status;\r
}\r
\r
/* __endpt_mgr_insert expects *one* reference to be held. */\r
cl_atomic_inc( &p_port->endpt_rdr );\r
- status = __endpt_mgr_insert( p_port, p_port->p_adapter->params.conf_mac, p_endpt );\r
+ status = __endpt_mgr_insert( p_port,\r
+ p_port->p_adapter->params.conf_mac,\r
+ p_endpt );\r
cl_atomic_dec( &p_port->endpt_rdr );\r
if( status != IB_SUCCESS )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
("__endpt_mgr_insert for local endpoint returned %s\n",\r
- p_port->p_adapter->p_ifc->get_err_str( status )) );\r
+ p_port->p_adapter->p_ifc->get_err_str( status )) );\r
return status;\r
}\r
\r
}\r
\r
\r
-\r
-\r
static ib_api_status_t\r
__port_get_bcast(\r
IN ipoib_port_t* const p_port )\r
/* reference the object for the multicast query. */\r
ipoib_port_ref( p_port, ref_get_bcast );\r
\r
- status = p_port->p_adapter->p_ifc->query(\r
- p_port->p_adapter->h_al, &query, &p_port->ib_mgr.h_query );\r
+ status = p_port->p_adapter->p_ifc->query( p_port->p_adapter->h_al,\r
+ &query,\r
+ &p_port->ib_mgr.h_query );\r
if( status != IB_SUCCESS )\r
{\r
ipoib_port_deref( p_port, ref_get_bcast );\r
\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_INIT,\r
("status of request %s\n", \r
- p_port->p_adapter->p_ifc->get_err_str( status )) );\r
+ p_port->p_adapter->p_ifc->get_err_str( status )) );\r
\r
switch( status )\r
{\r
mcast_req.member_rec.mgid.raw[4] = (uint8_t) (p_port->p_adapter->guids.port_guid.pkey >> 8); \r
mcast_req.member_rec.mgid.raw[5] = (uint8_t) p_port->p_adapter->guids.port_guid.pkey;\r
ib_gid_set_default( &mcast_req.member_rec.port_gid,\r
- p_port->p_adapter->guids.port_guid.guid );\r
+ p_port->p_adapter->guids.port_guid.guid );\r
/*\r
* IPOIB spec requires that the QKEY have the MSb set so that the QKEY\r
* from the QP is used rather than the QKEY in the send WR.\r
if( p_mcast_rec->status == IB_SUCCESS )\r
{\r
ipoib_port_ref(p_port, ref_leave_mcast);\r
- p_port->p_adapter->p_ifc->leave_mcast( p_mcast_rec->h_mcast, __leave_error_mcast_cb );\r
+ p_port->p_adapter->p_ifc->leave_mcast( p_mcast_rec->h_mcast,\r
+ __leave_error_mcast_cb );\r
}\r
KeSetEvent( &p_port->sa_event, EVENT_INCREMENT, FALSE );\r
ipoib_port_deref( p_port, ref_bcast_inv_state );\r
("__endpt_mgr_add_bcast returned %s\n",\r
p_port->p_adapter->p_ifc->get_err_str( status )) );\r
ipoib_port_ref(p_port, ref_leave_mcast);\r
- status = p_port->p_adapter->p_ifc->leave_mcast( p_mcast_rec->h_mcast, __leave_error_mcast_cb );\r
+ status = p_port->p_adapter->p_ifc->leave_mcast( p_mcast_rec->h_mcast,\r
+ __leave_error_mcast_cb );\r
CL_ASSERT( status == IB_SUCCESS );\r
goto err;\r
}\r
ipoib_port_deref( p_port, ref_join_bcast );\r
return;\r
}\r
-#if 0 //CM\r
+#if IPOIB_CM //CM\r
if( p_port->p_adapter->params.cm_enabled &&\r
!p_port->p_local_endpt->conn.h_cm_listen )\r
{\r
if( ipoib_port_listen( p_port ) != IB_SUCCESS )\r
{\r
- IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
+ IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
("Port CM Listen failed\n" ) );\r
/*keep going with UD only */\r
p_port->p_adapter->params.cm_enabled = FALSE;\r
\r
\r
/* Transition to a passive level thread. */\r
+\r
ib_api_status_t\r
ipoib_port_join_mcast(\r
IN ipoib_port_t* const p_port,\r
case NDIS_STATUS_PENDING:\r
IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,\r
("<ipoib_port_join_mcast> PENDING\n") );\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,("__endpt_mgr_ref called for %p\n", p_endpt));\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,\r
+ ("__endpt_mgr_ref called for %p\n", p_endpt));\r
return IB_SUCCESS;\r
}\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,("__endpt_mgr_ref called for %p\n", p_endpt));\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_ENDPT,\r
+ ("__endpt_mgr_ref called for %p\n", p_endpt));\r
/*\r
* Issue the mcast request, using the parameters of the broadcast group.\r
* This allows us to do a create request that should always succeed since\r
* mcast callback is invoked, it would not find the corresponding endpoint\r
* and would be undone.\r
*/\r
- p_endpt = ipoib_endpt_create(\r
- &mcast_req.member_rec.mgid, 0, CL_HTON32(0x00FFFFFF) );\r
+ p_endpt = ipoib_endpt_create( &mcast_req.member_rec.mgid,\r
+ 0,\r
+ CL_HTON32(0x00FFFFFF) );\r
if( !p_endpt )\r
{\r
IPOIB_PRINT_EXIT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
\r
{\r
ipoib_port_ref(p_port, ref_leave_mcast);\r
- p_port->p_adapter->p_ifc->leave_mcast( p_mcast_rec->h_mcast, __leave_error_mcast_cb );\r
+ p_port->p_adapter->p_ifc->leave_mcast( p_mcast_rec->h_mcast,\r
+ __leave_error_mcast_cb );\r
}\r
ipoib_port_deref( p_port, ref_mcast_inv_state );\r
- IPOIB_PRINT_EXIT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST ,("Invalid state - Aborting.\n") );\r
- IPOIB_PRINT_EXIT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_INIT ,("Invalid state - Aborting.\n") );\r
+ IPOIB_PRINT_EXIT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,\r
+ ("Invalid state - Aborting.\n") );\r
+ IPOIB_PRINT_EXIT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_INIT,\r
+ ("Invalid state - Aborting.\n") );\r
\r
cl_spinlock_acquire(&p_port->send_lock);\r
//ipoib_port_resume(p_port , FALSE);\r
cl_obj_unlock( &p_port->obj );\r
IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_ERROR,\r
("Multicast join request failed with status %s.\n",\r
- p_port->p_adapter->p_ifc->get_err_str( p_mcast_rec->status )) );\r
+ p_port->p_adapter->p_ifc->get_err_str( p_mcast_rec->status )) );\r
/* Flag the adapter as hung. */\r
p_port->p_adapter->hung =TRUE;\r
ipoib_port_deref( p_port, ref_mcast_req_failed );\r
return;\r
}\r
\r
- p_item = cl_fmap_get(\r
- &p_port->endpt_mgr.gid_endpts, &p_mcast_rec->p_member_rec->mgid );\r
+ p_item = cl_fmap_get( &p_port->endpt_mgr.gid_endpts,\r
+ &p_mcast_rec->p_member_rec->mgid );\r
if( p_item == cl_fmap_end( &p_port->endpt_mgr.gid_endpts ) )\r
{\r
/*\r
("Failed to find endpoint for update.\n") );\r
\r
ipoib_port_ref(p_port, ref_leave_mcast);\r
- p_port->p_adapter->p_ifc->leave_mcast( p_mcast_rec->h_mcast, __leave_error_mcast_cb );\r
+ p_port->p_adapter->p_ifc->leave_mcast( p_mcast_rec->h_mcast,\r
+ __leave_error_mcast_cb );\r
ipoib_port_deref( p_port, ref_mcast_no_endpt );\r
IPOIB_EXIT( IPOIB_DBG_MCAST );\r
return;\r
p_endpt->p_ifc = p_port->p_adapter->p_ifc;\r
\r
/* Setup the endpoint for use. */\r
- status = ipoib_endpt_set_mcast(\r
- p_endpt, p_port->ib_mgr.h_pd, p_port->port_num, p_mcast_rec );\r
+ status = ipoib_endpt_set_mcast( p_endpt,\r
+ p_port->ib_mgr.h_pd,\r
+ p_port->port_num,\r
+ p_mcast_rec );\r
if( status != IB_SUCCESS )\r
{\r
cl_obj_unlock( &p_port->obj );\r
IPOIB_PRINT( TRACE_LEVEL_ERROR, IPOIB_DBG_MCAST,\r
("ipoib_endpt_set_mcast returned %s.\n",\r
- p_port->p_adapter->p_ifc->get_err_str( status )) );\r
+ p_port->p_adapter->p_ifc->get_err_str( status )) );\r
/* Flag the adapter as hung. */\r
p_port->p_adapter->hung = TRUE;\r
ipoib_port_deref( p_port, ref_mcast_av_failed );\r
\r
/* Try to send all pending sends. */\r
cl_spinlock_acquire( &p_port->send_lock );\r
- IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST, ("Calling ipoib_port_resume from mcast_cb\n"));\r
+ IPOIB_PRINT( TRACE_LEVEL_INFORMATION, IPOIB_DBG_MCAST,\r
+ ("Calling ipoib_port_resume from mcast_cb, xmit pending sends\n"));\r
ipoib_port_resume(p_port , FALSE);\r
cl_spinlock_release( &p_port->send_lock );\r
\r
\r
p_port = (ipoib_port_t*)context;\r
\r
- IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_MCAST,("p_port->mcast_cnt = %d\n", p_port->mcast_cnt));\r
+ IPOIB_PRINT( TRACE_LEVEL_VERBOSE, IPOIB_DBG_MCAST,\r
+ ("p_port->mcast_cnt %d\n", p_port->mcast_cnt));\r
\r
ipoib_port_deref( p_port, ref_leave_mcast);\r
//It happens\r
\r
\r
//TODO don't use DISPATCH LEVEL\r
- __send_complete_net_buffer(\r
- s_buf, NDIS_STATUS_SEND_ABORTED ,NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL, TRUE);\r
+ __send_complete_net_buffer( s_buf, NDIS_STATUS_SEND_ABORTED,\r
+ NDIS_SEND_COMPLETE_FLAGS_DISPATCH_LEVEL, TRUE);\r
}\r
\r
}\r
-\r
IPOIB_EXIT( IPOIB_DBG_SEND );\r
}\r
\r
projects / ~shefty / rdma-win.git / commitdiff