]> git.mxchange.org Git - hub.git/commitdiff
Stubs added for queue (not yet documented)
authorRoland Häder <roland@mxchange.org>
Sun, 5 Jul 2009 21:11:48 +0000 (21:11 +0000)
committerRoland Häder <roland@mxchange.org>
Sun, 5 Jul 2009 21:11:48 +0000 (21:11 +0000)
application/hub/class_ApplicationHelper.php
application/hub/main/nodes/regular/class_HubRegularNode.php

index ed5f03642b97a330590abe037c5998b5ef6efb79..055d9c988ebcfa14e2924ca57716e6eeb64c0468 100644 (file)
@@ -153,7 +153,7 @@ class ApplicationHelper extends BaseFrameworkSystem implements ManageableApplica
         * @return      void
         */
        public final function entryPoint () {
-               // --------------------- Init phase ---------------------
+               // ----------------------------- Init phase ---------------------------
                // The default node-mode is from our configuration
                $nodeMode = $this->getConfigInstance()->readConfig('node_mode');
 
@@ -185,11 +185,29 @@ class ApplicationHelper extends BaseFrameworkSystem implements ManageableApplica
                        die('Node mode ' . $nodeMode . ' is invalid.' . "\n");
                }
 
-               // --------------------- Bootstrapping phase ---------------------
+               // ----------------------- Bootstrapping phase ------------------------
                // Try to bootstrap the node and pass the request instance to it for
                // extra arguments which mostly override config entries or enable special
                // features within the hub (none is ready at this development stage)
-               $nodeInstance->doBootstrapping($requestInstance);
+               $nodeInstance->doBootstrapping();
+
+               // ----------------------- Init all query queues ----------------------
+               // After the bootstrap is done we need to initialize the query queues
+               // which will help us to communicate between the "tasks" a hub needs to
+               // do.
+               $nodeInstance->initQueryQueues();
+
+               // ----------------------------- Main loop ----------------------------
+               // This is the main loop. Queried calls should come back here very fast
+               // so the whole application runs on nice speed. This while-loop goes
+               // until the hub is no longer active.
+               while ($nodeInstance->isHubActive()) {
+               } // END - while
+
+               // -------------------------- Shutdown phase --------------------------
+               // Shutting down the hub by saying "good bye" to all connected clients
+               // and other hubs, flushing all queues and caches.
+               $nodeInstance->doShutdown();
        }
 
        /**
@@ -202,7 +220,7 @@ class ApplicationHelper extends BaseFrameworkSystem implements ManageableApplica
        public function handleFatalMessages (array $messageList) {
                // Walk through all messages
                foreach ($messageList as $message) {
-                       die("MSG:".$message);
+                       die("MSG:" . $message);
                }
        }
 
index 4c497e6136ffc4a94d31311034f9e4e44362a500..e1c144537db643d85a17e8ac303a0ba70154007f 100644 (file)
@@ -61,6 +61,7 @@ class HubRegularNode extends BaseHubNode implements NodeHelper {
         * command-line arguments stored in the request instance. The regular node
         * should communicate with the bootstrap-nodes at this point.
         *
+        * @param       $requestInstance        A Requestable instance
         * @return      void
         * @todo        Implement this method
         */