Renamed 'stacker' -> 'stack'
authorRoland Häder <roland@mxchange.org>
Thu, 25 Jul 2013 01:14:40 +0000 (01:14 +0000)
committerRoland Häder <roland@mxchange.org>
Thu, 25 Jul 2013 01:14:40 +0000 (01:14 +0000)
application/hub/interfaces/package/class_Deliverable.php
application/hub/main/cruncher/class_BaseHubCruncher.php
application/hub/main/decoder/package/class_PackageDecoder.php
application/hub/main/dht/class_BaseDht.php
application/hub/main/handler/chunks/class_ChunkHandler.php
application/hub/main/handler/network/class_BaseRawDataHandler.php
application/hub/main/package/class_NetworkPackage.php
application/hub/main/producer/class_BaseProducer.php
application/hub/main/template/class_BaseXmlTemplateEngine.php
application/hub/main/visitor/socket/class_ShutdownSocketVisitor.php

index 17f148c4ba3d161e8f0676fdc2a657504e6c0315..470b90d3bdaab29c2f637138539d26feee760ab9 100644 (file)
@@ -83,11 +83,11 @@ interface Deliverable extends FrameworkInterface {
        function sendWaitingPackage ();
 
        /**
-        * Clears all stacker
+        * Clears all stacks
         *
         * @return      void
         */
-       function clearAllStacker ();
+       function clearAllStacks ();
 }
 
 // [EOF]
index 1b6bdab093cf47df978c53190940d800824361d5..0f68adc7c27cd3d1314eb6fec06f2d2989b7eaba 100644 (file)
@@ -158,7 +158,7 @@ abstract class BaseHubCruncher extends BaseHubSystem implements Updateable {
                $this->bufferInstance = ObjectFactory::createObjectByConfiguredName('cruncher_buffer_stacker_class');
 
                // Initialize common stackers, like in/out
-               $this->bufferInstance->initStackers(array(
+               $this->bufferInstance->initStacks(array(
                        self::STACKER_NAME_IN_QUEUE,
                        self::STACKER_NAME_OUT_QUEUE
                ));
index 2db2c2a1be50ad88a0e32c7cb49846c51ea528a1..06bc7ccadb2a4b57d4696aefe467f7358192f40b 100644 (file)
@@ -48,7 +48,7 @@ class PackageDecoder extends BaseDecoder implements Decodeable {
                $decoderInstance = new PackageDecoder();
 
                // Init stacker for received packages
-               $stackerInstance->initStacker(self::STACKER_NAME_DECODED_PACKAGE);
+               $stackerInstance->initStack(self::STACKER_NAME_DECODED_PACKAGE);
 
                // Set the stacker instance here
                $decoderInstance->setStackerInstance($stackerInstance);
index 691f12035c55ec8fd7a83ca1a2fdf358d6de77fa..172b0e5a11b7cc769c44f6d1543251c2ae6d7f50 100644 (file)
@@ -44,7 +44,7 @@ abstract class BaseDht extends BaseHubSystem {
                $this->setStackerInstance($stackerInstance);
 
                // Init all stackers
-               $this->initStackers();
+               $this->initStacks();
 
                /*
                 * Get the state factory and create the initial state, we don't need
@@ -58,9 +58,9 @@ abstract class BaseDht extends BaseHubSystem {
         *
         * @return      void
         */
-       private function initStackers () {
+       private function initStacks () {
                // Initialize all stacker
-               $this->getStackerInstance()->initStackers(array(
+               $this->getStackerInstance()->initStacks(array(
                        self::STACKER_NAME_INSERT_NODE,
                ));
        }
index a7708cf2f4fce359d1468bd9895b12fd33602f5f..d0a7feafb6d12de0d417a5a0f5b7746ee0416b46 100644 (file)
@@ -91,7 +91,7 @@ class ChunkHandler extends BaseHandler implements HandleableChunks, Registerable
                $stackerInstance = ObjectFactory::createObjectByConfiguredName('chunk_handler_stacker_class');
 
                // Init all stacker
-               $stackerInstance->initStackers(array(
+               $stackerInstance->initStacks(array(
                        self::STACKER_NAME_CHUNKS_WITH_FINAL_EOP,
                        self::STACKER_NAME_CHUNKS_WITHOUT_FINAL,
                        self::STACKER_NAME_ASSEMBLED_RAW_DATA
index 57857bfcdacb6815fbfe7203b213f2df1fc9f7e2..d7b99dcee5b7f062b20db4120bf6021283e2d17a 100644 (file)
@@ -82,7 +82,7 @@ class BaseRawDataHandler extends BaseHandler {
                $this->setStackerInstance($stackerInstance);
 
                // Init stacker
-               $this->initStacker();
+               $this->initStack();
        }
 
        /**
@@ -90,8 +90,8 @@ class BaseRawDataHandler extends BaseHandler {
         *
         * @return      void
         */
-       protected function initStacker () {
-               $this->getStackerInstance()->initStacker(self::STACKER_NAME_RAW_DATA);
+       protected function initStack () {
+               $this->getStackerInstance()->initStack(self::STACKER_NAME_RAW_DATA);
        }
 
        /**
index df1ff642ae204087d87e3caad946e6769eac2acc..1d6d6e467a0220fac7b033423d8ce80089e1173b 100644 (file)
@@ -256,7 +256,7 @@ class NetworkPackage extends BaseHubSystem implements Deliverable, Receivable, R
                $packageInstance->setStackerInstance($stackerInstance);
 
                // Init all stacker
-               $packageInstance->initStackers();
+               $packageInstance->initStacks();
 
                // Get a visitor instance for speeding up things and set it
                $visitorInstance = ObjectFactory::createObjectByConfiguredName('node_raw_data_monitor_visitor_class', array($packageInstance));
@@ -280,9 +280,9 @@ class NetworkPackage extends BaseHubSystem implements Deliverable, Receivable, R
         * @param       $forceReInit    Whether to force reinitialization of all stacks
         * @return      void
         */
-       protected function initStackers ($forceReInit = FALSE) {
+       protected function initStacks ($forceReInit = FALSE) {
                // Initialize all
-               $this->getStackerInstance()->initStackers(array(
+               $this->getStackerInstance()->initStacks(array(
                        self::STACKER_NAME_UNDECLARED,
                        self::STACKER_NAME_DECLARED,
                        self::STACKER_NAME_OUTGOING,
@@ -292,7 +292,7 @@ class NetworkPackage extends BaseHubSystem implements Deliverable, Receivable, R
                        self::STACKER_NAME_NEW_MESSAGE,
                        self::STACKER_NAME_PROCESSED_MESSAGE,
                        self::STACKER_NAME_BACK_BUFFER
-               ));
+               ), $forceReInit);
        }
 
        /**
@@ -954,13 +954,13 @@ class NetworkPackage extends BaseHubSystem implements Deliverable, Receivable, R
        }
 
        /**
-        * Clears all stacker
+        * Clears all stacks
         *
         * @return      void
         */
-       public function clearAllStacker () {
+       public function clearAllStacks () {
                // Call the init method to force re-initialization
-               $this->initStackers(TRUE);
+               $this->initStacks(TRUE);
 
                // Debug message
                //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __LINE__ . ']: All stacker have been re-initialized.');
index 1045a0153a8f9a46985a76980a57549c1a9805c1..9c22b5dc02016f7ab9faf6100a9d73d7b5196e46 100644 (file)
@@ -133,7 +133,7 @@ abstract class BaseProducer extends BaseFrameworkSystem {
         * @return      void
         */
        protected function initOutgoingQueue () {
-               $this->getOutgoingQueueInstance()->initStacker(self::STACKER_NAME_OUT_QUEUE, TRUE);
+               $this->getOutgoingQueueInstance()->initStack(self::STACKER_NAME_OUT_QUEUE, TRUE);
        }
 
        /**
@@ -162,7 +162,7 @@ abstract class BaseProducer extends BaseFrameworkSystem {
         * @return      void
         */
        protected function initIncomingQueue () {
-               $this->getIncomingQueueInstance()->initStacker(self::STACKER_NAME_IN_QUEUE, TRUE);
+               $this->getIncomingQueueInstance()->initStack(self::STACKER_NAME_IN_QUEUE, TRUE);
        }
 
        /**
index 2cb598f38bafa944ebc3d3535131b6771fe82ede..ca168bf52d05099a02b70880296e1dedd9871a49 100644 (file)
@@ -121,7 +121,7 @@ class BaseXmlTemplateEngine extends BaseTemplateEngine {
                $this->stackerName = $typePrefix . '_' . $xmlTemplateType;
 
                // Init stacker
-               $stackerInstance->initStacker($this->stackerName);
+               $stackerInstance->initStack($this->stackerName);
 
                // Set it
                $this->setStackerInstance($stackerInstance);
index aa22ef538d569665ba2eeceeaa10c80827d66974..5b514282a0f71bfc158fcd99e8b79782d6fe2c1b 100644 (file)
@@ -78,7 +78,7 @@ class ShutdownSocketVisitor extends BaseVisitor implements Visitor {
         */
        public function visitNetworkPackage (Deliverable $packageInstance) {
                // Just call it back
-               $packageInstance->clearAllStacker();
+               $packageInstance->clearAllStacks();
        }
 }