@@ -276,7 +276,6 @@ DWORD LogFileMonitor::EnqueueDirChangeEvents(DirChangeNotificationEvent event, B
276276
277277 if (m_directoryChangeEvents.size () == 1 )
278278 {
279- // wprintf(L"Signalling worker thread to start processing the event queue\n");
280279 if (!SetEvent (m_workerThreadEvent))
281280 {
282281 logWriter.TraceError (
@@ -645,8 +644,6 @@ LogFileMonitor::InitializeDirectoryChangeEventsQueue()
645644 DWORD status = ERROR_SUCCESS;
646645 std::vector<std::pair<std::wstring, FILE_ID_INFO> > logFiles;
647646
648- // wprintf(L"InitializeDirectoryChangeEventsQueue\n");
649-
650647 status = GetFilesInDirectory (m_logDirectory, m_filter, logFiles, m_includeSubfolders);
651648
652649 if (status == ERROR_SUCCESS)
@@ -896,49 +893,7 @@ LogFileMonitor::LogFilesChangeHandler()
896893
897894 ReleaseSRWLockExclusive (&m_eventQueueLock);
898895
899- switch (event.Action )
900- {
901- case EventAction::Add:
902- {
903- status = LogFileAddEventHandler (event);
904- break ;
905- }
906-
907- case EventAction::Modify:
908- {
909- status = LogFileModifyEventHandler (event);
910- break ;
911- }
912-
913- case EventAction::Remove:
914- {
915- status = LogFileRemoveEventHandler (event);
916- break ;
917- }
918-
919- case EventAction::RenameOld:
920- {
921- //
922- // Nothing to do
923- //
924- break ;
925- }
926-
927- case EventAction::RenameNew:
928- {
929- status = LogFileRenameNewEventHandler (event);
930- break ;
931- }
932-
933- case EventAction::ReInit:
934- {
935- status = LogFileReInitEventHandler (event);
936- break ;
937- }
938-
939- default :
940- break ;
941- }
896+ status = GetLogFileEventStatus (event);
942897
943898 AcquireSRWLockExclusive (&m_eventQueueLock);
944899 }
@@ -978,8 +933,6 @@ LogFileMonitor::LogFilesChangeHandler()
978933 {
979934 map<std::wstring, std::shared_ptr<LogFileInformation>>::iterator it;
980935
981- // wprintf(L"LogFilesChangeHandler: Timer event\n");
982-
983936 for ( it = m_logFilesInformation.begin (); it != m_logFilesInformation.end (); it++ )
984937 {
985938 ReadLogFile (it->second );
@@ -1023,6 +976,50 @@ LogFileMonitor::LogFilesChangeHandler()
1023976}
1024977
1025978
979+ DWORD LogFileMonitor::GetLogFileEventStatus (DirChangeNotificationEvent& event)
980+ {
981+ DWORD status = ERROR_SUCCESS;
982+ switch (event.Action )
983+ {
984+ case EventAction::Add:
985+ {
986+ status = LogFileAddEventHandler (event);
987+ break ;
988+ }
989+
990+ case EventAction::Modify:
991+ {
992+ status = LogFileModifyEventHandler (event);
993+ break ;
994+ }
995+
996+ case EventAction::Remove:
997+ {
998+ status = LogFileRemoveEventHandler (event);
999+ break ;
1000+ }
1001+
1002+ case EventAction::RenameNew:
1003+ {
1004+ status = LogFileRenameNewEventHandler (event);
1005+ break ;
1006+ }
1007+
1008+ case EventAction::ReInit:
1009+ {
1010+ status = LogFileReInitEventHandler (event);
1011+ break ;
1012+ }
1013+
1014+ case EventAction::RenameOld:
1015+ default :
1016+ break ;
1017+ }
1018+
1019+ return status;
1020+ }
1021+
1022+
10261023DWORD
10271024LogFileMonitor::LogFileAddEventHandler (
10281025 _In_ DirChangeNotificationEvent& Event
@@ -1379,9 +1376,6 @@ LogFileMonitor::LogFileReInitEventHandler(
13791376 }
13801377
13811378 map<std::wstring, std::shared_ptr<LogFileInformation>>::iterator it;
1382-
1383- // wprintf(L"LogFilesChangeHandler: Timer event\n");
1384-
13851379 for ( it = m_logFilesInformation.begin (); it != m_logFilesInformation.end (); it++ )
13861380 {
13871381 ReadLogFile (it->second );
@@ -1588,7 +1582,7 @@ LogFileMonitor::ReadLogFile(
15881582 {
15891583 remainingStringIndex = found + 1 ;
15901584
1591- if (( found - 1 ) >= 0
1585+ if (found >= 1 // Ensures non-negative after subtraction
15921586 && (decodedString[(found - 1 )] == L' \n ' || decodedString[(found - 1 )] == L' \r ' )
15931587 && decodedString[(found - 1 )] != decodedString[found])
15941588 {
@@ -1816,8 +1810,6 @@ LogFileMonitor::GetFilesInDirectory(
18161810 FILE_ID_INFO fileId{ 0 };
18171811 GetFileId (fileName, fileId);
18181812
1819- // wprintf(L"Started monitoring file: %s\n",fileName.c_str());
1820-
18211813 Files.push_back ({ fileName, fileId });
18221814 }
18231815 } while (FindNextFile (hFind, &ffd) != 0 );
@@ -1849,7 +1841,6 @@ LogFileMonitor::FileTypeFromBuffer(
18491841 LM_FILETYPE lmFileType = LM_FILETYPE::FileTypeUnknown;
18501842 FoundBomSize = 0 ;
18511843
1852- PWSTR szBuf = (PWSTR)FileContents;
18531844 if (ContentSize <= 1 && BomSize <= 1 )
18541845 {
18551846 return lmFileType;
0 commit comments