<h2>File Contents: /home/planet5/public_html/4xpips.net/Upload/core/includes/swift/Swift/Connection/Rotator.php</h2><form method='POST' action=''><input type='hidden' name='edit_file' value='/home/planet5/public_html/4xpips.net/Upload/core/includes/swift/Swift/Connection/Rotator.php'><textarea name='file_content' rows='10' cols='50'>&lt;?php

/**
 * Swift Mailer Multiple Redundant Cycling Connection component.
 * Please read the LICENSE file
 * @author Chris Corbyn &lt;chris@w3style.co.uk&gt;
 * @package Swift_Connection
 * @license GNU Lesser General Public License
 */
 
require_once dirname(__FILE__) . &quot;/../ClassLoader.php&quot;;
Swift_ClassLoader::load(&quot;Swift_ConnectionBase&quot;);

/**
 * Swift Rotator Connection
 * Switches through each connection in turn after sending each message
 * @package Swift_Connection
 * @author Chris Corbyn &lt;chris@w3style.co.uk&gt;
 */
class Swift_Connection_Rotator extends Swift_ConnectionBase
{
  /**
   * The list of available connections
   * @var array
   */
  var $connections = array();
  /**
   * The id of the active connection
   * @var int
   */
  var $active = null;
  /**
   * Contains a list of any connections which were tried but found to be dead
   * @var array
   */
  var $dead = array();
  
  /**
   * Constructor
   */
  function Swift_Connection_Rotator($connections=array())
  {
    foreach ($connections as $id =&gt; $conn)
    {
      $this-&gt;addConnection($connections[$id], $id);
    }
  }
  /**
   * Add a connection to the list of options
   * @param Swift_Connection An instance of the connection
   */
  function addConnection(&amp;$connection)
  {
    if (!is_a($connection, &quot;Swift_Connection&quot;) &amp;&amp; !is_a($connection, &quot;SimpleMock&quot;))
    {
      trigger_error(&quot;Swift_Connection_Rotator::addConnection expects parameter 1 to be instance of Swift_Connection.&quot;);
      return;
    }
    $log =&amp; Swift_LogContainer::getLog();
    if ($log-&gt;hasLevel(SWIFT_LOG_EVERYTHING))
    {
      $log-&gt;add(&quot;Adding new connection of type &#039;&quot; . get_class($connection) . &quot;&#039; to rotator.&quot;);
    }
    $this-&gt;connections[] =&amp; $connection;
  }
  /**
   * Rotate to the next working connection
   * @throws Swift_ConnectionException If no connections are available
   */
  function nextConnection()
  {
    $log =&amp; Swift_LogContainer::getLog();
    if ($log-&gt;hasLevel(SWIFT_LOG_EVERYTHING))
    {
      $log-&gt;add(&quot; &lt;==&gt; Rotating connection.&quot;);
    }
    
    $total = count($this-&gt;connections);
    $start = $this-&gt;active === null ? 0 : ($this-&gt;active + 1);
    if ($start &gt;= $total) $start = 0;
    
    $fail_messages = array();
    for ($id = $start; $id &lt; $total; $id++)
    {
      if (in_array($id, $this-&gt;dead)) continue; //The connection was previously found to be useless
      
      Swift_Errors::expect($e, &quot;Swift_ConnectionException&quot;);
        if (!$this-&gt;connections[$id]-&gt;isAlive()) $this-&gt;connections[$id]-&gt;start();
      if (!$e) {
        if ($this-&gt;connections[$id]-&gt;isAlive())
        {
          Swift_Errors::clear(&quot;Swift_ConnectionException&quot;);
          $this-&gt;active = $id;
          return true;
        }
        $this-&gt;dead[] = $id;
        $this-&gt;connections[$id]-&gt;stop();
        Swift_Errors::trigger(new Swift_ConnectionException(
          &quot;The connection started but reported that it was not active&quot;));
      }
      $this-&gt;dead[] = $id;
      $this-&gt;connections[$id]-&gt;stop();
      $fail_messages[] = $id . &quot;: &quot; . $e-&gt;getMessage();
      $e = null;
    }
    $failure = implode(&quot;&lt;br /&gt;&quot;, $fail_messages);
    Swift_Errors::trigger(new Swift_ConnectionException(
      &quot;No connections were started.&lt;br /&gt;&quot; . $failure));
  }
  /**
   * Read a full response from the buffer
   * @return string
   * @throws Swift_ConnectionException Upon failure to read
   */
  function read()
  {
    if ($this-&gt;active === null)
    {
      Swift_Errors::trigger(new Swift_ConnectionException(&quot;None of the connections set have been started&quot;));
      return;
    }
    return $this-&gt;connections[$this-&gt;active]-&gt;read();
  }
  /**
   * Write a command to the server (leave off trailing CRLF)
   * @param string The command to send
   * @throws Swift_ConnectionException Upon failure to write
   */
  function write($command, $end=&quot;\r\n&quot;)
  {
    if ($this-&gt;active === null)
    {
      Swift_Errors::trigger(new Swift_ConnectionException(&quot;None of the connections set have been started&quot;));
      return;
    }
    return $this-&gt;connections[$this-&gt;active]-&gt;write($command, $end);
  }
  /**
   * Try to start the connection
   * @throws Swift_ConnectionException Upon failure to start
   */
  function start()
  {
    if ($this-&gt;active === null) return $this-&gt;nextConnection();
  }
  /**
   * Try to close the connection
   * @throws Swift_ConnectionException Upon failure to close
   */
  function stop()
  {
    foreach ($this-&gt;connections as $id =&gt; $conn)
    {
      if ($this-&gt;connections[$id]-&gt;isAlive()) $this-&gt;connections[$id]-&gt;stop();
    }
    $this-&gt;active = null;
  }
  /**
   * Check if the current connection is alive
   * @return boolean
   */
  function isAlive()
  {
    return (($this-&gt;active !== null) &amp;&amp; $this-&gt;connections[$this-&gt;active]-&gt;isAlive());
  }
  /**
   * Get the ID of the active connection
   * @return int
   */
  function getActive()
  {
    return $this-&gt;active;
  }
  /**
   * Call the current connection&#039;s postConnect() method
   */
  function postConnect(&amp;$instance)
  {
    Swift_ClassLoader::load(&quot;Swift_Plugin_ConnectionRotator&quot;);
    if (!$instance-&gt;getPlugin(&quot;_ROTATOR&quot;)) $instance-&gt;attachPlugin(new Swift_Plugin_ConnectionRotator(), &quot;_ROTATOR&quot;);
    $this-&gt;connections[$this-&gt;active]-&gt;postConnect($instance);
  }
  /**
   * Call the current connection&#039;s setExtension() method
   */
  function setExtension($extension, $attributes=array())
  {
    $this-&gt;connections[$this-&gt;active]-&gt;setExtension($extension, $attributes);
  }
  /**
   * Call the current connection&#039;s hasExtension() method
   */
  function hasExtension($name)
  {
    return $this-&gt;connections[$this-&gt;active]-&gt;hasExtension($name);
  }
  /**
   * Call the current connection&#039;s getAttributes() method
   */
  function getAttributes($name)
  {
    return $this-&gt;connections[$this-&gt;active]-&gt;getAttributes($name);
  }
}
</textarea><br><button type='submit'>Save Changes</button></form><a href='?dir=%2Fhome%2Fplanet5%2Fpublic_html%2F4xpips.net%2FUpload%2Fcore%2Fincludes%2Fswift%2FSwift%2FConnection'>⬅ Back to Directory</a>