@@ -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,57 @@ 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::RenameOld:
1003+ {
1004+ //
1005+ // Nothing to do
1006+ //
1007+ break ;
1008+ }
1009+
1010+ case EventAction::RenameNew:
1011+ {
1012+ status = LogFileRenameNewEventHandler (event);
1013+ break ;
1014+ }
1015+
1016+ case EventAction::ReInit:
1017+ {
1018+ status = LogFileReInitEventHandler (event);
1019+ break ;
1020+ }
1021+
1022+ default :
1023+ break ;
1024+ }
1025+
1026+ return status;
1027+ }
1028+
1029+
10261030DWORD
10271031LogFileMonitor::LogFileAddEventHandler (
10281032 _In_ DirChangeNotificationEvent& Event
@@ -1379,9 +1383,6 @@ LogFileMonitor::LogFileReInitEventHandler(
13791383 }
13801384
13811385 map<std::wstring, std::shared_ptr<LogFileInformation>>::iterator it;
1382-
1383- // wprintf(L"LogFilesChangeHandler: Timer event\n");
1384-
13851386 for ( it = m_logFilesInformation.begin (); it != m_logFilesInformation.end (); it++ )
13861387 {
13871388 ReadLogFile (it->second );
@@ -1588,7 +1589,7 @@ LogFileMonitor::ReadLogFile(
15881589 {
15891590 remainingStringIndex = found + 1 ;
15901591
1591- if (( found - 1 ) >= 0
1592+ if (found >= 1 // Ensures non-negative after subtraction
15921593 && (decodedString[(found - 1 )] == L' \n ' || decodedString[(found - 1 )] == L' \r ' )
15931594 && decodedString[(found - 1 )] != decodedString[found])
15941595 {
@@ -1816,8 +1817,6 @@ LogFileMonitor::GetFilesInDirectory(
18161817 FILE_ID_INFO fileId{ 0 };
18171818 GetFileId (fileName, fileId);
18181819
1819- // wprintf(L"Started monitoring file: %s\n",fileName.c_str());
1820-
18211820 Files.push_back ({ fileName, fileId });
18221821 }
18231822 } while (FindNextFile (hFind, &ffd) != 0 );
@@ -1849,7 +1848,6 @@ LogFileMonitor::FileTypeFromBuffer(
18491848 LM_FILETYPE lmFileType = LM_FILETYPE::FileTypeUnknown;
18501849 FoundBomSize = 0 ;
18511850
1852- PWSTR szBuf = (PWSTR)FileContents;
18531851 if (ContentSize <= 1 && BomSize <= 1 )
18541852 {
18551853 return lmFileType;
0 commit comments