DWORD CListener::Loop()
{
    HANDLE hChanges[ 2 ];
    DWORD dwStatus;
    
    hChanges[ 1 ] = ::CreateEvent(NULL, FALSE, FALSE, _T( "RPServiceExit" ));    
    if(!(hChanges[ 1 ]))
    {
        _Module.LogEvent(_T( "Required event isn't created. Cannot begin listening!"));
        return 0;
    }

    hChanges[0] = ::FindFirstChangeNotification
        (m_szFolder, FALSE, FILE_NOTIFY_CHANGE_ATTRIBUTES);
    if(hChanges[0] == INVALID_HANDLE_VALUE) 
    {
        _Module.LogEvent(_T("Notification isn't started. Cannot begin listening!" ));
        return  1 ;
    }

    _Module.LogEvent(_T( "Listening started" ));
    BOOL bBreak = FALSE;

    while(TRUE)
    {
        _Module.LogEvent(_T( "Waiting for files..." ));
        dwStatus = ::WaitForMultipleObjects( 2 , hChanges, FALSE, INFINITE);

        switch(dwStatus)
        {
        case WAIT_OBJECT_0:
            ScanFolder();
            if(!FindNextChangeNotification(hChanges[ 0 ]))
            {
                _Module.LogEvent(_T( "Cannot continue listening. It will be stopped!" ));
                bBreak = TRUE;
            }
            break;

        case WAIT_OBJECT_0 +  1 :
        default:
            bBreak = TRUE; // Exit worker thread
        }

        if(bBreak) break;
    }
    
    ::FindCloseChangeNotification(hChanges[ 0 ]);
    ::CloseHandle(hChanges[ 1 ]);

    _Module.LogEvent(_T( "Listening stopped" ));
    return  0 ;
}