* @version 0.0.0 * @copyright Copyright (c) 2007, 2008 Roland Haeder, 2009 - 2012 Hub Developer Team * @license GNU GPL 3.0 or any newer version * @link http://www.ship-simu.org * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ class NodePackageDecoderTask extends BaseTask implements Taskable, Visitable { /** * Protected constructor * * @return void */ protected function __construct () { // Call parent constructor parent::__construct(__CLASS__); } /** * Creates an instance of this class * * @return $taskInstance An instance of a Visitable class */ public final static function createNodePackageDecoderTask () { // Get new instance $taskInstance = new NodePackageDecoderTask(); // Get a chunk handler instance $handlerInstance = ChunkHandlerFactory::createChunkHandlerInstance(); // Get the stacker from it, we don't need the handler here $stackerInstance = $handlerInstance->getStackerInstance(); // Get a decoder instance $decoderInstance = ObjectFactory::createObjectByConfiguredName('package_decoder_class', array($stackerInstance)); // ... and also set the decoder instance here $taskInstance->setDecoderInstance($decoderInstance); // Return the prepared instance return $taskInstance; } /** * Accepts the visitor to process the visitor * * @param $visitorInstance An instance of a Visitor class * @return void */ public function accept (Visitor $visitorInstance) { // Visit this task $visitorInstance->visitTask($this); } /** * Executes the task * * @return void */ public function executeTask () { // Check if the stacker has some entries left if ($this->getDecoderInstance()->ifUnhandledRawPackageDataLeft()) { // Then handle it $this->getDecoderInstance()->handleRawPackageData(); } elseif ($this->getDecoderInstance()->ifDeocedPackagesLeft()) { // Some decoded packages have arrived (for this peer) $this->getDecoderInstance()->handleDecodedPackage(); } } } // [EOF] ?>