Class SubscriptionSchedulerImpl

java.lang.Object

com.biglybt.core.subs.impl.SubscriptionSchedulerImpl

All Implemented Interfaces:

SubscriptionManagerListener, SubscriptionScheduler

public class SubscriptionSchedulerImpl
extends Object
implements SubscriptionScheduler, SubscriptionManagerListener

Field Summary

Fields

Modifier and Type	Field	Description
private Set<String>	active_result_downloaders
private Map<Subscription, List<AESemaphore>>	active_subscription_downloaders
private FrequencyLimitedDispatcher	calculateScheduleDispatcher
private static final int	FAIL_INIT_DELAY
private static final int	FAIL_MAX_DELAY
private String	last_sched_str
private long	last_schedule
private SubscriptionManagerImpl	manager
private Map<String,Long>	rate_limit_map
private ThreadPool<AERunnable>	result_downloader
private TimerEvent	schedule_event
private boolean	schedule_in_progress
private static final Object	SCHEDULER_FAILED_SCAN_CONSEC_KEY
private static final Object	SCHEDULER_FAILED_SCAN_TIME_KEY
private static final Object	SCHEDULER_NEXT_SCAN_KEY
private boolean	schedulng_permitted

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SubscriptionSchedulerImpl(SubscriptionManagerImpl _manager)

Method Summary

Modifier and Type	Method	Description
void	associationsChanged(byte[] association_hash)
protected void	calculateSchedule()
boolean	download(Subscription subs, boolean is_auto)
void	download(Subscription subs, boolean is_auto, SubscriptionDownloadListener listener)
void	download(Subscription subs, SubscriptionResult original_result)
void	downloadAsync(Subscription subs, boolean is_auto)
protected long	getNextScan(Subscription sub)
long	getNextUpdateTime(Subscription subs)
protected void	log(String str)
protected void	log(String str, Throwable e)
protected void	scanFailed(Subscription sub)
protected void	scanSuccess(Subscription sub)
protected void	schedule()
void	subscriptionAdded(Subscription subscription)
void	subscriptionChanged(Subscription subscription, int reason)
void	subscriptionRemoved(Subscription subscription)
void	subscriptionRequested(SearchProvider sp, Map<String,Object> properties)
void	subscriptionRequested(URL url, Map<String,Object> options)
void	subscriptionSelected(Subscription subscription)

Methods inherited from class Object

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

Field Details

SCHEDULER_NEXT_SCAN_KEY

private static final Object SCHEDULER_NEXT_SCAN_KEY

SCHEDULER_FAILED_SCAN_CONSEC_KEY

private static final Object SCHEDULER_FAILED_SCAN_CONSEC_KEY

SCHEDULER_FAILED_SCAN_TIME_KEY

private static final Object SCHEDULER_FAILED_SCAN_TIME_KEY

FAIL_INIT_DELAY

private static final int FAIL_INIT_DELAY

See Also:

• Constant Field Values

FAIL_MAX_DELAY

private static final int FAIL_MAX_DELAY

See Also:

• Constant Field Values

manager

private SubscriptionManagerImpl manager

active_subscription_downloaders

private Map<Subscription, List<AESemaphore>> active_subscription_downloaders

rate_limit_map

private Map<String,Long> rate_limit_map

active_result_downloaders

private Set<String> active_result_downloaders

result_downloader

private ThreadPool<AERunnable> result_downloader

schedulng_permitted

private boolean schedulng_permitted

schedule_event

private TimerEvent schedule_event

schedule_in_progress

private boolean schedule_in_progress

last_schedule

private long last_schedule

last_sched_str

private String last_sched_str

calculateScheduleDispatcher

private FrequencyLimitedDispatcher calculateScheduleDispatcher

Constructor Details

SubscriptionSchedulerImpl

protected SubscriptionSchedulerImpl(SubscriptionManagerImpl _manager)

Method Details

downloadAsync

public void downloadAsync(Subscription subs,
 boolean is_auto)
                   throws SubscriptionException

Specified by:

downloadAsync in interface SubscriptionScheduler

Throws:

SubscriptionException

download

public void download(Subscription subs,
 boolean is_auto,
 SubscriptionDownloadListener listener)

Specified by:

download in interface SubscriptionScheduler

download

public boolean download(Subscription subs,
 boolean is_auto)
                 throws SubscriptionException

Specified by:

download in interface SubscriptionScheduler

Throws:

SubscriptionException

download

public void download(Subscription subs,
 SubscriptionResult original_result)

Specified by:

download in interface SubscriptionScheduler

calculateSchedule

protected void calculateSchedule()

schedule

protected void schedule()

getNextScan

protected long getNextScan(Subscription sub)

getNextUpdateTime

public long getNextUpdateTime(Subscription subs)

Specified by:

getNextUpdateTime in interface SubscriptionScheduler

scanSuccess

protected void scanSuccess(Subscription sub)

scanFailed

protected void scanFailed(Subscription sub)

log

protected void log(String str)

log

protected void log(String str,
 Throwable e)

subscriptionAdded

public void subscriptionAdded(Subscription subscription)

Specified by:

subscriptionAdded in interface SubscriptionManagerListener

subscriptionChanged

public void subscriptionChanged(Subscription subscription,
 int reason)

Specified by:

subscriptionChanged in interface SubscriptionManagerListener

subscriptionSelected

public void subscriptionSelected(Subscription subscription)

Specified by:

subscriptionSelected in interface SubscriptionManagerListener

subscriptionRemoved

public void subscriptionRemoved(Subscription subscription)

Specified by:

subscriptionRemoved in interface SubscriptionManagerListener

associationsChanged

public void associationsChanged(byte[] association_hash)

Specified by:

associationsChanged in interface SubscriptionManagerListener

subscriptionRequested

public void subscriptionRequested(URL url,
 Map<String,Object> options)

Specified by:

subscriptionRequested in interface SubscriptionManagerListener

subscriptionRequested

public void subscriptionRequested(SearchProvider sp,
 Map<String,Object> properties)
                           throws SubscriptionException

Throws:

SubscriptionException