PVOID Data;
WCHAR Buff[25];
- if(ParameterType != NdisParameterInteger &&
- ParameterType != NdisParameterHexInteger &&
- ParameterType != NdisParameterString &&
- ParameterType != NdisParameterMultiString &&
- ParameterType != NdisParameterBinary
- )
- {
- *Status = NDIS_STATUS_NOT_SUPPORTED;
- return;
- }
-
/* reset parameter type to standard reg types */
switch(ParameterType)
{
break;
default:
- *Status = NDIS_STATUS_FAILURE;
+ *Status = NDIS_STATUS_NOT_SUPPORTED;
return;
}
)
{
NDIS_DbgPrint(MID_TRACE,("unsupported parameter type\n"));
+ *Status = NDIS_STATUS_NOT_SUPPORTED;
return;
}
}
}
}
+ Lock->Context = PsGetCurrentThread();
LockState->LockState = 3;
}
}
KeLowerIrql(RaiseOldIrql);
}
}
- if( NdisStatus != NDIS_STATUS_PENDING ) {
+
+ if( NdisStatus == NDIS_STATUS_RESOURCES )
+ MiniQueueWorkItem(Adapter, WorkItemType, WorkItemContext);
+ else if( NdisStatus != NDIS_STATUS_PENDING ) {
NdisMSendComplete
( Adapter, (PNDIS_PACKET)WorkItemContext, NdisStatus );
Adapter->MiniportBusy = FALSE;
* ShutdownHandler: Function to call to handle the bugcheck
* NOTES:
* - I'm not sure about ShutdownContext
- * - FIXME - memory leak below
*/
{
PLOGICAL_ADAPTER Adapter = (PLOGICAL_ADAPTER)MiniportHandle;
BugcheckContext->ShutdownHandler = ShutdownHandler;
BugcheckContext->DriverContext = ShutdownContext;
- /* not sure if this needs to be initialized or not... oh well, it's a leak. */
BugcheckContext->CallbackRecord = ExAllocatePool(NonPagedPool, sizeof(KBUGCHECK_CALLBACK_RECORD));
+ KeInitializeCallbackRecord(BugcheckContext->CallbackRecord);
+
KeRegisterBugCheckCallback(BugcheckContext->CallbackRecord, NdisIBugcheckCallback,
BugcheckContext, sizeof(BugcheckContext), (PUCHAR)"Ndis Miniport");
}
/* Convert returned link speed to bps (it is in 100bps increments) */
IF->Speed = Speed * 100L;
- /* Add adapter to the adapter list */
- ExInterlockedInsertTailList(&AdapterListHead,
- &IF->ListEntry,
- &AdapterListLock);
-
/* Bind adapter to IP layer */
if( !BindAdapter(IF, RegistryPath) ) {
TI_DbgPrint(DEBUG_DATALINK,("denying adapter %wZ (BindAdapter)\n", AdapterName));
return NDIS_STATUS_NOT_ACCEPTED;
}
+ /* Add adapter to the adapter list */
+ ExInterlockedInsertTailList(&AdapterListHead,
+ &IF->ListEntry,
+ &AdapterListLock);
+
TI_DbgPrint(DEBUG_DATALINK, ("Leaving.\n"));
return NDIS_STATUS_SUCCESS;
Status = TCPSocket( Connection, AF_INET, SOCK_STREAM, IPPROTO_TCP );
+ if( !NT_SUCCESS(Status) ) {
+ TCPFreeConnectionEndpoint( Connection );
+ return Status;
+ }
+
/* Return connection endpoint file object */
Request->Handle.ConnectionContext = Connection;
Buffer = ExAllocatePool(NonPagedPool, Size);
+ RtlZeroMemory(Buffer, Size);
+
TI_DbgPrint(DEBUG_MEMORY, ("Allocated (%i) bytes at (0x%X).\n", Size, Buffer));
return Buffer;
("Called. Context (0x%X) NdisPacket (0x%X) NdisStatus (0x%X)\n",
Context, NdisPacket, NdisStatus));
- /* FIXME: Stop sending fragments and cleanup datagram buffers if
- there was an error */
-
- if (PrepareNextFragment(IFC)) {
+ if (NT_SUCCESS(NdisStatus) && PrepareNextFragment(IFC)) {
/* A fragment was prepared for transmission, so send it */
IPSendFragment(IFC->NdisPacket, IFC->NCE, IFC);
} else {
if( Bucket->AssociatedEndpoint == Connection ) {
RemoveEntryList( ListEntry->Blink );
ExFreePool( Bucket );
+ break;
}
}
if( Status == STATUS_PENDING ) {
Bucket = ExAllocatePool( NonPagedPool, sizeof(*Bucket) );
- Bucket->AssociatedEndpoint = Connection;
- Bucket->Request.RequestNotifyObject = Complete;
- Bucket->Request.RequestContext = Context;
- InsertHeadList( &Listener->ListenRequest, &Bucket->Entry );
+
+ if( Bucket ) {
+ Bucket->AssociatedEndpoint = Connection;
+ Bucket->Request.RequestNotifyObject = Complete;
+ Bucket->Request.RequestContext = Context;
+ InsertHeadList( &Listener->ListenRequest, &Bucket->Entry );
+ } else
+ Status = STATUS_NO_MEMORY;
}
TcpipRecursiveMutexLeave( &TCPLock );
IPSendDatagram( &Packet, NCE, TCPPacketSendComplete, NULL );
- if( !NT_SUCCESS(NdisStatus) ) return OSK_EINVAL;
- else return 0;
+ return 0;
}
int TCPSleep( void *ClientData, void *token, int priority, char *msg,
TcpipRecursiveMutexEnter( &TCPLock, TRUE );
PoolFreeBuffer( SleepingThread );
- }
+ } else
+ return OSK_ENOBUFS;
+
TI_DbgPrint(DEBUG_TCP,("Waiting finished: %x\n", token));
return 0;
}