1.1 --- a/tests/start_indexer.py Tue Sep 27 14:16:48 2005 +0000
1.2 +++ b/tests/start_indexer.py Tue Sep 27 14:18:01 2005 +0000
1.3 @@ -21,20 +21,23 @@
1.4 # Start listening for responses.
1.5
1.6 exchange = Exchange(channels)
1.7 - while len(channels) > 0:
1.8 - print "Waiting for %d channels..." % len(channels)
1.9 + while exchange.active():
1.10 + print "Waiting for %d channels..." % exchange.active()
1.11 for channel in exchange.ready():
1.12 index = channel.receive()
1.13 update(master_index, index)
1.14 - channels.remove(channel)
1.15 + exchange.remove(channel)
1.16 + channel.close()
1.17
1.18 # Provide a search interface.
1.19
1.20 return Searcher(master_index)
1.21
1.22 if __name__ == "__main__":
1.23 - import sys
1.24 - window_size, filenames = int(sys.argv[1]), sys.argv[2:]
1.25 + import sys, os
1.26 + window_size, directory = int(sys.argv[1]), sys.argv[2]
1.27 + filenames = [os.path.join(directory, filename) for filename in os.listdir(directory)]
1.28 +
1.29 searcher = get_searcher(filenames, window_size)
1.30 while 1:
1.31 print "Pattern:",