崩溃使用ReadDirectoryChangesW

Question

时，这是所谓的JNotify一个开源项目的一部分。我试图修复Win32实现，这真的让我疯狂。我已经阅读了MSDN中关于此的所有内容，并阅读了每篇关于这个糟糕的API的文章。 我正尝试使用ReadDirectoryChangesW在窗口上使用完成端口接收文件系统通知。

我看到的行为是，通常它的工作原理，但有些时候缓冲区我收到的时候则GetQueuedCompletionStatus返回以奇怪的方式被破坏。 eitehr FILE_NOTIFY_INFORMATION.NextEntryOffset指向自身（导致无限循环），或者其他出错，并且我收到伪造文件名称长度。 这只发生，如果我重新观看目录，从来没有在第一个事件（但重新观看的需要，否则你只能得到该目录的一个事件）。

的测试代码崩溃每一件事情是微不足道的，它只是看多显示目录和每个目录下创建两个文件。

这里是一些相关的代码，我可以添加所有的，如果你想（整个事情是不是太大），但感觉太大了这里的问题。

这段代码创建完成端口，它只能运行一次 - 然后我用这个完成端口的所有目录。

_completionPort = CreateIoCompletionPort(INVALID_HANDLE_VALUE, NULL, 0, 1); 

这是WatchData构造函数，它实际上打开目录句柄并将其与完成端口相关联。

WatchData::WatchData(const WCHAR* path, int mask, bool watchSubtree, HANDLE completionPort) 
    : 
    _watchId(++_counter), 
    _mask(mask), 
    _watchSubtree(watchSubtree), 
    _byteReturned(0), 
    _completionPort(completionPort) 
{ 
    _path = _wcsdup(path); 
    _hDir = CreateFileW(_path, 
         FILE_LIST_DIRECTORY | GENERIC_READ | GENERIC_WRITE, 
         FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE, 
         NULL, //security attributes 
         OPEN_EXISTING, 
         FILE_FLAG_BACKUP_SEMANTICS | FILE_FLAG_OVERLAPPED, NULL); 
    if(_hDir == INVALID_HANDLE_VALUE) 
    { 
     throw GetLastError(); 
    } 

    if (NULL == CreateIoCompletionPort(_hDir, _completionPort, (ULONG_PTR)&_watchId, 0)) 
    { 
     throw GetLastError(); 
    } 
} 

这是运行的代码（握奇数据对象中），当我开始观看目录：

int WatchData::watchDirectory() 
{ 
    printf("(Re)watching %ls\n", _path); 
    memset(_buffer, 0, sizeof(_buffer)); 
    memset(&_overLapped, 0, sizeof(_overLapped)); 
    if(!ReadDirectoryChangesW(_hDir, 
           _buffer,//<--FILE_NOTIFY_INFORMATION records are put into this buffer 
           sizeof(_buffer), 
           _watchSubtree, 
           _mask, 
           &_byteReturned, 
           &_overLapped, 
           NULL)) 



    { 
     return GetLastError(); 
    } 
    else 
    { 
     return 0; 
    } 
} 

这是在它自己的线程中运行，处理完成事件的主循环。 请注意，“这应该不会发生”，它实际上发生了很多。

DWORD WINAPI Win32FSHook::mainLoop(LPVOID lpParam) 
{ 
    debug("mainLoop starts"); 
    Win32FSHook* _this = (Win32FSHook*)lpParam; 

    HANDLE hPort = _this->_completionPort; 
    DWORD dwNoOfBytes = 0; 
    ULONG_PTR ulKey = 0; 
    OVERLAPPED* pov = NULL; 
    WCHAR name[1024]; 

    while (_this->_isRunning) 
    { 
     pov = NULL; 
     BOOL fSuccess = GetQueuedCompletionStatus(
         hPort,   // Completion port handle 
         &dwNoOfBytes, // Bytes transferred 
         &ulKey, 
         &pov,   // OVERLAPPED structure 
         INFINITE  // Notification time-out interval 
         ); 
     if (fSuccess) 
     { 
      if (dwNoOfBytes == 0) 
      { 
       // can happen after a watch is removed 
       continue; 
      } 
      int wd = *(int*)ulKey; 
      EnterCriticalSection(&_this->_cSection); 
      WatchData *watchData = _this->find(wd); 
      if (!watchData) 
      { 
       log("mainLoop : ignoring event for watch id %d, no longer in wid2WatchData map", wd); 
       LeaveCriticalSection(&_this->_cSection); 
       continue; 
      } 

      //const char* buffer = watchData->getBuffer(); 
      char buffer[watchData->getBufferSize()]; 
      memcpy(buffer, watchData->getBuffer(), watchData->getBufferSize()); 
      LeaveCriticalSection(&_this->_cSection); 
      FILE_NOTIFY_INFORMATION *event; 
      DWORD i=0; 
      do 
      { 
       event = (FILE_NOTIFY_INFORMATION*)(buffer+i); 
       int action = event->Action; 
       DWORD len = event->FileNameLength/sizeof(WCHAR); 
       for (DWORD k=0;k<len && k < (sizeof(name)-sizeof(WCHAR))/sizeof(WCHAR);k++) 
       { 
        name[k] = event->FileName[k]; 
       } 
       name[len] = 0; 

       _this->_callback(watchData->getId(), action, watchData->getPath(), name); 

       if (i != 0 && event->NextEntryOffset == i) 
       { 
        log("should not happen!"); 
        break; 
       } 

       i = event->NextEntryOffset; 
      } 
      while (i != 0); 

      int res = watchData->watchDirectory(); 
      if (res != 0) 
      { 
       log("Error watching dir %s : %d",watchData->getPath(), res); 
      } 
     } 
     else 
     { 
      log("GetQueuedCompletionStatus returned an error"); 
     } 
    } 
    debug("mainLoop exits"); 
    return 0; 
} 

Answer 1

我很确定NextEntryOffset是相对于当前记录而不是第一条记录。

... 
char* current = buffer; 
do 
{ 
    event = (FILE_NOTIFY_INFORMATION*)current; 
    ... 
    i = event->NextEntryOffset; 
    current += i; 
} 
while (i != 0); 
...