1.1 --- a/tests/start_indexer.py Mon Sep 26 22:26:22 2005 +0000
1.2 +++ b/tests/start_indexer.py Mon Sep 26 22:27:07 2005 +0000
1.3 @@ -8,24 +8,25 @@
1.4 indexer = Indexer(filename)
1.5 channel.send(indexer.get_index())
1.6
1.7 -def get_searcher(filenames):
1.8 +def get_searcher(filenames, window_size):
1.9 master_index = {}
1.10
1.11 # Start indexing.
1.12
1.13 - channels = []
1.14 - for filename in filenames:
1.15 - channels.append(start(apply_indexer, filename))
1.16 + for i in range(0, len(filenames), window_size):
1.17 + channels = []
1.18 + for filename in filenames[i:i + window_size]:
1.19 + channels.append(start(apply_indexer, filename))
1.20
1.21 - # Start listening for responses.
1.22 + # Start listening for responses.
1.23
1.24 - exchange = Exchange(channels)
1.25 - while len(channels) > 0:
1.26 - print "Waiting for %d channels..." % len(channels)
1.27 - for channel in exchange.ready():
1.28 - index = channel.receive()
1.29 - update(master_index, index)
1.30 - channels.remove(channel)
1.31 + exchange = Exchange(channels)
1.32 + while len(channels) > 0:
1.33 + print "Waiting for %d channels..." % len(channels)
1.34 + for channel in exchange.ready():
1.35 + index = channel.receive()
1.36 + update(master_index, index)
1.37 + channels.remove(channel)
1.38
1.39 # Provide a search interface.
1.40
1.41 @@ -33,8 +34,8 @@
1.42
1.43 if __name__ == "__main__":
1.44 import sys
1.45 - filenames = sys.argv[1:]
1.46 - searcher = get_searcher(filenames)
1.47 + window_size, filenames = int(sys.argv[1]), sys.argv[2:]
1.48 + searcher = get_searcher(filenames, window_size)
1.49 while 1:
1.50 print "Pattern:",
1.51 pattern = raw_input()