0

我有一个应用程序，用于监视目录中的文件/目录更改。但是，此目录还包含symlinks其他目录（可访问）。但是，当我file在目录中修改 a 时，不会触发symlink通知。例如，当我监控时：Root

--Root
  --Dir
    --File1 //Trigger works
  --SDir(Symlink dir)
    --File2 //Trigger won't work

但是，当我监视时Root/SDir，这是符号链接目录，而不是 File2 上的触发器正常工作。例如：

--SDir
  --File2 //Trigger works

因此，当symlink directory不是根目录时，它不会触发该目录中的文件更改。但是，当我将其设置symlink directory为根时，它工作正常。是的， 中的bWatchSubtree参数ReadDirectoryChangesW-function设置为true。

CreateFile为了良好的顺序，我使用以下函数打开目录句柄：

CreateFile(
    Dir, //Root or Root/SDir in this example
    FILE_LIST_DIRECTORY,
    FILE_SHARE_WRITE | FILE_SHARE_READ | FILE_SHARE_DELETE,
    NULL,
    OPEN_EXISTING,
    FILE_FLAG_BACKUP_SEMANTICS,
    NULL);

那么，如果相同的符号链接不是 symlink 的根，为什么触发器不会对符号链接中的文件起作用ReadDirectoryChangesW？

4

2 回答 2

0

只有当文件夹内的文件发生更改时，文件系统才会向您发送通知。符号链接（或挂载点）这只是文件夹内的文件，它指向另一个文件/文件夹。如果目标文件/目录不在我们的原始文件夹内 - 我们不会收到有关此目标文件夹内更改的通知

当您打开直接符号链接（或挂载点）而没有FILE_FLAG_OPEN_REPARSE_POINT真正打开目标目录（此符号链接到该点）并从该目录获得通知时

从某个文件夹收到通知通常需要下一步：

  • 创建类，它封装文件夹句柄和您需要从此目录处理通知的所有数据（例如它的完整路径等）
  • FILE_FLAG_OVERLAPPED用于进程 ReadDirectoryChangesW异步的打开目录句柄
  • 调用BindIoCompletionCallback打开的句柄 - 结果，当通知来自文件系统时，将调用您的回调。
  • 第一次直接调用ReadDirectoryChangesW ，下一次从回调（通过注册 BindIoCompletionCallback）调用它，直到我们没有得到 ERROR_NOTIFY_CLEANUP
  • 当我们想要停止通知过程时 - 需要关闭目录句柄。结果当前活动查询将刚刚完成 ERROR_NOTIFY_CLEANUP
  • 当然需要在课堂上实现引用计数和处理损坏保护（关闭后不使用它）。

有了这个类，我们可以有任意数量的目录间谍——只需要创建这个类的 N 个实例。无需等待、循环等。只需继续执行您的任务。当您不再需要来自目录的通知时 - 关闭它处理并释放结构

最简单的实现：

class SPYDATA : public OVERLAPPED, RUNDOWN_REF
{
    HANDLE m_hFile;
    DWORD _dwNotifyFilter;
    LONG _dwRef;
    UCHAR _buf[PAGE_SIZE];

    ~SPYDATA()
    {
        Close();
        DbgPrint("%s<%p>\n", __FUNCTION__, this);
    }

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

        buf = _buf;

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

            ULONG NextEntryOffset = pfni->NextEntryOffset;

            if (!NextEntryOffset)
            {
                break;
            }

            pb += NextEntryOffset;
        }
    }

    void IOCompletionRoutine(DWORD dwErrorCode, DWORD dwNumberOfBytesTransfered)
    {
        switch (dwErrorCode)
        {
        case ERROR_NOTIFY_CLEANUP:
            DbgPrint("%p>[%x] ---- NOTIFY_CLEANUP -----\n", this, _dwNotifyFilter);
            return ;
        case NOERROR:
            if (dwNumberOfBytesTransfered) DumpDirectoryChanges();
            DoRead();
            return;
        }

        DbgPrint("%p>[%x] error=%x\n", this, _dwNotifyFilter, dwErrorCode);
    }

    void IOCompletionRoutineAndRelease(DWORD dwErrorCode, DWORD dwNumberOfBytesTransfered)
    {
        IOCompletionRoutine(dwErrorCode, dwNumberOfBytesTransfered);
        Release();
    }

    static VOID CALLBACK _IOCompletionRoutine(
        __in  DWORD status,
        __in  DWORD dwNumberOfBytesTransfered,
        __in  LPOVERLAPPED lpOverlapped
        )
    {
        static_cast<SPYDATA*>(lpOverlapped)->IOCompletionRoutineAndRelease(RtlNtStatusToDosError(status), dwNumberOfBytesTransfered);
    }

    virtual void RundownCompleted()
    {
        if (m_hFile) CloseHandle(m_hFile);
    }

public:

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

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

    SPYDATA(DWORD dwNotifyFilter) : _dwNotifyFilter(dwNotifyFilter)
    {
        _dwRef = 1;
        m_hFile = 0;
        RtlZeroMemory(static_cast<OVERLAPPED*>(this), sizeof(OVERLAPPED));
        DbgPrint("%s<%p>\n", __FUNCTION__, this);
    }

    void DoRead()
    {
        if (AcquireRundownProtection())
        {
            AddRef();

            ULONG dwErrorCode = ReadDirectoryChangesW(m_hFile, _buf, sizeof(_buf), 
                TRUE, _dwNotifyFilter, NULL, this, NULL) ? NOERROR : GetLastError();

            ReleaseRundownProtection();

            switch (dwErrorCode)
            {
            case NOERROR:
            case ERROR_IO_PENDING:
                break;
            default:
                IOCompletionRoutineAndRelease(dwErrorCode, 0);
            }
        }
    }

    ULONG Open(PCWSTR lpFileName )
    {
        HANDLE hFile = CreateFile(lpFileName, FILE_GENERIC_READ, FILE_SHARE_VALID_FLAGS, 0, 
            OPEN_EXISTING, FILE_FLAG_BACKUP_SEMANTICS|FILE_FLAG_OVERLAPPED, 0);

        if (hFile != INVALID_HANDLE_VALUE)
        {
            if (BindIoCompletionCallback(hFile, _IOCompletionRoutine, 0))
            {
                m_hFile = hFile;

                return NOERROR;
            }
            CloseHandle(hFile);
        }

        return GetLastError();
    }

    void Close()
    {
        BeginRundown();
    }
};

BOOL CreateSpy(DWORD dwNotifyFilter, PCWSTR lpFileName, SPYDATA** pp)
{
    if (SPYDATA* p = new SPYDATA(dwNotifyFilter))
    {
        ULONG dwError = p->Open(lpFileName);

        if (!dwError)
        {
            *pp = p;
            p->DoRead();
            return NOERROR;
        }

        p->Release();

        return dwError;
    }

    return ERROR_NO_SYSTEM_RESOURCES;
}

void DestroySpyData(SPYDATA* p)
{
    if (p) 
    {
        p->Close();
        p->Release();
    }
}

并将其用作：

SPYDATA* p;
if (!CreateSpy(FILE_NOTIFY_VALID_MASK, L"<some path>", &p))
{
    MessageBoxW(0,0,0,0);// really here any code
    DestroySpyData(p);
}

我对破旧保护的实现（它不是由用户模式下的 api 实现的）是

#define RUNDOWN_INIT_VALUE 0x80000000
#define RUNDOWN_COMPLETE_VALUE 0
#define ObpBeginRundown(p) _interlockedbittestandreset(p, 31)
#define ObpUnlock _InterlockedDecrement

__forceinline BOOL ObpLock(PLONG pLock)
{
    LONG Value = *pLock, NewValue;

    for ( ; Value; Value = NewValue)
    {
        NewValue = _InterlockedCompareExchange(pLock, Value + 1, Value);

        if (NewValue == Value) return TRUE;
    }

    return FALSE;
}

__forceinline BOOL ObpAcquireRundownProtection(PLONG pLock)
{
    LONG Value = *pLock, NewValue;

    for ( ; Value < 0; Value = NewValue)
    {
        NewValue = _InterlockedCompareExchange(pLock, Value + 1, Value);

        if (NewValue == Value) return TRUE;
    }

    return FALSE;
}

class __declspec(novtable) RUNDOWN_REF
{
    LONG _LockCount;

protected:

    virtual void RundownCompleted() = 0;

public:

    BOOL IsRundownBegin()
    {
        return 0 <= _LockCount;
    }

    __forceinline void Reinit()
    {
        if (InterlockedCompareExchange(&_LockCount, RUNDOWN_INIT_VALUE, RUNDOWN_COMPLETE_VALUE) != RUNDOWN_COMPLETE_VALUE)
        {
            __debugbreak();
        }
    }

    __forceinline RUNDOWN_REF()
    {
        _LockCount = RUNDOWN_INIT_VALUE;
    }

    __forceinline BOOL AcquireRundownProtection()
    {
        return ObpAcquireRundownProtection(&_LockCount);
    }

    __forceinline void ReleaseRundownProtection()
    {
        if (!_InterlockedDecrement(&_LockCount))
        {
            RundownCompleted();
        }
    }

    void BeginRundown()
    {
        if (AcquireRundownProtection())
        {
            ObpBeginRundown(&_LockCount);
            ReleaseRundownProtection();
        }
    }
};
于 2017-07-23T10:19:09.303 回答
0

这是设置监视整个树的一种方法...这些是我的代码库中的例外，由于依赖关系，我无法将整个代码放在这里...

用法：

   FolderWatchInfo fwi;
   fwi.Create(strRootPath,  TRUE, 
        FolderWatchInfo::flagDirWatch | FolderWatchInfo::flagFileWatch);

    WaitForSingleObject(fwi.GetHandle(), INFINITE);  // or the usual WaitForMultipleObjects(...)
                                                     // with an exit event
    //...
    //On event signaled:

    CStringsVector vFolders;
    fwi.GetSubDirChangeList(vFolders);
    Sleep(1000);        // give a little time for things to settle...

    for each (const CIRString& str in vFolders)
    {
       OnFolderChange(str);  // signal my app
    }

事件是自动重置的，因此无需对此进行维护。

不存在的东西：

CIRSingleLock 就像 lock_guard

DirScanner 是 FindFirstFile() 的包装器，它将文件夹报告给 Reader 结构。

包含文件：

// *********************************************************************************************************************************
// *********************************************************************************************************************************

#pragma once

#include <DirScanner.h>
#include <shared_ptr.h>
#include <boost/weak_ptr.hpp>
#include <vector>
#include <IRSingleLock.h>

// *********************************************************************************************************************************
// *********************************************************************************************************************************

class FolderWatchInfo
{
    // --------------------------------------------------------------------------------------------------------------------------------

public:
    enum Flags
    {
        flagFileCreateDelete  = FILE_NOTIFY_CHANGE_FILE_NAME,
        flagFileModify        = FILE_NOTIFY_CHANGE_SIZE | FILE_NOTIFY_CHANGE_LAST_WRITE,
        flagFileSecurity      = FILE_NOTIFY_CHANGE_SECURITY,
        flagFileAttributes    = FILE_NOTIFY_CHANGE_ATTRIBUTES,
        flagDirCreateDetelete = FILE_NOTIFY_CHANGE_DIR_NAME,

        flagFileWatch = flagFileCreateDelete | flagFileModify,
        flagDirWatch  = flagDirCreateDetelete,
    };

    // --------------------------------------------------------------------------------------------------------------------------------

    typedef shared_ptr<FolderWatchInfo> FolderWatchInfoPtr;
    typedef std::vector<FolderWatchInfoPtr> FWIVector;
    typedef std::vector<CIRString> CStringsVector;

    // --------------------------------------------------------------------------------------------------------------------------------
private:
    struct Reader : public DirScanner::Reader
    {
        FolderWatchInfo& fwi;

        Reader(FolderWatchInfo& fwi_) 
            : DirScanner::Reader(fwi_.GetPathName(), _T("__NOFILES__"), 1)
            ,  fwi(fwi_)
        { }

        virtual bool OnDirectoryFound(LPCTSTR szPathName, const WIN32_FIND_DATA& findData)
        {
            FolderWatchInfoPtr p = make_shared<FolderWatchInfo>();
            p->Create(fwi.GetPathName() + _T("\\") + szPathName, fwi.GetFlags());
            fwi.m_vChildren.push_back(p);
            return TRUE;
        }
    };

    friend struct Reader;

private:
    CIRCriticalSection m_lock;
    weak_ptr<FolderWatchInfo> m_pParent;
    CIRString m_strPathName;
    HANDLE m_hWatchEvent;
    DWORD m_dwFlags;
    FWIVector m_vChildren;

    // --------------------------------------------------------------------------------------------------------------------------------

private:
    inline FolderWatchInfo(const FolderWatchInfo&) {}
    inline bool operator = (const FolderWatchInfo&) {}

    // --------------------------------------------------------------------------------------------------------------------------------

public:
    FolderWatchInfo();
    ~FolderWatchInfo();

    // --------------------------------------------------------------------------------------------------------------------------------

    HANDLE Create(const CIRString& strPathName, BOOL bRecursive, DWORD dwFlags);
    void CloseHandle();
    void ResetEvent();

protected:
    HANDLE Create(const CIRString& strPathName, DWORD dwFlags);
    void AddToSubDirChangeList(CStringsVector& vSubDirs);

    // --------------------------------------------------------------------------------------------------------------------------------
public:
    inline HANDLE GetHandle() const
    {
        return m_hWatchEvent;
    }

    // --------------------------------------------------------------------------------------------------------------------------------

    inline void GetSubDirChangeList(CStringsVector& vSubDirs)
    {
        CIRSingleLock lock(m_lock);
        vSubDirs.clear();
        AddToSubDirChangeList(vSubDirs);
    }

    // --------------------------------------------------------------------------------------------------------------------------------

    inline FolderWatchInfoPtr GetParent() const
    {
        return FolderWatchInfoPtr(m_pParent, boost::detail::sp_nothrow_tag());
    }

    // --------------------------------------------------------------------------------------------------------------------------------

    inline const FWIVector& GetChildren() const
    {
        return m_vChildren;
    }

    // --------------------------------------------------------------------------------------------------------------------------------

    inline const CIRString& GetPathName() const
    {
        return m_strPathName;
    }

    // --------------------------------------------------------------------------------------------------------------------------------

    inline DWORD GetFlags() const
    {
        return m_dwFlags;
    }

    // --------------------------------------------------------------------------------------------------------------------------------

    inline bool operator == (LPCTSTR szPath)
    {
        return (m_strPathName.CompareNoCase(szPath) == 0);
    }
};

// ***************************************************************************************************************************** EOF

cpp。

// *********************************************************************************************************************************
// *********************************************************************************************************************************

#include "StdAfx.h"
#include "FolderWatchInfo.h"

// *********************************************************************************************************************************

FolderWatchInfo::FolderWatchInfo()
    : m_hWatchEvent(INVALID_HANDLE_VALUE)
    , m_dwFlags(0)
{ }

// *********************************************************************************************************************************

FolderWatchInfo::~FolderWatchInfo(void)
{
    CIRSingleLock lock(m_lock);
    if (m_hWatchEvent != INVALID_HANDLE_VALUE)
    {
        FindCloseChangeNotification(m_hWatchEvent);
    }
}

// *********************************************************************************************************************************

HANDLE FolderWatchInfo::Create(const CIRString& strPathName, BOOL bRecursive, DWORD dwFlags)
{
    CIRSingleLock lock(m_lock);

    ASSERT(m_hWatchEvent == INVALID_HANDLE_VALUE);
    m_strPathName = CleanPathName(strPathName);
    m_dwFlags = dwFlags;
    m_hWatchEvent = FindFirstChangeNotification(m_strPathName, bRecursive, dwFlags);

    if (bRecursive)
    {
        DirScanner().ScanFolder(Reader(*this));
    }
    return m_hWatchEvent;
}

// *********************************************************************************************************************************

HANDLE FolderWatchInfo::Create(const CIRString& strPathName, DWORD dwFlags)
{
    CIRSingleLock lock(m_lock);

    ASSERT(m_hWatchEvent == INVALID_HANDLE_VALUE);

    m_strPathName = CleanPathName(strPathName);
    m_dwFlags = dwFlags;
    m_hWatchEvent = FindFirstChangeNotification(m_strPathName, FALSE, dwFlags);
    DirScanner().ScanFolder(Reader(*this));
    return m_hWatchEvent;
}

// *********************************************************************************************************************************

void FolderWatchInfo::CloseHandle()
{
    CIRSingleLock lock(m_lock);

    if (m_hWatchEvent != INVALID_HANDLE_VALUE)
    {
        FindCloseChangeNotification(m_hWatchEvent);
        m_hWatchEvent = INVALID_HANDLE_VALUE;
    }
}

// *********************************************************************************************************************************

void FolderWatchInfo::ResetEvent()
{
    if (m_hWatchEvent != INVALID_HANDLE_VALUE)
    {
        while (WAIT_OBJECT_0 == WaitForSingleObject(m_hWatchEvent, 0))
        {
            if (!FindNextChangeNotification(m_hWatchEvent))
            {
                CloseHandle();
                break;
            }
        }
    }
}

// *********************************************************************************************************************************

void FolderWatchInfo::AddToSubDirChangeList(CStringsVector& vSubDirs)
{
    CIRSingleLock lock(m_lock);

    if (WAIT_OBJECT_0 == WaitForSingleObject(m_hWatchEvent, 0))
    {
        ResetEvent();
        vSubDirs.push_back(m_strPathName);
    }
    for each (const FolderWatchInfoPtr& p in m_vChildren)
    {
        p->AddToSubDirChangeList(vSubDirs);
    }
}

// ***************************************************************************************************************************** EOF
于 2017-07-22T23:29:50.680 回答