]> git.mxchange.org Git - hub.git/commitdiff
Continued:
authorRoland Häder <roland@mxchange.org>
Tue, 10 May 2022 23:03:48 +0000 (01:03 +0200)
committerRoland Häder <roland@mxchange.org>
Tue, 10 May 2022 23:03:48 +0000 (01:03 +0200)
- Are we invoking methods or are we calling them?

Signed-off-by: Roland Häder <roland@mxchange.org>
32 files changed:
application/hub/classes/container/socket/class_SocketContainer.php
application/hub/classes/database/frontend/node_dht/class_NodeDistributedHashTableDatabaseFrontend.php
application/hub/classes/database/frontend/node_information/class_NodeInformationDatabaseFrontend.php
application/hub/classes/decoder/package/class_PackageDecoder.php
application/hub/classes/dht/class_BaseDht.php
application/hub/classes/dht/node/class_NodeDhtFacade.php
application/hub/classes/discovery/recipient/package/class_PackageRecipientDiscovery.php
application/hub/classes/discovery/recipient/socket/class_PackageSocketDiscovery.php
application/hub/classes/handler/data/class_BaseDataHandler.php
application/hub/classes/handler/package/class_NetworkPackageHandler.php
application/hub/classes/helper/connection/class_BaseConnectionHelper.php
application/hub/classes/helper/node/connection/class_NodeSelfConnectHelper.php
application/hub/classes/info/connection/class_ConnectionInfo.php
application/hub/classes/listener/class_BaseListener.php
application/hub/classes/listener/class_BaseListenerDecorator.php
application/hub/classes/listener/socket/class_SocketFileListener.php
application/hub/classes/listener/socket/decorator/class_SocketFileListenerDecorator.php
application/hub/classes/listener/tcp/class_TcpListener.php
application/hub/classes/listener/tcp/decorators/class_ClientTcpListenerDecorator.php
application/hub/classes/listener/tcp/decorators/class_HubTcpListenerDecorator.php
application/hub/classes/listener/udp/class_UdpListener.php
application/hub/classes/listener/udp/decorators/class_ClientUdpListenerDecorator.php
application/hub/classes/listener/udp/decorators/class_HubUdpListenerDecorator.php
application/hub/classes/nodes/class_BaseHubNode.php
application/hub/classes/recipient/dht/class_DhtRecipient.php
application/hub/classes/registry/socket/class_SocketRegistry.php
application/hub/classes/source/urls/class_CrawlerUploadedListUrlSource.php
application/hub/classes/states/miner/booting/class_MinerBootingState.php
application/hub/classes/tasks/network/class_NetworkPackageReaderTask.php
application/hub/classes/tasks/network/class_NetworkPackageWriterTask.php
application/hub/classes/tasks/node/decoder/class_NodePackageDecoderTask.php
application/hub/classes/tools/hub/class_HubTools.php

index fca7dd3a782db159326e734a10f70d9230de41d7..43cebca3490656c4ab742b24e8e12246038911e4 100644 (file)
@@ -748,7 +748,7 @@ class SocketContainer extends BaseHubContainer implements StorableSocket, Visita
                $excepts = [];
 
                // Check if we have some peers left
-               /* EXTREME-NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('%s-SOCKET: Calling socket_select(%d,%d,%d,0%d) ...', strtoupper($this->getSocketProtocol()), count($readers), count($writers), count($excepts), self::$configEntries['socket_select_timeout']));
+               /* EXTREME-NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('%s-SOCKET: Invoking socket_select(%d,%d,%d,0%d) ...', strtoupper($this->getSocketProtocol()), count($readers), count($writers), count($excepts), self::$configEntries['socket_select_timeout']));
                $left = socket_select(
                        $readers,
                        $writers,
index dda53a6269e58a11a3d56998966b1d42e7c51bce..a58f23511e61e5c022b8f926554c6e72e2c3916d 100644 (file)
@@ -266,7 +266,7 @@ class NodeDistributedHashTableDatabaseFrontend extends BaseHubDatabaseFrontend i
                $dataSetInstance = $this->prepareLocalDataSetInstance();
 
                // "Insert" this dataset instance completely into the database
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('DHT-FRONTEND: Calling this->queryInsertDataSet(' . $dataSetInstance->__toString() . ') ...');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('DHT-FRONTEND: Invoking this->queryInsertDataSet(' . $dataSetInstance->__toString() . ') ...');
                $this->queryInsertDataSet($dataSetInstance);
 
                // Debug message
@@ -625,7 +625,7 @@ class NodeDistributedHashTableDatabaseFrontend extends BaseHubDatabaseFrontend i
         */
        public function removeNonPublicDataFromArray(array $data) {
                // Currently call only inner method
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('DHT-FRONTEND: Calling parent::removeNonPublicDataFromArray(data) ...');
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('DHT-FRONTEND: Invoking parent::removeNonPublicDataFromArray(data) ...');
                $data = parent::removeNonPublicDataFromArray($data);
                //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('DHT-FRONTEND: data[]=' . gettype($data));
 
index b1ab7c28f0315c0979efbfe7e2b9eafac0a38947..f843bf4ede1a7c70ff93a6f1a9138ad6199a24ca 100644 (file)
@@ -184,7 +184,7 @@ class NodeInformationDatabaseFrontend extends BaseHubDatabaseFrontend implements
         */
        public function removeNonPublicDataFromArray(array $data) {
                // Currently call only inner method
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NODE-FRONTEND: Calling parent::removeNonPublicDataFromArray(data) ...');
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NODE-FRONTEND: Invoking parent::removeNonPublicDataFromArray(data) ...');
                $data = parent::removeNonPublicDataFromArray($data);
 
                // Return cleaned data
index 4efb6bd814bdc0918a8c69f8f9c8a28f30765ead..681b61cb444d2a2646fed0e40f43b6aecc65ab5d 100644 (file)
@@ -121,7 +121,7 @@ class PackageDecoder extends BaseDecoder implements Decodeable, Registerable {
                $discoveryInstance = PackageDiscoveryFactory::createPackageDiscoveryInstance();
 
                // ... then disover all recipient (might be only one), this package may shall be forwarded
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('PACKAGE-DECODER: Calling discoveryInstance->discoverRawRecipients(%s) ...', $packageInstance->__toString()));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('PACKAGE-DECODER: Invoking discoveryInstance->discoverRawRecipients(%s) ...', $packageInstance->__toString()));
                $discoveryInstance->discoverRawRecipients($packageInstance);
 
                // Check for 'recipient' field (the 'sender' field and others are ignored here)
index 5b562ae3f2ccc4aa9f56c40039739aff450cd1a3..f020cfb4fbfb6dcf6273a11ba2cd0f91609dff86 100644 (file)
@@ -265,7 +265,7 @@ 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__, __LINE__)->debugOutput('BASE-DHT: Calling this->getFrontendInstance()->removeNonPublicDataFromArray(data) ...');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('BASE-DHT: Invoking this->getFrontendInstance()->removeNonPublicDataFromArray(data) ...');
                $entry = $this->getFrontendInstance()->removeNonPublicDataFromArray($entry);
                /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('BASE-DHT: entry[]=' . gettype($entry));
 
@@ -276,7 +276,7 @@ abstract class BaseDht extends BaseHubSystem implements Distributable {
                $this->publishHelperInstance->getTemplateInstance()->assignMultipleVariables($entry);
 
                // "Publish" the descriptor by sending it to the bootstrap/list nodes
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('BASE-DHT: Calling this->publishHelperInstance->sendPackage(' . $this->__toString() . ') ...');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('BASE-DHT: Invoking this->publishHelperInstance->sendPackage(' . $this->__toString() . ') ...');
                $this->publishHelperInstance->sendPackage($this);
        }
 
index e6b8ad3317390bcf17d81296fbdda077a74bd803..3f5a73ae8df73cd160112828d2a52e091bca24c4 100644 (file)
@@ -155,7 +155,7 @@ class NodeDhtFacade extends BaseDht implements DistributableNode, Registerable {
                $helperInstance->getTemplateInstance()->compileConfigInVariables();
 
                // "Publish" the descriptor by sending it to the bootstrap/list nodes
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NODE-DHT-FACADE: Calling helperInstance->sendPackage(%s) ...', $this->__toString()));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NODE-DHT-FACADE: Invoking helperInstance->sendPackage(%s) ...', $this->__toString()));
                $helperInstance->sendPackage($this);
 
                // Change state
index c658250d411ecddc3d65c3221e368b4e681dbc7b..eeb4098300f005ef74e9b98447c25b2960cc4392 100644 (file)
@@ -85,7 +85,7 @@ class PackageRecipientDiscovery extends BaseRecipientDiscovery implements Discov
                        ));
 
                        // Try to solve it
-                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('RECIPIENT-DISCOVERY: Calling recipientInstance->resolveRecipientByPackageInstance(%s, %s) ...', $packageInstance->__toString(), $this->getListInstance()->__toString()));
+                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('RECIPIENT-DISCOVERY: Invoking recipientInstance->resolveRecipientByPackageInstance(%s, %s) ...', $packageInstance->__toString(), $this->getListInstance()->__toString()));
                        $recipientInstance->resolveRecipientByPackageInstance($packageInstance, $this->getListInstance());
                } catch (FrameworkException $e) {
                        // Could not find class, what ever failed
index 31e92942b104916b29739ceab9d586a9417cd774..8ecb5c2bb6b07fe48ad34f085f6a31051698480a 100644 (file)
@@ -117,7 +117,7 @@ class PackageSocketDiscovery extends BaseRecipientDiscovery implements Discovera
                        assert($listenerInstance instanceof Listenable);
 
                        // Trace message
-                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('PACKAGE-SOCKET-DISCOVERY: Calling listenerInstance->ifListenerAcceptsPackageData(%s) ...', $packageInstance->__toString()));
+                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('PACKAGE-SOCKET-DISCOVERY: Invoking listenerInstance->ifListenerAcceptsPackageData(%s) ...', $packageInstance->__toString()));
 
                        // Does the listener want that package?
                        if ($listenerInstance->ifListenerAcceptsPackageData($packageInstance)) {
index ec345845fb2dc73d9d495ecb217d0a9677965ec6..69ea15ecb5b21a4fa65e9a82c39da80f7c8b3031 100644 (file)
@@ -113,7 +113,7 @@ abstract class BaseDataHandler extends BaseHubHandler implements HubInterface {
                $helperInstance->getTemplateInstance()->compileConfigInVariables();
 
                // Deliver the package
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-DATA-HANDLER: Calling helperInstance->sendPackage(%s) ...', $nodeInstance->__toString()));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-DATA-HANDLER: Invoking helperInstance->sendPackage(%s) ...', $nodeInstance->__toString()));
                $helperInstance->sendPackage($nodeInstance);
 
                // Debug message
@@ -144,7 +144,7 @@ abstract class BaseDataHandler extends BaseHubHandler implements HubInterface {
                $helperInstance->getTemplateInstance()->compileConfigInVariables();
 
                // Deliver the package
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NODE-DHT-FACADE: Calling helperInstance->sendPackage(%s) ...', $nodeInstance->__toString()));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NODE-DHT-FACADE: Invoking helperInstance->sendPackage(%s) ...', $nodeInstance->__toString()));
                $helperInstance->sendPackage($nodeInstance);
 
                // Debug message
index b3951ece29655287ce5a7f2c1dc55ae4e9f90b74..f88f4f159dff4fd4c59791e1dbd0f86b95823864 100644 (file)
@@ -634,7 +634,7 @@ class NetworkPackageHandler extends BaseHubHandler implements Deliverable, Recei
                 * shall be delivered has already been added for all entries from the
                 * list.
                 */
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-HANDLER: Calling discoveryInstance->clearRecipients() ...');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-HANDLER: Invoking discoveryInstance->clearRecipients() ...');
                $discoveryInstance->clearRecipients();
 
                // Trace message
@@ -678,7 +678,7 @@ class NetworkPackageHandler extends BaseHubHandler implements Deliverable, Recei
                $infoInstance = ConnectionInfoFactory::createConnectionInfoInstance($helperInstance->getProtocolName(), 'helper');
 
                // Will the info instance with connection helper data
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NETWORK-PACKAGE-HANDLER: Calling infoInstance->fillWithConnectionHelperInformation(%s) ...', $helperInstance->__toString()));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NETWORK-PACKAGE-HANDLER: Invoking infoInstance->fillWithConnectionHelperInformation(%s) ...', $helperInstance->__toString()));
                $infoInstance->fillWithConnectionHelperInformation($helperInstance);
 
                // Is it not there?
@@ -696,11 +696,11 @@ class NetworkPackageHandler extends BaseHubHandler implements Deliverable, Recei
                }
 
                // Make sure the connection is up
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-HANDLER: Calling helperInstance->stateInstance->validatePeerStateConnected() ...');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-HANDLER: Invoking helperInstance->stateInstance->validatePeerStateConnected() ...');
                $helperInstance->getStateInstance()->validatePeerStateConnected();
 
                // Enqueue it again on the out-going queue, the connection is up and working at this point
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NETWORK-PACKAGE-HANDLER: Calling this->stackInstance->pushNamed(%s, %s) ...', self::STACKER_NAME_OUTGOING, $packageInstance->__toString()));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NETWORK-PACKAGE-HANDLER: Invoking this->stackInstance->pushNamed(%s, %s) ...', self::STACKER_NAME_OUTGOING, $packageInstance->__toString()));
                $this->getStackInstance()->pushNamed(self::STACKER_NAME_OUTGOING, $packageInstance);
 
                // Trace message
@@ -1134,7 +1134,7 @@ class NetworkPackageHandler extends BaseHubHandler implements Deliverable, Recei
                $encodedDataArray[self::RAW_INDEX_SOCKET_INSTANCE] = NULL;
 
                // And deliver it
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NETWORK-PACKAGE-HANDLER: Calling socketInstance->writeBufferToSocketByArray(%d,%d) ...', count($encodedDataArray), $sentBytes));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NETWORK-PACKAGE-HANDLER: Invoking socketInstance->writeBufferToSocketByArray(%d,%d) ...', count($encodedDataArray), $sentBytes));
                if (!$socketInstance->writeBufferToSocketByArray($encodedDataArray, $sentBytes)) {
                        // Something bad happened while writing to socket
                        $socketInstance->handleSocketError(__METHOD__, __LINE__);
@@ -1189,7 +1189,7 @@ class NetworkPackageHandler extends BaseHubHandler implements Deliverable, Recei
         */
        public function isNewRawDataPending () {
                // Visit the pool. This monitors the pool for incoming raw data.
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NETWORK-PACKAGE-HANDLER: Calling this->getListenerPoolInstance()->accept(%s) ... - CALLED!', $this->getVisitorInstance()));
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NETWORK-PACKAGE-HANDLER: Invoking this->getListenerPoolInstance()->accept(%s) ... - CALLED!', $this->getVisitorInstance()));
                $this->getListenerPoolInstance()->accept($this->getVisitorInstance());
 
                // Check for new data arrival
@@ -1312,7 +1312,7 @@ class NetworkPackageHandler extends BaseHubHandler implements Deliverable, Recei
         */
        public function handleAssemblerPendingData () {
                // Handle it
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-HANDLER: Calling this->getAssemblerInstance()->handlePendingData() ...');
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-HANDLER: Invoking this->getAssemblerInstance()->handlePendingData() ...');
                $this->getAssemblerInstance()->handlePendingData();
        }
 
@@ -1323,7 +1323,7 @@ class NetworkPackageHandler extends BaseHubHandler implements Deliverable, Recei
         */
        public function handleMultipleMessages () {
                // Handle it
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-HANDLER: Calling this->getAssemblerInstance()->handleMultipleMessages() ...');
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-HANDLER: Invoking this->getAssemblerInstance()->handleMultipleMessages() ...');
                $this->getAssemblerInstance()->handleMultipleMessages();
        }
 
index 6350345a22f5b1e528a94d6aaccbdaf857a6f556..896fddb24b381a543f087c899857680281e9bdfc 100644 (file)
@@ -355,7 +355,7 @@ abstract class BaseConnectionHelper extends BaseHubSystemHelper implements Visit
                }
 
                // Was some raw data been collected?
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-CONNECTION-HELPER: rawData()=%d - after loop ...', strlen($rawData)));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-CONNECTION-HELPER: rawData()=%d - after loop ...', gettype($rawData), strlen($rawData)));
                if (empty($rawData)) {
                        // That should not happen
                        throw new LogicException('rawData should not be empty at this point.');
@@ -365,7 +365,7 @@ abstract class BaseConnectionHelper extends BaseHubSystemHelper implements Visit
                $bufferSize = FrameworkBootstrap::getConfigurationInstance()->getConfigEntry($this->getProtocolName() . '_buffer_length');
 
                // Encode the raw data with our output-stream
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-CONNECTION-HELPER: bufferSize=%d, socketResource[%s]=%s', $bufferSize, gettype($this->getSocketInstance()->getSocketResource()), $this->getSocketInstance()->getSocketResource()));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-CONNECTION-HELPER: bufferSize=%d,rawData()=%d, socketResource[%s]=%s', $bufferSize, strlen($rawData), gettype($this->getSocketInstance()->getSocketResource()), $this->getSocketInstance()->getSocketResource()));
                $encodedDataArray = [
                        NetworkPackageHandler::RAW_INDEX_FINAL_HASH      => $this->currentFinalHash,
                        NetworkPackageHandler::RAW_INDEX_ENCODED_DATA    => $this->getOutputStreamInstance()->streamData($rawData),
index a600362ad5471a74aec3fa228eaad3f8ec8abd87..5deda8a3b404c5a1a01292d006ff058f73da93d9 100644 (file)
@@ -109,7 +109,7 @@ class NodeSelfConnectHelper extends BaseNodeHelper implements HelpableNode {
                $handlerInstance = NetworkPackageHandlerFactory::createNetworkPackageHandlerInstance();
 
                // Next, feed the content in. The network package class is a pipe-through class.
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NODE-SELF-CONNECT-HELPER: Calling handlerInstance->enqueueRawDataFromTemplate(' . $this->__toString() . ') ...');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NODE-SELF-CONNECT-HELPER: Invoking handlerInstance->enqueueRawDataFromTemplate(' . $this->__toString() . ') ...');
                $handlerInstance->enqueueRawDataFromTemplate($this);
 
                // Trace message
index 4b6557bfb91808f5e56f9cc6bbf77e721aa39fbc..723868ecbc346af1c7a72f08f15364e1213bb069 100644 (file)
@@ -205,7 +205,7 @@ class ConnectionInfo extends BaseInfo implements ShareableInfo, Registerable {
                $socketPort    = 0;
 
                // Get peer name
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('CONNECTION-INFO: Calling socketInstance->determineSocketPeerName(%s,%d) ...', $socketAddress, $socketPort));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('CONNECTION-INFO: Invoking socketInstance->determineSocketPeerName(%s,%d) ...', $socketAddress, $socketPort));
                if (!$socketInstance->determineSocketPeerName($socketAddress, $socketPort)) {
                        // Did not work
                        throw new InvalidSocketException(array($this, $socketInstance->getSocketResource()), self::EXCEPTION_INVALID_SOCKET);
index d7358883746f323710ecad202215c8ad59ab5d0b..689bc3837eb519017615571c25ae6798b87dd9af 100644 (file)
@@ -413,7 +413,7 @@ abstract class BaseListener extends BaseHubSystem implements Visitable {
                }
 
                // Will the info instance with listener data
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('%s-LISTENER: Calling infoInstance->fillWithSocketPeerInformation(%s) ...', strtoupper($this->getProtocolName()), $socketInstance->__toString()));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('%s-LISTENER: Invoking infoInstance->fillWithSocketPeerInformation(%s) ...', strtoupper($this->getProtocolName()), $socketInstance->__toString()));
                $infoInstance->fillWithSocketPeerInformation($socketInstance);
 
                // Init peer address/port
@@ -437,7 +437,7 @@ abstract class BaseListener extends BaseHubSystem implements Visitable {
                $this->getRegistryInstance()->registerSocketInstance($infoInstance, $socketInstance);
 
                // Invoke private method
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('%s-LISTENER: Calling this->handleIncomingSocket(%s) ...', strtoupper($this->getProtocolName()), $socketInstance->__toString()));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('%s-LISTENER: Invoking this->handleIncomingSocket(%s) ...', strtoupper($this->getProtocolName()), $socketInstance->__toString()));
                $this->handleIncomingSocket($socketInstance);
 
                // Trace message
index 06103e93ec339e6134771409d7ecc1c8c6d00260..c1c156e9ebc9cd121b4a8530d0b011b38ef6f05e 100644 (file)
@@ -85,7 +85,7 @@ abstract class BaseListenerDecorator extends BaseDecorator implements Visitable
         */
        public final function getListenAddress () {
                // Trace message
-               //* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(strtoupper($this->getProtocolName()) . '-LISTENER-DECORATOR: Calling this->getListenerInstance()->getListenAddress() ...');
+               //* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(strtoupper($this->getProtocolName()) . '-LISTENER-DECORATOR: Invoking this->getListenerInstance()->getListenAddress() ...');
                return $this->getListenerInstance()->getListenAddress();
        }
 
@@ -96,7 +96,7 @@ abstract class BaseListenerDecorator extends BaseDecorator implements Visitable
         */
        public final function getListenPort () {
                // Trace message
-               //* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(strtoupper($this->getProtocolName()) . '-LISTENER-DECORATOR: Calling this->getListenerInstance()->getListenPort() ...');
+               //* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(strtoupper($this->getProtocolName()) . '-LISTENER-DECORATOR: Invoking this->getListenerInstance()->getListenPort() ...');
                return $this->getListenerInstance()->getListenPort();
        }
 
@@ -114,7 +114,7 @@ abstract class BaseListenerDecorator extends BaseDecorator implements Visitable
                $visitorInstance->visitDecorator($this);
 
                // Trace message
-               //* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('%s-LISTENER-DECORATOR: Calling visitorInstance->visitListener(%s) ...', strtoupper($this->getProtocolName()), $this->getListenerInstance()->__toString()));
+               //* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('%s-LISTENER-DECORATOR: Invoking visitorInstance->visitListener(%s) ...', strtoupper($this->getProtocolName()), $this->getListenerInstance()->__toString()));
 
                // Visit the covered class
                $visitorInstance->visitListener($this->getListenerInstance());
index ec370fa878564bccff200f56dcd69b4f4c30c7fa..32863225baecbf9b05ecfb3ada9d50d9e34946a3 100644 (file)
@@ -109,7 +109,7 @@ class SocketFileListener extends BaseListener implements Listenable {
         */
        public function doListen() {
                // Trace message
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('SOCKET-FILE-LISTENER: Calling this->doListenSocketSelect() ... - CALLED!');
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('SOCKET-FILE-LISTENER: Invoking this->doListenSocketSelect() ... - CALLED!');
 
                // Call super method
                $this->doListenSocketSelect('');
index c6e3acae9bf482cf156873305d22f204002ec0e9..a46c44a8fd33b9e5c5b980d3db53b47084b3e931 100644 (file)
@@ -81,7 +81,7 @@ class SocketFileListenerDecorator extends BaseListenerDecorator implements Liste
         */
        public function doListen () {
                // Trace message
-               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('SOCKET-FILE-LISTENER: Calling this->getListenerInstance()->doListen() ...');
+               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('SOCKET-FILE-LISTENER: Invoking this->getListenerInstance()->doListen() ...');
 
                // Handle generic TCP package
                $this->getListenerInstance()->doListen();
@@ -98,7 +98,7 @@ class SocketFileListenerDecorator extends BaseListenerDecorator implements Liste
         */
        public function ifListenerAcceptsPackageData (DeliverablePackage $packageInstance) {
                // Debug message
-               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('SOCKET-FILE-LISTENER: Calling this->getListenerInstance()->ifListenerAcceptsPackageData() ...');
+               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('SOCKET-FILE-LISTENER: Invoking this->getListenerInstance()->ifListenerAcceptsPackageData() ...');
 
                // Call inner method, no decoration is wanted in this method
                return $this->getListenerInstance()->ifListenerAcceptsPackageData($packageInstance);
index 514612d0887504ca29a11a4a46ce96979d75fd4e..4ce47c3466ddf4fddd68532c0790d5d2d5b2ce52 100644 (file)
@@ -105,7 +105,7 @@ class TcpListener extends BaseListener implements Listenable {
         */
        public function doListen () {
                // Trace message
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('TCP-LISTENER: Calling this->doListenSocketSelect() ... - CALLED!');
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('TCP-LISTENER: Invoking this->doListenSocketSelect() ... - CALLED!');
 
                // Call super method
                $this->doListenSocketSelect();
index c792eaaa7cda666bc35176410102250a94fb6434..5602de7a67357eb7539d96351abc462f7600ede1 100644 (file)
@@ -81,7 +81,7 @@ class ClientTcpListenerDecorator extends BaseListenerDecorator implements Listen
         */
        public function doListen () {
                // Trace message
-               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('CLIENT-TCP-LISTENER: Calling this->getListenerInstance() ...');
+               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('CLIENT-TCP-LISTENER: Invoking this->getListenerInstance() ...');
 
                // Handle generic TCP package
                $this->getListenerInstance()->doListen();
index 080774f81240fcbfcf4d07e4562faccbe4510672..919638cdcc55841dfd520420a55124826837428e 100644 (file)
@@ -81,7 +81,7 @@ class HubTcpListenerDecorator extends BaseListenerDecorator implements Listenabl
         */
        public function doListen () {
                // Trace message
-               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('HUB-TCP-LISTENER: Calling this->getListenerInstance() ...');
+               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('HUB-TCP-LISTENER: Invoking this->getListenerInstance() ...');
 
                // Handle generic TCP package
                $this->getListenerInstance()->doListen();
index 79b2f662bf79f41466e1c3b17f47356b524d342e..025f71a48127e8f2cc34e8660680eb503c43557e 100644 (file)
@@ -107,7 +107,7 @@ class UdpListener extends BaseListener implements Listenable {
         */
        public function doListen () {
                // Trace message
-               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('UDP-LISTENER: Calling this->doListenSocketSelect() ... - CALLED!');
+               //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('UDP-LISTENER: Invoking this->doListenSocketSelect() ... - CALLED!');
 
                // Call super method
                $this->doListenSocketSelect();
index f69614e1e2ff44c7853ddd0a88613985e4ad41a2..901512d99d1fbb7e8399c658cc985c965864f37c 100644 (file)
@@ -81,7 +81,7 @@ class ClientUdpListenerDecorator extends BaseListenerDecorator implements Listen
         */
        public function doListen () {
                // Trace message
-               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('CLIENT-UDP-LISTENER: Calling this->getListenerInstance() ...');
+               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('CLIENT-UDP-LISTENER: Invoking this->getListenerInstance() ...');
 
                // Handle generic UDP packages first
                $this->getListenerInstance()->doListen();
index 5b0dda70172d95156d48e3321dde3de58aa9cf95..a21120572a80c9c1822b696627c8e3852862b890 100644 (file)
@@ -81,7 +81,7 @@ class HubUdpListenerDecorator extends BaseListenerDecorator implements Listenabl
         */
        public function doListen () {
                // Trace message
-               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('HUB-UDP-LISTENER: Calling this->getListenerInstance() ...');
+               /* NOSY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('HUB-UDP-LISTENER: Invoking this->getListenerInstance() ...');
 
                // Handle generic UDP package first
                $this->getListenerInstance()->doListen();
index e901e8f38dd732db70be717a64d6dd9077e8db00..ea97f3c5ad40779fcb13368fdde4eaa4d9fbda24 100644 (file)
@@ -451,7 +451,7 @@ abstract class BaseHubNode extends BaseHubSystem implements Updateable, AddableC
                                 * "tables". This allows a smooth update for the underlaying
                                 * database table.
                                 */
-                               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-HUB-NODE: Calling this->generatePrivateKeyAndHash(%s) ...', $this->getSearchInstance()->__toString()));
+                               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-HUB-NODE: Invoking this->generatePrivateKeyAndHash(%s) ...', $this->getSearchInstance()->__toString()));
                                $this->generatePrivateKeyAndHash($this->getSearchInstance());
                        } else {
                                // Get the node id from result and set it
@@ -583,7 +583,7 @@ abstract class BaseHubNode extends BaseHubSystem implements Updateable, AddableC
                $helperInstance->getTemplateInstance()->compileConfigInVariables();
 
                // "Publish" the descriptor by sending it to the bootstrap/list nodes
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-HUB-NODE: Calling helperInstance->sendPackage(%s) ...', $this->__toString()));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-HUB-NODE: Invoking helperInstance->sendPackage(%s) ...', $this->__toString()));
                $helperInstance->sendPackage($this);
 
                // Change the state, this should be the last line except debug output
@@ -615,7 +615,7 @@ abstract class BaseHubNode extends BaseHubSystem implements Updateable, AddableC
                $helperInstance->getTemplateInstance()->compileConfigInVariables();
 
                // And send the package away
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-HUB-NODE: Calling helperInstance->sendPackage(%s) ...', $this->__toString()));
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('BASE-HUB-NODE: Invoking helperInstance->sendPackage(%s) ...', $this->__toString()));
                $helperInstance->sendPackage($this);
 
                // Debug output
index cd7b71dccc879ad1ba6d84f8364c3ea53c9fd68b..2026a1754baeb5e496d41ed591b6bac9f8828929 100644 (file)
@@ -101,7 +101,7 @@ class DhtRecipient extends BaseRecipient implements Recipient {
                        }
 
                        // Add it to the list
-                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('DHT-RECIPIENT: Calling listInstance->addEntry(%s) ...', $recipient[NodeDistributedHashTableDatabaseFrontend::DB_COLUMN_EXTERNAL_ADDRESS]));
+                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('DHT-RECIPIENT: Invoking listInstance->addEntry(%s) ...', $recipient[NodeDistributedHashTableDatabaseFrontend::DB_COLUMN_EXTERNAL_ADDRESS]));
                        $listInstance->addEntry('unl', $recipient[NodeDistributedHashTableDatabaseFrontend::DB_COLUMN_EXTERNAL_ADDRESS]);
                }
 
index 73f6f0ef9a3157b0c716cb51d5da730b99b4736d..19c5980c454df0c199d171ec3a7b5597fa081c62 100644 (file)
@@ -307,7 +307,7 @@ class SocketRegistry extends BaseRegistry implements Register, RegisterableSocke
                                                $infoInstance = ConnectionInfoFactory::createConnectionInfoInstance($listenerInstance->getProtocolName(), 'helper');
 
                                                // Fill info instance with listener data
-                                               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('SOCKET-REGISTRY: key=%s,subKey=%s: Calling infoInstance->fillWithListenerInformation(%s) ...', $key, $subKey, $listenerInstance->__toString()));
+                                               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('SOCKET-REGISTRY: key=%s,subKey=%s: Invoking infoInstance->fillWithListenerInformation(%s) ...', $key, $subKey, $listenerInstance->__toString()));
                                                $infoInstance->fillWithListenerInformation($listenerInstance);
                                        } elseif ($helperInstance instanceof ConnectionHelper) {
                                                // Found a helper, so get the info instance first
@@ -315,7 +315,7 @@ class SocketRegistry extends BaseRegistry implements Register, RegisterableSocke
                                                $infoInstance = ConnectionInfoFactory::createConnectionInfoInstance($helperInstance->getProtocolName(), 'helper');
 
                                                // Helper is found
-                                               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('SOCKET-REGISTRY: key=%s,subKey=%s: Calling infoInstance->fillWithHelperInformation(%s) ...', $key, $subKey, $helperInstance->__toString()));
+                                               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('SOCKET-REGISTRY: key=%s,subKey=%s: Invoking infoInstance->fillWithHelperInformation(%s) ...', $key, $subKey, $helperInstance->__toString()));
                                                $infoInstance->fillWithConnectionHelperInformation($helperInstance);
                                        } else {
                                                // Not supported state!
index 7a5bf1a8851c64be73d71ec05f9864f5a947c7d7..ce3a18f5893bf3b5fb5cb3f5d0b1a92ba38ea03a 100644 (file)
@@ -376,14 +376,14 @@ class CrawlerUploadedListUrlSource extends BaseUrlSource implements UrlSource, R
                         * A CSV file has been found and "imported" (added to stack). Now
                         * the file can be read line by line and checked every one of it.
                         */
-                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('CRAWLER-UPLOADED-LIST-URL-SOURCE: Calling this->parseCsvEntry() ...');
+                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('CRAWLER-UPLOADED-LIST-URL-SOURCE: Invoking this->parseCsvEntry() ...');
                        $this->parseCsvEntry();
                } elseif ($this->isCsvFileAdded()) {
                        /*
                         * A CSV file has been found and "imported" (added to stack). Now
                         * the file can be read line by line and checked every one of it.
                         */
-                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('CRAWLER-UPLOADED-LIST-URL-SOURCE: Calling this->parseCsvFile() ...');
+                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('CRAWLER-UPLOADED-LIST-URL-SOURCE: Invoking this->parseCsvFile() ...');
                        $this->parseCsvFile();
                } elseif ($this->isCsvFileFound() && !$this->isLastCsvFileImported()) {
                        /*
@@ -391,7 +391,7 @@ class CrawlerUploadedListUrlSource extends BaseUrlSource implements UrlSource, R
                         * CSV-like as you may wish to provide meta data such as crawl
                         * depth, handling of 3rd-party URLs and such.
                         */
-                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('CRAWLER-UPLOADED-LIST-URL-SOURCE: Calling this->addCsvFile() ...');
+                       /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('CRAWLER-UPLOADED-LIST-URL-SOURCE: Invoking this->addCsvFile() ...');
                        $this->addCsvFile();
                }
 
index a270efc118870a14d9d1e5b2f3da456e78c095e9..a86861b42098a45b7d395aaf7cd89974d6d1d6e5 100644 (file)
@@ -74,7 +74,7 @@ class MinerBootingState extends BaseMinerState implements Stateable {
                }
 
                // Debug message
-               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('MINER-STATE: Calling prepareBlockProduction() on ' . $executorInstance->__toString() . ' ...');
+               /* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('MINER-STATE: Invoking executorInstance->prepareBlockProduction(%s) ...', $executorInstance->__toString()));
 
                // Now prepare the unit production to maybe become 'virgin' or 'active' if work/test units are there
                $executorInstance->prepareBlockProduction($this);
index d70889db35f375f15c55ca95df016def740f11b9..f0ca8858d6666875ff985f09f14fc29ddcc46e35 100644 (file)
@@ -95,7 +95,7 @@ class NetworkPackageReaderTask extends BaseHubTask implements Taskable, Visitabl
                         * "interpreted". This is done by trying to find a configuration
                         * entry based on 'message_type' element.
                         */
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Calling handlerInstance->handleProcessedMessage() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Invoking handlerInstance->handleProcessedMessage() ...');
                        $handlerInstance->handleProcessedMessage();
                        //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: After handlerInstance->handleProcessedMessage() ...');
                } elseif ($handlerInstance->isDecodedPackageXmlPending()) {
@@ -103,7 +103,7 @@ class NetworkPackageReaderTask extends BaseHubTask implements Taskable, Visitabl
                         * A fully "decoded" package has arrived. This is raw XML and needs
                         * to be parsed to a message.
                         */
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Calling handlerInstance->handleDecodedPackageXml() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Invoking handlerInstance->handleDecodedPackageXml() ...');
                        $handlerInstance->handleDecodedPackageXml();
                        //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: After handlerInstance->handleDecodedPackageXml() ...');
                } elseif ($handlerInstance->isNewMessageArrived()) {
@@ -114,7 +114,7 @@ class NetworkPackageReaderTask extends BaseHubTask implements Taskable, Visitabl
                         * as "XML variables" from the content (which must be a well-formed
                         * XML) and then pushing it on the next stack "processed messages".
                         */
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Calling handlerInstance->handleNewlyArrivedMessage() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Invoking handlerInstance->handleNewlyArrivedMessage() ...');
                        $handlerInstance->handleNewlyArrivedMessage();
                        //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: After handlerInstance->handleNewlyArrivedMessage() ...');
                } elseif ($handlerInstance->isIncomingRawDataHandled()) {
@@ -124,7 +124,7 @@ class NetworkPackageReaderTask extends BaseHubTask implements Taskable, Visitabl
                         * PackageData for further details (what array elements are
                         * required et cetera).
                         */
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Calling handlerInstance->assembleDecodedDataToPackage() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Invoking handlerInstance->assembleDecodedDataToPackage() ...');
                        $handlerInstance->assembleDecodedDataToPackage();
                        //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: After handlerInstance->assembleDecodedDataToPackage() ...');
                } elseif ($handlerInstance->ifMultipleMessagesPending()) {
@@ -132,17 +132,17 @@ class NetworkPackageReaderTask extends BaseHubTask implements Taskable, Visitabl
                         * Some raw data contained multiple messages which where now
                         * splitted.
                         */
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Calling handlerInstance->handleMultipleMessages() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Invoking handlerInstance->handleMultipleMessages() ...');
                        $handlerInstance->handleMultipleMessages();
                        //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: After handlerInstance->handleMultipleMessages() ...');
                } elseif ($handlerInstance->isNewRawDataPending()) {
                        // Raw, decoded data has been received
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Calling handlerInstance->handleIncomingDecodedData() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Invoking handlerInstance->handleIncomingDecodedData() ...');
                        $handlerInstance->handleIncomingDecodedData();
                        //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: After handlerInstance->handleIncomingDecodedData() ...');
                } elseif ($handlerInstance->ifAssemblerHasPendingDataLeft()) {
                        // Handle any pending data from the package assembler
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Calling handlerInstance->handleAssemblerPendingData() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: Invoking handlerInstance->handleAssemblerPendingData() ...');
                        $handlerInstance->handleAssemblerPendingData();
                        //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-READER-TASK: After handlerInstance->handleAssemblerPendingData() ...');
                }
index fbfbffeafb7f37e34c20163998029442ee18ab2a..68047940cc909276336f169a2e8effb819de4507 100644 (file)
@@ -91,19 +91,19 @@ class NetworkPackageWriterTask extends BaseHubTask implements Taskable, Visitabl
                //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NETWORK-PACKAGE-WRITER-TASK: handlerInstance=%s', $handlerInstance->__toString()));
                if ($handlerInstance->isEncodedDataPending()) {
                        // Sent encoded (raw) data
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-WRITER-TASK: Calling handlerInstance->sendEncodedData() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-WRITER-TASK: Invoking handlerInstance->sendEncodedData() ...');
                        $handlerInstance->sendEncodedData();
                } elseif ($handlerInstance->isPackageWaitingForDelivery()) {
                        // Sent it finally out
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-WRITER-TASK: Calling handlerInstance->sendWaitingPackage() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-WRITER-TASK: Invoking handlerInstance->sendWaitingPackage() ...');
                        $handlerInstance->sendWaitingPackage();
                } elseif ($handlerInstance->isPackageDeclared()) {
                        // Prepare package for delivery
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-WRITER-TASK: Calling handlerInstance->processDeclaredPackage() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-WRITER-TASK: Invoking handlerInstance->processDeclaredPackage() ...');
                        $handlerInstance->processDeclaredPackage();
                } elseif ($handlerInstance->isPackageEnqueued()) {
                        // Okay, then deliver (better discover its recipients) this package
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-WRITER-TASK: Calling handlerInstance->declareEnqueuedPackage() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NETWORK-PACKAGE-WRITER-TASK: Invoking handlerInstance->declareEnqueuedPackage() ...');
                        $handlerInstance->declareEnqueuedPackage();
                }
 
index 0e29eabb38fc098c5c2f8a7332af8b4b6fc3be61..9c0abfe089b7a8ac49019dc1c27fbeb30438c984 100644 (file)
@@ -83,11 +83,11 @@ class NodePackageDecoderTask extends BaseHubTask implements Taskable, Visitable
                //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput(sprintf('NODE-PACKAGE-DECODER-TASK: decoderInstance=%s', $decoderInstance->__toString()));
                if ($decoderInstance->ifDeocedPackagesLeft()) {
                        // Some decoded packages have arrived (for this node)
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NODE-PACKAGE-DECODER-TASK: Calling decoderInstance->handleDecodedPackage() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NODE-PACKAGE-DECODER-TASK: Invoking decoderInstance->handleDecodedPackage() ...');
                        $decoderInstance->handleDecodedPackage();
                } elseif ($decoderInstance->ifUnhandledRawPackageDataLeft()) {
                        // Handle raw data as last option to prevent that the stack runs full
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NODE-PACKAGE-DECODER-TASK: Calling decoderInstance->handleRawPackageData() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('NODE-PACKAGE-DECODER-TASK: Invoking decoderInstance->handleRawPackageData() ...');
                        $decoderInstance->handleRawPackageData();
                }
 
index a7a8b220d33d8ce53404847ec26ab4832f6bd528..fcdcda41577c1048df09e9a82b866dbc8387ecfe 100644 (file)
@@ -268,7 +268,7 @@ class HubTools extends BaseHubSystem {
                        self::$cachedAddresses['external'] = $unl;
                } else {
                        // Determine own external address by connecting to home server at 188.138.90.169
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('HUB-TOOLS: Calling self::determineExternalUniversalNodeLocator() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('HUB-TOOLS: Invoking self::determineExternalUniversalNodeLocator() ...');
                        $unl = self::determineExternalUniversalNodeLocator();
                        self::$cachedAddresses['external'] = $unl;
                }
@@ -292,7 +292,7 @@ class HubTools extends BaseHubSystem {
                        $unl = self::$cachedAddresses['internal'];
                } elseif (FrameworkBootstrap::getConfigurationInstance()->getConfigEntry('allow_publish_internal_address') == 'N') {
                        // Not allowed to publish internal address, so use external
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('HUB-TOOLS: Calling self::determineOwnExternalAddress() as allow_publish_internal_address=N is set ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('HUB-TOOLS: Invoking self::determineOwnExternalAddress() as allow_publish_internal_address=N is set ...');
                        $unl = self::determineOwnExternalAddress();
                        self::$cachedAddresses['internal'] = $unl;
                } elseif (FrameworkBootstrap::getConfigurationInstance()->getConfigEntry('internal_address') != '') {
@@ -302,7 +302,7 @@ class HubTools extends BaseHubSystem {
                        self::$cachedAddresses['internal'] = $unl;
                } else {
                        // Determine own internal address
-                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('HUB-TOOLS: Calling self::determineInternalUniversalNodeLocator() ...');
+                       //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('HUB-TOOLS: Invoking self::determineInternalUniversalNodeLocator() ...');
                        $unl = self::determineInternalUniversalNodeLocator();
                        self::$cachedAddresses['internal'] = $unl;
                }