Package com.biglybt.core.global.impl
Class GlobalManagerFileMerger
- java.lang.Object
-
- com.biglybt.core.global.impl.GlobalManagerFileMerger
-
- All Implemented Interfaces:
AEDiagnosticsEvidenceGenerator
public class GlobalManagerFileMerger extends java.lang.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) java.util.Map<HashWrapper,DownloadManager>
dm_map
(package private) boolean
enabled
(package private) boolean
enabled_extended
private static int
FORCE_PIECE_TIMER_PERIOD
private static int
FORCE_PIECE_TIMER_TICKS
private GlobalManagerImpl
gm
private static int
HASH_FAILS_BEFORE_QUIT
(package private) boolean
initialised
private LoggerChannel
log
private boolean
logging_paused
(package private) static java.lang.Object
merged_data_lock
(package private) int
min_pieces
private static java.lang.String
ORIGINATOR_PREFIX
(package private) AsyncDispatcher
read_write_dispatcher
(package private) java.util.List<GlobalManagerFileMerger.SameSizeFiles>
sames
(package private) java.util.Set<DownloadManager>
sames_dms
(package private) AsyncDispatcher
sync_dispatcher
private static int
SYNC_TIMER_PERIOD
private static int
SYNC_TIMER_TICKS
private TimerEventPeriodic
timer_event
private static int
TIMER_PERIOD
(package private) int
tolerance
-
Constructor Summary
Constructors Modifier Constructor Description protected
GlobalManagerFileMerger(GlobalManagerImpl _gm)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
generate(IndentWriter writer)
protected java.lang.String
getSwarmMergingInfo(DownloadManager dm)
(package private) void
initialise()
protected boolean
isSwarmMergingZ(DownloadManager dm)
(package private) void
log(IndentWriter writer, java.lang.String str)
(package private) void
log(java.lang.String str)
private void
logCurrentState(IndentWriter write)
(package private) void
logSupport(java.lang.String str)
(package private) void
setLoggingPaused(boolean b)
(package private) void
syncFileSets(boolean force)
-
-
-
Field Detail
-
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 java.lang.String ORIGINATOR_PREFIX
- See Also:
- Constant Field Values
-
merged_data_lock
static final java.lang.Object merged_data_lock
-
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 java.util.Map<HashWrapper,DownloadManager> dm_map
-
sames
final java.util.List<GlobalManagerFileMerger.SameSizeFiles> sames
-
sames_dms
final java.util.Set<DownloadManager> sames_dms
-
read_write_dispatcher
final AsyncDispatcher read_write_dispatcher
-
sync_dispatcher
final AsyncDispatcher sync_dispatcher
-
timer_event
private TimerEventPeriodic timer_event
-
-
Constructor Detail
-
GlobalManagerFileMerger
protected GlobalManagerFileMerger(GlobalManagerImpl _gm)
-
-
Method Detail
-
initialise
void initialise()
-
setLoggingPaused
void setLoggingPaused(boolean b)
-
log
void log(java.lang.String str)
-
log
void log(IndentWriter writer, java.lang.String str)
-
logSupport
void logSupport(java.lang.String str)
-
isSwarmMergingZ
protected boolean isSwarmMergingZ(DownloadManager dm)
-
getSwarmMergingInfo
protected java.lang.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 interfaceAEDiagnosticsEvidenceGenerator
-
-