com.aelitis.azureus.core.content
Class RelatedContentSearcher

java.lang.Object
  com.aelitis.azureus.core.content.RelatedContentSearcher

All Implemented Interfaces:

DistributedDatabaseTransferHandler

public class RelatedContentSearcher
extends Object
implements DistributedDatabaseTransferHandler

Constructor Summary

protected

RelatedContentSearcher(RelatedContentManager _manager)

Method Summary

protected List<RelatedContent>	matchContent(String term)
DistributedDatabaseValue	read(DistributedDatabaseContact contact, DistributedDatabaseTransferType type, DistributedDatabaseKey ddb_key)
protected Map<String,Object>	receiveRemoteRequest(DistributedDatabaseContact originator, Map<String,Object> request)
protected SearchInstance	searchRCM(Map<String,Object> search_parameters, SearchObserver _observer)
protected BloomFilter	sendRemoteFetch(DistributedDatabaseContact contact)
protected List<DistributedDatabaseContact>	sendRemoteSearch(SearchInstance si, Set<String> hashes_sync_me, DistributedDatabaseContact contact, String term, SearchObserver observer)
protected BloomFilter	sendRemoteUpdate(com.aelitis.azureus.core.content.RelatedContentSearcher.ForeignBloom f_bloom)
protected void	setDHTPlugin(DHTPlugin _dht_plugin)
protected void	timerTick(boolean enabled, int tick_count)
protected void	updateKeyBloom(RelatedContentManager.ContentCache cc)
DistributedDatabaseValue	write(DistributedDatabaseContact contact, DistributedDatabaseTransferType type, DistributedDatabaseKey key, DistributedDatabaseValue value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RelatedContentSearcher

protected RelatedContentSearcher(RelatedContentManager _manager)

Method Detail

setDHTPlugin

protected void setDHTPlugin(DHTPlugin _dht_plugin)

timerTick

protected void timerTick(boolean enabled,
                         int tick_count)

searchRCM

protected SearchInstance searchRCM(Map<String,Object> search_parameters,
                                   SearchObserver _observer)
                            throws SearchException

Throws:

SearchException

matchContent

protected List<RelatedContent> matchContent(String term)

sendRemoteSearch

protected List<DistributedDatabaseContact> sendRemoteSearch(SearchInstance si,
                                                            Set<String> hashes_sync_me,
                                                            DistributedDatabaseContact contact,
                                                            String term,
                                                            SearchObserver observer)

sendRemoteFetch

protected BloomFilter sendRemoteFetch(DistributedDatabaseContact contact)

sendRemoteUpdate

protected BloomFilter sendRemoteUpdate(com.aelitis.azureus.core.content.RelatedContentSearcher.ForeignBloom f_bloom)

receiveRemoteRequest

protected Map<String,Object> receiveRemoteRequest(DistributedDatabaseContact originator,
                                                  Map<String,Object> request)

read

public DistributedDatabaseValue read(DistributedDatabaseContact contact,
                                     DistributedDatabaseTransferType type,
                                     DistributedDatabaseKey ddb_key)
                              throws DistributedDatabaseException

Specified by:

read in interface DistributedDatabaseTransferHandler

Throws:

DistributedDatabaseException

write

public DistributedDatabaseValue write(DistributedDatabaseContact contact,
                                      DistributedDatabaseTransferType type,
                                      DistributedDatabaseKey key,
                                      DistributedDatabaseValue value)
                               throws DistributedDatabaseException

Specified by:

write in interface DistributedDatabaseTransferHandler

Throws:

DistributedDatabaseException

updateKeyBloom

protected void updateKeyBloom(RelatedContentManager.ContentCache cc)