diff --git a/.project b/.project index 969b67fb5..2ef8b129c 100644 --- a/.project +++ b/.project @@ -1,17 +1,22 @@ - - - yacy - - - - - - org.eclipse.jdt.core.javabuilder - - - - - - org.eclipse.jdt.core.javanature - - + + + yacy + + + + + + org.eclipse.jdt.core.javabuilder + + + + + org.eclipse.wst.validation.validationbuilder + + + + + + org.eclipse.jdt.core.javanature + + diff --git a/source/de/anomic/content/dao/PhpBB3Dao.java b/source/de/anomic/content/dao/PhpBB3Dao.java index 6a407eb22..53b00d80d 100644 --- a/source/de/anomic/content/dao/PhpBB3Dao.java +++ b/source/de/anomic/content/dao/PhpBB3Dao.java @@ -44,9 +44,9 @@ import de.anomic.yacy.yacyURL; public class PhpBB3Dao implements Dao { - private DatabaseConnection conn = null; - private String urlstub, prefix; - private HashMap users; + protected DatabaseConnection conn = null; + private String urlstub, prefix; + private HashMap users; public PhpBB3Dao( String urlstub, @@ -195,7 +195,7 @@ public class PhpBB3Dao implements Dao { return queue; } - private DCEntry parseResultSet(ResultSet rs) throws SQLException, MalformedURLException { + protected DCEntry parseResultSet(ResultSet rs) throws SQLException, MalformedURLException { yacyURL url; int item = rs.getInt("post_id"); url = new yacyURL(this.urlstub + "/viewtopic.php?t=" + item); diff --git a/source/de/anomic/crawler/Balancer.java b/source/de/anomic/crawler/Balancer.java index e3e5876ac..660531c76 100644 --- a/source/de/anomic/crawler/Balancer.java +++ b/source/de/anomic/crawler/Balancer.java @@ -45,18 +45,15 @@ public class Balancer { private static final int EcoFSBufferSize = 200; // class variables - private final ConcurrentHashMap> - domainStacks; // a map from domain name part to Lists with url hashs - private ConcurrentLinkedQueue - top; - private TreeMap - delayed; - private ObjectIndex urlFileIndex; - private final File cacheStacksPath; - private long minimumLocalDelta; - private long minimumGlobalDelta; - private int profileErrors; - private long lastDomainStackFill; + private final ConcurrentHashMap> domainStacks; // a map from domain name part to Lists with url hashs + private ConcurrentLinkedQueue top; + private TreeMap delayed; + protected ObjectIndex urlFileIndex; + private final File cacheStacksPath; + private long minimumLocalDelta; + private long minimumGlobalDelta; + private int profileErrors; + private long lastDomainStackFill; public Balancer(final File cachePath, final String stackname, final boolean fullram, final long minimumLocalDelta, final long minimumGlobalDelta) { diff --git a/source/de/anomic/crawler/CrawlQueues.java b/source/de/anomic/crawler/CrawlQueues.java index b48e2dd46..656812bb1 100644 --- a/source/de/anomic/crawler/CrawlQueues.java +++ b/source/de/anomic/crawler/CrawlQueues.java @@ -55,11 +55,11 @@ import de.anomic.yacy.logging.Log; public class CrawlQueues { - private plasmaSwitchboard sb; - private Log log; - private Map workers; // mapping from url hash to Worker thread object - private ProtocolLoader loader; - private final ArrayList remoteCrawlProviderHashes; + protected plasmaSwitchboard sb; + protected Log log; + protected Map workers; // mapping from url hash to Worker thread object + protected ProtocolLoader loader; + private final ArrayList remoteCrawlProviderHashes; public NoticedURL noticeURL; public ZURL errorURL, delegatedURL; @@ -538,7 +538,7 @@ public class CrawlQueues { protected final class crawlWorker extends Thread { - private CrawlEntry entry; + protected CrawlEntry entry; private final Integer code; private long start; diff --git a/source/de/anomic/crawler/IndexingStack.java b/source/de/anomic/crawler/IndexingStack.java index 7d872ff0b..d84f145a9 100644 --- a/source/de/anomic/crawler/IndexingStack.java +++ b/source/de/anomic/crawler/IndexingStack.java @@ -52,10 +52,10 @@ import de.anomic.yacy.logging.Log; public class IndexingStack { - private final Stack sbQueueStack; - private final CrawlProfile profiles; - private final yacySeedDB peers; - private final ConcurrentHashMap queueInProcess; + protected final CrawlProfile profiles; + protected final Stack sbQueueStack; + protected final yacySeedDB peers; + protected final ConcurrentHashMap queueInProcess; public IndexingStack( final yacySeedDB peers, diff --git a/source/de/anomic/crawler/ZURL.java b/source/de/anomic/crawler/ZURL.java index 451f09e72..4f63dca1e 100755 --- a/source/de/anomic/crawler/ZURL.java +++ b/source/de/anomic/crawler/ZURL.java @@ -58,7 +58,7 @@ public class ZURL { ); // the class object - private final ObjectIndex urlIndex; + protected final ObjectIndex urlIndex; private final LinkedList stack; public ZURL(final File cachePath, final String tablename, final boolean startWithEmptyFile) { diff --git a/source/de/anomic/data/diff.java b/source/de/anomic/data/diff.java index 83ae0ce0b..9222dd9a1 100644 --- a/source/de/anomic/data/diff.java +++ b/source/de/anomic/data/diff.java @@ -37,9 +37,9 @@ import de.anomic.htmlFilter.htmlFilterCharacterCoding; */ public class diff { - private final ArrayList parts = new ArrayList(); - private final Object[] o; - private final Object[] n; + private final ArrayList parts = new ArrayList(); + protected final Object[] o; + protected final Object[] n; /** * @param o the original String diff --git a/source/de/anomic/http/httpdFileHandler.java b/source/de/anomic/http/httpdFileHandler.java index be61b3ce1..4b9925233 100644 --- a/source/de/anomic/http/httpdFileHandler.java +++ b/source/de/anomic/http/httpdFileHandler.java @@ -115,7 +115,7 @@ public final class httpdFileHandler { private static File htDefaultPath = null; private static File htLocalePath = null; - private static final class TemplateCacheEntry { + protected static final class TemplateCacheEntry { Date lastModified; byte[] content; } diff --git a/source/de/anomic/kelondro/blob/ArrayStack.java b/source/de/anomic/kelondro/blob/ArrayStack.java index b9bd33503..6879c678d 100755 --- a/source/de/anomic/kelondro/blob/ArrayStack.java +++ b/source/de/anomic/kelondro/blob/ArrayStack.java @@ -78,16 +78,16 @@ public class ArrayStack implements BLOB { public static final long oneMonth = 1000L * 60L * 60L * 24L * 365L / 12L; - private int keylength; - private ByteOrder ordering; - private File heapLocation; - private long fileAgeLimit; - private long fileSizeLimit; - private long repositoryAgeMax; - private long repositorySizeMax; - private List blobs; - private String prefix; - private int buffersize; + protected int keylength; + protected ByteOrder ordering; + private File heapLocation; + private long fileAgeLimit; + private long fileSizeLimit; + private long repositoryAgeMax; + private long repositorySizeMax; + protected List blobs; + private String prefix; + private int buffersize; // the thread pool for the keeperOf executor service private ExecutorService executor; diff --git a/source/de/anomic/kelondro/index/HandleMap.java b/source/de/anomic/kelondro/index/HandleMap.java index df7d5c823..05125e6de 100644 --- a/source/de/anomic/kelondro/index/HandleMap.java +++ b/source/de/anomic/kelondro/index/HandleMap.java @@ -54,8 +54,8 @@ import de.anomic.yacy.dht.FlatWordPartitionScheme; public class HandleMap implements Iterable { - private final Row rowdef; - private ObjectIndexCache index; + private final Row rowdef; + protected ObjectIndexCache index; /** * initialize a HandleMap @@ -296,7 +296,8 @@ public class HandleMap implements Iterable { this.l = l; } } - private static final entry poisonEntry = new entry(new byte[0], 0); + + protected static final entry poisonEntry = new entry(new byte[0], 0); public static class initDataConsumer implements Callable { diff --git a/source/de/anomic/kelondro/index/RowSet.java b/source/de/anomic/kelondro/index/RowSet.java index bda0c4c1c..2f4118927 100644 --- a/source/de/anomic/kelondro/index/RowSet.java +++ b/source/de/anomic/kelondro/index/RowSet.java @@ -230,7 +230,7 @@ public class RowSet extends RowCollection implements ObjectIndex, Iterable { - public final static boolean accessOrder = false; // if false, then a insertion-order is used - private int cacheSize; - private Map levelA, levelB; + public final static boolean accessOrder = false; // if false, then a insertion-order is used + + protected int cacheSize; + private Map levelA, levelB; public SimpleARC(int cacheSize) { this.cacheSize = cacheSize / 2; diff --git a/source/de/anomic/kelondro/order/Digest.java b/source/de/anomic/kelondro/order/Digest.java index 0ef791d75..b868dc8d6 100644 --- a/source/de/anomic/kelondro/order/Digest.java +++ b/source/de/anomic/kelondro/order/Digest.java @@ -199,10 +199,10 @@ public class Digest { private static class md5FilechunkConsumer implements Callable { - private BlockingQueue empty; - private BlockingQueue filed; - private static filechunk poison = new filechunk(0); - private MessageDigest digest; + private BlockingQueue empty; + private BlockingQueue filed; + protected static filechunk poison = new filechunk(0); + private MessageDigest digest; public md5FilechunkConsumer(int bufferSize, int bufferCount) { empty = new ArrayBlockingQueue(bufferCount); diff --git a/source/de/anomic/kelondro/table/Stack.java b/source/de/anomic/kelondro/table/Stack.java index b4058d1a2..596bf19b3 100644 --- a/source/de/anomic/kelondro/table/Stack.java +++ b/source/de/anomic/kelondro/table/Stack.java @@ -207,7 +207,7 @@ public final class Stack extends Records { return row().newEntry(n.getValueRow()); } - private void unlinkNode(final Node n) throws IOException { + protected void unlinkNode(final Node n) throws IOException { // join chaines over node final Records.Handle l = n.getOHHandle(left); final Records.Handle r = n.getOHHandle(right); diff --git a/source/de/anomic/kelondro/table/Table.java b/source/de/anomic/kelondro/table/Table.java index e29099412..429e37d5c 100644 --- a/source/de/anomic/kelondro/table/Table.java +++ b/source/de/anomic/kelondro/table/Table.java @@ -73,16 +73,16 @@ public class Table implements ObjectIndex { public static final int tailCacheForceUsage = 1; public static final int tailCacheUsageAuto = 2; - public static final long maxarraylength = 134217727L; // that may be the maxmimum size of array length in some JVMs - private static final long minmemremaining = 20 * 1024 * 1024; // if less than this memory is remaininig, the memory copy of a table is abandoned - private RowSet table; - private HandleMap index; - private BufferedEcoFS file; - private Row rowdef; - private int fail; - private File tablefile; - private Row taildef; - private final int buffersize; + public static final long maxarraylength = 134217727L; // that may be the maxmimum size of array length in some JVMs + private static final long minmemremaining = 20 * 1024 * 1024; // if less than this memory is remaininig, the memory copy of a table is abandoned + private int fail; + private final int buffersize; + protected HandleMap index; + protected BufferedEcoFS file; + protected Row rowdef; + protected File tablefile; + protected RowSet table; + protected Row taildef; public Table(final File tablefile, final Row rowdef, final int useTailCache, final int buffersize, final int initialSpace) { this.tablefile = tablefile; diff --git a/source/de/anomic/kelondro/text/IODispatcher.java b/source/de/anomic/kelondro/text/IODispatcher.java index fbff48e2c..9fac1c40f 100644 --- a/source/de/anomic/kelondro/text/IODispatcher.java +++ b/source/de/anomic/kelondro/text/IODispatcher.java @@ -48,13 +48,13 @@ import de.anomic.yacy.logging.Log; */ public class IODispatcher extends Thread { - private Semaphore controlQueue; - private Semaphore termination; - private ArrayBlockingQueue mergeQueue; - private ArrayBlockingQueue> dumpQueue; + private Semaphore controlQueue; + private Semaphore termination; + private ArrayBlockingQueue mergeQueue; + private ArrayBlockingQueue> dumpQueue; //private ReferenceFactory factory; - private boolean terminate; - private int writeBufferSize; + private boolean terminate; + protected int writeBufferSize; public IODispatcher(int dumpQueueLength, int mergeQueueLength, int writeBufferSize) { this.termination = new Semaphore(0); diff --git a/source/de/anomic/kelondro/text/MetadataRepository.java b/source/de/anomic/kelondro/text/MetadataRepository.java index 90bcc6362..9fad18f5e 100644 --- a/source/de/anomic/kelondro/text/MetadataRepository.java +++ b/source/de/anomic/kelondro/text/MetadataRepository.java @@ -58,10 +58,10 @@ import de.anomic.yacy.logging.Log; public final class MetadataRepository implements Iterable { // class objects - private ObjectIndex urlIndexFile; - private Export exportthread; // will have a export thread assigned if exporter is running - private File location; - private ArrayList statsDump; + protected ObjectIndex urlIndexFile; + private Export exportthread; // will have a export thread assigned if exporter is running + private File location; + private ArrayList statsDump; public MetadataRepository(final File path) { this.location = path; diff --git a/source/de/anomic/kelondro/text/ReferenceContainer.java b/source/de/anomic/kelondro/text/ReferenceContainer.java index b193cce04..9315b6348 100644 --- a/source/de/anomic/kelondro/text/ReferenceContainer.java +++ b/source/de/anomic/kelondro/text/ReferenceContainer.java @@ -50,8 +50,8 @@ import de.anomic.kelondro.util.ByteBuffer; */ public class ReferenceContainer extends RowSet { - private byte[] termHash; - private ReferenceFactory factory; + private byte[] termHash; + protected ReferenceFactory factory; public ReferenceContainer(final ReferenceFactory factory, final byte[] termHash, final RowSet collection) { super(collection); diff --git a/source/de/anomic/kelondro/text/ReferenceContainerArray.java b/source/de/anomic/kelondro/text/ReferenceContainerArray.java index a6dfe994d..b4a121f5a 100644 --- a/source/de/anomic/kelondro/text/ReferenceContainerArray.java +++ b/source/de/anomic/kelondro/text/ReferenceContainerArray.java @@ -40,10 +40,10 @@ import de.anomic.yacy.logging.Log; public final class ReferenceContainerArray { - private final ReferenceFactory factory; - private final Row payloadrow; - private final ArrayStack array; - private final IODispatcher merger; + protected final ReferenceFactory factory; + protected final Row payloadrow; + protected final ArrayStack array; + private final IODispatcher merger; /** * open a index container based on a BLOB dump. The content of the BLOB will not be read @@ -128,7 +128,7 @@ public final class ReferenceContainerArray { // plus the mentioned features private final boolean rot; - private CloneableIterator iterator; + protected CloneableIterator iterator; public heapCacheIterator(final byte[] startWordHash, final boolean rot) throws IOException { this.rot = rot; diff --git a/source/de/anomic/kelondro/text/ReferenceContainerCache.java b/source/de/anomic/kelondro/text/ReferenceContainerCache.java index 6732e1e7b..51f2aa529 100644 --- a/source/de/anomic/kelondro/text/ReferenceContainerCache.java +++ b/source/de/anomic/kelondro/text/ReferenceContainerCache.java @@ -48,9 +48,9 @@ import de.anomic.yacy.logging.Log; public final class ReferenceContainerCache extends AbstractIndex implements Index, IndexReader, Iterable> { - private final Row payloadrow; - private final ByteOrder termOrder; - private Map> cache; + private final Row payloadrow; + private final ByteOrder termOrder; + protected Map> cache; /** * opens an existing heap file in undefined mode diff --git a/source/de/anomic/kelondro/text/Segment.java b/source/de/anomic/kelondro/text/Segment.java index c715ac78e..0e854532c 100644 --- a/source/de/anomic/kelondro/text/Segment.java +++ b/source/de/anomic/kelondro/text/Segment.java @@ -68,12 +68,12 @@ public final class Segment { public static final ReferenceFactory navigationReferenceFactory = new NavigationReferenceFactory(); public static final ByteOrder wordOrder = Base64Order.enhancedCoder; - private final Log log; - private final IndexCell termIndex; - private final IndexCell authorNavIndex; - private final MetadataRepository urlMetadata; - private final File segmentPath; - private final IODispatcher merger; + private final Log log; + protected final IndexCell termIndex; + private final IndexCell authorNavIndex; + protected final MetadataRepository urlMetadata; + private final File segmentPath; + private final IODispatcher merger; public Segment( final Log log, diff --git a/source/de/anomic/net/UPnP.java b/source/de/anomic/net/UPnP.java index 83532d338..e54243906 100644 --- a/source/de/anomic/net/UPnP.java +++ b/source/de/anomic/net/UPnP.java @@ -177,7 +177,7 @@ public class UPnP { // DiscoveryAdvertisement.getInstance().unRegisterEvent(DiscoveryAdvertisement.EVENT_SSDP_BYE_BYE, devicetype, handler); } - private static class Handler implements DiscoveryEventHandler { + protected static class Handler implements DiscoveryEventHandler { public void eventSSDPAlive(String usn, String udn, String nt, String maxAge, URL location) { InternetGatewayDevice[] newIGD = { null }; diff --git a/source/de/anomic/server/serverCore.java b/source/de/anomic/server/serverCore.java index 506a44bcb..7d36b0bfc 100644 --- a/source/de/anomic/server/serverCore.java +++ b/source/de/anomic/server/serverCore.java @@ -84,13 +84,13 @@ public final class serverCore extends serverAbstractBusyThread implements server /** * Line End of HTTP/ICAP headers */ - public static final byte[] CRLF = {CR, LF}; - public static final String CRLF_STRING = new String(CRLF); - public static final String LF_STRING = new String(new byte[]{LF}); - public static final Class[] stringType = {"".getClass()}; // set up some reflection - public static final long startupTime = System.currentTimeMillis(); - public static final ThreadGroup sessionThreadGroup = new ThreadGroup("sessionThreadGroup"); - private static final HashMap commandObjMethodCache = new HashMap(5); + public static final byte[] CRLF = {CR, LF}; + public static final String CRLF_STRING = new String(CRLF); + public static final String LF_STRING = new String(new byte[]{LF}); + public static final Class[] stringType = {"".getClass()}; // set up some reflection + public static final long startupTime = System.currentTimeMillis(); + public static final ThreadGroup sessionThreadGroup = new ThreadGroup("sessionThreadGroup"); + protected static final HashMap commandObjMethodCache = new HashMap(5); /** * will be increased with each session and is used to return a hash code diff --git a/source/de/anomic/tools/DidYouMean.java b/source/de/anomic/tools/DidYouMean.java index ab7e984e5..e9b490214 100644 --- a/source/de/anomic/tools/DidYouMean.java +++ b/source/de/anomic/tools/DidYouMean.java @@ -28,16 +28,16 @@ import de.anomic.yacy.logging.Log; */ public class DidYouMean { - private static final char[] alphabet = {'a','b','c','d','e','f','g','h','i','j','k','l','m','n','o','p', + protected static final char[] alphabet = {'a','b','c','d','e','f','g','h','i','j','k','l','m','n','o','p', 'q','r','s','t','u','v','w','x','y','z','\u00e4','\u00f6','\u00fc','\u00df'}; public static final int availableCPU = Runtime.getRuntime().availableProcessors(); final LinkedBlockingQueue queue = new LinkedBlockingQueue(); - private final Set set; - private final IndexCell index; - private String word; - private int len; + protected final Set set; + protected final IndexCell index; + protected String word; + protected int len; /** @@ -140,7 +140,7 @@ public class DidYouMean { * based on the given alphabet and puts it on the blocking queue, to be 'consumed' by a consumer thread.

* Note: the loop runs (alphabet.length * len) tests. */ - private class ChangingOneLetter extends Thread { + public class ChangingOneLetter extends Thread { public void run() { String s; @@ -161,7 +161,7 @@ public class DidYouMean { * and puts it on the blocking queue, to be 'consumed' by a consumer thread.

* Note: the loop runs (len) tests. */ - private class DeletingOneLetter extends Thread { + protected class DeletingOneLetter extends Thread { public void run() { String s; @@ -180,7 +180,7 @@ public class DidYouMean { * based on the given alphabet and puts it on the blocking queue, to be 'consumed' by a consumer thread.

* Note: the loop runs (alphabet.length * len) tests. */ - private class AddingOneLetter extends Thread { + protected class AddingOneLetter extends Thread { public void run() { String s; @@ -201,7 +201,7 @@ public class DidYouMean { * and puts it on the blocking queue, to be 'consumed' by a consumer thread.

* Note: the loop runs (len-1) tests. */ - private class ReversingTwoConsecutiveLetters extends Thread { + protected class ReversingTwoConsecutiveLetters extends Thread { public void run() { String s; @@ -245,7 +245,7 @@ public class DidYouMean { * wordSizeComparator is used by DidYouMean to order terms by index.count()

* Warning: this causes heavy i/o */ - private class wordSizeComparator implements Comparator { + protected class wordSizeComparator implements Comparator { public int compare(final String o1, final String o2) { final Integer i1 = index.count(Word.word2hash(o1)); final Integer i2 = index.count(Word.word2hash(o2)); diff --git a/source/de/anomic/tools/mediawikiIndex.java b/source/de/anomic/tools/mediawikiIndex.java index b4149e84b..f58a6c587 100644 --- a/source/de/anomic/tools/mediawikiIndex.java +++ b/source/de/anomic/tools/mediawikiIndex.java @@ -79,15 +79,15 @@ public class mediawikiIndex extends Thread { private static final byte[] pagestartb = pagestart.getBytes(); private static final byte[] pageendb = pageend.getBytes(); - private wikiParser wparser; - private plasmaParser hparser; - private String urlStub; - public File sourcefile; - public File targetdir; - public int count; - private long start; - private long docsize; - private int approxdocs; + protected wikiParser wparser; + protected plasmaParser hparser; + protected String urlStub; + public File sourcefile; + public File targetdir; + public int count; + private long start; + private long docsize; + private int approxdocs; private static final int docspermbinxmlbz2 = 800; // documents per megabyte in a xml.bz2 wikimedia dump @@ -328,7 +328,7 @@ public class mediawikiIndex extends Thread { private BlockingQueue entries; PrintWriter out; - private static wikisourcerecord poison = new wikisourcerecord("", 0, 0); + protected static wikisourcerecord poison = new wikisourcerecord("", 0, 0); int count; public indexProducer(int bufferCount, File indexFile) throws IOException { @@ -375,10 +375,10 @@ public class mediawikiIndex extends Thread { private static class wikiConsumer implements Callable { - private BlockingQueue entries; - private static wikiraw poison = new wikiraw(new byte[0], 0, 0); - private indexProducer producer; - private int count; + private BlockingQueue entries; + protected static wikiraw poison = new wikiraw(new byte[0], 0, 0); + private indexProducer producer; + private int count; public wikiConsumer(int bufferCount, indexProducer producer) { entries = new ArrayBlockingQueue(bufferCount); diff --git a/source/de/anomic/yacy/Tray.java b/source/de/anomic/yacy/Tray.java index 76d7cdd72..43dbc6b67 100644 --- a/source/de/anomic/yacy/Tray.java +++ b/source/de/anomic/yacy/Tray.java @@ -43,7 +43,7 @@ import de.anomic.server.serverSystem; public final class Tray { - private static plasmaSwitchboard sb; + protected static plasmaSwitchboard sb; private static nativeTrayIcon ti; private static boolean isIntegrated; // browser integration @@ -142,7 +142,7 @@ public final class Tray { } - private static void trayClickAction(){ //doubleclick + protected static void trayClickAction(){ //doubleclick if (lockBrowserPopup) { String label; if(deutsch) label = "Bitte warten bis YaCy gestartet ist."; @@ -153,7 +153,7 @@ public final class Tray { } } - private static void openBrowser(final String browserPopUpPage){ + protected static void openBrowser(final String browserPopUpPage){ if(isIntegrated) return; // no need for https, because we are on localhost serverSystem.openBrowser("http://localhost:" + sb.getConfig("port", "8080") + "/" + browserPopUpPage); diff --git a/source/de/anomic/yacy/dht/PeerSelection.java b/source/de/anomic/yacy/dht/PeerSelection.java index efb0c3533..474f751b8 100755 --- a/source/de/anomic/yacy/dht/PeerSelection.java +++ b/source/de/anomic/yacy/dht/PeerSelection.java @@ -242,7 +242,7 @@ public class PeerSelection { * @param minVersion * @return */ - private static Iterator getDHTSeeds(yacySeedDB seedDB, final byte[] firstHash, final float minVersion) { + protected static Iterator getDHTSeeds(yacySeedDB seedDB, final byte[] firstHash, final float minVersion) { // enumerates seed-type objects: all seeds with starting point in the middle, rotating at the end/beginning return new seedDHTEnum(seedDB, firstHash, minVersion); } diff --git a/source/de/anomic/yacy/dht/Transmission.java b/source/de/anomic/yacy/dht/Transmission.java index 866ae42fd..afe9fa20c 100644 --- a/source/de/anomic/yacy/dht/Transmission.java +++ b/source/de/anomic/yacy/dht/Transmission.java @@ -46,12 +46,12 @@ import de.anomic.yacy.logging.Log; public class Transmission { - private Log log; - private MetadataRepository repository; - private yacySeedDB seeds; - private Index backend; - private boolean gzipBody4Transfer; - private int timeout4Transfer; + protected Log log; + protected MetadataRepository repository; + protected yacySeedDB seeds; + protected boolean gzipBody4Transfer; + protected int timeout4Transfer; + protected Index backend; public Transmission( Log log, diff --git a/source/de/anomic/yacy/logging/Log.java b/source/de/anomic/yacy/logging/Log.java index ec3f1ec27..025da6205 100644 --- a/source/de/anomic/yacy/logging/Log.java +++ b/source/de/anomic/yacy/logging/Log.java @@ -301,9 +301,9 @@ public final class Log { } } - private static logEntry poison = new logEntry(); - private static BlockingQueue logQueue = new LinkedBlockingQueue(); - private static logRunner logRunnerThread = null; + protected static logEntry poison = new logEntry(); + protected static BlockingQueue logQueue = new LinkedBlockingQueue(); + private static logRunner logRunnerThread = null; protected static class logRunner extends Thread { public logRunner() {