]> git.mxchange.org Git - hub.git/commitdiff
Continued:
authorRoland Haeder <roland@mxchange.org>
Tue, 25 Mar 2014 21:39:07 +0000 (22:39 +0100)
committerRoland Haeder <roland@mxchange.org>
Tue, 25 Mar 2014 21:39:07 +0000 (22:39 +0100)
- improved logging messages
- added logger for enableAcceptDhtBootstrap()
- moved this call from 'init' state to 'booting' as on 'init' state the DHT has
  no records registered. This may require reconsidering.

Signed-off-by: Roland Haeder <roland@mxchange.org>
application/hub/main/dht/class_BaseDht.php
application/hub/main/handler/class_BaseDataHandler.php
application/hub/main/states/dht/booting/class_DhtBootingState.php
application/hub/main/states/dht/virgin/class_DhtVirginState.php
application/hub/main/wrapper/node/class_NodeDistributedHashTableDatabaseWrapper.php
application/hub/main/wrapper/node/class_NodeInformationDatabaseWrapper.php

index 64dda6e4712565e3507f7829eee9a7e346e5f3d2..f4e4a0344acea228ad57b7786fcda5690741c393 100644 (file)
@@ -224,9 +224,9 @@ abstract class BaseDht extends BaseHubSystem implements Distributable {
                assert(is_array($entry));
 
                // Remove any non-public data the database layer desires
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('DHT[' . $this->__toString() . ']: Calling this->getWrapperInstance()->removeNonPublicDataFromArray(data) ...');
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('DHT[' . __METHOD__ . ':' . __LINE__ . ']: Calling this->getWrapperInstance()->removeNonPublicDataFromArray(data) ...');
                $entry = $this->getWrapperInstance()->removeNonPublicDataFromArray($entry);
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('DHT[' . $this->__toString() . ']: entry[]=' . gettype($entry));
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('DHT[' . __METHOD__ . ':' . __LINE__ . ']: entry[]=' . gettype($entry));
 
                // Some sanity-checks again
                assert(is_array($entry));
index 8af6712819c1757a30ad1a79c7c37581f047acc2..3b154ca8454b76e2e1e66f0da92a69b5ce0e656d 100644 (file)
@@ -102,7 +102,7 @@ abstract class BaseDataHandler extends BaseHandler {
         */
        protected function prepareAnswerMessage (array $messageData, Deliverable $packageInstance) {
                // Debug message
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('MESSAGE-HANDLER[' . $this->__toString() . ']: Going to send an answer message ...');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('MESSAGE-HANDLER[' . __METHOD__ . ':' . __LINE__ . ']: Going to send an answer message ...');
 
                // Get a helper instance based on this handler's name
                $helperInstance = ObjectFactory::createObjectByConfiguredName('node_answer_' . $this->getHandlerName() . '_helper_class', array($messageData));
@@ -131,7 +131,7 @@ abstract class BaseDataHandler extends BaseHandler {
                $this->removeMessageConfigurationData($messageData);
 
                // Debug message
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('MESSAGE-HANDLER[' . $this->__toString() . ']: Answer message has been prepared.');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('MESSAGE-HANDLER[' . __METHOD__ . ':' . __LINE__ . ']: Answer message has been prepared.');
        }
 
        /**
@@ -143,7 +143,7 @@ abstract class BaseDataHandler extends BaseHandler {
         */
        protected function prepareNextMessage (array $messageData, Deliverable $packageInstance) {
                // Debug message
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('MESSAGE-HANDLER[' . $this->__toString() . ']: Going to send next message ...');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('MESSAGE-HANDLER[' . __METHOD__ . ':' . __LINE__ . ']: Going to send next message ...');
 
                // Get a helper instance based on this handler's name
                $helperInstance = ObjectFactory::createObjectByConfiguredName('node_next_' . $this->getHandlerName() . '_helper_class', array($messageData));
@@ -172,7 +172,7 @@ abstract class BaseDataHandler extends BaseHandler {
                $this->removeMessageConfigurationData($messageData);
 
                // Debug message
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('MESSAGE-HANDLER[' . $this->__toString() . ']: Next message has been prepared.');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('MESSAGE-HANDLER[' . __METHOD__ . ':' . __LINE__ . ']: Next message has been prepared.');
        }
 
        /**
index e590148a1b4bb904506f21e4f7b81ac11c80480c..2cec6825d4bb8a75b07f6c9d916ecdebe314c865 100644 (file)
@@ -46,11 +46,17 @@ class DhtBootingState extends BaseDhtState implements Stateable {
                $stateInstance = new DhtBootingState();
 
                // Debug message
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('DHT-STATE: Has changed from ' . $dhtInstance->getPrintableState() . ' to ' . $stateInstance->getStateName() . '.');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('DHT-STATE: Has changed from ' . $dhtInstance->getPrintableState() . ' to ' . $stateInstance->getStateName() . '.');
 
                // Set the dht instance
                $stateInstance->setDhtInstance($dhtInstance);
 
+               // Get node instance and enable DHT bootstrap requests
+               NodeObjectFactory::createNodeInstance()->enableAcceptDhtBootstrap();
+
+               // Update DHT node info as well
+               $dhtInstance->enableAcceptDhtBootstrap();
+
                // Return the prepared instance
                return $stateInstance;
        }
index 69882f3674063fc3570b3b60464692030f19f55e..3d42a391aeb0725df73b869a0a48b914500b8afd 100644 (file)
@@ -51,12 +51,6 @@ class DhtVirginState extends BaseDhtState implements Stateable {
                // Set the dht instance
                $stateInstance->setDhtInstance($dhtInstance);
 
-               // Get node instance and enable DHT bootstrap requests
-               NodeObjectFactory::createNodeInstance()->enableAcceptDhtBootstrap();
-
-               // Update DHT node info as well
-               $dhtInstance->enableAcceptDhtBootstrap();
-
                // Return the prepared instance
                return $stateInstance;
        }
index 1dd336996473ac9b8c0d49f565ea753a49d22089..fea84caec9468814c617de7d95c450e4bde497a1 100644 (file)
@@ -230,7 +230,7 @@ class NodeDistributedHashTableDatabaseWrapper extends BaseDatabaseWrapper implem
        }
 
        /**
-        * Updates local (*this*) node data in DHT, this is but not limited to the
+        * Updates local (*this*) node's data in DHT, this is but not limited to the
         * session id, ip number (and/or hostname) and port number.
         *
         * @return      void
@@ -503,9 +503,9 @@ class NodeDistributedHashTableDatabaseWrapper extends BaseDatabaseWrapper implem
         */
        public function removeNonPublicDataFromArray(array $data) {
                // Currently call only inner method
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('DHT-WRAPPER[' . $this->__toString() . ']: Calling parent::removeNonPublicDataFromArray(data) ...');
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('DHT-WRAPPER[' . __METHOD__ . ':' . __LINE__ . ']: Calling parent::removeNonPublicDataFromArray(data) ...');
                $data = parent::removeNonPublicDataFromArray($data);
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('DHT-WRAPPER[' . $this->__toString() . ']: data[]=' . gettype($data));
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('DHT-WRAPPER[' . __METHOD__ . ':' . __LINE__ . ']: data[]=' . gettype($data));
 
                // Return cleaned data
                return $data;
@@ -571,6 +571,9 @@ class NodeDistributedHashTableDatabaseWrapper extends BaseDatabaseWrapper implem
         * @return      void
         */
        public function enableAcceptDhtBootstrap () {
+               // Debug message
+               /* DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('DHT-WRAPPER[' . __METHOD__ . ':' . __LINE__ . ']: Enabling DHT bootstrap requests ...');
+
                // Just update our record
                $this->updateLocalNode();
        }
index 820102f504515cc5b96aef943ad28c0ed644d02d..79a5c701a8527e35de66f7783aa74082386742bf 100644 (file)
@@ -172,7 +172,7 @@ class NodeInformationDatabaseWrapper extends BaseDatabaseWrapper implements Node
         */
        public function removeNonPublicDataFromArray(array $data) {
                // Currently call only inner method
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NODE-WRAPPER[' . $this->__toString() . ']: Calling parent::removeNonPublicDataFromArray(data) ...');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NODE-WRAPPER[' . __METHOD__ . ':' . __LINE__ . ']: Calling parent::removeNonPublicDataFromArray(data) ...');
                $data = parent::removeNonPublicDataFromArray($data);
 
                // Return cleaned data