Searched refs:q_wait_time (Results 1 – 5 of 5) sorted by relevance
| /dports/biology/sra-tools/sra-tools-2.11.0/tools/fasterq-dump/ |
| H A D | concatenator.c | 162 uint32_t q_wait_time ) in execute_concat_compressed() argument
168 … rc = make_a_copy( dir, dst, files, progress, 0, buf_size, 0, q_wait_time ); /* copy_machine.c */ in execute_concat_compressed()
190 uint32_t q_wait_time ) in execute_concat_un_compressed_append() argument
228 uint32_t q_wait_time ) in execute_concat_un_compressed_no_append() argument
312 files_offset, q_wait_time ); /* copy_machine.c */ in execute_concat_un_compressed_no_append()
338 uint32_t q_wait_time ) in execute_concat_un_compressed() argument
345 buf_size, progress, count, q_wait_time ); in execute_concat_un_compressed()
350 buf_size, progress, force, count, q_wait_time ); in execute_concat_un_compressed()
375 uint32_t q_wait_time = 500; in execute_concat() local
379 progress, force, append, compress, count, q_wait_time ); /* above */ in execute_concat()
[all …]
|
| H A D | copy_machine.c | 58 uint32_t q_wait_time; member
155 rc = TimeoutInit ( &tm, self -> q_wait_time ); in copy_this_file()
158 … ErrMsg( "copy_machine.c copy_this_file().TimeoutInit( %lu ms ) -> %R", self -> q_wait_time, rc ); in copy_this_file()
177 rc = push2q ( self -> to_write_q, block, self -> q_wait_time ); in copy_this_file()
182 rc = push2q ( self -> empty_q, block, self -> q_wait_time ); in copy_this_file()
273 rc = TimeoutInit ( &tm, self -> q_wait_time ); in copy_machine_writer_thread()
298 rc = push2q ( self -> empty_q, block, self -> q_wait_time ); /* above */ in copy_machine_writer_thread()
307 rc = push2q ( self -> empty_q, block, self -> q_wait_time ); /* above */ in copy_machine_writer_thread()
346 uint32_t q_wait_time ) in make_a_copy() argument
368 cm . q_wait_time = q_wait_time; in make_a_copy()
[all …]
|
| H A D | merge_sorter.c | 242 uint32_t q_wait_time; /* timeout in milliseconds to get something out of in_q */ member
391 rc = TimeoutInit ( &tm, self -> q_wait_time ); in background_vector_merger_collect_batch()
571 uint32_t q_wait_time, in make_background_vector_merger() argument
587 b -> q_wait_time = q_wait_time; in make_background_vector_merger()
644 rc = TimeoutInit ( &tm, self -> q_wait_time ); in push_to_background_vector_merger()
647 …ge_sorter.c push_to_background_vector_merger().TimeoutInit( %u ) -> %R", self -> q_wait_time, rc ); in push_to_background_vector_merger()
662 KSleepMs( self -> q_wait_time ); in push_to_background_vector_merger()
|
| H A D | copy_machine.h | 61 uint32_t q_wait_time );
|
| H A D | merge_sorter.h | 65 uint32_t q_wait_time,
|