diff --git a/blackarrow/blackarrow.py b/blackarrow/blackarrow.py index ccbec18..ae55beb 100755 --- a/blackarrow/blackarrow.py +++ b/blackarrow/blackarrow.py @@ -61,20 +61,22 @@ def start_search(args: argparse.Namespace): final_queue = mp.Queue() # Use final queue for external output processes = [] - indexer = mp.Process( - name="indexer", - target=index_worker, - args=( - args.directories, - ignore_re, - filename_re, - numworkers, - search_queue, - args.depth, - ), - ) - indexer.start() - processes.append(indexer) + for i, directory in enumerate(args.directories): + depth = None if args.depth is None else args.depth + directory.count(os.sep) + indexer = mp.Process( + name="indexer-{}".format(i+1), + target=index_worker, + args=( + [directory], + ignore_re, + filename_re, + numworkers, + search_queue, + depth, + ), + ) + indexer.start() + processes.append(indexer) for i in range(numworkers): worker = mp.Process(