Class GlobalManagerFileMerger

java.lang.Object

com.biglybt.core.global.impl.GlobalManagerFileMerger

All Implemented Interfaces:

AEDiagnosticsEvidenceGenerator

public class GlobalManagerFileMerger
extends Object
implements AEDiagnosticsEvidenceGenerator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	GlobalManagerFileMerger.DownloadManagerPeerListenerEx
private class	GlobalManagerFileMerger.SameSizeFiles

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Map<HashWrapper, DownloadManager>	dm_map
(package private) boolean	enabled
(package private) boolean	enabled_extended
private static final int	FORCE_PIECE_TIMER_PERIOD
private static final int	FORCE_PIECE_TIMER_TICKS
private final GlobalManagerImpl	gm
private static final int	HASH_FAILS_BEFORE_QUIT
(package private) boolean	initialised
private LoggerChannel	log
private boolean	logging_paused
(package private) static final Object	merged_data_lock
(package private) int	min_pieces
private static final String	ORIGINATOR_PREFIX
(package private) final AsyncDispatcher	read_write_dispatcher
(package private) final CopyOnWriteList<GlobalManagerFileMerger.SameSizeFiles>	sames_cow
(package private) Set<DownloadManager>	sames_dms_cow
(package private) static boolean	switch_to_upload_only_enable
(package private) final AsyncDispatcher	sync_dispatcher
private static final int	SYNC_TIMER_PERIOD
private static final int	SYNC_TIMER_TICKS
private TimerEventPeriodic	timer_event
private static final int	TIMER_PERIOD
(package private) int	tolerance

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GlobalManagerFileMerger(GlobalManagerImpl _gm)

Method Summary

Modifier and Type	Method	Description
void	generate(IndentWriter writer)
protected String	getSwarmMergingInfo(DownloadManager dm)
(package private) void	initialise()
protected boolean	isSwarmMergingZ(DownloadManager dm)
(package private) void	log(IndentWriter writer, String str)
(package private) void	log(String str)
private void	logCurrentState(IndentWriter write)
(package private) void	logSupport(String str)
(package private) void	setLoggingPaused(boolean b)
(package private) void	syncFileSets(boolean force)

Methods inherited from class Object

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

Field Details

HASH_FAILS_BEFORE_QUIT

private static final int HASH_FAILS_BEFORE_QUIT

See Also:

• Constant Field Values

TIMER_PERIOD

private static final int TIMER_PERIOD

See Also:

• Constant Field Values

FORCE_PIECE_TIMER_PERIOD

private static final int FORCE_PIECE_TIMER_PERIOD

See Also:

• Constant Field Values

FORCE_PIECE_TIMER_TICKS

private static final int FORCE_PIECE_TIMER_TICKS

See Also:

• Constant Field Values

SYNC_TIMER_PERIOD

private static final int SYNC_TIMER_PERIOD

See Also:

• Constant Field Values

SYNC_TIMER_TICKS

private static final int SYNC_TIMER_TICKS

See Also:

• Constant Field Values

ORIGINATOR_PREFIX

private static final String ORIGINATOR_PREFIX

See Also:

• Constant Field Values

merged_data_lock

static final Object merged_data_lock

switch_to_upload_only_enable

static volatile boolean switch_to_upload_only_enable

gm

private final GlobalManagerImpl gm

log

private LoggerChannel log

logging_paused

private boolean logging_paused

initialised

boolean initialised

enabled

boolean enabled

enabled_extended

boolean enabled_extended

tolerance

int tolerance

min_pieces

int min_pieces

dm_map

final Map<HashWrapper, DownloadManager> dm_map

sames_cow

final CopyOnWriteList<GlobalManagerFileMerger.SameSizeFiles> sames_cow

sames_dms_cow

volatile Set<DownloadManager> sames_dms_cow

read_write_dispatcher

final AsyncDispatcher read_write_dispatcher

sync_dispatcher

final AsyncDispatcher sync_dispatcher

timer_event

private TimerEventPeriodic timer_event

Constructor Details

GlobalManagerFileMerger

protected GlobalManagerFileMerger(GlobalManagerImpl _gm)

Method Details

initialise

void initialise()

setLoggingPaused

void setLoggingPaused(boolean b)

log

void log(String str)

log

void log(IndentWriter writer,
 String str)

logSupport

void logSupport(String str)

isSwarmMergingZ

protected boolean isSwarmMergingZ(DownloadManager dm)

getSwarmMergingInfo

protected String getSwarmMergingInfo(DownloadManager dm)

syncFileSets

void syncFileSets(boolean force)

logCurrentState

private void logCurrentState(IndentWriter write)

generate

public void generate(IndentWriter writer)

Specified by:

generate in interface AEDiagnosticsEvidenceGenerator