class RadioactivityRedisIncidentStorage in Radioactivity 7.2

@file Memcached incident storage class

Hierarchy

• class \RadioactivityIncidentStorage
  • class \RadioactivityRedisIncidentStorage

File

includes/RadioactivityRedisIncidentStorage.inc, line 7

Memcached incident storage class

class RadioactivityRedisIncidentStorage extends RadioactivityIncidentStorage {

  /**
   * Constructor
   */
  public function __construct() {
  }

  /**
   * Connect to the memcache server
   */
  private function connect() {
    $redis = new Redis();
    $port = VAR_RADIOACTIVITY_REDIS_PORT;
    if (!empty($port)) {
      $redis
        ->connect(VAR_RADIOACTIVITY_REDIS_HOST, VAR_RADIOACTIVITY_REDIS_PORT);
    }
    else {
      $redis
        ->connect(VAR_RADIOACTIVITY_REDIS_HOST);
    }
    return $redis;
  }

  /**
   * Add incident to cache
   */
  public function addIncident(RadioactivityIncident $incident) {
    if (!($rc = $this
      ->connect())) {
      return;
    }
    $i = $rc
      ->get("radioactivity_top");
    if (!$i) {
      $i = 0;
    }
    $rc
      ->set("radioactivity_top", $i + 1);
    $rc
      ->set("radioactivity_incident_" . $i, serialize($incident));
  }

  /**
   * Process incidents in the deferred queue
   */
  public function processIncidents() {
    $rc = $this
      ->connect();
    if (!$rc) {
      return;
    }
    $i = 0;

    // get and reset top
    $to = $rc
      ->get("radioactivity_top");
    $rc
      ->set("radioactivity_top", 0);
    if (!$to) {
      $to = 0;
    }
    while ($i < $to) {
      $incident = unserialize($rc
        ->get("radioactivity_incident_" . $i));
      if ($incident && $incident
        ->floodCheck()) {
        $incident
          ->updateEnergy();
      }
      $i++;
    }
  }

  /**
   * Does this require boostrapping?
   */
  public function requiresBootstrap() {
    return FALSE;
  }

}

Members

Name	Modifiers	Type	Description	Overrides
RadioactivityIncidentStorage::getDecayProfile	public	function	Get decay profile attached to this instance
RadioactivityRedisIncidentStorage::addIncident	public	function	Add incident to cache Overrides RadioactivityIncidentStorage::addIncident
RadioactivityRedisIncidentStorage::connect	private	function	Connect to the memcache server
RadioactivityRedisIncidentStorage::processIncidents	public	function	Process incidents in the deferred queue Overrides RadioactivityIncidentStorage::processIncidents
RadioactivityRedisIncidentStorage::requiresBootstrap	public	function	Does this require boostrapping? Overrides RadioactivityIncidentStorage::requiresBootstrap
RadioactivityRedisIncidentStorage::__construct	public	function	Constructor Overrides RadioactivityIncidentStorage::__construct