15 char *events_list[] = {
"AFD_EVENT_RECEIVE",
16 "AFD_EVENT_OOB_RECEIVE",
18 "AFD_EVENT_DISCONNECT",
23 "AFD_EVENT_CONNECT_FAIL",
25 "AFD_EVENT_GROUP_QOS",
29 for(
i = 0; events_list[
i];
i++ )
38 for(
i = 0;
i < HandleCount;
i++ ) {
48 for(
i = 0;
i < HandleCount;
i++ ) {
64 PIRP Irp = _Irp ? _Irp : Poll->Irp;
75 Irp->IoStatus.Information =
82 (
"Handle(%x): Got %x,%x\n",
114 PollReq =
Irp->AssociatedIrp.SystemBuffer;
141 while ( ListEntry != &DeviceExt->
Polls ) {
143 ListEntry = ListEntry->
Flink;
145 PollReq =
Irp->AssociatedIrp.SystemBuffer;
152 (!OnlyExclusive || (OnlyExclusive && Poll->
Exclusive)) ) {
173 UINT i, Signalled = 0;
187 Irp->IoStatus.Information = 0;
279 if ( !EventSelectInfo ) {
285 EventSelectInfo->
Events));
305 FCB->EventSelectTriggers = EventSelectInfo->
Events;
308 FCB->EventSelectTriggers = 0;
312 if((
FCB->EventSelect) &&
313 (
FCB->PollState & (
FCB->EventSelectTriggers & ~
FCB->EventSelectDisabled)))
376 FCB->EventSelectDisabled |= (
FCB->PollState &
FCB->EventSelectTriggers);
404 return Signalled ? 1 : 0;
430 while( ThePollEnt != &DeviceExt->
Polls ) {
432 PollReq = Poll->
Irp->AssociatedIrp.SystemBuffer;
436 ThePollEnt = ThePollEnt->
Flink;
440 ThePollEnt = ThePollEnt->
Flink;
445 if((
FCB->EventSelect) &&
446 (
FCB->PollState & (
FCB->EventSelectTriggers & ~
FCB->EventSelectDisabled)))
#define KeGetCurrentIrql()
NTSYSAPI VOID NTAPI RtlCopyMemory(VOID UNALIGNED *Destination, CONST VOID UNALIGNED *Source, ULONG Length)
BOOLEAN NTAPI KeSetTimer(IN OUT PKTIMER Timer, IN LARGE_INTEGER DueTime, IN PKDPC Dpc OPTIONAL)
VOID PollReeval(PAFD_DEVICE_EXTENSION DeviceExt, PFILE_OBJECT FileObject)
struct png_info_def **typedef void(__cdecl typeof(png_destroy_read_struct))(struct png_struct_def **
struct _AFD_HANDLE_ AFD_HANDLE
#define UNREFERENCED_PARAMETER(P)
PVOID LockRequest(PIRP Irp, PIO_STACK_LOCATION IrpSp, BOOLEAN Output, KPROCESSOR_MODE *LockMode)
BOOLEAN SocketAcquireStateLock(PAFD_FCB FCB)
VOID NTAPI ObDereferenceObject(IN PVOID Object)
NTSTATUS NTAPI UnlockAndMaybeComplete(PAFD_FCB FCB, NTSTATUS Status, PIRP Irp, UINT Information)
#define InsertTailList(ListHead, Entry)
IoSetCancelRoutine(Irp, CancelRoutine)
LONG NTAPI KeSetEvent(IN PKEVENT Event, IN KPRIORITY Increment, IN BOOLEAN Wait)
VOID KillSelectsForFCB(PAFD_DEVICE_EXTENSION DeviceExt, PFILE_OBJECT FileObject, BOOLEAN OnlyExclusive)
VOID ZeroEvents(PAFD_HANDLE HandleArray, UINT HandleCount)
POBJECT_TYPE ExEventObjectType
NTSTATUS NTAPI AfdEnumEvents(PDEVICE_OBJECT DeviceObject, PIRP Irp, PIO_STACK_LOCATION IrpSp)
struct _AFD_ENUM_NETWORK_EVENTS_INFO * PAFD_ENUM_NETWORK_EVENTS_INFO
FORCEINLINE BOOLEAN RemoveEntryList(_In_ PLIST_ENTRY Entry)
VOID SignalSocket(PAFD_ACTIVE_POLL Poll OPTIONAL, PIRP _Irp OPTIONAL, PAFD_POLL_INFO PollReq, NTSTATUS Status)
GLsizei GLenum const GLvoid GLsizei GLenum GLbyte GLbyte GLbyte GLdouble GLdouble GLdouble GLfloat GLfloat GLfloat GLint GLint GLint GLshort GLshort GLshort GLubyte GLubyte GLubyte GLuint GLuint GLuint GLushort GLushort GLushort GLbyte GLbyte GLbyte GLbyte GLdouble GLdouble GLdouble GLdouble GLfloat GLfloat GLfloat GLfloat GLint GLint GLint GLint GLshort GLshort GLshort GLshort GLubyte GLubyte GLubyte GLubyte GLuint GLuint GLuint GLuint GLushort GLushort GLushort GLushort GLboolean const GLdouble const GLfloat const GLint const GLshort const GLbyte const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLdouble const GLfloat const GLfloat const GLint const GLint const GLshort const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort GLenum GLenum GLenum GLfloat GLenum GLint GLenum GLenum GLenum GLfloat GLenum GLenum GLint GLenum GLfloat GLenum GLint GLint GLushort GLenum GLenum GLfloat GLenum GLenum GLint GLfloat const GLubyte GLenum GLenum GLenum const GLfloat GLenum GLenum const GLint GLenum GLint GLint GLsizei GLsizei GLint GLenum GLenum const GLvoid GLenum GLenum const GLfloat GLenum GLenum const GLint GLenum GLenum const GLdouble GLenum GLenum const GLfloat GLenum GLenum const GLint GLsizei GLuint GLfloat GLuint GLbitfield GLfloat GLint GLuint GLboolean GLenum GLfloat GLenum GLbitfield GLenum GLfloat GLfloat GLint GLint const GLfloat GLenum GLfloat GLfloat GLint GLint GLfloat GLfloat GLint GLint const GLfloat GLint GLfloat GLfloat GLint GLfloat GLfloat GLint GLfloat GLfloat const GLdouble const GLfloat const GLdouble const GLfloat GLint i
#define SET_AFD_HANDLES(x, y)
NTSTATUS NTAPI ObReferenceObjectByHandle(IN HANDLE Handle, IN ACCESS_MASK DesiredAccess, IN POBJECT_TYPE ObjectType, IN KPROCESSOR_MODE AccessMode, OUT PVOID *Object, OUT POBJECT_HANDLE_INFORMATION HandleInformation OPTIONAL)
static VOID CopyBackStatus(PAFD_HANDLE HandleArray, UINT HandleCount)
NTSTATUS(* NTAPI)(IN PFILE_FULL_EA_INFORMATION EaBuffer, IN ULONG EaLength, OUT PULONG ErrorOffset)
#define AFD_DbgPrint(_t_, _x_)
#define TAG_AFD_ACTIVE_POLL
#define IoCompleteRequest
NTSTATUS NTAPI AfdSelect(PDEVICE_OBJECT DeviceObject, PIRP Irp, PIO_STACK_LOCATION IrpSp)
_Inout_ PFILE_OBJECT FileObject
PFLT_MESSAGE_WAITER_QUEUE CONTAINING_RECORD(Csq, DEVICE_EXTENSION, IrpQueue)) -> WaiterQ.mLock) _IRQL_raises_(DISPATCH_LEVEL) VOID NTAPI FltpAcquireMessageWaiterLock(_In_ PIO_CSQ Csq, _Out_ PKIRQL Irql)
#define IO_NETWORK_INCREMENT
struct _AFD_FCB * PAFD_FCB
_In_opt_ PVOID _In_opt_ PVOID SystemArgument1
struct _LIST_ENTRY * Flink
_In_ LARGE_INTEGER _In_opt_ PKDPC Dpc
BOOLEAN NTAPI KeCancelTimer(IN OUT PKTIMER Timer)
#define NT_SUCCESS(StatCode)
VOID UnlockRequest(PIRP Irp, PIO_STACK_LOCATION IrpSp)
#define KeAcquireSpinLock(sl, irql)
ASSERT((InvokeOnSuccess||InvokeOnError||InvokeOnCancel) ?(CompletionRoutine !=NULL) :TRUE)
#define ExAllocatePoolWithTag(hernya, size, tag)
_Requires_lock_held_ Interrupt _Releases_lock_ Interrupt _In_ _IRQL_restores_ KIRQL OldIrql
struct _AFD_EVENT_SELECT_INFO * PAFD_EVENT_SELECT_INFO
_In_opt_ PVOID _In_opt_ PVOID _In_opt_ PVOID SystemArgument2
IN PDEVICE_OBJECT DeviceObject
__drv_aliasesMem FORCEINLINE PIO_STACK_LOCATION IoGetCurrentIrpStackLocation(_In_ PIRP Irp)
NTSTATUS LostSocket(PIRP Irp)
_In_ PIO_STACK_LOCATION IrpSp
#define FIELD_OFFSET(t, f)
#define KeReleaseSpinLock(sl, irql)
PAFD_DEVICE_EXTENSION DeviceExt
#define ExFreePoolWithTag(_P, _T)
static VOID PrintEvents(ULONG Events)
VOID NTAPI KeInitializeDpc(IN PKDPC Dpc, IN PKDEFERRED_ROUTINE DeferredRoutine, IN PVOID DeferredContext)
VOID NTAPI KeClearEvent(IN PKEVENT Event)
VOID UnlockHandles(PAFD_HANDLE HandleArray, UINT HandleCount)
static BOOLEAN UpdatePollWithFCB(PAFD_ACTIVE_POLL Poll, PFILE_OBJECT FileObject)
static KDEFERRED_ROUTINE SelectTimeout
VOID NTAPI KeInitializeTimerEx(OUT PKTIMER Timer, IN TIMER_TYPE Type)
NTSTATUS NTAPI AfdEventSelect(PDEVICE_OBJECT DeviceObject, PIRP Irp, PIO_STACK_LOCATION IrpSp)
NTSTATUS EventStatus[AFD_MAX_EVENTS]
DRIVER_CANCEL AfdCancelHandler
PAFD_HANDLE LockHandles(PAFD_HANDLE HandleArray, UINT HandleCount)
PULONG MinorVersion OPTIONAL
_In_opt_ PVOID DeferredContext