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, DistributedDatabaseTransferType _transfer_type, DHTPluginInterface _dht_plugin, boolean _defer_ddb_check)

Method Summary

protected DHTPluginInterface	getDHTPlugin()
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, int min_seeds, int min_leechers, SearchObserver _observer)
protected BloomFilter	sendRemoteUpdate(com.aelitis.azureus.core.content.RelatedContentSearcher.ForeignBloom f_bloom)
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,
                                 DistributedDatabaseTransferType _transfer_type,
                                 DHTPluginInterface _dht_plugin,
                                 boolean _defer_ddb_check)

Method Detail

getDHTPlugin

protected DHTPluginInterface getDHTPlugin()

timerTick

protected void timerTick(boolean enabled,
                         int tick_count)

searchRCM

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

Throws:

SearchException

sendRemoteSearch

protected List<DistributedDatabaseContact> sendRemoteSearch(SearchInstance si,
                                                            Set<String> hashes_sync_me,
                                                            DistributedDatabaseContact contact,
                                                            String term,
                                                            int min_seeds,
                                                            int min_leechers,
                                                            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)