Использование ReadDirectoryChangesW асинхронно в цикле

вариант косвенного использования IOCP

1. создать унаследованный класс / структуру (содержащий) OVERLAPPED (или
   IO_STATUS_BLOCK), счетчик ссылок, дескриптор каталога и данные, которые
   тебе нужно
2. вызов BindIoCompletionCallback (RtlSetIoCompletionCallback) за
   дескриптор каталога, для настройки вашего обратного вызова
3. иметь DoRead() рутина, которую мы впервые вызываем из основного потока
   а затем от обратного вызова
4. в DoRead() перед каждым звонком ReadDirectoryChangesW вызов
   AddRef(); потому что мы передаем ссылку (через OVERLAPPED) нашим
   структура к ядру
5. main (скажем, в GUI-потоке) может продолжать выполнять свою задачу после первоначального вызова
   DoRead()В отличие от варианта APC ему не нужно ждать в аварийном состоянии
6. в обратном вызове мы получили указатель на нашу структуру из унаследованных (содержащих)
   ПЕРЕКРЫВАЕТСЯ. делать какие-либо задачи (processDirectoryChanges) ,если нужно
   продолжить шпионский звонок DoRead() и, наконец, вызвать Release ()
7. если ReadDirectoryChangesW от DoRead() ошибка (в результате не будет обратного вызова) — нам нужен прямой обратный вызов
   с кодом ошибки
8. для остановки мы можем просто закрыть дескриптор каталога — в результате мы получили
   STATUS_NOTIFY_CLEANUP в обратном вызове

==================================

//#define _USE_NT_VERSION_

class SPYDATA :
#ifdef _USE_NT_VERSION_
IO_STATUS_BLOCK
#else
OVERLAPPED
#endif
{
HANDLE _hFile;
LONG _dwRef;
union {
FILE_NOTIFY_INFORMATION _fni;
UCHAR _buf[PAGE_SIZE];
};

void DumpDirectoryChanges()
{
union {
PVOID buf;
PBYTE pb;
PFILE_NOTIFY_INFORMATION pfni;
};

buf = _buf;

for (;;)
{
DbgPrint("%x <%.*S>\n", pfni->Action, pfni->FileNameLength >> 1, pfni->FileName);

ULONG NextEntryOffset = pfni->NextEntryOffset;

if (!NextEntryOffset)
{
break;
}

pb += NextEntryOffset;
}
}

#ifdef _USE_NT_VERSION_
static VOID WINAPI _OvCompRoutine(
_In_    NTSTATUS dwErrorCode,
_In_    ULONG_PTR dwNumberOfBytesTransfered,
_Inout_ PIO_STATUS_BLOCK Iosb
)
{
static_cast<SPYDATA*>(Iosb)->OvCompRoutine(dwErrorCode, (ULONG)dwNumberOfBytesTransfered);
}
#else
static VOID WINAPI _OvCompRoutine(
_In_    DWORD dwErrorCode, // really this is NTSTATUS
_In_    DWORD dwNumberOfBytesTransfered,
_Inout_ LPOVERLAPPED lpOverlapped
)
{
static_cast<SPYDATA*>(lpOverlapped)->OvCompRoutine(dwErrorCode, dwNumberOfBytesTransfered);
}
#endif

VOID OvCompRoutine(NTSTATUS status, DWORD dwNumberOfBytesTransfered)
{
DbgPrint("[%x,%x]\n", status, dwNumberOfBytesTransfered);

if (0 <= status)
{
if (status != STATUS_NOTIFY_CLEANUP)
{
if (dwNumberOfBytesTransfered) DumpDirectoryChanges();
process_list_of_existing_files();// so hard do this here ?!?
DoRead();
}
else
{
DbgPrint("\n---- NOTIFY_CLEANUP -----\n");
}
}

Release();
MyReleaseRundownProtection();
}

~SPYDATA()
{
Cancel();
}

public:

void DoRead()
{
if (MyAcquireRundownProtection())
{
AddRef();
#ifdef _USE_NT_VERSION_
NTSTATUS status = ZwNotifyChangeDirectoryFile(_hFile, 0, 0, this, this, &_fni, sizeof(_buf), FILE_NOTIFY_VALID_MASK, TRUE);
if (NT_ERROR(status))
{
OvCompRoutine(status, 0);
}
#else
if (!ReadDirectoryChangesW(_hFile, _buf, sizeof(_buf), TRUE, FILE_NOTIFY_VALID_MASK, (PDWORD)&InternalHigh, this, 0))
{
OvCompRoutine(RtlGetLastNtStatus(), 0);
}
#endif
}
}

SPYDATA()
{
_hFile = 0;// ! not INVALID_HANDLE_VALUE because use ntapi for open file
_dwRef = 1;
#ifndef _USE_NT_VERSION_
RtlZeroMemory(static_cast<OVERLAPPED*>(this), sizeof(OVERLAPPED));
#endif
}

void AddRef()
{
InterlockedIncrement(&_dwRef);
}

void Release()
{
if (!InterlockedDecrement(&_dwRef))
{
delete this;
}
}

BOOL Create(POBJECT_ATTRIBUTES poa)
{
IO_STATUS_BLOCK iosb;
NTSTATUS status = ZwOpenFile(&_hFile, FILE_GENERIC_READ, poa, &iosb, FILE_SHARE_VALID_FLAGS, FILE_DIRECTORY_FILE);
if (0 <= status)
{
return
#ifdef _USE_NT_VERSION_
0 <= RtlSetIoCompletionCallback(_hFile, _OvCompRoutine, 0);
#else
BindIoCompletionCallback(_hFile, _OvCompRoutine, 0);
#endif
}
return FALSE;
}

void Cancel()
{
if (HANDLE hFile = InterlockedExchangePointer(&_hFile, 0))
{
NtClose(hFile);
}
}
};

void DemoF()
{
if (MyInitializeRundownProtection())
{
STATIC_OBJECT_ATTRIBUTES(oa, "<SOME_DIRECTORY>");

if (SPYDATA* p = new SPYDATA)
{
if (p->Create(&oa))
{
p->DoRead();
}

//++ GUI thread run
MessageBoxW(0, L"wait close program...", L"", MB_OK);
//-- GUI thread end

p->Cancel();

p->Release();
}

MyWaitForRundownProtectionRelease();
}
}