tuned;
authorwenzelm
Mon, 21 Aug 2023 11:42:16 +0200
changeset 78548 6cdf9b00dc76
parent 78547 7f564f33172b
child 78549 1c5cbece77d2
tuned;
src/Pure/System/progress.scala
--- a/src/Pure/System/progress.scala	Mon Aug 21 11:24:47 2023 +0200
+++ b/src/Pure/System/progress.scala	Mon Aug 21 11:42:16 2023 +0200
@@ -328,9 +328,7 @@
       consume = { bulk_output0 =>
         val results =
           for (bulk_output <- bulk_output0.grouped(200).toList) yield {
-            val serial = _serial
             val serial_db = Progress.private_data.read_messages_serial(db, _context)
-
             _serial = _serial max serial_db
 
             if (bulk_output.nonEmpty) {
@@ -347,13 +345,10 @@
                   yield (_serial + i + 1) -> out.message
 
               Progress.private_data.write_messages(db, _context, messages)
-
               _serial = messages.last._1
             }
 
-            if (_serial != serial_db) {
-              Progress.private_data.update_agent(db, _agent_uuid, _serial)
-            }
+            if (_serial != serial_db) Progress.private_data.update_agent(db, _agent_uuid, _serial)
 
             bulk_output.map(_ => Exn.Res(()))
           }