CDirectoryWatcher.cpp File Reference

#include "shelldesktop.h"
#include "CDirectoryWatcher.h"
#include <process.h>
#include <assert.h>

Include dependency graph for CDirectoryWatcher.cpp:

Go to the source code of this file.

Macros
#define	BUFFER_SIZE   0x1000

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (shcn)
static void	NotifyFileSystemChange (LONG wEventId, LPCWSTR path1, LPCWSTR path2)
static unsigned __stdcall	DirectoryWatcherThreadFuncAPC (void *)
static void NTAPI	_AddDirectoryProcAPC (ULONG_PTR Parameter)
static void NTAPI	_RequestTerminationAPC (ULONG_PTR Parameter)
static void NTAPI	_RequestAllTerminationAPC (ULONG_PTR Parameter)
static DWORD	ConvertActionToEvent (DWORD Action, BOOL fDir)
static void CALLBACK	_NotificationCompletion (DWORD dwErrorCode, DWORD dwNumberOfBytesTransfered, LPOVERLAPPED lpOverlapped)
static DWORD	GetFilterFromEvents (DWORD fEvents)

Variables
static HANDLE	s_hThreadAPC = NULL
static BOOL	s_fTerminateAllWatchers = FALSE
static BYTE	s_buffer [BUFFER_SIZE]

Macro Definition Documentation

BUFFER_SIZE

#define BUFFER_SIZE   0x1000

Definition at line 28 of file CDirectoryWatcher.cpp.

Function Documentation

_AddDirectoryProcAPC()

static void NTAPI _AddDirectoryProcAPC ( ULONG_PTR  Parameter )

static

Definition at line 46 of file CDirectoryWatcher.cpp.

{
    CDirectoryWatcher *pDirectoryWatcher = (CDirectoryWatcher *)Parameter;
    assert(pDirectoryWatcher != NULL);
 
    pDirectoryWatcher->RestartWatching();
}

Referenced by CDirectoryWatcher::RequestAddWatcher().

_NotificationCompletion()

static void CALLBACK _NotificationCompletion ( DWORD  dwErrorCode, DWORD  dwNumberOfBytesTransfered, LPOVERLAPPED  lpOverlapped  )

static

Definition at line 281 of file CDirectoryWatcher.cpp.

{
    // MSDN: The hEvent member of the OVERLAPPED structure is not used by the
    // system in this case, so you can use it yourself. We do just this, storing
    // a pointer to the working struct in the overlapped structure.
    CDirectoryWatcher *pDirectoryWatcher = (CDirectoryWatcher *)lpOverlapped->hEvent;
    assert(pDirectoryWatcher != NULL);
 
    pDirectoryWatcher->ReadCompletion(dwErrorCode, dwNumberOfBytesTransfered);
}

Referenced by CDirectoryWatcher::RestartWatching().

_RequestAllTerminationAPC()

static void NTAPI _RequestAllTerminationAPC ( ULONG_PTR  Parameter )

static

Definition at line 64 of file CDirectoryWatcher.cpp.

{
    s_fTerminateAllWatchers = TRUE;
    CloseHandle(s_hThreadAPC);
    s_hThreadAPC = NULL;
}

Referenced by CDirectoryWatcher::RequestAllWatchersTermination().

_RequestTerminationAPC()

static void NTAPI _RequestTerminationAPC ( ULONG_PTR  Parameter )

static

Definition at line 55 of file CDirectoryWatcher.cpp.

{
    CDirectoryWatcher *pDirectoryWatcher = (CDirectoryWatcher *)Parameter;
    assert(pDirectoryWatcher != NULL);
 
    pDirectoryWatcher->QuitWatching();
}

Referenced by CDirectoryWatcher::RequestTermination().

ConvertActionToEvent()

static DWORD ConvertActionToEvent ( DWORD  Action, BOOL  fDir  )

static

Definition at line 113 of file CDirectoryWatcher.cpp.

{
    switch (Action)
    {
        case FILE_ACTION_ADDED:
            return (fDir ? SHCNE_MKDIR : SHCNE_CREATE);
        case FILE_ACTION_REMOVED:
            return (fDir ? SHCNE_RMDIR : SHCNE_DELETE);
        case FILE_ACTION_MODIFIED:
            return (fDir ? SHCNE_UPDATEDIR : SHCNE_UPDATEITEM);
        case FILE_ACTION_RENAMED_OLD_NAME:
            break;
        case FILE_ACTION_RENAMED_NEW_NAME:
            return (fDir ? SHCNE_RENAMEFOLDER : SHCNE_RENAMEITEM);
        default:
            break;
    }
    return 0;
}

Referenced by CDirectoryWatcher::ProcessNotification().

DirectoryWatcherThreadFuncAPC()

static unsigned __stdcall DirectoryWatcherThreadFuncAPC ( void *  )

static

Definition at line 32 of file CDirectoryWatcher.cpp.

{
    while (!s_fTerminateAllWatchers)
    {
#if 1 // FIXME: This is a HACK
        WaitForSingleObjectEx(GetCurrentThread(), INFINITE, TRUE);
#else
        SleepEx(INFINITE, TRUE);
#endif
    }
    return 0;
}

Referenced by CDirectoryWatcher::CreateAPCThread().

GetFilterFromEvents()

static DWORD GetFilterFromEvents ( DWORD  fEvents )

static

Definition at line 296 of file CDirectoryWatcher.cpp.

{
    // FIXME
    return (FILE_NOTIFY_CHANGE_FILE_NAME |
            FILE_NOTIFY_CHANGE_DIR_NAME |
            FILE_NOTIFY_CHANGE_CREATION |
            FILE_NOTIFY_CHANGE_SIZE |
            FILE_NOTIFY_CHANGE_ATTRIBUTES);
}

Referenced by CDirectoryWatcher::RestartWatching().

NotifyFileSystemChange()

static void NotifyFileSystemChange ( LONG  wEventId, LPCWSTR  path1, LPCWSTR  path2  )

inlinestatic

Definition at line 16 of file CDirectoryWatcher.cpp.

{
    SHChangeNotify(wEventId | SHCNE_INTERRUPT, SHCNF_PATHW | SHCNF_FLUSH, path1, path2);
}

Referenced by CDirectoryWatcher::ProcessNotification(), and CDirectoryWatcher::ReadCompletion().

WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL

(

shcn

)

Variable Documentation

s_buffer

BYTE s_buffer[BUFFER_SIZE]

static

Definition at line 29 of file CDirectoryWatcher.cpp.

Referenced by CDirectoryWatcher::ProcessNotification(), and CDirectoryWatcher::RestartWatching().

s_fTerminateAllWatchers

BOOL s_fTerminateAllWatchers = FALSE

static

Definition at line 25 of file CDirectoryWatcher.cpp.

Referenced by _RequestAllTerminationAPC(), CDirectoryWatcher::CreateAPCThread(), and DirectoryWatcherThreadFuncAPC().

s_hThreadAPC

HANDLE s_hThreadAPC = NULL

static

Definition at line 22 of file CDirectoryWatcher.cpp.

Referenced by _RequestAllTerminationAPC(), CDirectoryWatcher::CreateAPCThread(), CDirectoryWatcher::RequestAddWatcher(), CDirectoryWatcher::RequestAllWatchersTermination(), and CDirectoryWatcher::RequestTermination().