mirror of https://github.com/apache/lucene.git
- Added FIXME.
git-svn-id: https://svn.apache.org/repos/asf/lucene/java/trunk@150832 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
9aadfdbc15
commit
25926e6866
|
@ -127,6 +127,7 @@ public class FetcherTaskQueue extends TaskQueue
|
||||||
// add a new host to the queue
|
// add a new host to the queue
|
||||||
//String host2 = host.replace(':', '_').replace('/', '_').replace('\\', '_');
|
//String host2 = host.replace(':', '_').replace('/', '_').replace('\\', '_');
|
||||||
// make it file system ready
|
// make it file system ready
|
||||||
|
// FIXME: put '100' in properties. This is block size (the number of objects/block)
|
||||||
q = new CachingQueue(host, 100);
|
q = new CachingQueue(host, 100);
|
||||||
servers.put(host, q);
|
servers.put(host, q);
|
||||||
}
|
}
|
||||||
|
|
|
@ -319,8 +319,6 @@ class QueueBlock
|
||||||
|
|
||||||
public class CachingQueue implements Queue
|
public class CachingQueue implements Queue
|
||||||
{
|
{
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* the Blocks
|
* the Blocks
|
||||||
*/
|
*/
|
||||||
|
@ -373,6 +371,7 @@ public class CachingQueue implements Queue
|
||||||
queueBlocks = new LinkedList();
|
queueBlocks = new LinkedList();
|
||||||
this.name = name;
|
this.name = name;
|
||||||
this.blockSize = blockSize;
|
this.blockSize = blockSize;
|
||||||
|
// FIXME: the name of the caching queue directory needs to be in properties
|
||||||
File cq = new File("cachingqueue");
|
File cq = new File("cachingqueue");
|
||||||
cq.mkdir();
|
cq.mkdir();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue