From 46d78fedc209832f6d4641ef274a7aa5df92eceb Mon Sep 17 00:00:00 2001 From: =?utf8?q?Roland=20H=C3=A4der?= Date: Sun, 5 Jul 2009 21:11:48 +0000 Subject: [PATCH] Stubs added for queue (not yet documented) --- application/hub/class_ApplicationHelper.php | 26 ++++++++++++++++--- .../nodes/regular/class_HubRegularNode.php | 1 + 2 files changed, 23 insertions(+), 4 deletions(-) diff --git a/application/hub/class_ApplicationHelper.php b/application/hub/class_ApplicationHelper.php index ed5f03642..055d9c988 100644 --- a/application/hub/class_ApplicationHelper.php +++ b/application/hub/class_ApplicationHelper.php @@ -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); } } diff --git a/application/hub/main/nodes/regular/class_HubRegularNode.php b/application/hub/main/nodes/regular/class_HubRegularNode.php index 4c497e613..e1c144537 100644 --- a/application/hub/main/nodes/regular/class_HubRegularNode.php +++ b/application/hub/main/nodes/regular/class_HubRegularNode.php @@ -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 */ -- 2.39.5