1.1 --- a/tests/start_indexer.py Wed Sep 28 16:23:54 2005 +0000
1.2 +++ b/tests/start_indexer.py Wed Sep 28 16:24:06 2005 +0000
1.3 @@ -1,6 +1,6 @@
1.4 #!/usr/bin/env python
1.5
1.6 -from parallel import start, Exchange
1.7 +from parallel import start, Exchange, waitall
1.8 from Dict import Indexer, Searcher, Parser
1.9
1.10 def apply_parser(channel, filename):
1.11 @@ -33,6 +33,8 @@
1.12 for channel in channels:
1.13 channel.close()
1.14
1.15 + waitall()
1.16 +
1.17 # Provide a search interface.
1.18
1.19 return Searcher(master_index.get_index())
1.20 @@ -52,14 +54,7 @@
1.21 # Get a searcher using an index built in parallel.
1.22
1.23 searcher = get_searcher(filenames, window_size)
1.24 -
1.25 - # Wait for all created processes to terminate.
1.26 -
1.27 - try:
1.28 - while 1:
1.29 - os.wait()
1.30 - except OSError:
1.31 - pass
1.32 + waitall()
1.33
1.34 # Present a user interface.
1.35