|
@ -225,7 +225,7 @@ _calculate_thread_counts(int *read_thread_count_, |
|
|
int *process_thread_count_, |
|
|
int *process_thread_count_, |
|
|
int *process_thread_queue_depth_) |
|
|
int *process_thread_queue_depth_) |
|
|
{ |
|
|
{ |
|
|
constexpr int DEFAULT_QUEUE_DEPTH = 3; |
|
|
|
|
|
|
|
|
constexpr int DEFAULT_QUEUE_DEPTH = 2; |
|
|
|
|
|
|
|
|
if((*read_thread_count_ == -1) && (*process_thread_count_ == -1)) |
|
|
if((*read_thread_count_ == -1) && (*process_thread_count_ == -1)) |
|
|
{ |
|
|
{ |
|
|