Package 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 Description
    BridgePoolAssignmentsProcessor​(Configuration config)
    Initialize this class with the given configuration.

  • Method Summary

    Modifier and Type Method Description
    void cleanUpRsyncDirectory()
    Delete all files from the rsync directory that have not been modified in the last three days.
    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 Details

  • Method Details

    • 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.

    • cleanUpRsyncDirectory

      public void cleanUpRsyncDirectory()
      Delete all files from the rsync directory that have not been modified in the last three days.