File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -221,6 +221,7 @@ let main () =
221
221
Log. info " computing input file #chunks..." ;
222
222
let total_items = nb_chunks demux input_fn in
223
223
Log. info " %d" total_items;
224
+ let nb_chunks = Utls. ceil ((float total_items) /. (float csize)) in
224
225
(* Parany has a csize of one, because read_some takes care of the number
225
226
of chunks per job *)
226
227
let work_dir = Utls. get_command_output ! Flags. debug " mktemp -d -t pardi_XXXX" in
@@ -231,7 +232,7 @@ let main () =
231
232
~demux: (read_some work_dir input_ext
232
233
(Buffer. create 1024 ) (ref 0 ) csize in_chan demux)
233
234
~work: (process_some output_ext cmd)
234
- ~mux: (gather_some total_items start_t (ref 0 ) mux);
235
+ ~mux: (gather_some nb_chunks start_t (ref 0 ) mux);
235
236
if not ! Flags. debug then
236
237
Utls. run_command ! Flags. debug (sprintf " rm -rf %s" work_dir);
237
238
close_in in_chan
You can’t perform that action at this time.
0 commit comments