Leaked source code of windows server 2003
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 
 
 

2492 lines
76 KiB

/* ++
Copyright (c) 1999-2000 Microsoft Corporation
Module Name:
SERIOCTL.C
Abstract:
Routines to handle IOCTL_SERIAL_Xxx
Environment:
kernel mode only
Revision History:
07-14-99 Jeff Midkiff (jeffmi)
-- */
#include "wceusbsh.h"
VOID
SerialCompletePendingWaitMasks(
IN PDEVICE_EXTENSION PDevExt
);
VOID
SerialCancelWaitMask(
IN PDEVICE_OBJECT PDevObj,
IN PIRP PIrp
);
//
// Debug spew
//
#if DBG
//
// gets the function code fom an ioctl code, which uses method buffered.
// assumes the device type is serial port
//
#define SERIAL_FNCT_CODE( _ctl_code_ ) ( (_ctl_code_ & 0xFF) >> 2)
//
// debug dumps. no spin lock usage to better simulate free build's run time.
// if these trap in the debugger you know why.
//
#define DBG_DUMP_BAUD_RATE( _PDevExt ) \
{ \
DbgDump(DBG_SERIAL, ("SerialPort.CurrentBaud: %d\n", _PDevExt->SerialPort.CurrentBaud.BaudRate)); \
}
#define DBG_DUMP_LINE_CONTROL( _PDevExt ) \
{ \
DbgDump(DBG_SERIAL, ("SerialPort.LineControl.StopBits : 0x%x\n", _PDevExt->SerialPort.LineControl.StopBits )); \
DbgDump(DBG_SERIAL, ("SerialPort.LineControl.Parity : 0x%x\n", _PDevExt->SerialPort.LineControl.Parity )); \
DbgDump(DBG_SERIAL, ("SerialPort.LineControl.WordLength : 0x%x\n", _PDevExt->SerialPort.LineControl.WordLength )); \
}
#define DBG_DUMP_SERIAL_HANDFLOW( _PDevExt ) \
{ \
DbgDump(DBG_SERIAL, ("SerialPort.HandFlow.ControlHandShake: 0x%x\n", PDevExt->SerialPort.HandFlow.ControlHandShake)); \
DbgDump(DBG_SERIAL, ("SerialPort.HandFlow.FlowReplace: 0x%x\n", PDevExt->SerialPort.HandFlow.FlowReplace)); \
DbgDump(DBG_SERIAL, ("SerialPort.HandFlow.XonLimit: 0x%x\n", PDevExt->SerialPort.HandFlow.XonLimit)); \
DbgDump(DBG_SERIAL, ("SerialPort.HandFlow.XoffLimit: 0x%x\n", PDevExt->SerialPort.HandFlow.XoffLimit)); \
}
#define DBG_DUMP_SERIAL_TIMEOUTS( _PDevExt ) \
{ \
DbgDump(DBG_SERIAL|DBG_TIME, ("SerialPort.Timeouts.ReadIntervalTimeout: %d\n", _PDevExt->SerialPort.Timeouts.ReadIntervalTimeout )); \
DbgDump(DBG_SERIAL|DBG_TIME, ("SerialPort.Timeouts.ReadTotalTimeoutMultiplier: %d\n", _PDevExt->SerialPort.Timeouts.ReadTotalTimeoutMultiplier )); \
DbgDump(DBG_SERIAL|DBG_TIME, ("SerialPort.Timeouts.ReadTotalTimeoutConstant: %d\n", _PDevExt->SerialPort.Timeouts.ReadTotalTimeoutConstant )); \
DbgDump(DBG_SERIAL|DBG_TIME, ("SerialPort.Timeouts.WriteTotalTimeoutMultiplier: %d\n", _PDevExt->SerialPort.Timeouts.WriteTotalTimeoutMultiplier )); \
DbgDump(DBG_SERIAL|DBG_TIME, ("SerialPort.Timeouts.WriteTotalTimeoutConstant: %d\n", _PDevExt->SerialPort.Timeouts.WriteTotalTimeoutConstant )); \
}
#define DBG_DUMP_SERIAL_CHARS( _PDevExt) \
{ \
DbgDump(DBG_SERIAL, ("SerialPort.SpecialChars.EofChar: 0x%x\n", _PDevExt->SerialPort.SpecialChars.EofChar )); \
DbgDump(DBG_SERIAL, ("SerialPort.SpecialChars.ErrorChar: 0x%x\n", _PDevExt->SerialPort.SpecialChars.ErrorChar )); \
DbgDump(DBG_SERIAL, ("SerialPort.SpecialChars.BreakChar: 0x%x\n", _PDevExt->SerialPort.SpecialChars.BreakChar )); \
DbgDump(DBG_SERIAL, ("SerialPort.SpecialChars.EventChar: 0x%x\n", _PDevExt->SerialPort.SpecialChars.EventChar )); \
DbgDump(DBG_SERIAL, ("SerialPort.SpecialChars.XonChar: 0x%x\n", _PDevExt->SerialPort.SpecialChars.XonChar )); \
DbgDump(DBG_SERIAL, ("SerialPort.SpecialChars.XoffChar: 0x%x\n", _PDevExt->SerialPort.SpecialChars.XoffChar )); \
}
#else
#define DBG_DUMP_BAUD_RATE( _PDevExt )
#define DBG_DUMP_LINE_CONTROL( _PDevExt )
#define DBG_DUMP_SERIAL_HANDFLOW( _PDevExt )
#define DBG_DUMP_SERIAL_TIMEOUTS( _PDevExt )
#define DBG_DUMP_SERIAL_CHARS( _PDevExt)
#endif
__inline
NTSTATUS
IoctlSetSerialValue(
IN PDEVICE_EXTENSION PDevExt,
IN PIRP PIrp,
ULONG Size,
IN OUT PVOID PDest
)
{
PIO_STACK_LOCATION pIrpSp;
NTSTATUS status = STATUS_DELETE_PENDING;
ULONG information = Size;
KIRQL oldIrql;
KeAcquireSpinLock(&PDevExt->ControlLock, &oldIrql);
pIrpSp = IoGetCurrentIrpStackLocation(PIrp);
if (pIrpSp->Parameters.DeviceIoControl.InputBufferLength < Size) {
information = 0;
status = STATUS_BUFFER_TOO_SMALL;
DbgDump(DBG_ERR, ("IoctlSetSerialValue: (0x%x)\n", status));
} else {
memcpy( PDest, PIrp->AssociatedIrp.SystemBuffer, Size);
status = STATUS_SUCCESS;
}
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
PIrp->IoStatus.Information = information;
PIrp->IoStatus.Status = status;
return status;
}
__inline
NTSTATUS
IoctlGetSerialValue(
IN PDEVICE_EXTENSION PDevExt,
IN PIRP PIrp,
ULONG Size,
IN PVOID PSrc
)
{
PIO_STACK_LOCATION pIrpSp;
NTSTATUS status = STATUS_DELETE_PENDING;
ULONG information = Size;
KIRQL oldIrql;
KeAcquireSpinLock(&PDevExt->ControlLock, &oldIrql);
pIrpSp = IoGetCurrentIrpStackLocation(PIrp);
if (pIrpSp->Parameters.DeviceIoControl.OutputBufferLength < Size) {
information = 0;
status = STATUS_BUFFER_TOO_SMALL;
DbgDump(DBG_ERR, ("IoctlGetSerialValue: (0x%x)\n", status));
} else {
memcpy( PIrp->AssociatedIrp.SystemBuffer, PSrc, Size );
status = STATUS_SUCCESS;
}
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
PIrp->IoStatus.Information = information;
PIrp->IoStatus.Status = status;
return status;
}
__inline
NTSTATUS
SetBaudRate(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL, (">SetBaudRate(%p)\n", PIrp));
status = IoctlSetSerialValue(PDevExt,
PIrp,
sizeof( PDevExt->SerialPort.CurrentBaud ),
&PDevExt->SerialPort.CurrentBaud );
DBG_DUMP_BAUD_RATE(PDevExt);
DbgDump(DBG_SERIAL, ("<SetBaudRate %x\n", status));
return status;
}
__inline
NTSTATUS
GetBaudRate(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL, (">GetBaudRate(%p)\n", PIrp));
status = IoctlGetSerialValue( PDevExt,
PIrp,
sizeof( PDevExt->SerialPort.CurrentBaud ),
&PDevExt->SerialPort.CurrentBaud);
DBG_DUMP_BAUD_RATE(PDevExt);
DbgDump(DBG_SERIAL, ("<GetBaudRate %x\n", status));
return status;
}
__inline
NTSTATUS
SetLineControl(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL, (">SetLineControl(%p)\n", PIrp));
status = IoctlSetSerialValue( PDevExt,
PIrp,
sizeof(PDevExt->SerialPort.LineControl),
&PDevExt->SerialPort.LineControl);
DBG_DUMP_LINE_CONTROL( PDevExt );
DbgDump(DBG_SERIAL, ("<SetLineControl %x\n",
status));
return status;
}
__inline
NTSTATUS
GetLineControl(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status= STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL, (">GetLineControl(%p)\n", PIrp));
status = IoctlGetSerialValue( PDevExt,
PIrp,
sizeof(PDevExt->SerialPort.LineControl),
&PDevExt->SerialPort.LineControl );
DBG_DUMP_LINE_CONTROL( PDevExt );
DbgDump(DBG_SERIAL, ("<GetLineControl %x\n",
status));
return status;
}
__inline
NTSTATUS
SetTimeouts(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL|DBG_TIME,(">SetTimeouts(%p)\n", PIrp));
status = IoctlSetSerialValue( PDevExt,
PIrp,
sizeof(PDevExt->SerialPort.Timeouts),
&PDevExt->SerialPort.Timeouts);
DBG_DUMP_SERIAL_TIMEOUTS( PDevExt );
DbgDump(DBG_SERIAL|DBG_TIME,("<SetTimeouts %x\n", status));
return status;
}
__inline
NTSTATUS
GetTimeouts(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL|DBG_TIME, (">GetTimeouts(%p)\n", PIrp));
status = IoctlGetSerialValue( PDevExt,
PIrp,
sizeof(PDevExt->SerialPort.Timeouts),
&PDevExt->SerialPort.Timeouts);
DBG_DUMP_SERIAL_TIMEOUTS( PDevExt );
DbgDump(DBG_SERIAL|DBG_TIME, ("<GetTimeouts %x\n", status));
return status;
}
__inline
NTSTATUS
SetSpecialChars(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL, (">SetSpecialChars(%p)\n", PIrp));
status = IoctlSetSerialValue( PDevExt,
PIrp,
sizeof(PDevExt->SerialPort.SpecialChars),
&PDevExt->SerialPort.SpecialChars);
DBG_DUMP_SERIAL_CHARS( PDevExt);
DbgDump(DBG_SERIAL, ("<SetSpecialChars %x\n", status));
return status;
}
__inline
NTSTATUS
GetSpecialChars(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL, (">GetSpecialChars(%p)\n", PIrp));
status = IoctlGetSerialValue( PDevExt,
PIrp,
sizeof(PDevExt->SerialPort.SpecialChars),
&PDevExt->SerialPort.SpecialChars);
DBG_DUMP_SERIAL_CHARS( PDevExt);
DbgDump(DBG_SERIAL, ("<GetSpecialChars %x\n", status));
return status;
}
__inline
NTSTATUS
SetClearDTR(
IN PDEVICE_EXTENSION PDevExt,
IN PIRP Irp,
IN BOOLEAN Set
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
KIRQL irql;
USHORT usState = 0; // DRT/RTS state to send to USB device
USHORT usOldMSR = 0;
USHORT usDeltaMSR = 0;
ULONG ulOldHistoryMask = 0;
ULONG ulOldRS232Lines = 0;
DbgDump(DBG_SERIAL, (">SetClearDTR (%x, %x)\n", PDevExt->DeviceObject, Set));
KeAcquireSpinLock(&PDevExt->ControlLock, &irql);
//
// we queue the user's Irp because this operation may take some time,
// and we only want to hit the USB with one of these requests at a time.
//
if ( NULL != PDevExt->SerialPort.ControlIrp ) {
DbgDump(DBG_WRN, ("SetClearDTR: STATUS_DEVICE_BUSY\n"));
status = STATUS_DEVICE_BUSY;
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
return status;
}
if ( !CanAcceptIoRequests(PDevExt->DeviceObject, FALSE, TRUE) ||
!NT_SUCCESS(AcquireRemoveLock(&PDevExt->RemoveLock, Irp)) )
{
status = STATUS_DELETE_PENDING;
DbgDump(DBG_ERR, ("SetClearDTR: 0x%x\n", status));
KeReleaseSpinLock( &PDevExt->ControlLock, irql);
return status;
}
//
// Queue the Irp.
//
ASSERT( NULL == PDevExt->SerialPort.ControlIrp );
PDevExt->SerialPort.ControlIrp = Irp;
usOldMSR = PDevExt->SerialPort.ModemStatus;
ulOldRS232Lines = PDevExt->SerialPort.RS232Lines;
ulOldHistoryMask = PDevExt->SerialPort.HistoryMask;
if (PDevExt->SerialPort.RS232Lines & SERIAL_RTS_STATE) {
usState |= USB_COMM_RTS;
}
if (Set) {
PDevExt->SerialPort.RS232Lines |= SERIAL_DTR_STATE;
//
// If there is an INT pipe then MSR could get modified
//
PDevExt->SerialPort.ModemStatus |= SERIAL_MSR_DSR | SERIAL_MSR_DCD;
usState |= USB_COMM_DTR;
} else {
PDevExt->SerialPort.RS232Lines &= ~SERIAL_DTR_STATE;
//
// If there is an INT pipe then MSR could get modified
//
PDevExt->SerialPort.ModemStatus &= ~SERIAL_MSR_DSR & ~SERIAL_MSR_DCD;
}
// see what has changed in the MSR
usDeltaMSR = usOldMSR ^ PDevExt->SerialPort.ModemStatus;
if (usDeltaMSR & (SERIAL_MSR_DSR|SERIAL_MSR_DCD)) {
// set delta MSR bits
PDevExt->SerialPort.ModemStatus |= SERIAL_MSR_DDSR | SERIAL_MSR_DDCD;
}
DbgDump(DBG_SERIAL, ("SerialPort.RS232Lines : 0x%x\n", PDevExt->SerialPort.RS232Lines ));
DbgDump(DBG_SERIAL, ("SerialPort.ModemStatus: 0x%x\n", PDevExt->SerialPort.ModemStatus ));
DbgDump(DBG_SERIAL, ("SerialPort.HistoryMask: 0x%x\n", PDevExt->SerialPort.HistoryMask ));
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
//
// set DTR/RTS on the USB device
//
status = UsbClassVendorCommand( PDevExt->DeviceObject,
USB_COMM_SET_CONTROL_LINE_STATE,
usState,
PDevExt->UsbInterfaceNumber,
NULL,
NULL,
FALSE,
WCEUSB_CLASS_COMMAND );
DbgDump(DBG_SERIAL|DBG_READ_LENGTH, ("USB_COMM_SET_CONTROL_LINE_STATE(1, State: 0x%x, Status: 0x%x)\n", usState, status ));
_EzLink:
if ( STATUS_SUCCESS == status ) {
KeAcquireSpinLock(&PDevExt->ControlLock, &irql);
// signal history massk
if ( usDeltaMSR & (SERIAL_MSR_DSR|SERIAL_MSR_DCD) ) {
PDevExt->SerialPort.HistoryMask |= SERIAL_EV_DSR | SERIAL_EV_RLSD;
}
PDevExt->EP0DeviceErrors = 0;
DbgDump(DBG_SERIAL, ("SerialPort.HistoryMask: 0x%x\n", PDevExt->SerialPort.HistoryMask ));
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
} else {
// Ez-link
if ((PDevExt->DeviceDescriptor.idVendor != 0x0547) &&
((PDevExt->DeviceDescriptor.idProduct != 0x2710) && (PDevExt->DeviceDescriptor.idProduct != 0x2720)))
{
// WINCE BUG 19544:
// AS 3.1 does not handle STATUS_TIMEOUT, so will not see a problem.
// A side effect is that it could sit spinning the green light trying to connect forever.
// However, this is a different case from BUG 19544, which is a disconnect problem.
// If we return failure then it will keep pounding us with Set DTR Irps.
// This would be OK if AS would recognize that we disabled the interface, but it won't - see above.
// You only see this bug when you have a flakey device (iPAQ, hung Jornada, etc.) that times out or
// fails to properly handle the command. To prevent the bugcheck 0xCE the choices as of today are:
// a) let it spin and never connect for these bad devices (iPAQ). Fix your firmware.
// b) fix AcvtiveSync
// I prefer both - pending email with COMPAQ (HTC) and ActiveSync. When AS gets their changes in then we need to
// investigate again.
status = STATUS_TIMEOUT;
KeAcquireSpinLock( &PDevExt->ControlLock, &irql);
if ( ++PDevExt->EP0DeviceErrors < MAX_EP0_DEVICE_ERRORS) {
DbgDump(DBG_ERR, ("USB_COMM_SET_CONTROL_LINE_STATE error: 0x%x\n", status ));
//
// The command failed. Reset the old states, propogate status, and disable the device interface.
// This should stop AS 3.1 from pounding us with Set DTR Irps.
// However, AS does not participate in PnP well if we disable the interface
// (see the note in IRP_MN_QUERY_PNP_DEVICE_STATE). Disabeling the
// interface has the desired effect of notifying apps to stop sending us requests and Close the handle.
//
PDevExt->SerialPort.ModemStatus = usOldMSR;
PDevExt->SerialPort.HistoryMask = ulOldHistoryMask;
PDevExt->SerialPort.RS232Lines = ulOldRS232Lines;
KeReleaseSpinLock( &PDevExt->ControlLock, irql);
} else {
DbgDump(DBG_ERR, ("*** UNRECOVERABLE DEVICE ERROR.2: (0x%x, %d) No longer Accepting Requests ***\n", status, PDevExt->EP0DeviceErrors ));
// mark as PNP_DEVICE_FAILED
InterlockedExchange(&PDevExt->AcceptingRequests, FALSE);
KeReleaseSpinLock( &PDevExt->ControlLock, irql);
IoInvalidateDeviceState( PDevExt->PDO );
LogError( NULL,
PDevExt->DeviceObject,
0, 0,
(UCHAR)PDevExt->EP0DeviceErrors,
ERR_NO_DTR,
status,
SERIAL_HARDWARE_FAILURE,
PDevExt->DeviceName.Length + sizeof(WCHAR),
PDevExt->DeviceName.Buffer,
0,
NULL );
}
} else {
DbgDump(DBG_WRN, ("Ez-Link\n" ));
status = STATUS_SUCCESS;
goto _EzLink;
}
}
//
// finally, release any pending serial events
//
ProcessSerialWaits(PDevExt);
//
// DeQueue the user's Irp. It gets completed in the SerialIoctl dispatch
//
KeAcquireSpinLock(&PDevExt->ControlLock, &irql);
ReleaseRemoveLock(&PDevExt->RemoveLock, Irp);
ASSERT( NULL != PDevExt->SerialPort.ControlIrp );
PDevExt->SerialPort.ControlIrp = NULL;
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
DbgDump(DBG_SERIAL, ("<SetClearDTR %x\n", status ));
return status;
}
__inline
NTSTATUS
SetClearRTS(
IN PDEVICE_EXTENSION PDevExt,
IN PIRP Irp,
IN BOOLEAN Set
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
KIRQL irql;
USHORT usState = 0; // DRT/RTS state to send to USB device
USHORT usOldMSR = 0;
USHORT usDeltaMSR = 0;
ULONG ulOldRS232Lines = 0;
ULONG ulOldHistoryMask = 0;
DbgDump(DBG_SERIAL, (">SetClearRTS (%x, %x)\n", PDevExt->DeviceObject, Set));
KeAcquireSpinLock(&PDevExt->ControlLock, &irql);
//
// we queue the user's Irp because this operation may take some time,
// and we only want to hit the USB with one of these requests at a time.
//
if ( NULL != PDevExt->SerialPort.ControlIrp ) {
status = STATUS_DEVICE_BUSY;
DbgDump(DBG_WRN, ("SetClearRTS.1: 0x%x\n", status));
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
return status;
}
if ( !CanAcceptIoRequests(PDevExt->DeviceObject, FALSE, TRUE) ||
!NT_SUCCESS(AcquireRemoveLock(&PDevExt->RemoveLock, Irp)) )
{
status = STATUS_DELETE_PENDING;
DbgDump(DBG_ERR, ("SetClearRTS.2: 0x%x\n", status));
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
return status;
}
//
// Queue the Irp.
//
ASSERT( NULL == PDevExt->SerialPort.ControlIrp );
PDevExt->SerialPort.ControlIrp = Irp;
usOldMSR = PDevExt->SerialPort.ModemStatus;
ulOldRS232Lines = PDevExt->SerialPort.RS232Lines;
ulOldHistoryMask = PDevExt->SerialPort.HistoryMask;
if (PDevExt->SerialPort.RS232Lines & SERIAL_DTR_STATE) {
usState |= USB_COMM_DTR;
}
if (Set) {
PDevExt->SerialPort.RS232Lines |= SERIAL_RTS_STATE;
//
// If there is an INT pipe then MSR could get modified
//
PDevExt->SerialPort.ModemStatus |= SERIAL_MSR_CTS;
usState |= USB_COMM_RTS;
} else {
PDevExt->SerialPort.RS232Lines &= ~SERIAL_RTS_STATE;
//
// If there is an INT pipe then MSR could get modified
//
PDevExt->SerialPort.ModemStatus &= ~SERIAL_MSR_CTS;
}
// see what has changed in the MSR
usDeltaMSR = usOldMSR ^ PDevExt->SerialPort.ModemStatus;
if (usDeltaMSR & SERIAL_MSR_CTS) {
// set delta MSR bits
PDevExt->SerialPort.ModemStatus |= SERIAL_MSR_DCTS;
}
DbgDump(DBG_SERIAL, ("SerialPort.RS232Lines : 0x%x\n", PDevExt->SerialPort.RS232Lines ));
DbgDump(DBG_SERIAL, ("SerialPort.ModemStatus: 0x%x\n", PDevExt->SerialPort.ModemStatus));
DbgDump(DBG_SERIAL, ("SerialPort.HistoryMask: 0x%x\n", PDevExt->SerialPort.HistoryMask ));
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
//
// set DTR/RTS on the USB device
//
status = UsbClassVendorCommand( PDevExt->DeviceObject,
USB_COMM_SET_CONTROL_LINE_STATE,
usState,
PDevExt->UsbInterfaceNumber,
NULL,
NULL,
FALSE,
WCEUSB_CLASS_COMMAND );
DbgDump(DBG_SERIAL|DBG_READ_LENGTH, ("USB_COMM_SET_CONTROL_LINE_STATE(2, State: 0x%x, Status: 0x%x)\n", usState, status ));
_EzLink:
if ( STATUS_SUCCESS == status ) {
KeAcquireSpinLock(&PDevExt->ControlLock, &irql);
// signal history mask
if ( usDeltaMSR & SERIAL_MSR_CTS ) {
PDevExt->SerialPort.HistoryMask |= SERIAL_EV_CTS;
}
PDevExt->EP0DeviceErrors = 0;
DbgDump(DBG_SERIAL, ("SerialPort.HistoryMask: 0x%x\n", PDevExt->SerialPort.HistoryMask ));
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
} else {
// Ez-link
if ((PDevExt->DeviceDescriptor.idVendor != 0x0547) &&
((PDevExt->DeviceDescriptor.idProduct != 0x2710) && (PDevExt->DeviceDescriptor.idProduct != 0x2720)))
{
// AS 3.1 does not handle STATUS_TIMEOUT, so will not see a problem.
// A side effect is that it could sit spinning the green light trying to connect forever.
// However, this is a different case from BUG 19544, which is a disconnect problem.
// If we return failure then it will keep pounding us with Set DTR Irps.
// This would be OK if AS would recognize that we disabled the interface, but it won't - see above.
// You only see this bug when you have a flakey device (iPAQ, hung Jornada, etc.) that times out or
// fails to properly handle the command. To prevent the bugcheck 0xCE the choices as of today are:
// a) let it spin and never connect for these bad devices (iPAQ). Fix your firmware.
// b) fix AcvtiveSync
// I prefer both - pending email with COMPAQ (HTC) and ActiveSync. When AS gets their changes in then we need to
// investigate again.
status = STATUS_TIMEOUT;
KeAcquireSpinLock( &PDevExt->ControlLock, &irql);
TEST_TRAP();
if ( ++PDevExt->EP0DeviceErrors < MAX_EP0_DEVICE_ERRORS) {
DbgDump(DBG_ERR, ("USB_COMM_SET_CONTROL_LINE_STATE error: %x\n", status ));
//
// The command failed. Reset the old states, propogate status, and disable the device interface.
// This should stop AS 3.1 from pounding us with Set DTR Irps.
// However, AS does not participate in PnP well if we disable the interface
// (see the note in IRP_MN_QUERY_PNP_DEVICE_STATE). Disabeling the
// interface has the desired effect of notifying apps to stop sending us requests and Close the handle.
//
PDevExt->SerialPort.ModemStatus = usOldMSR;
PDevExt->SerialPort.RS232Lines = ulOldRS232Lines;
PDevExt->SerialPort.HistoryMask = ulOldHistoryMask;
KeReleaseSpinLock( &PDevExt->ControlLock, irql);
} else {
DbgDump(DBG_ERR, ("*** UNRECOVERABLE DEVICE ERROR.3: (0x%x, %d) No longer Accepting Requests ***\n", status, PDevExt->EP0DeviceErrors ));
// mark as PNP_DEVICE_FAILED
InterlockedExchange(&PDevExt->AcceptingRequests, FALSE);
KeReleaseSpinLock( &PDevExt->ControlLock, irql);
IoInvalidateDeviceState( PDevExt->PDO );
LogError( NULL,
PDevExt->DeviceObject,
0, 0,
(UCHAR)PDevExt->EP0DeviceErrors,
ERR_NO_RTS,
status,
SERIAL_HARDWARE_FAILURE,
PDevExt->DeviceName.Length + sizeof(WCHAR),
PDevExt->DeviceName.Buffer,
0,
NULL );
}
} else {
DbgDump(DBG_WRN, ("Ez-Link\n" ));
status = STATUS_SUCCESS;
goto _EzLink;
}
}
//
// finally, release any pending serial events
//
ProcessSerialWaits(PDevExt);
//
// DeQueue the user's Irp. It gets completed in the SerialIoctl dispatch
//
KeAcquireSpinLock(&PDevExt->ControlLock, &irql);
ReleaseRemoveLock(&PDevExt->RemoveLock, Irp);
ASSERT( NULL != PDevExt->SerialPort.ControlIrp );
PDevExt->SerialPort.ControlIrp = NULL;
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
DbgDump(DBG_SERIAL, ("<SetClearRTS %x\n", status ));
return status;
}
__inline
NTSTATUS
GetDtrRts(
IN PIRP Irp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL, (">GetDtrRts (%p)\n", Irp));
status = IoctlGetSerialValue( PDevExt,
Irp,
sizeof(PDevExt->SerialPort.RS232Lines),
&PDevExt->SerialPort.RS232Lines);
DbgDump(DBG_SERIAL, ("SerialPort.RS232Lines: 0x%x\n", PDevExt->SerialPort.RS232Lines ));
DbgDump(DBG_SERIAL, ("<GetDtrRts %x\n", status));
return status;
}
__inline
NTSTATUS
SerialResetDevice(
IN PDEVICE_EXTENSION PDevExt,
IN PIRP Irp,
IN BOOLEAN ClearDTR
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
BOOLEAN bRelease = TRUE;
KIRQL oldIrql;
DbgDump(DBG_SERIAL, (">SerialResetDevice (%x, %d)\n", PDevExt->DeviceObject, ClearDTR ));
KeAcquireSpinLock(&PDevExt->ControlLock, &oldIrql);
ASSERT_SERIAL_PORT( PDevExt->SerialPort );
PDevExt->SerialPort.SupportedBauds = SERIAL_BAUD_075 | SERIAL_BAUD_110 | SERIAL_BAUD_150
| SERIAL_BAUD_300 | SERIAL_BAUD_600 | SERIAL_BAUD_1200
| SERIAL_BAUD_1800 | SERIAL_BAUD_2400 | SERIAL_BAUD_4800 | SERIAL_BAUD_7200
| SERIAL_BAUD_9600 | SERIAL_BAUD_14400 | SERIAL_BAUD_19200 | SERIAL_BAUD_38400 | SERIAL_BAUD_56K
| SERIAL_BAUD_128K | SERIAL_BAUD_57600 | SERIAL_BAUD_115200 | SERIAL_BAUD_USER;
PDevExt->SerialPort.CurrentBaud.BaudRate = 115200;
PDevExt->SerialPort.LineControl.StopBits = STOP_BIT_1;
PDevExt->SerialPort.LineControl.Parity = NO_PARITY;
PDevExt->SerialPort.LineControl.WordLength = SERIAL_DATABITS_8;
PDevExt->SerialPort.HandFlow.ControlHandShake = 0;
PDevExt->SerialPort.HandFlow.FlowReplace = 0;
PDevExt->SerialPort.HandFlow.XonLimit = 0;
PDevExt->SerialPort.HandFlow.XoffLimit = 0;
RtlZeroMemory( &PDevExt->SerialPort.Timeouts, sizeof(SERIAL_TIMEOUTS) );
RtlZeroMemory( &PDevExt->SerialPort.SpecialChars, sizeof(SERIAL_CHARS) );
PDevExt->SerialPort.RS232Lines = 0;
PDevExt->SerialPort.HistoryMask = 0;
PDevExt->SerialPort.WaitMask = 0;
PDevExt->SerialPort.ModemStatus = 0;
DbgDump(DBG_SERIAL, ("SerialPort.RS232Lines : 0x%x\n", PDevExt->SerialPort.RS232Lines ));
DbgDump(DBG_SERIAL, ("SerialPort.ModemStatus: 0x%x\n", PDevExt->SerialPort.ModemStatus));
DbgDump(DBG_SERIAL, ("SerialPort.HistoryMask: 0x%x\n", PDevExt->SerialPort.HistoryMask));
if ( PDevExt->SerialPort.CurrentWaitMaskIrp ) {
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
bRelease = FALSE;
SerialCompletePendingWaitMasks(PDevExt);
}
//
// drop the RTS/DTR lines on the USB device
//
if (bRelease) {
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
bRelease = FALSE;
}
status = ClearDTR ? SetClearDTR(PDevExt, Irp, FALSE) : STATUS_SUCCESS;
if (bRelease) {
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
}
DBG_DUMP_BAUD_RATE(PDevExt);
DBG_DUMP_LINE_CONTROL(PDevExt);
DBG_DUMP_SERIAL_HANDFLOW(PDevExt);
DBG_DUMP_SERIAL_TIMEOUTS(PDevExt);
DBG_DUMP_SERIAL_CHARS(PDevExt);
DbgDump(DBG_SERIAL, ("<SerialResetDevice %x\n", status));
return status;
}
__inline
NTSTATUS
SetBreak(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt,
USHORT Time
)
{
UNREFERENCED_PARAMETER(PIrp);
UNREFERENCED_PARAMETER(PDevExt);
UNREFERENCED_PARAMETER(Time);
DbgDump(DBG_SERIAL, (">SetBreak(%p)\n", PIrp));
DbgDump(DBG_SERIAL, ("<SetBreak %x\n", STATUS_NOT_SUPPORTED));
return STATUS_NOT_SUPPORTED;
}
__inline
NTSTATUS
SetQueueSize(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
/* ++
IOCTL_SERIAL_SET_QUEUE_SIZE
Operation
Resizes the driver's internal typeahead and input buffers.
The driver can allocate buffers larger than the requested sizes
and can refuse to allocate buffers larger than its capacity.
Input
Parameters.DeviceIoControl.InputBufferLength
indicates the size in bytes (must be >= sizeof(SERIAL_QUEUE_SIZE))
of the buffer at Irp->AssociatedIrp.SystemBuffer, containing the
InSize and OutSize specifications.
Output
None
I/O Status Block
The Information field is set to zero.
The Status field is set to STATUS_SUCCESS or
possibly to STATUS_BUFFER_TOO_SMALL or
STATUS_INSUFFICIENT_RESOURCES if the driver
cannot satisfy the request by allocating more memory.
-- */
{
NTSTATUS status = STATUS_DELETE_PENDING;
UNREFERENCED_PARAMETER(PIrp);
UNREFERENCED_PARAMETER(PDevExt);
DbgDump(DBG_SERIAL, (">SetQueueSize (%p)\n", PIrp));
// we pretend to set this, but don't really care
status = IoctlSetSerialValue(PDevExt,
PIrp,
sizeof(PDevExt->SerialPort.FakeQueueSize ),
&PDevExt->SerialPort.FakeQueueSize );
DbgDump( DBG_SERIAL, ("SerialPort.FakeQueueSize.InSize = 0x%x\n", PDevExt->SerialPort.FakeQueueSize.InSize ));
DbgDump( DBG_SERIAL, ("SerialPort.FakeQueueSize.OutSize = 0x%x\n", PDevExt->SerialPort.FakeQueueSize.OutSize));
DbgDump(DBG_SERIAL, ("DataOutMaxPacketSize = %d\n", PDevExt->WritePipe.MaxPacketSize));
DbgDump(DBG_SERIAL, ("UsbReadBuffSize = %d\n", PDevExt->UsbReadBuffSize ));
#if USE_RING_BUFF
DbgDump(DBG_SERIAL, ("Internal RingBuffer Size: %d\n", PDevExt->RingBuff.Size ));
#endif
DbgDump(DBG_SERIAL, ("<SetQueueSize %x\n", status));
return status;
}
__inline
NTSTATUS
GetWaitMask(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL, (">GetWaitMask (%p)\n", PIrp));
status = IoctlGetSerialValue(PDevExt,
PIrp,
sizeof(PDevExt->SerialPort.WaitMask),
&PDevExt->SerialPort.WaitMask);
DbgDump(DBG_SERIAL, ("Current SerialPort.WaitMask = 0x%x\n", PDevExt->SerialPort.WaitMask));
DbgDump(DBG_SERIAL, ("<GetWaitMask %x\n", status));
return status;
}
__inline
NTSTATUS
SetWaitMask(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
/* ++
IOCTL_SERIAL_SET_WAIT_MASK
Operation
Causes the driver to track the specified events, or,
if the specified value is zero, to complete pending waits.
Input
Parameters.DeviceIoControl.InputBufferLength
indicates the size in bytes (must be >= sizeof(ULONG)) of
the bitmask at Irp->AssociatedIrp.SystemBuffer.
Output
None
I/O Status Block
The Information field is set to zero.
The Status field is set to STATUS_SUCCESS or
possibly to STATUS_PENDING, STATUS_CANCELLED,
STATUS_BUFFER_TOO_SMALL, or STATUS_INVALID_PARAMETER.
-- */
{
PULONG pWaitMask = (PULONG)PIrp->AssociatedIrp.SystemBuffer;
NTSTATUS status = STATUS_DELETE_PENDING;
KIRQL oldIrql;
PIO_STACK_LOCATION pIrpSp;
DbgDump(DBG_SERIAL, (">SetWaitMask (%p)\n", PIrp));
KeAcquireSpinLock(&PDevExt->ControlLock, &oldIrql);
PIrp->IoStatus.Information = 0;
pIrpSp = IoGetCurrentIrpStackLocation(PIrp);
if (pIrpSp->Parameters.DeviceIoControl.InputBufferLength < sizeof(ULONG)) {
status = STATUS_BUFFER_TOO_SMALL;
DbgDump(DBG_ERR, ("SetWaitMask: (0x%x)\n", status));
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
} else {
// make sure it's a valid request
if (*pWaitMask & ~(SERIAL_EV_RXCHAR |
SERIAL_EV_RXFLAG |
SERIAL_EV_TXEMPTY |
SERIAL_EV_CTS |
SERIAL_EV_DSR |
SERIAL_EV_RLSD |
SERIAL_EV_BREAK |
SERIAL_EV_ERR |
SERIAL_EV_RING |
SERIAL_EV_PERR |
SERIAL_EV_RX80FULL |
SERIAL_EV_EVENT1 |
SERIAL_EV_EVENT2) ) {
status = STATUS_INVALID_PARAMETER;
DbgDump(DBG_ERR, ("Invalid WaitMask: (0x%x)\n", *pWaitMask));
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
} else {
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
// force completion of any pending waits
SerialCompletePendingWaitMasks( PDevExt );
KeAcquireSpinLock(&PDevExt->ControlLock, &oldIrql);
PDevExt->SerialPort.HistoryMask = 0; // clear the history mask
PDevExt->SerialPort.WaitMask = *pWaitMask;
//
// for NT RAS
// A value of '0' means clear any pending waits, which should have read
// and cleared the MSR delta bits. The delta bits are the low nibble.
//
if (PDevExt->SerialPort.WaitMask == 0) {
// clear delta bits
PDevExt->SerialPort.ModemStatus &= 0xF0;
}
DbgDump(DBG_SERIAL, ("New SerialPort.WaitMask = 0x%x\n", PDevExt->SerialPort.WaitMask));
DbgDump(DBG_SERIAL, ("SerialPort.RS232Lines = 0x%x\n", PDevExt->SerialPort.RS232Lines ));
DbgDump(DBG_SERIAL, ("SerialPort.ModemStatus = 0x%x\n", PDevExt->SerialPort.ModemStatus));
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
status = STATUS_SUCCESS;
}
}
DbgDump(DBG_SERIAL, ("<SetWaitMask %x\n", status));
return status;
}
VOID
ProcessSerialWaits(
IN PDEVICE_EXTENSION PDevExt
)
{
KIRQL irql;
PULONG pWaitMask;
PIRP pMaskIrp;
BOOLEAN bReleaseNeeded = TRUE;
PERF_ENTRY( PERF_ProcessSerialWaits );
ASSERT(PDevExt);
DbgDump(DBG_SERIAL|DBG_TRACE, (">ProcessSerialWaits\n"));
KeAcquireSpinLock(&PDevExt->ControlLock, &irql);
if ( PDevExt->SerialPort.CurrentWaitMaskIrp ) {
ASSERT_SERIAL_PORT( PDevExt->SerialPort );
if ( PDevExt->SerialPort.WaitMask & PDevExt->SerialPort.HistoryMask) {
DbgDump(DBG_SERIAL, ("Releasing SerialPort.CurrentWaitMaskIrp(%p) with Mask: 0x%x\n",
PDevExt->SerialPort.CurrentWaitMaskIrp, PDevExt->SerialPort.HistoryMask));
pWaitMask = (PULONG)PDevExt->SerialPort.CurrentWaitMaskIrp->AssociatedIrp.SystemBuffer;
*pWaitMask = PDevExt->SerialPort.HistoryMask;
PDevExt->SerialPort.HistoryMask = 0;
pMaskIrp = PDevExt->SerialPort.CurrentWaitMaskIrp;
pMaskIrp->IoStatus.Information = sizeof(ULONG);
pMaskIrp->IoStatus.Status = STATUS_SUCCESS;
PDevExt->SerialPort.CurrentWaitMaskIrp = NULL;
IoSetCancelRoutine(pMaskIrp, NULL);
bReleaseNeeded = FALSE;
ReleaseRemoveLock(&PDevExt->RemoveLock, pMaskIrp);
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
IoCompleteRequest(pMaskIrp, IO_NO_INCREMENT );
} else {
DbgDump(DBG_SERIAL, ("No Serial Events\n" ));
}
} else {
DbgDump(DBG_SERIAL, ("No CurrentWaitMaskIrp\n"));
}
if (bReleaseNeeded) {
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
}
DbgDump(DBG_SERIAL|DBG_TRACE, ("<ProcessSerialWaits\n"));
PERF_EXIT( PERF_ProcessSerialWaits );
return;
}
__inline
NTSTATUS
WaitOnMask(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
/* ++
IOCTL_SERIAL_WAIT_ON_MASK
Operation
Returns information about which events have occurred
among those that the caller was waiting on.
Input
Parameters.DeviceIoControl.OutputBufferLength indicates the
size in bytes (must be >= sizeof(ULONG)) of the buffer.
Output
The driver returns a bitmask with bits set for events that
occurred (or with a value of zero if the preceding
set-waitmask request specified zero) to the buffer at
Irp->AssociatedIrp.SystemBuffer.
I/O Status Block
The Information field is set to sizeof(ULONG) when the
Status field is set to STATUS_SUCCESS. Otherwise,
the Information field is set to zero, and the Status field
can be set to STATUS_PENDING or
STATUS_INVALID_PARAMETER if a wait is already pending.
-- */
{
PULONG pWaitMask = (PULONG)PIrp->AssociatedIrp.SystemBuffer;
PIO_STACK_LOCATION pIrpSp;
NTSTATUS status = STATUS_DELETE_PENDING;
KIRQL oldIrql;
DbgDump(DBG_SERIAL|DBG_TRACE, (">WaitOnMask (%p)\n", PIrp));
KeAcquireSpinLock(&PDevExt->ControlLock, &oldIrql);
if ( !CanAcceptIoRequests(PDevExt->DeviceObject, FALSE, TRUE) ) {
status = STATUS_DELETE_PENDING;
DbgDump(DBG_ERR, ("WaitOnMask: 0x%x\n", status) );
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
return status;
}
status = STATUS_SUCCESS;
PIrp->IoStatus.Information = 0;
pIrpSp = IoGetCurrentIrpStackLocation(PIrp);
if (pIrpSp->Parameters.DeviceIoControl.OutputBufferLength < sizeof(ULONG)) {
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
status = STATUS_BUFFER_TOO_SMALL;
DbgDump(DBG_ERR, ("WaitOnMask: (0x%x)\n", status));
} else {
//
// Fake NULL modem...
//
if ((PDevExt->SerialPort.WaitMask & SERIAL_EV_CTS) && (PDevExt->SerialPort.ModemStatus & SERIAL_MSR_DCTS) ) {
PDevExt->SerialPort.HistoryMask |= SERIAL_EV_CTS;
PDevExt->SerialPort.ModemStatus &= ~SERIAL_MSR_DCTS;
}
if ((PDevExt->SerialPort.WaitMask & SERIAL_EV_DSR) && (PDevExt->SerialPort.ModemStatus & SERIAL_MSR_DDSR) ) {
PDevExt->SerialPort.HistoryMask |= SERIAL_EV_DSR;
PDevExt->SerialPort.ModemStatus &= ~SERIAL_MSR_DDSR;
// make RAS happy
PDevExt->SerialPort.HistoryMask |= SERIAL_EV_RLSD;
PDevExt->SerialPort.ModemStatus &= ~SERIAL_MSR_DDCD;
}
if ((PDevExt->SerialPort.WaitMask & SERIAL_EV_RLSD) && (PDevExt->SerialPort.ModemStatus & SERIAL_MSR_DDCD) ) {
PDevExt->SerialPort.HistoryMask |= SERIAL_EV_RLSD;
PDevExt->SerialPort.ModemStatus &= ~SERIAL_MSR_DDCD;
}
if ((PDevExt->SerialPort.WaitMask & SERIAL_EV_RING) && (PDevExt->SerialPort.ModemStatus & SERIAL_MSR_DRI) ) {
PDevExt->SerialPort.HistoryMask |= SERIAL_EV_RING;
PDevExt->SerialPort.ModemStatus &= ~SERIAL_MSR_DRI;
}
DbgDump(DBG_SERIAL, ("WaitOnMask::SerialPort.ModemStatus: 0x%x\n", PDevExt->SerialPort.ModemStatus ));
DbgDump(DBG_SERIAL, ("WaitOnMask::SerialPort.WaitMask : 0x%x\n", PDevExt->SerialPort.WaitMask ));
DbgDump(DBG_SERIAL, ("WaitOnMask::SerialPort.HistoryMask: 0x%x\n", PDevExt->SerialPort.HistoryMask ));
//
// If we already have an event to report, then just go ahead and return it.
//
if ( PDevExt->SerialPort.HistoryMask ) {
*pWaitMask = PDevExt->SerialPort.HistoryMask;
PDevExt->SerialPort.HistoryMask = 0;
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
PIrp->IoStatus.Information = sizeof(PDevExt->SerialPort.HistoryMask);
// the Irp gets completed by the calling routine
DbgDump(DBG_SERIAL | DBG_EVENTS, ("Returning WatiMask: 0x%08x\n", *pWaitMask));
} else {
//
// we don't have any events yet,
// so queue the input Irp (PIrp)
//
//
// just in case something comes in (Rx/Tx),
// we'll use a while loop to complete any
// pending wait mask Irps.
//
while (PDevExt->SerialPort.CurrentWaitMaskIrp) {
PIRP pOldIrp;
pOldIrp = PDevExt->SerialPort.CurrentWaitMaskIrp;
PDevExt->SerialPort.CurrentWaitMaskIrp = NULL;
pOldIrp->IoStatus.Status = STATUS_SUCCESS;
IoSetCancelRoutine(pOldIrp, NULL);
*pWaitMask = 0;
DbgDump(DBG_SERIAL|DBG_EVENTS|DBG_TRACE, ("Completing maskirp(4) %p\n", pOldIrp));
//
// Release locks, complete request, then reacquire locks
//
ReleaseRemoveLock(&PDevExt->RemoveLock, pOldIrp);
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
IoCompleteRequest(pOldIrp, IO_SERIAL_INCREMENT);
KeAcquireSpinLock(&PDevExt->ControlLock, &oldIrql);
}
//
// Check to see if the input Irp needs to be cancelled
//
if (PIrp->Cancel) {
PIrp->IoStatus.Information = 0;
status = PIrp->IoStatus.Status = STATUS_CANCELLED;
//
// the caller completes the Irp
//
} else {
//
// queue the input Irp as the SerialPort.CurrentWaitMaskIrp
//
DbgDump(DBG_SERIAL | DBG_EVENTS, ("Queuing Irp: %p for WatiMask: 0x%08x\n", PIrp, PDevExt->SerialPort.WaitMask ));
IoSetCancelRoutine( PIrp, SerialCancelWaitMask );
IoMarkIrpPending(PIrp);
status = PIrp->IoStatus.Status = STATUS_PENDING;
ASSERT( NULL == PDevExt->SerialPort.CurrentWaitMaskIrp); // don't want to drop Irps on the floor
PDevExt->SerialPort.CurrentWaitMaskIrp = PIrp;
//
// now the Irp is on our queue,
// so the caller should NOT try to complete it.
//
}
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
} // !SerialPort.HistoryMask
} // pIrpSp->Parameters
DbgDump(DBG_SERIAL, ("<WaitOnMask %x\n", status));
return status;
}
VOID
SerialCompletePendingWaitMasks(
IN PDEVICE_EXTENSION PDevExt
)
/*++
Routine Description:
This function is used to complete the pending SerialPort.WaitMask Irp
due to IOCTL_SERIAL_SET_WAIT_MASK
Arguments:
Return Value:
VOID
--*/
{
KIRQL oldIrql;
PIRP pCurrentMaskIrp = NULL;
ASSERT(PDevExt);
DbgDump(DBG_SERIAL|DBG_TRACE, (">SerialCompletePendingWaitMasks\n"));
KeAcquireSpinLock(&PDevExt->ControlLock, &oldIrql);
ASSERT_SERIAL_PORT( PDevExt->SerialPort );
pCurrentMaskIrp = PDevExt->SerialPort.CurrentWaitMaskIrp;
if (pCurrentMaskIrp) {
pCurrentMaskIrp->IoStatus.Status = STATUS_SUCCESS;
pCurrentMaskIrp->IoStatus.Information = sizeof(PDevExt->SerialPort.HistoryMask);
DbgDump(DBG_SERIAL, ("SerialCompletePendingWaitMasks: %p with 0x%x\n", PDevExt->SerialPort.CurrentWaitMaskIrp, PDevExt->SerialPort.HistoryMask));
*((PULONG)pCurrentMaskIrp->AssociatedIrp.SystemBuffer) = PDevExt->SerialPort.HistoryMask;
PDevExt->SerialPort.HistoryMask = 0;
PDevExt->SerialPort.CurrentWaitMaskIrp = NULL;
IoSetCancelRoutine(pCurrentMaskIrp, NULL);
}
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
// complete the queued SerialPort.WaitMask IRP if needed
if (pCurrentMaskIrp) {
ReleaseRemoveLock(&PDevExt->RemoveLock, pCurrentMaskIrp);
IoCompleteRequest(pCurrentMaskIrp, IO_SERIAL_INCREMENT);
}
DbgDump(DBG_SERIAL|DBG_TRACE, ("<SerialCompletePendingWaitMasks\n"));
return;
}
VOID
SerialCancelWaitMask(
IN PDEVICE_OBJECT PDevObj,
IN PIRP PIrp
)
/*++
Routine Description:
This function is used as a cancel routine for Irps queued due
to IOCTL_SERIAL_WAIT_ON_MASK
Arguments:
PDevObj - Pointer to Device Object
PIrp - Pointer to IRP that is being canceled; must be the same as
the current mask IRP.
Return Value:
VOID
--*/
{
PDEVICE_EXTENSION pDevExt = (PDEVICE_EXTENSION)PDevObj->DeviceExtension;
KIRQL oldIrql;
DbgDump(DBG_SERIAL|DBG_IRP|DBG_CANCEL|DBG_TRACE, (">SerialCancelWaitMask (%p)\n", PIrp));
//
// release ASAP since we queue our own Irps
//
IoReleaseCancelSpinLock(PIrp->CancelIrql);
KeAcquireSpinLock(&pDevExt->ControlLock, &oldIrql);
ASSERT_SERIAL_PORT( pDevExt->SerialPort );
ASSERT(pDevExt->SerialPort.CurrentWaitMaskIrp == PIrp);
PIrp->IoStatus.Status = STATUS_CANCELLED;
PIrp->IoStatus.Information = 0;
pDevExt->SerialPort.CurrentWaitMaskIrp = NULL;
ReleaseRemoveLock(&pDevExt->RemoveLock, PIrp);
KeReleaseSpinLock(&pDevExt->ControlLock, oldIrql);
IoCompleteRequest(PIrp, IO_SERIAL_INCREMENT);
DbgDump(DBG_SERIAL|DBG_IRP|DBG_CANCEL|DBG_TRACE, ("<SerialCancelWaitMask\n"));
return;
}
__inline
NTSTATUS
GetCommStatus(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
/* ++
IOCTL_SERIAL_GET_COMMSTATUS
Operation
Returns general status information, including how many
Errors and HoldReasons have occurred, how much data
is in the driver's buffers as indicated by the AmountInInQueue
and AmountInOutQueue values, and whether EofReceived and
WaitForImmediate are set.
Input
Parameters.DeviceIoControl.OutputBufferLength
indicates the size in bytes of the buffer, which must be
>= sizeof(SERIAL_STATUS).
Output
The driver returns information to the buffer at
Irp->AssociatedIrp.SystemBuffer.
I/O Status Block
The Information field is set to sizeof(SERIAL_STATUS)
when the Status field is set to STATUS_SUCCESS. Otherwise,
the Information field is set to zero and the Status field is set to
STATUS_BUFFER_TOO_SMALL.
-- */
{
PSERIAL_STATUS pSerialStatus = (PSERIAL_STATUS)PIrp->AssociatedIrp.SystemBuffer;
NTSTATUS status = STATUS_DELETE_PENDING;
KIRQL oldIrql;
PIO_STACK_LOCATION pIrpSp;
DbgDump(DBG_SERIAL, (">GetCommStatus (%p)\n", PIrp));
KeAcquireSpinLock(&PDevExt->ControlLock, &oldIrql);
pIrpSp = IoGetCurrentIrpStackLocation(PIrp);
if (pIrpSp->Parameters.DeviceIoControl.OutputBufferLength < sizeof(SERIAL_STATUS)) {
status = STATUS_BUFFER_TOO_SMALL;
PIrp->IoStatus.Information = 0;
DbgDump(DBG_ERR, ("GetCommStatus: (0x%x)\n", status));
} else {
status = STATUS_SUCCESS;
PIrp->IoStatus.Information = sizeof(SERIAL_STATUS);
RtlZeroMemory(pSerialStatus, sizeof(SERIAL_STATUS));
pSerialStatus->Errors = 0;
pSerialStatus->EofReceived = FALSE;
pSerialStatus->WaitForImmediate = 0;
pSerialStatus->HoldReasons = 0;
#if defined (USE_RING_BUFF)
pSerialStatus->AmountInInQueue = PDevExt->RingBuff.CharsInBuff;
#else
pSerialStatus->AmountInInQueue = PDevExt->UsbReadBuffChars;
#endif
pSerialStatus->AmountInOutQueue= PDevExt->SerialPort.CharsInWriteBuf;
DbgDump(DBG_SERIAL, ("AmountInInQueue: %x\n", pSerialStatus->AmountInInQueue ));
DbgDump(DBG_SERIAL, ("AmountInOutQueue: %x\n", pSerialStatus->AmountInOutQueue));
}
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
DbgDump(DBG_SERIAL, ("<GetCommStatus %x\n", status));
return status;
}
__inline
NTSTATUS
GetModemStatus(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL, (">GetModemStatus (%p)\n", PIrp));
// get current MSR
status = IoctlGetSerialValue(PDevExt,
PIrp,
sizeof( PDevExt->SerialPort.ModemStatus ),
&PDevExt->SerialPort.ModemStatus );
DbgDump(DBG_SERIAL, ("<GetModemStatus %x\n", status));
return status;
}
__inline
NTSTATUS
ImmediateChar(
IN PIRP Irp,
IN PDEVICE_OBJECT DeviceObject
)
{
PUCHAR Char = (PUCHAR) Irp->AssociatedIrp.SystemBuffer;
NTSTATUS status = STATUS_SUCCESS;
PIO_STACK_LOCATION IrpStack;
DbgDump(DBG_SERIAL, (">ImmediateChar (%p)\n", Irp));
TEST_TRAP();
Irp->IoStatus.Information = 0;
IrpStack = IoGetCurrentIrpStackLocation(Irp);
if (IrpStack->Parameters.DeviceIoControl.InputBufferLength < sizeof(UCHAR)) {
status = STATUS_BUFFER_TOO_SMALL;
DbgDump(DBG_ERR, ("ImmediateChar: (0x%x)\n", status));
} else {
//
// Fabricate a write irp & send it to our write path.
// We do this because the R/W path depends on receiving an Irp of type
// IRP_MJ_WRITE or IRP_MJ_READ. It would be easier to
// simply say "not supported", but legacy apps depend on this.
//
PIRP pIrp;
KEVENT event;
IO_STATUS_BLOCK ioStatusBlock = {0, 0};
LARGE_INTEGER startingOffset = {0, 0};
PAGED_CODE();
KeInitializeEvent(
&event,
NotificationEvent,
FALSE
);
pIrp = IoBuildSynchronousFsdRequest(
IRP_MJ_WRITE, // MajorFunction,
DeviceObject, // DeviceObject,
&Char, // Buffer,
sizeof(Char), // Length ,
&startingOffset,// StartingOffset,
&event, // Event,
&ioStatusBlock // OUT PIO_STATUS_BLOCK IoStatusBlock
);
if ( !pIrp ) {
status = Irp->IoStatus.Status = STATUS_INSUFFICIENT_RESOURCES;
DbgDump(DBG_ERR, ("IoBuildSynchronousFsdRequest: STATUS_INSUFFICIENT_RESOURCES\n", status));
} else {
status = IoCallDriver( DeviceObject,
pIrp );
if ( STATUS_PENDING == status ) {
KeWaitForSingleObject( &event, Suspended, KernelMode, FALSE, NULL );
}
//
// Propogate Write status.
// Note: the system released the Irp we just created & sent
// when the Write completes.... so don't touch it.
//
status = ioStatusBlock.Status ;
}
}
DbgDump(DBG_SERIAL, ("<ImmediateChar, %x\n", status));
return status;
}
NTSTATUS
SerialPurgeRxClear(
IN PDEVICE_OBJECT PDevObj,
IN BOOLEAN CancelRead
)
{
PDEVICE_EXTENSION pDevExt = PDevObj->DeviceExtension;
NTSTATUS status = STATUS_SUCCESS;
KIRQL irql;
DbgDump( DBG_SERIAL, (">SerialPurgeRxClear:%d\n", CancelRead));
//
// Cancel the USB INT & Read Irps, which effectvely NAKs all packets from the client
// device untill we resubmit it.
//
if ( CancelRead )
{
if (pDevExt->IntIrp)
{
status = CancelUsbInterruptIrp( PDevObj );
}
status = CancelUsbReadIrp( PDevObj );
}
if (STATUS_SUCCESS == status) {
//
// Now, purge the Rx buffer.
//
KeAcquireSpinLock(&pDevExt->ControlLock, &irql);
#if DBG
if ( DebugLevel & (DBG_DUMP_READS|DBG_READ_LENGTH))
{
ULONG i;
#if defined (USE_RING_BUFF)
KdPrint( ("PurgeRxBuff[%d]: ", pDevExt->RingBuff.CharsInBuff ));
for (i = 0; i < pDevExt->RingBuff.CharsInBuff; i++) {
KdPrint(("%02x ", *pDevExt->RingBuff.pHead++ & 0xFF));
}
#else
KdPrint( ("PurgeRxBuff[%d]: ", pDevExt->UsbReadBuffChars ));
for (i = 0; i < pDevExt->UsbReadBuffChars; i++) {
KdPrint(("%02x ", pDevExt->UsbReadBuff[i] & 0xFF));
}
#endif // USE_RING_BUFF
KdPrint(("\n"));
}
#endif // DBG
#if defined (USE_RING_BUFF)
pDevExt->RingBuff.CharsInBuff = 0;
pDevExt->RingBuff.pHead =
pDevExt->RingBuff.pTail =
pDevExt->RingBuff.pBase;
#else // USE_RING_BUFF
pDevExt->UsbReadBuffChars = 0;
pDevExt->UsbReadBuffIndex = 0;
#endif
if ( CancelRead ) {
//
// reset read states
//
InterlockedExchange(&pDevExt->UsbReadState, IRP_STATE_COMPLETE);
InterlockedExchange(&pDevExt->IntState, IRP_STATE_COMPLETE);
}
KeReleaseSpinLock(&pDevExt->ControlLock, irql);
}
DbgDump(DBG_SERIAL, ("<SerialPurgeRxClear:0x%x\n", status ));
return status;
}
__inline
NTSTATUS
Purge(
IN PDEVICE_OBJECT PDevObj,
IN PIRP Irp
)
/* ++
IOCTL_SERIAL_PURGE
Operation
Purges the specified operation(s) or queues: one or more of
the current and all pending writes, the current and all pending
reads, the transmit buffer if one exists, and the receive buffer
if one exists.
Input
Parameters.DeviceIoControl.InputBufferLength indicates the
size in bytes of the buffer at Irp->AssociatedIrp.SystemBuffer,
which contains a bitmask of type ULONG, indicating what to purge.
Output
None
I/O Status Block
The Information field is set to zero, and the Status field is set
to STATUS_SUCCESS or possibly to STATUS_PENDING,
STATUS_CANCELLED, or STATUS_INVALID_PARAMETER
-- */
{
PDEVICE_EXTENSION pDevExt = PDevObj->DeviceExtension;
PIO_STACK_LOCATION pIrpStack;
NTSTATUS status = STATUS_DELETE_PENDING;
ULONG ulMask = 0;
KIRQL irql;
PIRP NulllIrp = NULL;
DbgDump(DBG_SERIAL|DBG_IRP, (">Purge (%p)\n", Irp));
KeAcquireSpinLock(&pDevExt->ControlLock, &irql);
Irp->IoStatus.Information = 0;
pIrpStack = IoGetCurrentIrpStackLocation(Irp);
if (!Irp->AssociatedIrp.SystemBuffer ||
pIrpStack->Parameters.DeviceIoControl.InputBufferLength < sizeof(ULONG) ) {
status = STATUS_BUFFER_TOO_SMALL;
DbgDump(DBG_ERR, ("Purge: (0x%x)\n", status));
} else {
ulMask = *((PULONG) Irp->AssociatedIrp.SystemBuffer);
// make sure purge request is valid
if ( (!ulMask) || (ulMask & ( ~( SERIAL_PURGE_TXABORT |
SERIAL_PURGE_RXABORT |
SERIAL_PURGE_TXCLEAR |
SERIAL_PURGE_RXCLEAR)))) {
status = STATUS_INVALID_PARAMETER;
DbgDump(DBG_ERR, ("Purge: (0x%x)\n", status));
} else {
DbgDump(DBG_SERIAL, ("Purge Mask: 0x%x\n", ulMask ));
status = STATUS_SUCCESS;
if ( ulMask & SERIAL_PURGE_RXCLEAR) {
//
// SERIAL_PURGE_RXCLEAR - Implies the receive buffer if exists.
//
DbgDump(DBG_SERIAL|DBG_IRP, ("SERIAL_PURGE_RXCLEAR\n"));
KeReleaseSpinLock(&pDevExt->ControlLock, irql);
status = SerialPurgeRxClear(PDevObj, TRUE);
if ( NT_SUCCESS(status) ) {
if ( !pDevExt->IntPipe.hPipe ) {
DbgDump(DBG_SERIAL, ("kick starting another USB Read\n" ));
status = UsbRead( pDevExt, FALSE );
} else {
DbgDump(DBG_SERIAL, ("kick starting another USB INT Read\n" ));
status = UsbInterruptRead( pDevExt );
}
}
if ( NT_SUCCESS(status) ) {
// should be STATUS_PENDING
status = STATUS_SUCCESS;
}
KeAcquireSpinLock(&pDevExt->ControlLock, &irql);
}
if (ulMask & SERIAL_PURGE_RXABORT) {
//
// SERIAL_PURGE_RXABORT - Implies the current and all pending reads.
//
DbgDump(DBG_SERIAL|DBG_IRP, ("SERIAL_PURGE_RXABORT\n"));
KeReleaseSpinLock(&pDevExt->ControlLock, irql);
// cancel all outstanding USB read requests
//status = CleanUpPacketList( PDevObj, &pDevExt->PendingReadPackets);
// cancel all outstanding user reads
KillAllPendingUserReads( PDevObj,
&pDevExt->UserReadQueue,
&pDevExt->UserReadIrp ); //&NulllIrp );
KeAcquireSpinLock(&pDevExt->ControlLock, &irql);
}
if (ulMask & SERIAL_PURGE_TXCLEAR) {
//
// SERIAL_PURGE_TXCLEAR - Implies the transmit buffer if exists
//
DbgDump(DBG_SERIAL|DBG_IRP, ("SERIAL_PURGE_TXCLEAR\n"));
pDevExt->SerialPort.CharsInWriteBuf = 0;
}
if (ulMask & SERIAL_PURGE_TXABORT) {
//
// SERIAL_PURGE_TXABORT - Implies the current and all pending writes.
//
DbgDump(DBG_SERIAL|DBG_IRP, ("SERIAL_PURGE_TXABORT\n"));
KeReleaseSpinLock(&pDevExt->ControlLock, irql);
//
// We don't queue write Irps, rather write packets.
// So, cancel all outstanding write requests
//
status = CleanUpPacketList( PDevObj,
&pDevExt->PendingWritePackets,
&pDevExt->PendingDataOutEvent
);
KeAcquireSpinLock(&pDevExt->ControlLock, &irql);
}
}
}
KeReleaseSpinLock(&pDevExt->ControlLock, irql);
DbgDump(DBG_SERIAL|DBG_IRP, ("<Purge %x\n", status));
return status;
}
__inline
NTSTATUS
GetHandflow(
IN PIRP Irp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL, (">GetHandFlow (%p)\n", Irp));
status = IoctlGetSerialValue(PDevExt,
Irp,
sizeof( PDevExt->SerialPort.HandFlow ),
&PDevExt->SerialPort.HandFlow);
DBG_DUMP_SERIAL_HANDFLOW( PDevExt );
DbgDump(DBG_SERIAL, ("<GetHandFlow %x\n", status));
return status;
}
__inline
NTSTATUS
SetHandflow(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status= STATUS_DELETE_PENDING;
DbgDump(DBG_SERIAL, (">SetHandFlow(%p)\n", PIrp));
status = IoctlSetSerialValue( PDevExt,
PIrp,
sizeof( PDevExt->SerialPort.HandFlow ),
&PDevExt->SerialPort.HandFlow);
DBG_DUMP_SERIAL_HANDFLOW( PDevExt );
DbgDump(DBG_SERIAL, ("<SetHandFlow %x\n", status));
return status;
}
NTSTATUS
GetProperties(
IN PIRP Irp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
PSERIAL_COMMPROP Properties;
PIO_STACK_LOCATION IrpStack;
KIRQL oldIrql;
DbgDump(DBG_SERIAL, (">GetProperties (%p)\n", Irp));
KeAcquireSpinLock(&PDevExt->ControlLock, &oldIrql);
IrpStack = IoGetCurrentIrpStackLocation(Irp);
if (IrpStack->Parameters.DeviceIoControl.OutputBufferLength < sizeof(SERIAL_COMMPROP)) {
status = STATUS_BUFFER_TOO_SMALL;
DbgDump(DBG_ERR, ("GetProperties: (0x%x)\n", status));
} else {
Properties = (PSERIAL_COMMPROP)Irp->AssociatedIrp.SystemBuffer;
RtlZeroMemory(Properties, sizeof(SERIAL_COMMPROP));
Properties->PacketLength = sizeof(SERIAL_COMMPROP);
Properties->PacketVersion = 2;
Properties->ServiceMask = SERIAL_SP_SERIALCOMM;
// internal limits
Properties->MaxTxQueue = DEFAULT_PIPE_MAX_TRANSFER_SIZE;
#if defined (USE_RING_BUFF)
Properties->MaxRxQueue = PDevExt->RingBuff.Size;
#else
Properties->MaxRxQueue = PDevExt->UsbReadBuffSize;
#endif
Properties->MaxBaud = SERIAL_BAUD_USER; // SERIAL_BAUD_115200;
Properties->SettableBaud = PDevExt->SerialPort.SupportedBauds;
Properties->ProvSubType = SERIAL_SP_UNSPECIFIED; // SERIAL_SP_RS232;
Properties->ProvCapabilities = SERIAL_PCF_DTRDSR | SERIAL_PCF_RTSCTS
| SERIAL_PCF_CD | SERIAL_PCF_XONXOFF
| SERIAL_PCF_TOTALTIMEOUTS | SERIAL_PCF_INTTIMEOUTS
| SERIAL_PCF_SPECIALCHARS;
Properties->SettableParams = SERIAL_SP_BAUD | SERIAL_SP_CARRIER_DETECT;
Properties->SettableData = SERIAL_DATABITS_8;
Properties->SettableStopParity = SERIAL_STOPBITS_10 | SERIAL_STOPBITS_20
| SERIAL_PARITY_NONE | SERIAL_PARITY_ODD
| SERIAL_PARITY_EVEN | SERIAL_PARITY_MARK
| SERIAL_PARITY_SPACE;
#if defined (USE_RING_BUFF)
Properties->CurrentRxQueue = PDevExt->RingBuff.Size;
#else
Properties->CurrentRxQueue = PDevExt->UsbReadBuffSize;
Properties->CurrentTxQueue = PDevExt->ReadPipe.MaxPacketSize;
#endif
status = STATUS_SUCCESS;
}
KeReleaseSpinLock(&PDevExt->ControlLock, oldIrql);
if (STATUS_SUCCESS == status) {
Irp->IoStatus.Information = sizeof(SERIAL_COMMPROP);
} else {
Irp->IoStatus.Information = 0;
}
DbgDump(DBG_SERIAL, ("<GetProperties %x\n", status));
return status;
}
__inline
NTSTATUS
LsrmstInsert(
IN PIRP Irp,
IN PDEVICE_EXTENSION PDevExt
)
{
UNREFERENCED_PARAMETER( Irp );
UNREFERENCED_PARAMETER( PDevExt );
DbgDump(DBG_SERIAL, (">LsrmstInsert (%p)\n", Irp));
DbgDump(DBG_SERIAL, ("<LsrmstInsert (%x)\n", STATUS_NOT_SUPPORTED));
return STATUS_NOT_SUPPORTED;
}
__inline
NTSTATUS
ConfigSize(
IN PIRP Irp,
IN PDEVICE_EXTENSION PDevExt
)
{
PULONG ConfigSize = (PULONG) Irp->AssociatedIrp.SystemBuffer;
NTSTATUS status = STATUS_SUCCESS;
PIO_STACK_LOCATION IrpStack;
UNREFERENCED_PARAMETER( PDevExt );
DbgDump(DBG_SERIAL, (">ConfigSize (%p)\n", Irp));
Irp->IoStatus.Information = 0;
IrpStack = IoGetCurrentIrpStackLocation(Irp);
if (IrpStack->Parameters.DeviceIoControl.OutputBufferLength < sizeof(ULONG)) {
status = STATUS_BUFFER_TOO_SMALL;
DbgDump(DBG_ERR, ("ConfigSize: (0x%x)\n", status));
} else {
*ConfigSize = 0;
Irp->IoStatus.Information = sizeof(ULONG);
}
DbgDump(DBG_SERIAL, ("<ConfigSize %x\n", status));
return status;
}
__inline
NTSTATUS
GetStats(
IN PIRP PIrp,
IN PDEVICE_EXTENSION PDevExt
)
{
PSERIALPERF_STATS pStats = NULL;
PIO_STACK_LOCATION pIrpSp;
NTSTATUS status = STATUS_DELETE_PENDING;
ULONG information = 0;
KIRQL irql;
DbgDump(DBG_SERIAL, (">GetStats %p\n", PIrp));
KeAcquireSpinLock(&PDevExt->ControlLock, &irql );
pIrpSp = IoGetCurrentIrpStackLocation(PIrp);
if (pIrpSp->Parameters.DeviceIoControl.OutputBufferLength < sizeof(SERIALPERF_STATS) ) {
status = STATUS_BUFFER_TOO_SMALL;
DbgDump(DBG_ERR, ("GetStats: (0x%x)\n", status));
} else {
information = sizeof(SERIALPERF_STATS);
status = STATUS_SUCCESS;
pStats = (PSERIALPERF_STATS)PIrp->AssociatedIrp.SystemBuffer;
RtlZeroMemory(pStats , sizeof(SERIALPERF_STATS));
pStats->ReceivedCount = PDevExt->TtlUSBReadBytes;
pStats->TransmittedCount = PDevExt->TtlWriteBytes;
pStats->FrameErrorCount = PDevExt->ReadDeviceErrors + PDevExt->WriteDeviceErrors + PDevExt->IntDeviceErrors; // ??
pStats->SerialOverrunErrorCount = PDevExt->TtlUSBReadBuffOverruns;
#if defined (USE_RING_BUFF)
pStats->BufferOverrunErrorCount = PDevExt->TtlRingBuffOverruns;
#else
pStats->BufferOverrunErrorCount = 0;
#endif
pStats->ParityErrorCount = 0;
DbgDump(DBG_SERIAL, ("ReceivedCount: %d\n", pStats->ReceivedCount )); \
DbgDump(DBG_SERIAL, ("TransmittedCount: %d\n", pStats->TransmittedCount )); \
DbgDump(DBG_SERIAL, ("FrameErrorCount: %d\n", pStats->FrameErrorCount )); \
DbgDump(DBG_SERIAL, ("SerialOverrunErrorCount: %d\n", pStats->SerialOverrunErrorCount )); \
DbgDump(DBG_SERIAL, ("BufferOverrunErrorCount: %d\n", pStats->BufferOverrunErrorCount )); \
DbgDump(DBG_SERIAL, ("ParityErrorCount: %d\n", pStats->ParityErrorCount )); \
}
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
PIrp->IoStatus.Information = information;
PIrp->IoStatus.Status = status;
DbgDump(DBG_SERIAL, ("<GetStats %x\n", status));
return status;
}
NTSTATUS
ClearStats(
IN PIRP Irp,
IN PDEVICE_EXTENSION PDevExt
)
{
NTSTATUS status = STATUS_DELETE_PENDING;
KIRQL irql;
DbgDump(DBG_SERIAL, (">ClearStats (%p)\n", Irp));
KeAcquireSpinLock(&PDevExt->ControlLock, &irql);
PDevExt->TtlWriteRequests = 0;
PDevExt->TtlWriteBytes = 0;
PDevExt->TtlReadRequests = 0;
PDevExt->TtlReadBytes = 0;
PDevExt->TtlUSBReadRequests = 0;
PDevExt->TtlUSBReadBytes = 0;
PDevExt->TtlUSBReadBuffOverruns = 0;
#if defined (USE_RING_BUFF)
PDevExt->TtlRingBuffOverruns = 0;
#endif
status = STATUS_SUCCESS;
Irp->IoStatus.Information = 0;
KeReleaseSpinLock(&PDevExt->ControlLock, irql);
DbgDump(DBG_SERIAL, ("<ClearStats %x\n", status));
return status;
}
/*++
Note: Unhandled IOCTL_SERIAL_: 0x2b002c : function code 11 is IOCTL_MODEM_CHECK_FOR_MODEM,
which if unhandled tells the system to load modem.sys over this serial port driver.
This is setup by RAS & unimodem.
--*/
NTSTATUS
SerialIoctl(
PDEVICE_OBJECT PDevObj,
PIRP PIrp
)
{
PDEVICE_EXTENSION pDevExt = (PDEVICE_EXTENSION)PDevObj->DeviceExtension;
PIO_STACK_LOCATION pIrpSp = IoGetCurrentIrpStackLocation(PIrp);
ULONG ioctl = pIrpSp->Parameters.DeviceIoControl.IoControlCode;
NTSTATUS status = STATUS_NOT_SUPPORTED;
BOOLEAN bSignalNeeded = FALSE;
KIRQL irql;
LONG lSanity = 0;
DbgDump(DBG_SERIAL|DBG_TRACE, (">SerialIoctl(%p)\n", PIrp));
do {
KeAcquireSpinLock(&pDevExt->ControlLock, &irql);
//
// Make sure the device is accepting request
//
if ( !CanAcceptIoRequests( PDevObj, FALSE, TRUE) ||
!NT_SUCCESS(AcquireRemoveLock(&pDevExt->RemoveLock, PIrp)) )
{
status = STATUS_DELETE_PENDING;
DbgDump(DBG_WRN, ("SerialIoctl: 0x%x, 0x%x\n", ioctl, status));
PIrp->IoStatus.Status = status;
KeReleaseSpinLock(&pDevExt->ControlLock, irql);
IoCompleteRequest(PIrp, IO_NO_INCREMENT);
return status;
}
ASSERT_SERIAL_PORT( pDevExt->SerialPort );
KeReleaseSpinLock(&pDevExt->ControlLock, irql);
switch (ioctl)
{
case IOCTL_SERIAL_SET_BAUD_RATE:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_SET_BAUD_RATE\n"));
status = SetBaudRate(PIrp, pDevExt);
break;
case IOCTL_SERIAL_GET_BAUD_RATE:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_GET_BAUD_RATE\n"));
status = GetBaudRate(PIrp, pDevExt);
break;
case IOCTL_SERIAL_SET_LINE_CONTROL:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_SET_LINE_CONTROL\n"));
status = SetLineControl(PIrp, pDevExt);
break;
case IOCTL_SERIAL_GET_LINE_CONTROL:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_GET_LINE_CONTROL\n"));
status = GetLineControl(PIrp, pDevExt);
break;
case IOCTL_SERIAL_SET_TIMEOUTS:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_SET_TIMEOUTS\n"));
status = SetTimeouts(PIrp, pDevExt);
break;
case IOCTL_SERIAL_GET_TIMEOUTS:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_GET_TIMEOUTS\n"));
status = GetTimeouts(PIrp, pDevExt);
break;
case IOCTL_SERIAL_SET_CHARS:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_SET_CHARS\n"));
status = SetSpecialChars(PIrp, pDevExt);
break;
case IOCTL_SERIAL_GET_CHARS:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_GET_CHARS\n"));
status = GetSpecialChars(PIrp, pDevExt);
break;
case IOCTL_SERIAL_SET_DTR:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_SET_DTR\n"));
status = SetClearDTR(pDevExt, PIrp, TRUE);
break;
case IOCTL_SERIAL_CLR_DTR:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_CLR_DTR\n"));
status = SetClearDTR(pDevExt, PIrp, FALSE);
break;
case IOCTL_SERIAL_SET_RTS:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_SET_RTS\n"));
status = SetClearRTS(pDevExt, PIrp, TRUE);
break;
case IOCTL_SERIAL_CLR_RTS:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_CLR_RTS\n"));
status = SetClearRTS(pDevExt, PIrp, FALSE);
break;
case IOCTL_SERIAL_GET_DTRRTS:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_GET_DTRRTS\n"));
status = GetDtrRts(PIrp, pDevExt);
break;
case IOCTL_SERIAL_SET_BREAK_ON:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_SET_BREAK_ON\n"));
status = SetBreak(PIrp, pDevExt, 0xFFFF);
break;
case IOCTL_SERIAL_SET_BREAK_OFF:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_SET_BREAK_OFF\n"));
status = SetBreak(PIrp, pDevExt, 0);
break;
case IOCTL_SERIAL_SET_QUEUE_SIZE:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_SET_QUEUE_SIZE\n"));
status = SetQueueSize(PIrp, pDevExt);
break;
case IOCTL_SERIAL_GET_WAIT_MASK:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_GET_WAIT_MASK\n"));
status = GetWaitMask(PIrp, pDevExt);
break;
case IOCTL_SERIAL_SET_WAIT_MASK:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_SET_WAIT_MASK\n"));
status = SetWaitMask(PIrp, pDevExt);
break;
case IOCTL_SERIAL_WAIT_ON_MASK:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_WAIT_ON_MASK\n"));
status = WaitOnMask(PIrp, pDevExt);
break;
case IOCTL_SERIAL_GET_MODEMSTATUS:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_GET_MODEMSTATUS\n"));
status = GetModemStatus(PIrp, pDevExt);
break;
case IOCTL_SERIAL_GET_COMMSTATUS:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_GET_COMMSTATUS\n"));
status = GetCommStatus(PIrp, pDevExt);
break;
case IOCTL_SERIAL_IMMEDIATE_CHAR:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_IMMEDIATE_CHAR\n"));
status = ImmediateChar(PIrp, PDevObj);
break;
case IOCTL_SERIAL_PURGE:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_PURGE\n"));
status = Purge(PDevObj, PIrp);
break;
case IOCTL_SERIAL_GET_HANDFLOW:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_GET_HANDFLOW\n"));
status = GetHandflow(PIrp, pDevExt);
break;
case IOCTL_SERIAL_SET_HANDFLOW:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_SET_HANDFLOW\n"));
status = SetHandflow(PIrp, pDevExt);
break;
case IOCTL_SERIAL_RESET_DEVICE:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_RESET_DEVICE\n"));
status = SerialResetDevice(pDevExt, PIrp, TRUE);
break;
case IOCTL_SERIAL_LSRMST_INSERT:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_LSRMST_INSERT\n"));
status = LsrmstInsert(PIrp, pDevExt);
break;
case IOCTL_SERIAL_CONFIG_SIZE:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_CONFIG_SIZE\n"));
status = ConfigSize(PIrp, pDevExt);
break;
case IOCTL_SERIAL_GET_STATS:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_GET_STATS\n"));
status = GetStats(PIrp, pDevExt);
break;
case IOCTL_SERIAL_CLEAR_STATS:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_CLEAR_STATS\n"));
status = ClearStats(PIrp, pDevExt);
break;
case IOCTL_SERIAL_GET_PROPERTIES:
DbgDump(DBG_SERIAL, ("IOCTL_SERIAL_GET_PROPERTIES\n"));
status = GetProperties(PIrp, pDevExt);
break;
default:
DbgDump(DBG_WRN, ("Unhandled IOCTL_SERIAL_: 0x%x : function code %d\n",
ioctl, SERIAL_FNCT_CODE(ioctl) ) );
status = STATUS_NOT_SUPPORTED;
break;
}
} while (0);
//
// Don't complete any pending Irps
//
if ( STATUS_PENDING != status) {
PIrp->IoStatus.Status = status;
ReleaseRemoveLock(&pDevExt->RemoveLock, PIrp);
IoCompleteRequest(PIrp, IO_SERIAL_INCREMENT);
}
#ifdef DELAY_RXBUFF
//
// Special Case: the device was just opened.
// To emulate a serial port RX buffer we need to kick start a USB read.
// We don't want to do this in the IRP_MJ_CREATE code since AS does
// IOCTL_SERIAL_SET_WAIT_MASK then *two* IOCTL_SERIAL_SET_DTR requests. If we start the USB read
// too soon then the CE device can get confused with a Read then SetDTR requests.
// So, if we were just opened, and we have seen *one* successful IOCTL_SERIAL_SET_DTR then start our USB read.
// Two good DTRs works better, but we'll let one slip for a timeout or something to recover, e.g. iPAQ on NEC E13+.
// This may cause problems with other apps, but our target is ActiveSync. We could add a magic registry flag is required.
// This means that outside of the initial get/set descriptors/configuration the USB is quiet until
// an app opens the device for I/O... which is a good thing.
// However, this implementation causes the initial connect to a bit too slow for slow devices (e.g., HP Jornada, Cassiopeia).
//
if ( pDevExt->StartUsbRead && (IOCTL_SERIAL_SET_DTR == ioctl) && (STATUS_SUCCESS == status))
{
if ( 0 == InterlockedDecrement(&pDevExt->StartUsbRead))
{
if ( !pDevExt->IntPipe.hPipe ) {
DbgDump(DBG_SERIAL, ("SerialIoctl: kick starting another USB Read\n" ));
status = UsbRead( pDevExt, FALSE );
} else {
DbgDump(DBG_SERIAL, ("SerialIoctl: kick starting another USB INT Read\n" ));
status = UsbInterruptRead( pDevExt );
}
if ( NT_SUCCESS(status) ) {
// should be STATUS_PENDING
status = STATUS_SUCCESS;
} else {
InterlockedIncrement(&pDevExt->StartUsbRead);
}
}
}
#endif
DbgDump(DBG_SERIAL|DBG_TRACE, ("<SerialIoctl: %p, 0x%x\n", PIrp, status));
return status;
}
// EOF