org.torproject.metrics.collector.bridgepools

Class BridgePoolAssignmentsProcessor

java.lang.Object

org.torproject.metrics.collector.sync.SyncManager

org.torproject.metrics.collector.cron.CollecTorMain

org.torproject.metrics.collector.bridgepools.BridgePoolAssignmentsProcessor

All Implemented Interfaces:

java.lang.Runnable, java.util.concurrent.Callable<java.lang.Object>

public class BridgePoolAssignmentsProcessor
extends CollecTorMain

Field Summary

Fields inherited from class org.torproject.metrics.collector.cron.CollecTorMain

config, mapPathDescriptors, SOURCES

Fields inherited from class org.torproject.metrics.collector.sync.SyncManager

SYNCORIGINS

Constructor Summary

Constructors

Constructor and Description
BridgePoolAssignmentsProcessor(Configuration config) Initialize this class with the given configuration.

Method Summary

Modifier and Type	Method and Description
void	cleanUpDirectories() Delete all files from the rsync (out) directory that have not been modified in the last three days (seven weeks).
java.lang.String	module() Return the module identifier.
protected void	startProcessing() Start processing files, which includes reading original, not-yet-sanitized bridge pool assignment files from disk, splitting them into bridge pool assignment descriptors, sanitizing contained fingerprints, and writing sanitized bridge pool assignments to disk.
protected java.lang.String	syncMarker() Return the synchronization marker.

Methods inherited from class org.torproject.metrics.collector.cron.CollecTorMain

call, checkAvailableSpace, readProcessedFiles, run, syncMapPathsDescriptors, writeProcessedFiles

Methods inherited from class org.torproject.metrics.collector.sync.SyncManager

merge

Methods inherited from class java.lang.Object

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

Constructor Detail

BridgePoolAssignmentsProcessor

public BridgePoolAssignmentsProcessor(Configuration config)

Initialize this class with the given configuration.

Method Detail

module

public java.lang.String module()

Return the module identifier.

Specified by:

module in class CollecTorMain

Returns:

Module identifier.

syncMarker

protected java.lang.String syncMarker()

Return the synchronization marker.

Specified by:

syncMarker in class CollecTorMain

Returns:

Synchronization marker.

startProcessing

protected void startProcessing()
                        throws ConfigurationException

Start processing files, which includes reading original, not-yet-sanitized bridge pool assignment files from disk, splitting them into bridge pool assignment descriptors, sanitizing contained fingerprints, and writing sanitized bridge pool assignments to disk.

Specified by:

startProcessing in class CollecTorMain

Throws:

ConfigurationException - Thrown if configuration values cannot be obtained.

cleanUpDirectories

public void cleanUpDirectories()

Delete all files from the rsync (out) directory that have not been modified in the last three days (seven weeks).