Ticket #14175: 0001-text_search-avoid-flooding-messages-while-searching.patch

src/apps/text_search/Grepper.cpp

@@ -170 +170 @@
     BMessage message;
     char fileName[B_PATH_NAME_LENGTH*2];
     int count = 0;
+    bigtime_t lastProgressReportTime = 0, now;
 
     printf("paths_writer started.\n");
 
     while (!fMustQuit && fIterator->GetNextName(fileName)) {
 
-        message.MakeEmpty();
-        message.what = MSG_REPORT_FILE_NAME;
-        message.AddString("filename", fileName);
-
         BEntry entry(fileName);
         entry_ref ref;
         entry.GetRef(&ref);
         if (!entry.Exists()) {
             if (fIterator->NotifyNegatives()) {
+                message.MakeEmpty();
                 message.what = MSG_REPORT_RESULT;
+                message.AddString("filename", fileName);
                 message.AddRef("ref", &ref);
                 fTarget.SendMessage(&message);
             }
@@ -202 +201 @@
             continue;
         }
 
+        count++;
+
         // file exists, send it to xargs
         write(fXargsInput, fileName, strlen(fileName));
         write(fXargsInput, "\n", 1);
         // printf(">>>>>> %s\n", fileName);
 
-        fTarget.SendMessage(&message);
-
-        count++;
+        now = system_time();
+        // to avoid message flood,
+        // report progress no more than 20 times per second
+        if (now - lastProgressReportTime > 50000) {
+            message.MakeEmpty();
+            message.what = MSG_REPORT_FILE_NAME;
+            message.AddString("filename", fileName);
+            // message.AddInt32("count", count);
+            fTarget.SendMessage(&message);
+            lastProgressReportTime = now;
+        }
     }
 
     write(fXargsInput, kEOFTag, strlen(kEOFTag));
@@ -218 +227 @@
 
     printf("paths_writer stopped (%d paths).\n", count);
 
+
     return 0;
 }