github/penpot
1
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2026-04-30 05:38:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

WIP

Browse Source
This commit is contained in:
Andrey Antukh 2025-08-13 11:26:41 +02:00
parent 7e9c8e8f01
commit a4833f95b5
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
backend/src/app/srepl/main.clj
View File

@ -560,14 +560,10 @@
rollback? true}
:as opts}]
(l/dbg :hint "process:start"
:rollback rollback?
:max-jobs max-jobs
:max-chunks max-chunks)
(let [tpoint (ct/tpoint)
max-jobs (or max-jobs (px/get-available-processors))
chunks (atom 0)
(let [tpoint (ct/tpoint)
max-jobs (or max-jobs (px/get-available-processors))
max-chunks (max max-chunks max-jobs)
processed (atom 0)
start-job
(fn [jid]
@ -579,13 +575,18 @@
(assoc ::db/rollback rollback?)
(proc-fn opts))
total (+ total result)
chunks (swap! chunks inc)]
chunks (swap! processed inc)]
(l/dbg :hint "chunk processed" :jid jid :total total :chunk result)
(when (and (pos? result)
(< chunks max-chunks))
(recur total)))))]
(l/dbg :hint "process:start"
:rollback rollback?
:max-jobs max-jobs
:max-chunks max-chunks)
(try
(let [jobs (->> (range max-jobs)
(map (fn [jid] (px/fn->thread (partial start-job jid))))