[zhu] 71823: Fixed crash on client and server exit: Corrected some NULL data marking and checking. Moved some cleanup code so they actually execute on function failure (incomplete). Removed redunda...

Author: zhu
Date: Tue Jul  5 18:35:17 2016
New Revision: 71823

URL: http://svn.reactos.org/svn/reactos?rev=71823&view=rev
Log:
Fixed crash on client and server exit:
Corrected some NULL data marking and checking. 
Moved some cleanup code so they actually execute on function failure (incomplete).
Removed redundant tcp_close() call in error callback.
Changed listen request cancel mode from ABORT to CLOSE, since ABORT is illegal for a
listening pcb. 

Modified:
    branches/GSoC_2016/lwIP-tcpip/drivers/network/tcpip/address.c

Modified: branches/GSoC_2016/lwIP-tcpip/drivers/network/tcpip/address.c
URL:
http://svn.reactos.org/svn/reactos/branches/GSoC_2016/lwIP-tcpip/drivers/ne…
==============================================================================
--- branches/GSoC_2016/lwIP-tcpip/drivers/network/tcpip/address.c	[iso-8859-1] (original)
+++ branches/GSoC_2016/lwIP-tcpip/drivers/network/tcpip/address.c	[iso-8859-1] Tue Jul  5
18:35:17 2016
@@ -106,11 +106,10 @@
 	PTCP_REQUEST Request;
 	KIRQL OldIrql;
 	
-	DPRINT1("IRP Cancel on IRP at %08x\n", Irp);
-	
 	IoReleaseCancelSpinLock(Irp->CancelIrql);
 	
 	IrpSp = IoGetCurrentIrpStackLocation(Irp);
+	DPRINT1("IRP Cancel on IRP at %08x, with MinorFunction %08x\n", Irp,
IrpSp->MinorFunction);
 	switch ((ULONG)IrpSp->FileObject->FsContext2)
 	{
 		case TDI_TRANSPORT_ADDRESS_FILE :
@@ -357,15 +356,15 @@
 			
 			KeReleaseSpinLockFromDpcLevel(&Context->RequestListLock);
 			
-			if (Context->lwip_tcp_pcb != Context->AddressFile->lwip_tcp_pcb)
+			if (Context->lwip_tcp_pcb == Context->AddressFile->lwip_tcp_pcb);
 			{
-				tcp_close(Context->lwip_tcp_pcb);
+				Context->AddressFile->lwip_tcp_pcb = NULL;
 			}
 			Context->lwip_tcp_pcb = NULL;
 			
 			return;
 		default :
-			DPRINT1("Invalid argument\n");
+			DPRINT1("Invalid argument: %08x\n", arg);
 			return;
 	}
 }
@@ -520,7 +519,9 @@
 				ExFreePoolWithTag(Request, TAG_TCP_REQUEST);
 				return ERR_ABRT;
 			}
-		
+			
+			Request->PendingIrp = NULL;
+			
 			IoSetCancelRoutine(Irp, NULL);
 			Irp->Cancel = FALSE;
 			
@@ -667,6 +668,7 @@
 	UCHAR *CurrentSrceLocation;
 	PLIST_ENTRY Head;
 	PLIST_ENTRY Entry;
+	NTSTATUS Status;
 	
 	DPRINT1("lwIP TCP Receive Callback\n");
 	
@@ -719,6 +721,7 @@
 	DPRINT1("IRP at %08x\n", Irp);
 	
 	IrpSp = IoGetCurrentIrpStackLocation(Irp);
+	DPRINT1("IrpSp: %08x\n", IrpSp);
 	
 	IoSetCancelRoutine(Irp, NULL);
 	Irp->Cancel = FALSE;
@@ -769,15 +772,30 @@
 	RemainingDestBytes = Buffer->ByteCount;
 //	NdisQueryBuffer(Buffer, &CurrentDestLocation, &RemainingDestBytes);
 	
-	DPRINT1("\n  PTDI_REQUEST_KERNEL_RECEIVE->ReceiveLength = %d\n  NDIS_BUFFER
length = %d\n  pbuf->tot_len = %d\n",
-		ReceiveInfo->ReceiveLength,
-		RemainingDestBytes,
-		p->tot_len);
+	if (p)
+	{
+		DPRINT1("\n  PTDI_REQUEST_KERNEL_RECEIVE->ReceiveLength = %d\n  NDIS_BUFFER
length = %d\n  pbuf->tot_len = %d\n",
+			ReceiveInfo->ReceiveLength,
+			RemainingDestBytes,
+			p->tot_len);
+	}
+	else
+	{
+		DPRINT1("\n  The pbuf pointer p is NULL\n");
+	}
+	
+	if (!p)
+	{
+		CopiedLength = 0;
+		Status = STATUS_ADDRESS_CLOSED;
+		goto BAD;
+	}
 	
 	if (RemainingDestBytes <= p->len)
 	{
 		RtlCopyMemory(CurrentDestLocation, p->payload, RemainingDestBytes);
 		CopiedLength = RemainingDestBytes;
+		Status = STATUS_SUCCESS;
 		goto RETURN;
 	}
 	else
@@ -808,6 +826,7 @@
 				}
 				else
 				{
+					Status = STATUS_SUCCESS;
 					goto RETURN;
 				}
 			}
@@ -816,6 +835,7 @@
 				RtlCopyMemory(CurrentDestLocation, CurrentSrceLocation, RemainingDestBytes);
 				CopiedLength += RemainingDestBytes;
 				
+				Status = STATUS_SUCCESS;
 				goto RETURN;
 			}
 		}
@@ -826,23 +846,24 @@
 	
 	tcp_recved(tpcb, CopiedLength);
 	
+	while (Entry != Head)
+	{
+		Request = CONTAINING_RECORD(Entry, TCP_REQUEST, ListEntry);
+		if (Request->PendingMode == TCP_REQUEST_PENDING_RECEIVE)
+		{
+			tcp_recv(tpcb, lwip_tcp_receive_callback);
+			break;
+		}
+	}
+	
+BAD:
 	RemoveEntryList(&Request->ListEntry);
 	ExFreePoolWithTag(Request, TAG_TCP_REQUEST);
 	
-	while (Entry != Head)
-	{
-		Request = CONTAINING_RECORD(Entry, TCP_REQUEST, ListEntry);
-		if (Request->PendingMode == TCP_REQUEST_PENDING_RECEIVE)
-		{
-			tcp_recv(tpcb, lwip_tcp_receive_callback);
-			break;
-		}
-	}
-	
 	KeReleaseSpinLockFromDpcLevel(&Context->RequestListLock);
 	IoReleaseCancelSpinLock(OldIrql);
-
-	Irp->IoStatus.Status = STATUS_SUCCESS;
+	
+	Irp->IoStatus.Status = Status;
 	Irp->IoStatus.Information = CopiedLength;
 	IoCompleteRequest(Irp, IO_NETWORK_INCREMENT);
 	
@@ -1613,11 +1634,11 @@
 	
 	DPRINT1("TcpIpAssociateAddress Exiting\n");
 	
+	Context->TcpState = TCP_STATE_BOUND;
+	
+LEAVE:
 	KeReleaseSpinLock(&AddressFile->ContextListLock, OldIrql);
 	
-	Context->TcpState = TCP_STATE_BOUND;
-	
-LEAVE:
 	return Status;
 }
 
@@ -1631,6 +1652,9 @@
 	PADDRESS_FILE AddressFile;
 	
 	KIRQL OldIrql;
+	PLIST_ENTRY Head;
+	PLIST_ENTRY Entry;
+	PTCP_REQUEST Request;
 	
 	IrpSp = IoGetCurrentIrpStackLocation(Irp);
 	if ((ULONG)IrpSp->FileObject->FsContext2 != TDI_CONNECTION_FILE)
@@ -1666,6 +1690,21 @@
 	if (!(IsListEmpty(&Context->RequestListHead)))
 	{
 		DPRINT1("Disassociating context with outstanding requests\n");
+		Head = &Context->RequestListHead;
+		Entry = Head->Flink;
+		while (Entry != Head)
+		{
+			Request = CONTAINING_RECORD(Entry, TCP_REQUEST, ListEntry);
+			if (Request->PendingIrp)
+			{
+				IrpSp = IoGetCurrentIrpStackLocation(Request->PendingIrp);
+				DPRINT1("Pending IRP Control Code: %08x\n", IrpSp->MinorFunction);
+			}
+			else
+			{
+				DPRINT1("IRP is NULL\n");
+			}
+		}
 	}
 	KeReleaseSpinLockFromDpcLevel(&Context->RequestListLock);
 	
@@ -1737,7 +1776,7 @@
 	PrepareIrpForCancel(
 		Irp,
 		CancelRequestRoutine,
-		TCP_REQUEST_CANCEL_MODE_ABORT,
+		TCP_REQUEST_CANCEL_MODE_CLOSE,
 		TCP_REQUEST_PENDING_GENERAL);
 	Context->TcpState = TCP_STATE_LISTENING;
 	return STATUS_PENDING;