Source of file IgnoreUserAbort.php
Size: 5,144 Bytes - Last Modified: 2014-03-12T23:21:18+01:00
/home/theseer/Downloads/ZendFramework-2.3.0/library/Zend/Cache/Storage/Plugin/IgnoreUserAbort.php
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119 | <?php /** * Zend Framework (http://framework.zend.com/) * * @link http://github.com/zendframework/zf2 for the canonical source repository * @copyright Copyright (c) 2005-2014 Zend Technologies USA Inc. (http://www.zend.com) * @license http://framework.zend.com/license/new-bsd New BSD License */ namespace Zend\Cache\Storage\Plugin; use Zend\Cache\Exception; use Zend\Cache\Storage\Event; use Zend\EventManager\EventManagerInterface; class IgnoreUserAbort extends AbstractPlugin { /** * The storage who activated ignore_user_abort. * * @var null|\Zend\Cache\Storage\StorageInterface */ protected $activatedTarget = null; /** * {@inheritDoc} */ public function attach(EventManagerInterface $events, $priority = 1) { $cbOnBefore = array($this, 'onBefore'); $cbOnAfter = array($this, 'onAfter'); $this->listeners[] = $events->attach('setItem.pre', $cbOnBefore, $priority); $this->listeners[] = $events->attach('setItem.post', $cbOnAfter, $priority); $this->listeners[] = $events->attach('setItem.exception', $cbOnAfter, $priority); $this->listeners[] = $events->attach('setItems.pre', $cbOnBefore, $priority); $this->listeners[] = $events->attach('setItems.post', $cbOnAfter, $priority); $this->listeners[] = $events->attach('setItems.exception', $cbOnAfter, $priority); $this->listeners[] = $events->attach('addItem.pre', $cbOnBefore, $priority); $this->listeners[] = $events->attach('addItem.post', $cbOnAfter, $priority); $this->listeners[] = $events->attach('addItem.exception', $cbOnAfter, $priority); $this->listeners[] = $events->attach('addItems.pre', $cbOnBefore, $priority); $this->listeners[] = $events->attach('addItems.post', $cbOnAfter, $priority); $this->listeners[] = $events->attach('addItems.exception', $cbOnAfter, $priority); $this->listeners[] = $events->attach('replaceItem.pre', $cbOnBefore, $priority); $this->listeners[] = $events->attach('replaceItem.post', $cbOnAfter, $priority); $this->listeners[] = $events->attach('replaceItem.exception', $cbOnAfter, $priority); $this->listeners[] = $events->attach('replaceItems.pre', $cbOnBefore, $priority); $this->listeners[] = $events->attach('replaceItems.post', $cbOnAfter, $priority); $this->listeners[] = $events->attach('replaceItems.exception', $cbOnAfter, $priority); $this->listeners[] = $events->attach('checkAndSetItem.pre', $cbOnBefore, $priority); $this->listeners[] = $events->attach('checkAndSetItem.post', $cbOnAfter, $priority); $this->listeners[] = $events->attach('checkAndSetItem.exception', $cbOnAfter, $priority); // increment / decrement item(s) $this->listeners[] = $events->attach('incrementItem.pre', $cbOnBefore, $priority); $this->listeners[] = $events->attach('incrementItem.post', $cbOnAfter, $priority); $this->listeners[] = $events->attach('incrementItem.exception', $cbOnAfter, $priority); $this->listeners[] = $events->attach('incrementItems.pre', $cbOnBefore, $priority); $this->listeners[] = $events->attach('incrementItems.post', $cbOnAfter, $priority); $this->listeners[] = $events->attach('incrementItems.exception', $cbOnAfter, $priority); $this->listeners[] = $events->attach('decrementItem.pre', $cbOnBefore, $priority); $this->listeners[] = $events->attach('decrementItem.post', $cbOnAfter, $priority); $this->listeners[] = $events->attach('decrementItem.exception', $cbOnAfter, $priority); $this->listeners[] = $events->attach('decrementItems.pre', $cbOnBefore, $priority); $this->listeners[] = $events->attach('decrementItems.post', $cbOnAfter, $priority); $this->listeners[] = $events->attach('decrementItems.exception', $cbOnAfter, $priority); } /** * Activate ignore_user_abort if not already done * and save the target who activated it. * * @param Event $event * @return void */ public function onBefore(Event $event) { if ($this->activatedTarget === null && !ignore_user_abort(true)) { $this->activatedTarget = $event->getTarget(); } } /** * Reset ignore_user_abort if it's activated and if it's the same target * who activated it. * * If exit_on_abort is enabled and the connection has been aborted * exit the script. * * @param Event $event * @return void */ public function onAfter(Event $event) { if ($this->activatedTarget === $event->getTarget()) { // exit if connection aborted if ($this->getOptions()->getExitOnAbort() && connection_aborted()) { exit; } // reset ignore_user_abort ignore_user_abort(false); // remove activated target $this->activatedTarget = null; } } } |