com.aelitis.azureus.core.content
Class RelatedContentSearcher

java.lang.Object
  extended by 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)