Typo fixed, visitor introduced, SVN property set:

- New visitor introduced which will monitor incoming raw data
- Typo in method name fixed
- SVN property "eol-style" set to native

diff --git a/.gitattributes b/.gitattributes
index 7d10afbd6681d72e1ee23f6828e59250f386a49f..45d2e21b2273a335b1c72420bdd8282795cd032f 100644 (file)
--- a/.gitattributes
+++ b/.gitattributes
@@ -2,34 +2,34 @@
 /Doxyfile -text
 application/.htaccess -text svneol=unset#text/plain
 application/hub/.htaccess -text svneol=unset#text/plain
-application/hub/class_ApplicationHelper.php -text svneol=unset#text/plain
-application/hub/config.php -text svneol=unset#text/plain
-application/hub/data.php -text svneol=unset#text/plain
-application/hub/debug.php -text svneol=unset#text/plain
-application/hub/exceptions.php -text svneol=unset#text/plain
+application/hub/class_ApplicationHelper.php svneol=native#text/plain
+application/hub/config.php svneol=native#text/plain
+application/hub/data.php svneol=native#text/plain
+application/hub/debug.php svneol=native#text/plain
+application/hub/exceptions.php svneol=native#text/plain
 application/hub/exceptions/.htaccess -text svneol=unset#text/plain
 application/hub/exceptions/hub/.htaccess -text svneol=unset#text/plain
-application/hub/exceptions/hub/class_HubAlreadyAnnouncedException.php -text svneol=unset#text/plain
+application/hub/exceptions/hub/class_HubAlreadyAnnouncedException.php svneol=native#text/plain
 application/hub/exceptions/ids/.htaccess -text svneol=unset#text/plain
-application/hub/exceptions/ids/class_InvalidSessionIdException.php -text svneol=unset#text/plain
+application/hub/exceptions/ids/class_InvalidSessionIdException.php svneol=native#text/plain
 application/hub/exceptions/lists/.htaccess -text svneol=unset#text/plain
-application/hub/exceptions/lists/class_InvalidListHashException.php -text svneol=unset#text/plain
-application/hub/exceptions/lists/class_ListGroupAlreadyAddedException.php -text svneol=unset#text/plain
-application/hub/exceptions/lists/class_NoListGroupException.php -text svneol=unset#text/plain
+application/hub/exceptions/lists/class_InvalidListHashException.php svneol=native#text/plain
+application/hub/exceptions/lists/class_ListGroupAlreadyAddedException.php svneol=native#text/plain
+application/hub/exceptions/lists/class_NoListGroupException.php svneol=native#text/plain
 application/hub/exceptions/peer/.htaccess -text svneol=unset#text/plain
-application/hub/exceptions/peer/class_PeerAlreadyRegisteredException.php -text svneol=unset#text/plain
+application/hub/exceptions/peer/class_PeerAlreadyRegisteredException.php svneol=native#text/plain
 application/hub/exceptions/resolver/.htaccess svneol=native#text/plain
 application/hub/exceptions/resolver/class_NoValidHostnameException.php svneol=native#text/plain
 application/hub/exceptions/state/.htaccess -text svneol=unset#text/plain
-application/hub/exceptions/state/class_InvalidStateException.php -text svneol=unset#text/plain
+application/hub/exceptions/state/class_InvalidStateException.php svneol=native#text/plain
 application/hub/exceptions/tags/.htaccess -text svneol=unset#text/plain
 application/hub/exceptions/tags/class_InvalidTagException.php svneol=native#text/plain
 application/hub/exceptions/tasks/.htaccess -text svneol=unset#text/plain
-application/hub/exceptions/tasks/class_InvalidTaskException.php -text svneol=unset#text/plain
-application/hub/init.php -text svneol=unset#text/plain
+application/hub/exceptions/tasks/class_InvalidTaskException.php svneol=native#text/plain
+application/hub/init.php svneol=native#text/plain
 application/hub/interfaces/.htaccess -text svneol=unset#text/plain
 application/hub/interfaces/connectors/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/connectors/class_Connectable.php -text svneol=unset#text/plain
+application/hub/interfaces/connectors/class_Connectable.php svneol=native#text/plain
 application/hub/interfaces/consumer/.htaccess svneol=native#text/plain
 application/hub/interfaces/consumer/class_Consumer.php svneol=native#text/plain
 application/hub/interfaces/cruncher/.htaccess svneol=native#text/plain
@@ -40,43 +40,39 @@ application/hub/interfaces/discovery/class_DiscoverableSocket.php svneol=native#
 application/hub/interfaces/executor/.htaccess svneol=native#text/plain
 application/hub/interfaces/executor/class_Executor.php svneol=native#text/plain
 application/hub/interfaces/handler/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/handler/class_Handleable.php -text svneol=unset#text/plain
+application/hub/interfaces/handler/class_Handleable.php svneol=native#text/plain
 application/hub/interfaces/handler/network/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/handler/network/class_Networkable.php -text svneol=unset#text/plain
+application/hub/interfaces/handler/network/class_Networkable.php svneol=native#text/plain
 application/hub/interfaces/handler/task/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/handler/task/class_HandleableTask.php -text svneol=unset#text/plain
+application/hub/interfaces/handler/task/class_HandleableTask.php svneol=native#text/plain
 application/hub/interfaces/helper/.htaccess -text svneol=unset#text/plain
 application/hub/interfaces/helper/connections/.htaccess -text
-application/hub/interfaces/helper/connections/class_ConnectionHelper.php -text
 application/hub/interfaces/helper/hub/.htaccess -text svneol=unset#text/plain
 application/hub/interfaces/helper/hub/class_HelpableHub.php svneol=native#text/plain
 application/hub/interfaces/helper/messages/.htaccess svneol=native#text/plain
 application/hub/interfaces/helper/messages/class_MessageHelper.php svneol=native#text/plain
 application/hub/interfaces/listener/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/listener/class_Listenable.php -text svneol=unset#text/plain
+application/hub/interfaces/listener/class_Listenable.php svneol=native#text/plain
 application/hub/interfaces/lists/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/lists/class_Listable.php -text svneol=unset#text/plain
+application/hub/interfaces/lists/class_Listable.php svneol=native#text/plain
 application/hub/interfaces/lookup/.htaccess -text svneol=unset#text/plain
 application/hub/interfaces/lookup/class_Lookupable.php svneol=native#text/plain
 application/hub/interfaces/lookup/peer_states/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/lookup/peer_states/class_LookupablePeerState.php -text svneol=unset#text/plain
+application/hub/interfaces/lookup/peer_states/class_LookupablePeerState.php svneol=native#text/plain
 application/hub/interfaces/messages/.htaccess svneol=native#text/plain
 application/hub/interfaces/messages/class_MessageHelper.php svneol=native#text/plain
 application/hub/interfaces/nodes/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/nodes/class_NodeHelper.php -text svneol=unset#text/plain
+application/hub/interfaces/nodes/class_NodeHelper.php svneol=native#text/plain
 application/hub/interfaces/package/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/package/class_Deliverable.php -text svneol=unset#text/plain
-application/hub/interfaces/package/class_Receivable.php -text
+application/hub/interfaces/package/class_Deliverable.php svneol=native#text/plain
 application/hub/interfaces/package/fragmenter/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/package/fragmenter/class_Fragmentable.php -text
 application/hub/interfaces/pool/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/pool/class_Poolable.php -text svneol=unset#text/plain
+application/hub/interfaces/pool/class_Poolable.php svneol=native#text/plain
 application/hub/interfaces/pool/listener/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/pool/listener/class_PoolableListener.php -text svneol=unset#text/plain
+application/hub/interfaces/pool/listener/class_PoolableListener.php svneol=native#text/plain
 application/hub/interfaces/pool/peer/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/pool/peer/class_PoolablePeer.php -text svneol=unset#text/plain
+application/hub/interfaces/pool/peer/class_PoolablePeer.php svneol=native#text/plain
 application/hub/interfaces/producer/.htaccess svneol=native#text/plain
-application/hub/interfaces/producer/class_ -text
 application/hub/interfaces/producer/class_Producer.php svneol=native#text/plain
 application/hub/interfaces/producer/keys/.htaccess svneol=native#text/plain
 application/hub/interfaces/producer/keys/class_KeyProducer.php svneol=native#text/plain
@@ -85,87 +81,83 @@ application/hub/interfaces/producer/work_units/class_UnitProducer.php svneol=nat
 application/hub/interfaces/protocol/.htaccess -text svneol=unset#text/plain
 application/hub/interfaces/protocol/class_ProtocolHandler.php svneol=native#text/plain
 application/hub/interfaces/query/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/query/class_Queryable.php -text svneol=unset#text/plain
+application/hub/interfaces/query/class_Queryable.php svneol=native#text/plain
 application/hub/interfaces/queues/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/queues/class_Queueable.php -text svneol=unset#text/plain
+application/hub/interfaces/queues/class_Queueable.php svneol=native#text/plain
 application/hub/interfaces/socket/.htaccess -text svneol=unset#text/plain
 application/hub/interfaces/socket/class_SocketTag.php svneol=native#text/plain
 application/hub/interfaces/source/.htaccess svneol=native#text/plain
 application/hub/interfaces/source/class_Sourceable.php svneol=native#text/plain
 application/hub/interfaces/states/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/states/class_ -text svneol=unset#text/plain
-application/hub/interfaces/states/class_Stateable.php -text svneol=unset#text/plain
+application/hub/interfaces/states/class_ svneol=native#text/plain
+application/hub/interfaces/states/class_Stateable.php svneol=native#text/plain
 application/hub/interfaces/states/client/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/states/client/class_ClientStateable.php -text
 application/hub/interfaces/states/hub/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/states/hub/class_HubStateable.php -text
 application/hub/interfaces/states/node/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/states/node/class_NodeStateable.php -text svneol=unset#text/plain
+application/hub/interfaces/states/node/class_NodeStateable.php svneol=native#text/plain
 application/hub/interfaces/states/peer/.htaccess -text svneol=unset#text/plain
 application/hub/interfaces/states/peer/class_PeerStateable.php svneol=native#text/plain
 application/hub/interfaces/tags/.htaccess -text svneol=unset#text/plain
 application/hub/interfaces/tags/class_Tagable.php svneol=native#text/plain
 application/hub/interfaces/tasks/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/tasks/class_Taskable.php -text svneol=unset#text/plain
+application/hub/interfaces/tasks/class_Taskable.php svneol=native#text/plain
 application/hub/interfaces/visitor/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/visitor/class_Visitable.php -text svneol=unset#text/plain
-application/hub/interfaces/visitor/class_Visitor.php -text svneol=unset#text/plain
+application/hub/interfaces/visitor/class_Visitable.php svneol=native#text/plain
+application/hub/interfaces/visitor/class_Visitor.php svneol=native#text/plain
 application/hub/interfaces/visitor/connector/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/visitor/connector/class_QueryConnectorVisitor.php -text svneol=unset#text/plain
+application/hub/interfaces/visitor/connector/class_QueryConnectorVisitor.php svneol=native#text/plain
 application/hub/interfaces/visitor/connector/class_QueueConnectorVisitor.php svneol=native#text/plain
 application/hub/interfaces/visitor/decorator/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/visitor/decorator/class_DecoratorVisitor.php -text svneol=unset#text/plain
+application/hub/interfaces/visitor/decorator/class_DecoratorVisitor.php svneol=native#text/plain
 application/hub/interfaces/visitor/listener/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/visitor/listener/class_ListenerVisitor.php -text svneol=unset#text/plain
+application/hub/interfaces/visitor/listener/class_ListenerVisitor.php svneol=native#text/plain
 application/hub/interfaces/visitor/pool/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/visitor/pool/class_PoolVisitor.php -text svneol=unset#text/plain
+application/hub/interfaces/visitor/pool/class_PoolVisitor.php svneol=native#text/plain
 application/hub/interfaces/visitor/pool/listener/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/visitor/pool/listener/class_ListenerPoolVisitor.php -text svneol=unset#text/plain
+application/hub/interfaces/visitor/pool/listener/class_ListenerPoolVisitor.php svneol=native#text/plain
 application/hub/interfaces/visitor/query/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/visitor/query/class_QueryVisitor.php -text svneol=unset#text/plain
+application/hub/interfaces/visitor/query/class_QueryVisitor.php svneol=native#text/plain
 application/hub/interfaces/visitor/queue/.htaccess svneol=native#text/plain
 application/hub/interfaces/visitor/queue/class_QueueVisitor.php svneol=native#text/plain
 application/hub/interfaces/visitor/tasks/.htaccess -text svneol=unset#text/plain
-application/hub/interfaces/visitor/tasks/class_TaskVisitor.php -text svneol=unset#text/plain
+application/hub/interfaces/visitor/tasks/class_TaskVisitor.php svneol=native#text/plain
 application/hub/interfaces/work_units/.htaccess svneol=native#text/plain
 application/hub/interfaces/work_units/class_UnitHelper.php svneol=native#text/plain
-application/hub/loader.php -text svneol=unset#text/plain
+application/hub/loader.php svneol=native#text/plain
 application/hub/main/.htaccess -text svneol=unset#text/plain
-application/hub/main/class_ -text svneol=unset#text/plain
-application/hub/main/class_Base -text
-application/hub/main/class_BaseHubSystem.php -text svneol=unset#text/plain
+application/hub/main/class_ svneol=native#text/plain
+application/hub/main/class_BaseHubSystem.php svneol=native#text/plain
 application/hub/main/commands/.htaccess -text svneol=unset#text/plain
 application/hub/main/commands/console/.htaccess -text svneol=unset#text/plain
 application/hub/main/commands/console/class_HubConsoleCruncherCommand.php svneol=native#text/plain
-application/hub/main/commands/console/class_HubConsoleMainCommand.php -text svneol=unset#text/plain
+application/hub/main/commands/console/class_HubConsoleMainCommand.php svneol=native#text/plain
 application/hub/main/compressor/.htaccess -text svneol=unset#text/plain
 application/hub/main/compressor/decorator/.htaccess -text svneol=unset#text/plain
-application/hub/main/compressor/decorator/class_NetworkPackageCompressorDecorator.php -text svneol=unset#text/plain
+application/hub/main/compressor/decorator/class_NetworkPackageCompressorDecorator.php svneol=native#text/plain
 application/hub/main/connectors/.htaccess -text svneol=unset#text/plain
-application/hub/main/connectors/class_BaseConnector.php -text svneol=unset#text/plain
+application/hub/main/connectors/class_BaseConnector.php svneol=native#text/plain
 application/hub/main/connectors/query/.htaccess -text svneol=unset#text/plain
-application/hub/main/connectors/query/class_ -text svneol=unset#text/plain
-application/hub/main/connectors/query/class_BaseQueryConnector.php -text svneol=unset#text/plain
+application/hub/main/connectors/query/class_ svneol=native#text/plain
+application/hub/main/connectors/query/class_BaseQueryConnector.php svneol=native#text/plain
 application/hub/main/connectors/query/local/.htaccess -text svneol=unset#text/plain
-application/hub/main/connectors/query/local/class_LocalQueryConnector.php -text svneol=unset#text/plain
+application/hub/main/connectors/query/local/class_LocalQueryConnector.php svneol=native#text/plain
 application/hub/main/connectors/queues/.htaccess -text svneol=unset#text/plain
-application/hub/main/connectors/queues/class_ -text svneol=unset#text/plain
-application/hub/main/connectors/queues/class_BaseQueueConnector.php -text svneol=unset#text/plain
+application/hub/main/connectors/queues/class_ svneol=native#text/plain
+application/hub/main/connectors/queues/class_BaseQueueConnector.php svneol=native#text/plain
 application/hub/main/connectors/queues/local/.htaccess -text svneol=unset#text/plain
-application/hub/main/connectors/queues/local/class_LocalQueueConnector.php -text svneol=unset#text/plain
+application/hub/main/connectors/queues/local/class_LocalQueueConnector.php svneol=native#text/plain
 application/hub/main/controller/.htaccess -text svneol=unset#text/plain
 application/hub/main/controller/console/.htaccess -text svneol=unset#text/plain
 application/hub/main/controller/console/class_HubConsoleCruncherController.php svneol=native#text/plain
-application/hub/main/controller/console/class_HubConsoleDefaultNewsController.php -text svneol=unset#text/plain
+application/hub/main/controller/console/class_HubConsoleDefaultNewsController.php svneol=native#text/plain
 application/hub/main/cruncher/.htaccess svneol=native#text/plain
-application/hub/main/cruncher/class_ -text
 application/hub/main/cruncher/class_BaseHubCruncher.php svneol=native#text/plain
 application/hub/main/cruncher/mcrypt/.htaccess svneol=native#text/plain
 application/hub/main/cruncher/mcrypt/class_HubMcryptCruncher.php svneol=native#text/plain
 application/hub/main/database/.htaccess -text svneol=unset#text/plain
 application/hub/main/database/wrapper/.htaccess -text svneol=unset#text/plain
-application/hub/main/database/wrapper/class_NodeInformationDatabaseWrapper.php -text svneol=unset#text/plain
-application/hub/main/database/wrapper/class_NodeListDatabaseWrapper.php -text svneol=unset#text/plain
+application/hub/main/database/wrapper/class_NodeInformationDatabaseWrapper.php svneol=native#text/plain
+application/hub/main/database/wrapper/class_NodeListDatabaseWrapper.php svneol=native#text/plain
 application/hub/main/database/wrapper/class_PeerStateLookupDatabaseWrapper.php svneol=native#text/plain
 application/hub/main/database/wrapper/cruncher/.htaccess svneol=native#text/plain
 application/hub/main/database/wrapper/cruncher/class_CruncherUnitDatabaseWrapper.php svneol=native#text/plain
@@ -175,7 +167,6 @@ application/hub/main/database/wrapper/node/class_NodeListDatabaseWrapper.php svn
 application/hub/main/database/wrapper/states/.htaccess svneol=native#text/plain
 application/hub/main/database/wrapper/states/class_PeerStateLookupDatabaseWrapper.php svneol=native#text/plain
 application/hub/main/decorators/.htaccess -text svneol=unset#text/plain
-application/hub/main/decorators/class_BaseDecorator.php -text
 application/hub/main/discovery/.htaccess -text svneol=unset#text/plain
 application/hub/main/discovery/class_BaseHubDiscovery.php svneol=native#text/plain
 application/hub/main/discovery/package/.htaccess -text svneol=unset#text/plain
@@ -187,20 +178,18 @@ application/hub/main/factories/discovery/.htaccess -text svneol=unset#text/plain
 application/hub/main/factories/discovery/class_PackageDiscoveryFactory.php svneol=native#text/plain
 application/hub/main/factories/discovery/class_SocketDiscoveryFactory.php svneol=native#text/plain
 application/hub/main/factories/fragmenter/.htaccess -text
-application/hub/main/factories/fragmenter/class_FragmenterFactory.php -text
 application/hub/main/factories/lists/.htaccess -text svneol=unset#text/plain
 application/hub/main/factories/lists/class_RecipientListFactory.php svneol=native#text/plain
 application/hub/main/factories/package/.htaccess -text svneol=unset#text/plain
 application/hub/main/factories/package/class_NetworkPackageFactory.php svneol=native#text/plain
 application/hub/main/factories/producer/.htaccess -text
-application/hub/main/factories/producer/class_ProducerFactory.php -text
 application/hub/main/factories/socket/.htaccess -text svneol=unset#text/plain
 application/hub/main/factories/socket/class_SocketFactory.php svneol=native#text/plain
 application/hub/main/factories/source/.htaccess svneol=native#text/plain
 application/hub/main/factories/source/units/.htaccess svneol=native#text/plain
 application/hub/main/factories/source/units/class_UnitSourceFactory.php svneol=native#text/plain
 application/hub/main/factories/states/.htaccess -text svneol=unset#text/plain
-application/hub/main/factories/states/class_StateFactory.php -text svneol=unset#text/plain
+application/hub/main/factories/states/class_StateFactory.php svneol=native#text/plain
 application/hub/main/factories/states/cruncher/.htaccess svneol=native#text/plain
 application/hub/main/factories/states/cruncher/class_CruncherStateFactory.php svneol=native#text/plain
 application/hub/main/factories/states/node/.htaccess svneol=native#text/plain
@@ -211,88 +200,77 @@ application/hub/main/factories/tags/.htaccess -text svneol=unset#text/plain
 application/hub/main/factories/tags/class_PackageTagsFactory.php svneol=native#text/plain
 application/hub/main/filter/.htaccess -text svneol=unset#text/plain
 application/hub/main/filter/activation/.htaccess -text svneol=unset#text/plain
-application/hub/main/filter/activation/class_HubActivation -text
-application/hub/main/filter/activation/class_HubActivationSelfAnnouncementFilter.php -text svneol=unset#text/plain
+application/hub/main/filter/activation/class_HubActivationSelfAnnouncementFilter.php svneol=native#text/plain
 application/hub/main/filter/activation/node/.htaccess svneol=native#text/plain
-application/hub/main/filter/activation/node/class_NodeActivation -text
 application/hub/main/filter/activation/node/class_NodeActivationSelfAnnouncementFilter.php svneol=native#text/plain
 application/hub/main/filter/bootstrap/.htaccess -text svneol=unset#text/plain
-application/hub/main/filter/bootstrap/class_HubBootstrap -text
-application/hub/main/filter/bootstrap/class_HubBootstrapAquireHubIdFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/bootstrap/class_HubBootstrapExtraBootstrappingFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/bootstrap/class_HubBootstrapGenSessionIdFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/bootstrap/class_HubBootstrapGenerateHubIdFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/bootstrap/class_HubBootstrapGenerateSessionIdFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/bootstrap/class_HubBootstrapInitQueuesFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/bootstrap/class_HubBootstrapListenerPoolFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/bootstrap/class_HubBootstrapRestoreNodeListFilter.php -text svneol=unset#text/plain
+application/hub/main/filter/bootstrap/class_HubBootstrapAquireHubIdFilter.php svneol=native#text/plain
+application/hub/main/filter/bootstrap/class_HubBootstrapExtraBootstrappingFilter.php svneol=native#text/plain
+application/hub/main/filter/bootstrap/class_HubBootstrapGenSessionIdFilter.php svneol=native#text/plain
+application/hub/main/filter/bootstrap/class_HubBootstrapGenerateHubIdFilter.php svneol=native#text/plain
+application/hub/main/filter/bootstrap/class_HubBootstrapGenerateSessionIdFilter.php svneol=native#text/plain
+application/hub/main/filter/bootstrap/class_HubBootstrapInitQueuesFilter.php svneol=native#text/plain
+application/hub/main/filter/bootstrap/class_HubBootstrapListenerPoolFilter.php svneol=native#text/plain
+application/hub/main/filter/bootstrap/class_HubBootstrapRestoreNodeListFilter.php svneol=native#text/plain
 application/hub/main/filter/bootstrap/cruncher/.htaccess svneol=native#text/plain
-application/hub/main/filter/bootstrap/cruncher/class_CruncherBootstrap -text
 application/hub/main/filter/bootstrap/cruncher/class_CruncherBootstrapBufferQueueInitializerFilter.php svneol=native#text/plain
 application/hub/main/filter/bootstrap/cruncher/class_CruncherBootstrapExtraBootstrappingFilter.php svneol=native#text/plain
 application/hub/main/filter/bootstrap/cruncher/class_CruncherBootstrapGenericActivationFilter.php svneol=native#text/plain
 application/hub/main/filter/bootstrap/node/.htaccess svneol=native#text/plain
-application/hub/main/filter/bootstrap/node/class_NodeBootstrap -text
 application/hub/main/filter/bootstrap/node/class_NodeBootstrapExtraBootstrappingFilter.php svneol=native#text/plain
 application/hub/main/filter/bootstrap/node/class_NodeBootstrapGenerateNodeIdFilter.php svneol=native#text/plain
 application/hub/main/filter/bootstrap/node/class_NodeBootstrapGenerateSessionIdFilter.php svneol=native#text/plain
 application/hub/main/filter/bootstrap/node/class_NodeBootstrapInitQueuesFilter.php svneol=native#text/plain
 application/hub/main/filter/bootstrap/node/class_NodeBootstrapListenerPoolFilter.php svneol=native#text/plain
 application/hub/main/filter/bootstrap/node/class_NodeBootstrapRestoreNodeListFilter.php svneol=native#text/plain
-application/hub/main/filter/class_ -text svneol=unset#text/plain
+application/hub/main/filter/class_ svneol=native#text/plain
 application/hub/main/filter/console/.htaccess -text svneol=unset#text/plain
-application/hub/main/filter/console/class_Console -text
-application/hub/main/filter/console/class_ConsoleWelcomeTeaserFilter.php -text svneol=unset#text/plain
+application/hub/main/filter/console/class_ConsoleWelcomeTeaserFilter.php svneol=native#text/plain
 application/hub/main/filter/cruncher/.htaccess svneol=native#text/plain
-application/hub/main/filter/cruncher/class_Cruncher -text
 application/hub/main/filter/cruncher/class_CruncherInitializationFilter.php svneol=native#text/plain
 application/hub/main/filter/cruncher/class_CruncherPhpRequirementsFilter.php svneol=native#text/plain
 application/hub/main/filter/cruncher/class_CruncherWelcomeTeaserFilter.php svneol=native#text/plain
 application/hub/main/filter/node/.htaccess -text svneol=unset#text/plain
-application/hub/main/filter/node/class_Node -text
-application/hub/main/filter/node/class_NodeInitializationFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/node/class_NodePhpRequirementsFilter.php -text svneol=unset#text/plain
+application/hub/main/filter/node/class_NodeInitializationFilter.php svneol=native#text/plain
+application/hub/main/filter/node/class_NodePhpRequirementsFilter.php svneol=native#text/plain
 application/hub/main/filter/node/class_NodeWelcomeTeaserFilter.php svneol=native#text/plain
 application/hub/main/filter/shutdown/.htaccess -text svneol=unset#text/plain
-application/hub/main/filter/shutdown/class_HubShutdown -text
 application/hub/main/filter/shutdown/class_HubShutdownCruncherFilter.php svneol=native#text/plain
-application/hub/main/filter/shutdown/class_HubShutdownDeinitQueuesFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/shutdown/class_HubShutdownFlushNodeListFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/shutdown/class_HubShutdownListenerPoolFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/shutdown/class_HubShutdownNodeFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/shutdown/class_HubShutdownTaskHandlerFilter.php -text svneol=unset#text/plain
+application/hub/main/filter/shutdown/class_HubShutdownDeinitQueuesFilter.php svneol=native#text/plain
+application/hub/main/filter/shutdown/class_HubShutdownFlushNodeListFilter.php svneol=native#text/plain
+application/hub/main/filter/shutdown/class_HubShutdownListenerPoolFilter.php svneol=native#text/plain
+application/hub/main/filter/shutdown/class_HubShutdownNodeFilter.php svneol=native#text/plain
+application/hub/main/filter/shutdown/class_HubShutdownTaskHandlerFilter.php svneol=native#text/plain
 application/hub/main/filter/shutdown/cruncher/.htaccess svneol=native#text/plain
 application/hub/main/filter/shutdown/cruncher/class_CruncherShutdownCruncherFilter.php svneol=native#text/plain
 application/hub/main/filter/shutdown/node/.htaccess svneol=native#text/plain
-application/hub/main/filter/shutdown/node/class_NodeShutdown -text
 application/hub/main/filter/shutdown/node/class_NodeShutdownDeinitQueuesFilter.php svneol=native#text/plain
 application/hub/main/filter/shutdown/node/class_NodeShutdownFlushNodeListFilter.php svneol=native#text/plain
 application/hub/main/filter/shutdown/node/class_NodeShutdownNodeFilter.php svneol=native#text/plain
 application/hub/main/filter/shutdown/node/class_NodeShutdownTaskHandlerFilter.php svneol=native#text/plain
 application/hub/main/filter/task/.htaccess -text svneol=unset#text/plain
 application/hub/main/filter/task/class_CruncherTaskHandlerInitializerFilter.php svneol=native#text/plain
-application/hub/main/filter/task/class_HubTaskHandlerInitializerFilter.php -text svneol=unset#text/plain
-application/hub/main/filter/task/class_TaskHandlerInitializerFilter.php -text svneol=unset#text/plain
+application/hub/main/filter/task/class_HubTaskHandlerInitializerFilter.php svneol=native#text/plain
+application/hub/main/filter/task/class_TaskHandlerInitializerFilter.php svneol=native#text/plain
 application/hub/main/filter/task/cruncher/.htaccess svneol=native#text/plain
 application/hub/main/filter/task/cruncher/class_CruncherTaskHandlerInitializerFilter.php svneol=native#text/plain
 application/hub/main/filter/task/node/.htaccess svneol=native#text/plain
 application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php svneol=native#text/plain
 application/hub/main/handler/.htaccess -text svneol=unset#text/plain
-application/hub/main/handler/class_ -text svneol=unset#text/plain
-application/hub/main/handler/class_BaseHandler.php -text svneol=unset#text/plain
+application/hub/main/handler/class_ svneol=native#text/plain
+application/hub/main/handler/class_BaseHandler.php svneol=native#text/plain
 application/hub/main/handler/network/.htaccess -text svneol=unset#text/plain
-application/hub/main/handler/network/class_ -text svneol=unset#text/plain
-application/hub/main/handler/network/class_BaseNetworkPackageHandler.php -text svneol=unset#text/plain
+application/hub/main/handler/network/class_ svneol=native#text/plain
+application/hub/main/handler/network/class_BaseNetworkPackageHandler.php svneol=native#text/plain
 application/hub/main/handler/network/tcp/.htaccess -text svneol=unset#text/plain
-application/hub/main/handler/network/tcp/class_ -text svneol=unset#text/plain
-application/hub/main/handler/network/tcp/class_TcpNetworkPackageHandler.php -text svneol=unset#text/plain
+application/hub/main/handler/network/tcp/class_ svneol=native#text/plain
+application/hub/main/handler/network/tcp/class_TcpNetworkPackageHandler.php svneol=native#text/plain
 application/hub/main/handler/network/udp/.htaccess -text svneol=unset#text/plain
-application/hub/main/handler/network/udp/class_UdpNetworkPackageHandler.php -text svneol=unset#text/plain
+application/hub/main/handler/network/udp/class_UdpNetworkPackageHandler.php svneol=native#text/plain
 application/hub/main/handler/tasks/.htaccess -text svneol=unset#text/plain
-application/hub/main/handler/tasks/class_TaskHandler.php -text svneol=unset#text/plain
+application/hub/main/handler/tasks/class_TaskHandler.php svneol=native#text/plain
 application/hub/main/helper/.htaccess -text svneol=unset#text/plain
 application/hub/main/helper/connection/.htaccess -text svneol=unset#text/plain
-application/hub/main/helper/connection/class_ -text
 application/hub/main/helper/connection/class_BaseConnectionHelper.php svneol=native#text/plain
 application/hub/main/helper/connection/tcp/.htaccess -text svneol=unset#text/plain
 application/hub/main/helper/connection/tcp/class_TcpConnectionHelper.php svneol=native#text/plain
@@ -300,105 +278,100 @@ application/hub/main/helper/connection/udp/.htaccess -text svneol=unset#text/pla
 application/hub/main/helper/connection/udp/class_UdpConnectionHelper.php svneol=native#text/plain
 application/hub/main/helper/hub/.htaccess -text svneol=unset#text/plain
 application/hub/main/helper/hub/announcement/.htaccess -text svneol=unset#text/plain
-application/hub/main/helper/hub/announcement/class_HubDescriptorHelper.php -text svneol=unset#text/plain
-application/hub/main/helper/hub/class_ -text svneol=unset#text/plain
-application/hub/main/helper/hub/class_BaseHubHelper.php -text svneol=unset#text/plain
+application/hub/main/helper/hub/announcement/class_HubDescriptorHelper.php svneol=native#text/plain
+application/hub/main/helper/hub/class_ svneol=native#text/plain
+application/hub/main/helper/hub/class_BaseHubHelper.php svneol=native#text/plain
 application/hub/main/helper/hub/connection/.htaccess -text svneol=unset#text/plain
 application/hub/main/helper/hub/connection/class_HubSelfConnectHelper.php svneol=native#text/plain
 application/hub/main/helper/messages/.htaccess svneol=native#text/plain
-application/hub/main/helper/messages/class_ -text
 application/hub/main/helper/messages/class_BaseMessageHelper.php svneol=native#text/plain
 application/hub/main/helper/messages/crypto/.htaccess svneol=native#text/plain
 application/hub/main/helper/messages/crypto/class_CryptoRandomMessageHelper.php svneol=native#text/plain
 application/hub/main/helper/messages/crypto/class_CryptoRandomUnitMessageHelper.php svneol=native#text/plain
 application/hub/main/helper/work_units/.htaccess svneol=native#text/plain
-application/hub/main/helper/work_units/class_ -text
 application/hub/main/helper/work_units/class_BaseWorkUnitHelper.php svneol=native#text/plain
 application/hub/main/helper/work_units/cruncher/.htaccess svneol=native#text/plain
 application/hub/main/helper/work_units/cruncher/class_CruncherTestUnitHelper.php svneol=native#text/plain
 application/hub/main/iterator/.htaccess -text svneol=unset#text/plain
-application/hub/main/iterator/class_ -text svneol=unset#text/plain
-application/hub/main/iterator/class_BaseIterator.php -text svneol=unset#text/plain
+application/hub/main/iterator/class_ svneol=native#text/plain
+application/hub/main/iterator/class_BaseIterator.php svneol=native#text/plain
 application/hub/main/iterator/hub/.htaccess -text svneol=unset#text/plain
-application/hub/main/iterator/hub/class_HubPingIterator.php -text svneol=unset#text/plain
+application/hub/main/iterator/hub/class_HubPingIterator.php svneol=native#text/plain
 application/hub/main/iterator/network/.htaccess -text svneol=unset#text/plain
-application/hub/main/iterator/network/class_NetworkListenIterator.php -text svneol=unset#text/plain
+application/hub/main/iterator/network/class_NetworkListenIterator.php svneol=native#text/plain
 application/hub/main/iterator/pool/.htaccess -text svneol=unset#text/plain
-application/hub/main/iterator/pool/class_DefaultIterator.php -text svneol=unset#text/plain
+application/hub/main/iterator/pool/class_DefaultIterator.php svneol=native#text/plain
 application/hub/main/iterator/pool/handler/.htaccess -text svneol=unset#text/plain
-application/hub/main/iterator/pool/handler/class_Handler -text
-application/hub/main/iterator/pool/handler/class_HandlerPoolIterator.php -text svneol=unset#text/plain
+application/hub/main/iterator/pool/handler/class_HandlerPoolIterator.php svneol=native#text/plain
+application/hub/main/iterator/pool/monitor/.htaccess -text
 application/hub/main/iterator/pool/shutdown/.htaccess -text svneol=unset#text/plain
-application/hub/main/iterator/pool/shutdown/class_Shutdown -text
-application/hub/main/iterator/pool/shutdown/class_ShutdownPoolIterator.php -text svneol=unset#text/plain
+application/hub/main/iterator/pool/shutdown/class_ShutdownPoolIterator.php svneol=native#text/plain
 application/hub/main/iterator/pool/tasks/.htaccess -text svneol=unset#text/plain
-application/hub/main/iterator/pool/tasks/class_TaskPoolIterator.php -text svneol=unset#text/plain
+application/hub/main/iterator/pool/tasks/class_TaskPoolIterator.php svneol=native#text/plain
 application/hub/main/iterator/producer/.htaccess svneol=native#text/plain
 application/hub/main/iterator/producer/class_TestUnitKeyProducerIterator.php svneol=native#text/plain
 application/hub/main/iterator/producer/keys/.htaccess svneol=native#text/plain
 application/hub/main/iterator/producer/keys/class_TestUnitKeyProducerIterator.php svneol=native#text/plain
 application/hub/main/listener/.htaccess -text svneol=unset#text/plain
-application/hub/main/listener/class_ -text svneol=unset#text/plain
-application/hub/main/listener/class_BaseListener.php -text svneol=unset#text/plain
-application/hub/main/listener/class_BaseListenerDecorator.php -text svneol=unset#text/plain
+application/hub/main/listener/class_ svneol=native#text/plain
+application/hub/main/listener/class_BaseListener.php svneol=native#text/plain
+application/hub/main/listener/class_BaseListenerDecorator.php svneol=native#text/plain
 application/hub/main/listener/decorators/.htaccess -text svneol=unset#text/plain
 application/hub/main/listener/tcp/.htaccess -text svneol=unset#text/plain
-application/hub/main/listener/tcp/class_ -text svneol=unset#text/plain
-application/hub/main/listener/tcp/class_TcpListener.php -text svneol=unset#text/plain
+application/hub/main/listener/tcp/class_ svneol=native#text/plain
+application/hub/main/listener/tcp/class_TcpListener.php svneol=native#text/plain
 application/hub/main/listener/tcp/decorators/.htaccess -text svneol=unset#text/plain
-application/hub/main/listener/tcp/decorators/class_HubTcpListenerDecorator.php -text svneol=unset#text/plain
-application/hub/main/listener/tcp/decorators/class_PeerTcpListenerDecorator.php -text svneol=unset#text/plain
+application/hub/main/listener/tcp/decorators/class_HubTcpListenerDecorator.php svneol=native#text/plain
+application/hub/main/listener/tcp/decorators/class_PeerTcpListenerDecorator.php svneol=native#text/plain
 application/hub/main/listener/udp/.htaccess -text svneol=unset#text/plain
-application/hub/main/listener/udp/class_ -text svneol=unset#text/plain
-application/hub/main/listener/udp/class_UdpListener.php -text svneol=unset#text/plain
+application/hub/main/listener/udp/class_ svneol=native#text/plain
+application/hub/main/listener/udp/class_UdpListener.php svneol=native#text/plain
 application/hub/main/listener/udp/decorators/.htaccess -text svneol=unset#text/plain
-application/hub/main/listener/udp/decorators/class_HubUdpListenerDecorator.php -text svneol=unset#text/plain
-application/hub/main/listener/udp/decorators/class_PeerUdpListenerDecorator.php -text svneol=unset#text/plain
+application/hub/main/listener/udp/decorators/class_HubUdpListenerDecorator.php svneol=native#text/plain
+application/hub/main/listener/udp/decorators/class_PeerUdpListenerDecorator.php svneol=native#text/plain
 application/hub/main/lists/.htaccess -text svneol=unset#text/plain
-application/hub/main/lists/class_ -text svneol=unset#text/plain
-application/hub/main/lists/class_BaseList.php -text svneol=unset#text/plain
+application/hub/main/lists/class_ svneol=native#text/plain
+application/hub/main/lists/class_BaseList.php svneol=native#text/plain
 application/hub/main/lists/groups/.htaccess -text svneol=unset#text/plain
-application/hub/main/lists/groups/class_ListGroupList.php -text svneol=unset#text/plain
+application/hub/main/lists/groups/class_ListGroupList.php svneol=native#text/plain
 application/hub/main/lists/hub/.htaccess -text svneol=unset#text/plain
 application/hub/main/lists/hub/class_HubList.php svneol=native#text/plain
 application/hub/main/lists/pool/.htaccess -text svneol=unset#text/plain
-application/hub/main/lists/pool/class_PoolEntriesList.php -text svneol=unset#text/plain
+application/hub/main/lists/pool/class_PoolEntriesList.php svneol=native#text/plain
 application/hub/main/lists/query/.htaccess -text svneol=unset#text/plain
 application/hub/main/lists/query/local/.htaccess -text svneol=unset#text/plain
-application/hub/main/lists/query/local/class_LocalQueryList.php -text svneol=unset#text/plain
+application/hub/main/lists/query/local/class_LocalQueryList.php svneol=native#text/plain
 application/hub/main/lists/recipient/.htaccess -text svneol=unset#text/plain
 application/hub/main/lists/recipient/class_RecipientList.php svneol=native#text/plain
 application/hub/main/lists/tasks/.htaccess -text svneol=unset#text/plain
-application/hub/main/lists/tasks/class_TaskList.php -text svneol=unset#text/plain
+application/hub/main/lists/tasks/class_TaskList.php svneol=native#text/plain
 application/hub/main/lookup/.htaccess -text svneol=unset#text/plain
-application/hub/main/lookup/class_ -text svneol=unset#text/plain
+application/hub/main/lookup/class_ svneol=native#text/plain
 application/hub/main/lookup/class_BaseLookupTable.php svneol=native#text/plain
 application/hub/main/lookup/peer/.htaccess -text svneol=unset#text/plain
 application/hub/main/lookup/peer/class_PeerStateLookupTable.php svneol=native#text/plain
 application/hub/main/nodes/.htaccess -text svneol=unset#text/plain
 application/hub/main/nodes/boot/.htaccess -text svneol=unset#text/plain
-application/hub/main/nodes/boot/class_HubBootNode.php -text svneol=unset#text/plain
-application/hub/main/nodes/class_ -text svneol=unset#text/plain
-application/hub/main/nodes/class_BaseHubNode.php -text svneol=unset#text/plain
+application/hub/main/nodes/boot/class_HubBootNode.php svneol=native#text/plain
+application/hub/main/nodes/class_ svneol=native#text/plain
+application/hub/main/nodes/class_BaseHubNode.php svneol=native#text/plain
 application/hub/main/nodes/list/.htaccess -text svneol=unset#text/plain
-application/hub/main/nodes/list/class_HubListNode.php -text svneol=unset#text/plain
+application/hub/main/nodes/list/class_HubListNode.php svneol=native#text/plain
 application/hub/main/nodes/master/.htaccess -text svneol=unset#text/plain
-application/hub/main/nodes/master/class_HubMasterNode.php -text svneol=unset#text/plain
+application/hub/main/nodes/master/class_HubMasterNode.php svneol=native#text/plain
 application/hub/main/nodes/regular/.htaccess -text svneol=unset#text/plain
-application/hub/main/nodes/regular/class_HubRegularNode.php -text svneol=unset#text/plain
+application/hub/main/nodes/regular/class_HubRegularNode.php svneol=native#text/plain
 application/hub/main/package/.htaccess -text svneol=unset#text/plain
-application/hub/main/package/class_NetworkPackage.php -text svneol=unset#text/plain
+application/hub/main/package/class_NetworkPackage.php svneol=native#text/plain
 application/hub/main/package/fragmenter/.htaccess -text svneol=unset#text/plain
-application/hub/main/package/fragmenter/class_PackageFragmenter.php -text
 application/hub/main/pools/.htaccess -text svneol=unset#text/plain
-application/hub/main/pools/class_ -text svneol=unset#text/plain
-application/hub/main/pools/class_BasePool.php -text svneol=unset#text/plain
+application/hub/main/pools/class_ svneol=native#text/plain
+application/hub/main/pools/class_BasePool.php svneol=native#text/plain
 application/hub/main/pools/listener/.htaccess -text svneol=unset#text/plain
-application/hub/main/pools/listener/class_DefaultListenerPool.php -text svneol=unset#text/plain
+application/hub/main/pools/listener/class_DefaultListenerPool.php svneol=native#text/plain
 application/hub/main/pools/peer/.htaccess -text svneol=unset#text/plain
-application/hub/main/pools/peer/class_DefaultPeerPool.php -text svneol=unset#text/plain
+application/hub/main/pools/peer/class_DefaultPeerPool.php svneol=native#text/plain
 application/hub/main/producer/.htaccess svneol=native#text/plain
-application/hub/main/producer/class_ -text
 application/hub/main/producer/class_BaseProducer.php svneol=native#text/plain
 application/hub/main/producer/cruncher/.htaccess svneol=native#text/plain
 application/hub/main/producer/cruncher/class_BaseKeyProducer.php svneol=native#text/plain
@@ -408,15 +381,15 @@ application/hub/main/producer/cruncher/keys/class_CruncherKeyProducer.php svneol
 application/hub/main/producer/cruncher/work_units/.htaccess svneol=native#text/plain
 application/hub/main/producer/cruncher/work_units/class_CruncherTestUnitProducer.php svneol=native#text/plain
 application/hub/main/queries/.htaccess -text svneol=unset#text/plain
-application/hub/main/queries/class_ -text svneol=unset#text/plain
-application/hub/main/queries/class_BaseQuery.php -text svneol=unset#text/plain
+application/hub/main/queries/class_ svneol=native#text/plain
+application/hub/main/queries/class_BaseQuery.php svneol=native#text/plain
 application/hub/main/queries/local/.htaccess -text svneol=unset#text/plain
-application/hub/main/queries/local/class_LocalQuery.php -text svneol=unset#text/plain
+application/hub/main/queries/local/class_LocalQuery.php svneol=native#text/plain
 application/hub/main/queues/.htaccess -text svneol=unset#text/plain
-application/hub/main/queues/class_ -text svneol=unset#text/plain
-application/hub/main/queues/class_BaseQueue.php -text svneol=unset#text/plain
+application/hub/main/queues/class_ svneol=native#text/plain
+application/hub/main/queues/class_BaseQueue.php svneol=native#text/plain
 application/hub/main/queues/peer/.htaccess -text svneol=unset#text/plain
-application/hub/main/queues/peer/class_LocalPeerQueue.php -text svneol=unset#text/plain
+application/hub/main/queues/peer/class_LocalPeerQueue.php svneol=native#text/plain
 application/hub/main/registry/.htaccess -text svneol=unset#text/plain
 application/hub/main/registry/objects/.htaccess -text svneol=unset#text/plain
 application/hub/main/registry/objects/class_ObjectTypeRegistry.php svneol=native#text/plain
@@ -425,24 +398,22 @@ application/hub/main/registry/socket/class_SocketRegistry.php svneol=native#text
 application/hub/main/resolver/.htaccess -text svneol=unset#text/plain
 application/hub/main/resolver/command/.htaccess -text svneol=unset#text/plain
 application/hub/main/resolver/command/console/.htaccess -text svneol=unset#text/plain
-application/hub/main/resolver/command/console/class_HubConsoleCommandResolver.php -text svneol=unset#text/plain
+application/hub/main/resolver/command/console/class_HubConsoleCommandResolver.php svneol=native#text/plain
 application/hub/main/resolver/controller/.htaccess -text svneol=unset#text/plain
 application/hub/main/resolver/controller/console/.htaccess -text svneol=unset#text/plain
-application/hub/main/resolver/controller/console/class_HubConsoleControllerResolver.php -text svneol=unset#text/plain
+application/hub/main/resolver/controller/console/class_HubConsoleControllerResolver.php svneol=native#text/plain
 application/hub/main/resolver/state/.htaccess -text svneol=unset#text/plain
-application/hub/main/resolver/state/class_BaseStateResolver.php -text svneol=unset#text/plain
+application/hub/main/resolver/state/class_BaseStateResolver.php svneol=native#text/plain
 application/hub/main/resolver/state/network/.htaccess -text svneol=unset#text/plain
-application/hub/main/resolver/state/network/class_NetworkStateResolver.php -text svneol=unset#text/plain
+application/hub/main/resolver/state/network/class_NetworkStateResolver.php svneol=native#text/plain
 application/hub/main/source/.htaccess svneol=native#text/plain
-application/hub/main/source/class_ -text
 application/hub/main/source/class_BaseSource.php svneol=native#text/plain
 application/hub/main/source/units/.htaccess svneol=native#text/plain
 application/hub/main/source/units/class_TestUnitSource.php svneol=native#text/plain
 application/hub/main/states/.htaccess -text svneol=unset#text/plain
-application/hub/main/states/class_ -text svneol=unset#text/plain
-application/hub/main/states/class_BaseState.php -text svneol=unset#text/plain
+application/hub/main/states/class_ svneol=native#text/plain
+application/hub/main/states/class_BaseState.php svneol=native#text/plain
 application/hub/main/states/cruncher/.htaccess svneol=native#text/plain
-application/hub/main/states/cruncher/class_ -text
 application/hub/main/states/cruncher/class_BaseCruncherState.php svneol=native#text/plain
 application/hub/main/states/cruncher/init/.htaccess svneol=native#text/plain
 application/hub/main/states/cruncher/init/class_CruncherInitState.php svneol=native#text/plain
@@ -450,66 +421,60 @@ application/hub/main/states/cruncher/virgin/.htaccess svneol=native#text/plain
 application/hub/main/states/cruncher/virgin/class_CruncherVirginState.php svneol=native#text/plain
 application/hub/main/states/generic/.htaccess -text svneol=unset#text/plain
 application/hub/main/states/hub/.htaccess -text svneol=unset#text/plain
-application/hub/main/states/hub/class_BaseHubState.php -text svneol=unset#text/plain
+application/hub/main/states/hub/class_BaseHubState.php svneol=native#text/plain
 application/hub/main/states/node/.htaccess -text svneol=unset#text/plain
 application/hub/main/states/node/active/.htaccess -text svneol=unset#text/plain
-application/hub/main/states/node/active/class_NodeActiveState.php -text svneol=unset#text/plain
+application/hub/main/states/node/active/class_NodeActiveState.php svneol=native#text/plain
 application/hub/main/states/node/announced/.htaccess -text svneol=unset#text/plain
 application/hub/main/states/node/announced/class_NodeAnnouncedState.php svneol=native#text/plain
-application/hub/main/states/node/class_ -text svneol=unset#text/plain
-application/hub/main/states/node/class_BaseNodeState.php -text svneol=unset#text/plain
+application/hub/main/states/node/class_ svneol=native#text/plain
+application/hub/main/states/node/class_BaseNodeState.php svneol=native#text/plain
 application/hub/main/states/node/init/.htaccess -text svneol=unset#text/plain
-application/hub/main/states/node/init/class_NodeInitState.php -text svneol=unset#text/plain
+application/hub/main/states/node/init/class_NodeInitState.php svneol=native#text/plain
 application/hub/main/states/node/virgin/.htaccess -text svneol=unset#text/plain
-application/hub/main/states/node/virgin/class_NodeVirginState.php -text svneol=unset#text/plain
+application/hub/main/states/node/virgin/class_NodeVirginState.php svneol=native#text/plain
 application/hub/main/states/peer/.htaccess -text svneol=unset#text/plain
-application/hub/main/states/peer/class_ -text svneol=unset#text/plain
-application/hub/main/states/peer/class_BasePeerState.php -text svneol=unset#text/plain
+application/hub/main/states/peer/class_ svneol=native#text/plain
+application/hub/main/states/peer/class_BasePeerState.php svneol=native#text/plain
 application/hub/main/states/peer/new/.htaccess -text svneol=unset#text/plain
 application/hub/main/states/peer/new/class_NewConnectionPeerState.php svneol=native#text/plain
 application/hub/main/streams/.htaccess svneol=native#text/plain
 application/hub/main/streams/package/.htaccess svneol=native#text/plain
 application/hub/main/streams/package/input/.htaccess svneol=native#text/plain
-application/hub/main/streams/package/input/class_PackageInputStream.php -text
 application/hub/main/streams/package/output/.htaccess svneol=native#text/plain
 application/hub/main/streams/package/output/class_PackageOutputStream.php svneol=native#text/plain
 application/hub/main/streams/raw_data/.htaccess svneol=native#text/plain
 application/hub/main/streams/raw_data/input/.htaccess svneol=native#text/plain
-application/hub/main/streams/raw_data/input/class_RawDataInputStream.php -text
 application/hub/main/streams/raw_data/output/.htaccess svneol=native#text/plain
 application/hub/main/streams/raw_data/output/class_RawDataOutputStream.php svneol=native#text/plain
 application/hub/main/tags/.htaccess -text svneol=unset#text/plain
-application/hub/main/tags/class_ -text svneol=unset#text/plain
+application/hub/main/tags/class_ svneol=native#text/plain
 application/hub/main/tags/class_BaseTags.php svneol=native#text/plain
 application/hub/main/tags/package/.htaccess -text svneol=unset#text/plain
 application/hub/main/tags/package/class_PackageTags.php svneol=native#text/plain
 application/hub/main/tasks/.htaccess -text svneol=unset#text/plain
-application/hub/main/tasks/class_ -text svneol=unset#text/plain
-application/hub/main/tasks/class_BaseTask.php -text svneol=unset#text/plain
+application/hub/main/tasks/class_ svneol=native#text/plain
+application/hub/main/tasks/class_BaseTask.php svneol=native#text/plain
 application/hub/main/tasks/cruncher/.htaccess svneol=native#text/plain
-application/hub/main/tasks/cruncher/class_ -text
 application/hub/main/tasks/cruncher/class_CruncherKeyProducerTask.php svneol=native#text/plain
 application/hub/main/tasks/cruncher/class_CruncherTestUnitProducerTask.php svneol=native#text/plain
 application/hub/main/tasks/cruncher/class_CruncherWorkUnitFetcherTask.php svneol=native#text/plain
 application/hub/main/tasks/hub/.htaccess -text svneol=unset#text/plain
 application/hub/main/tasks/hub/announcement/.htaccess -text svneol=unset#text/plain
-application/hub/main/tasks/hub/announcement/class_HubSelfAnnouncementTask.php -text svneol=unset#text/plain
-application/hub/main/tasks/hub/class_HubSelfConnectTask.php -text svneol=unset#text/plain
-application/hub/main/tasks/hub/class_HubSocketListenerTask.php -text
+application/hub/main/tasks/hub/announcement/class_HubSelfAnnouncementTask.php svneol=native#text/plain
+application/hub/main/tasks/hub/class_HubSelfConnectTask.php svneol=native#text/plain
 application/hub/main/tasks/hub/ping/.htaccess -text svneol=unset#text/plain
-application/hub/main/tasks/hub/ping/class_HubPingTask.php -text svneol=unset#text/plain
+application/hub/main/tasks/hub/ping/class_HubPingTask.php svneol=native#text/plain
 application/hub/main/tasks/hub/update/.htaccess -text svneol=unset#text/plain
-application/hub/main/tasks/hub/update/class_HubUpdateCheckTask.php -text svneol=unset#text/plain
+application/hub/main/tasks/hub/update/class_HubUpdateCheckTask.php svneol=native#text/plain
 application/hub/main/tasks/idle/.htaccess -text svneol=unset#text/plain
-application/hub/main/tasks/idle/class_IdleLoopTask.php -text svneol=unset#text/plain
+application/hub/main/tasks/idle/class_IdleLoopTask.php svneol=native#text/plain
 application/hub/main/tasks/network/.htaccess -text svneol=unset#text/plain
-application/hub/main/tasks/network/class_NetworkPackageReaderTask.php -text
 application/hub/main/tasks/network/class_NetworkPackageWriterTask.php svneol=native#text/plain
 application/hub/main/template/.htaccess -text svneol=unset#text/plain
 application/hub/main/template/announcement/.htaccess -text svneol=unset#text/plain
-application/hub/main/template/announcement/class_AnnouncementTemplateEngine.php -text svneol=unset#text/plain
+application/hub/main/template/announcement/class_AnnouncementTemplateEngine.php svneol=native#text/plain
 application/hub/main/template/announcement/class_XmlAnnouncementTemplateEngine.php svneol=native#text/plain
-application/hub/main/template/class_ -text
 application/hub/main/template/connect/.htaccess -text svneol=unset#text/plain
 application/hub/main/template/connect/class_SelfConnectTemplateEngine.php svneol=native#text/plain
 application/hub/main/template/connect/class_XmlSelfConnectTemplateEngine.php svneol=native#text/plain
@@ -523,36 +488,35 @@ application/hub/main/template/work_units/.htaccess svneol=native#text/plain
 application/hub/main/tools/.htaccess -text svneol=unset#text/plain
 application/hub/main/tools/class_HubTools.php svneol=native#text/plain
 application/hub/main/visitor/.htaccess -text svneol=unset#text/plain
-application/hub/main/visitor/class_ -text svneol=unset#text/plain
-application/hub/main/visitor/class_BaseVisitor.php -text svneol=unset#text/plain
+application/hub/main/visitor/class_ svneol=native#text/plain
+application/hub/main/visitor/class_BaseVisitor.php svneol=native#text/plain
 application/hub/main/visitor/pool/.htaccess -text svneol=unset#text/plain
-application/hub/main/visitor/pool/class_ -text svneol=unset#text/plain
+application/hub/main/visitor/pool/class_ svneol=native#text/plain
 application/hub/main/visitor/pool/handler/.htaccess -text svneol=unset#text/plain
-application/hub/main/visitor/pool/handler/class_Handler -text
+application/hub/main/visitor/pool/monitor/.htaccess -text
 application/hub/main/visitor/pool/shutdown/.htaccess -text svneol=unset#text/plain
-application/hub/main/visitor/pool/shutdown/class_Shutdown -text
-application/hub/main/visitor/pool/shutdown/class_ShutdownListenerPoolVisitor.php -text svneol=unset#text/plain
+application/hub/main/visitor/pool/shutdown/class_ShutdownListenerPoolVisitor.php svneol=native#text/plain
 application/hub/main/visitor/socket/.htaccess -text svneol=unset#text/plain
 application/hub/main/visitor/socket/class_ShutdownSocketVisitor.php svneol=native#text/plain
 application/hub/main/visitor/tasks/.htaccess -text svneol=unset#text/plain
-application/hub/main/visitor/tasks/class_ActiveTaskVisitor.php -text svneol=unset#text/plain
+application/hub/main/visitor/tasks/class_ActiveTaskVisitor.php svneol=native#text/plain
 application/hub/main/visitor/tasks/class_ShutdownTaskVisitor.php svneol=native#text/plain
-application/hub/starter.php -text svneol=unset#text/plain
+application/hub/starter.php svneol=native#text/plain
 application/hub/templates/.htaccess -text svneol=unset#text/plain
 application/hub/templates/xml/.htaccess -text svneol=unset#text/plain
-application/hub/templates/xml/.xml -text svneol=unset#text/plain
+application/hub/templates/xml/.xml svneol=native#text/plain
 application/hub/templates/xml/announcement/.htaccess -text svneol=unset#text/plain
-application/hub/templates/xml/announcement/self_announcement.xml -text svneol=unset#text/plain
+application/hub/templates/xml/announcement/self_announcement.xml svneol=native#text/plain
 application/hub/templates/xml/cruncher/.htaccess svneol=native#text/plain
 application/hub/templates/xml/cruncher/producer/.htaccess svneol=native#text/plain
-application/hub/templates/xml/cruncher/producer/test_unit.xml -text svneol=unset#text/plain
-application/hub/templates/xml/cruncher/producer/work_unit.xml -text svneol=unset#text/plain
+application/hub/templates/xml/cruncher/producer/test_unit.xml svneol=native#text/plain
+application/hub/templates/xml/cruncher/producer/work_unit.xml svneol=native#text/plain
 application/hub/templates/xml/node/.htaccess -text svneol=unset#text/plain
-application/hub/templates/xml/node/node_status.xml -text svneol=unset#text/plain
+application/hub/templates/xml/node/node_status.xml svneol=native#text/plain
 application/hub/templates/xml/object_registry/.htaccess -text svneol=unset#text/plain
-application/hub/templates/xml/object_registry/object_registry.xml -text svneol=unset#text/plain
+application/hub/templates/xml/object_registry/object_registry.xml svneol=native#text/plain
 application/hub/templates/xml/self_connect/.htaccess -text svneol=unset#text/plain
-application/hub/templates/xml/self_connect/self_connect.xml -text svneol=unset#text/plain
+application/hub/templates/xml/self_connect/self_connect.xml svneol=native#text/plain
 /clear-cache.sh -text
 db/.htaccess -text svneol=unset#text/plain
 db/cruncher_projects/.htaccess svneol=native#text/plain
@@ -567,8 +531,8 @@ docs/COPYING.software -text
 docs/NEWS -text
 docs/README -text
 docs/THANKS -text
-docs/TODOs.txt -text svneol=unset#text/plain
-/index.php -text svneol=unset#text/plain
+docs/TODOs.txt svneol=native#text/plain
+/index.php svneol=native#text/plain
 /package.sh -text
 /pdepend.sh -text
 /rebuild_doc.sh -text

diff --git a/application/hub/config.php b/application/hub/config.php
index 311ea35949a8060a546df0a2964e460a558ce3b3..99051c87226bc5c41c305e5d0dfd07904ddbff94 100644 (file)
--- a/application/hub/config.php
+++ b/application/hub/config.php
@@ -120,6 +120,9 @@ $cfg->setConfigEntry('shutdown_socket_visitor_class', 'ShutdownSocketVisitor');
 // CFG: ACTIVE-TASK-VISITOR-CLASS
 $cfg->setConfigEntry('active_task_visitor_class', 'ActiveTaskVisitor');
 
+// CFG: NODE-RAW-DATA-MONITOR-VISITOR-CLASS
+$cfg->setConfigEntry('node_raw_data_monitor_visitor_class', 'RawDataPoolMonitorVisitor');
+
 // CFG: LIST-GROUP-CLASS
 $cfg->setConfigEntry('list_group_class', 'ListGroupList');
 
@@ -408,6 +411,9 @@ $cfg->setConfigEntry('task_list_class', 'TaskList');
 // CFG: TASK-POOL-ITERATOR-CLASS
 $cfg->setConfigEntry('task_pool_iterator_class', 'TaskPoolIterator');
 
+// CFG: MONITOR-POOL-ITERATOR-CLASS
+$cfg->setConfigEntry('monitor_pool_iterator_class', 'MonitorPoolIterator');
+
 // CFG: DEFAULT-ITERATOR-CLASS
 $cfg->setConfigEntry('default_iterator_class', 'DefaultIterator');
 

diff --git a/application/hub/interfaces/connectors/class_Connectable.php b/application/hub/interfaces/connectors/class_Connectable.php
index 4a734ce1d808f4001241315ab680cc02f06f7f70..a806e4850cb19152d7b269978e59333437b63acd 100644 (file)
--- a/application/hub/interfaces/connectors/class_Connectable.php
+++ b/application/hub/interfaces/connectors/class_Connectable.php
@@ -29,7 +29,7 @@ interface Connectable extends FrameworkInterface {
         *
         * @return      void
         */
-       function handlePanding ();
+       function handlePending ();
 }
 
 // [EOF]

diff --git a/application/hub/interfaces/handler/network/class_Networkable.php b/application/hub/interfaces/handler/network/class_Networkable.php
index 12b1ad2ada159cd6c3a945b380b9998aa1022fdb..0e88879edd23a6bbd1ca2e02bb74e378051c8eb4 100644 (file)
--- a/application/hub/interfaces/handler/network/class_Networkable.php
+++ b/application/hub/interfaces/handler/network/class_Networkable.php
@@ -30,7 +30,7 @@ interface Networkable extends Handleable {
         * @return      void
         * @throws      InvalidResourceException        If the given resource is invalid
         */
-       function processResourceRawData ($resource);
+       function processRawDataFromResource ($resource);
 }
 
 // [EOF]

diff --git a/application/hub/interfaces/listener/class_Listenable.php b/application/hub/interfaces/listener/class_Listenable.php
index c32a2d8b60d96ab097da799b6f9ff47cb7e891cd..05782bb3a7bd8e4ad46fddd000eb3ed8d92216e7 100644 (file)
--- a/application/hub/interfaces/listener/class_Listenable.php
+++ b/application/hub/interfaces/listener/class_Listenable.php
@@ -43,6 +43,15 @@ interface Listenable extends ProtocolHandler {
         * @return      $accepts                Wether this listener does accept
         */
        function ifListenerAcceptsPackageData (array $packageData);
+
+       /**
+        * Monitors incoming raw data from the handler and transfers it to the
+        * given receiver instance.
+        *
+        * @param       $receiverInstance       An instance of a Receivable class
+        * @return      void
+        */
+       function monitorIncomingRawData (Receivable $receiverInstance);
 }
 
 // [EOF]

diff --git a/application/hub/main/class_BaseHubSystem.php b/application/hub/main/class_BaseHubSystem.php
index d9f33239bdb45f494049ea0d71e5b52bb683c2f3..824353d673b3fd8aa462d9944e259b2302209a18 100644 (file)
--- a/application/hub/main/class_BaseHubSystem.php
+++ b/application/hub/main/class_BaseHubSystem.php
@@ -47,6 +47,11 @@ class BaseHubSystem extends BaseFrameworkSystem {
         */
        private $packageInstance = null;
 
+       /**
+        * A Receivable instance
+        */
+       private $receiverInstance = null;
+
        /**
         * State instance
         */
@@ -144,6 +149,25 @@ class BaseHubSystem extends BaseFrameworkSystem {
                return $this->packageInstance;
        }
 
+       /**
+        * Setter for receiver instance
+        *
+        * @param       $receiverInstance       A Receivable instance we shall set
+        * @return      void
+        */
+       protected final function setReceiverInstance (Receivable $receiverInstance) {
+               $this->receiverInstance = $receiverInstance;
+       }
+
+       /**
+        * Getter for receiver instance
+        *
+        * @return      $receiverInstance       A Receivable instance we shall get
+        */
+       protected final function getReceiverInstance () {
+               return $this->receiverInstance;
+       }
+
        /**
         * Setter for state instance
         *

diff --git a/application/hub/main/connectors/query/local/class_LocalQueryConnector.php b/application/hub/main/connectors/query/local/class_LocalQueryConnector.php
index f77945448eb2f0d87825af376e3acf193b00bb0a..94a5c9ac1ff389a92c3fec13a775635d24ac103c 100644 (file)
--- a/application/hub/main/connectors/query/local/class_LocalQueryConnector.php
+++ b/application/hub/main/connectors/query/local/class_LocalQueryConnector.php
@@ -112,7 +112,7 @@ class LocalQueryConnector extends BaseQueryConnector implements Connectable, Vis
         *
         * @return      void
         */
-       public function handlePanding () {
+       public function handlePending () {
                // Should we rewind?
                if (!$this->getIteratorInstance()->valid()) {
                        // Rewind to the beginning for next loop

diff --git a/application/hub/main/connectors/queues/local/class_LocalQueueConnector.php b/application/hub/main/connectors/queues/local/class_LocalQueueConnector.php
index f8cd16ddf456ef1de7f986831e56d20f2dbd3d48..a0c64191c1c715b7de99d63c385c056f1247f679 100644 (file)
--- a/application/hub/main/connectors/queues/local/class_LocalQueueConnector.php
+++ b/application/hub/main/connectors/queues/local/class_LocalQueueConnector.php
@@ -78,7 +78,7 @@ class LocalQueueConnector extends BaseQueueConnector implements Connectable, Que
         *
         * @return      void
         */
-       public function handlePanding () {
+       public function handlePending () {
                // Should we rewind?
                if (!$this->getIteratorInstance()->valid()) {
                        // Rewind to the beginning for next loop

diff --git a/application/hub/main/handler/network/tcp/class_TcpNetworkPackageHandler.php b/application/hub/main/handler/network/tcp/class_TcpNetworkPackageHandler.php
index 56a6fe5bcfba6476aa4894b97b56175e583a1372..f11045886f99b030fa6435da1045d739b7592069 100644 (file)
--- a/application/hub/main/handler/network/tcp/class_TcpNetworkPackageHandler.php
+++ b/application/hub/main/handler/network/tcp/class_TcpNetworkPackageHandler.php
@@ -55,7 +55,7 @@ class TcpNetworkPackageHandler extends BaseNetworkPackageHandler implements Netw
         * @param       $resource       A valid resource identifier
         * @return      void
         */
-       public function processResourceRawData ($resource) {
+       public function processRawDataFromResource ($resource) {
                // Check the resource
                if (!is_resource($resource)) {
                        // Throw an exception

diff --git a/application/hub/main/handler/network/udp/class_UdpNetworkPackageHandler.php b/application/hub/main/handler/network/udp/class_UdpNetworkPackageHandler.php
index 84e98fcb6262f6a182407ffe17a064b0ed6b8b08..5bd1ea09bc7712ec8c622268a0f386caedb98434 100644 (file)
--- a/application/hub/main/handler/network/udp/class_UdpNetworkPackageHandler.php
+++ b/application/hub/main/handler/network/udp/class_UdpNetworkPackageHandler.php
@@ -57,7 +57,7 @@ class UdpNetworkPackageHandler extends BaseNetworkPackageHandler implements Netw
         * @throws      InvalidResourceException        If the given resource is invalid
         * @todo        0%
         */
-       public function processResourceRawData ($resource) {
+       public function processRawDataFromResource ($resource) {
                // Check the resource
                if (!is_resource($resource)) {
                        // Throw an exception

diff --git a/application/hub/main/iterator/pool/monitor/.htaccess b/application/hub/main/iterator/pool/monitor/.htaccess
new file mode 100644 (file)
index 0000000..3a42882
--- /dev/null
+++ b/application/hub/main/iterator/pool/monitor/.htaccess
@@ -0,0 +1 @@
+Deny from all

diff --git a/application/hub/main/iterator/pool/monitor/class_MonitorPoolIterator.php b/application/hub/main/iterator/pool/monitor/class_MonitorPoolIterator.php
new file mode 100644 (file)
index 0000000..67a0f23
--- /dev/null
+++ b/application/hub/main/iterator/pool/monitor/class_MonitorPoolIterator.php
@@ -0,0 +1,124 @@
+<?php
+/**
+ * A MonitorPool iterator
+ *
+ * @author             Roland Haeder <webmaster@ship-simu.org>
+ * @version            0.0.0
+ * @copyright  Copyright (c) 2007, 2008 Roland Haeder, 2009 - 2011 Hub Developer Team
+ * @license            GNU GPL 3.0 or any newer version
+ * @link               http://www.ship-simu.org
+ * @todo               This current implementation is not recommended, use a
+ * @todo               latency-based iteration or similar approaches
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+class MonitorPoolIterator extends BaseIterator implements Iterator {
+       /**
+        * Key for the global list index
+        */
+       private $indexKey = 0;
+
+       /**
+        * Protected constructor
+        *
+        * @return      void
+        */
+       protected function __construct () {
+               // Call parent constructor
+               parent::__construct(__CLASS__);
+       }
+
+       /**
+        * Creates an instance of this class
+        *
+        * @param       $listInstance           A list of a Listable
+        * @return      $iteratorInstance       An instance a Iterator class
+        */
+       public static final function createMonitorPoolIterator (Listable $listInstance) {
+               // Get new instance
+               $iteratorInstance = new MonitorPoolIterator();
+
+               // Set the list
+               $iteratorInstance->setListInstance($listInstance);
+
+               // Return the prepared instance
+               return $iteratorInstance;
+       }
+
+       /**
+        * Getter for current value from group or generic
+        *
+        * @return      $current        Current value in iteration
+        * @throws      IndexOutOfBoundsException       If $indexKey is out of bounds
+        */
+       public function current () {
+               // Default is null
+               $current = null;
+
+               // Is the entry valid?
+               if (!$this->valid()) {
+                       // Throw an exception here
+                       throw new IndexOutOfBoundsException($this->key(), self::EXCEPTION_INDEX_OUT_OF_BOUNDS);
+               } // END - if
+
+               // Now get the entry
+               $current = $this->getListInstance()->getEntry($this->key());
+
+               // Return it
+               return $current;
+       }
+
+       /**
+        * Getter for key from group or generic
+        *
+        * @return      $indexKey       Current key in iteration
+        */
+       public function key () {
+               return $this->indexKey;
+       }
+
+       /**
+        * Advances to the next entry
+        *
+        * @return      void
+        */
+       public function next () {
+               $this->indexKey++;
+       }
+
+       /**
+        * Rewinds to the beginning of the iteration
+        *
+        * @return      void
+        */
+       public function rewind () {
+               $this->indexKey = 0;
+       }
+
+       /**
+        * Checks wether the current entry is valid (not at the end of the list)
+        *
+        * @return      $isValid        Wether the current entry is there
+        */
+       public function valid () {
+               // Check for total active peers and if we are not at the end
+               $isValid = ($this->key() < $this->getListInstance()->count());
+
+               // Return result
+               return $isValid;
+       }
+}
+
+// [EOF]
+?>

diff --git a/application/hub/main/listener/class_BaseListener.php b/application/hub/main/listener/class_BaseListener.php
index 5fc36c055fab4a3eab2a6e519fc8b227b8f40483..9c5f3fade1138b18bd51eeebf1e36ce52dd4fa06 100644 (file)
--- a/application/hub/main/listener/class_BaseListener.php
+++ b/application/hub/main/listener/class_BaseListener.php
@@ -291,6 +291,19 @@ class BaseListener extends BaseHubSystem implements Visitable {
                // Debug message
                //* DEBUG: */ $this->debugOutput('LISTENER: ' . $visitorInstance->__toString() . ' has visited ' . $this->__toString() . ' - FINISHED');
        }
+
+       /**
+        * Monitors incoming raw data from the handler and transfers it to the
+        * given receiver instance. This method should not be called, please call
+        * the decorator's version instead to seperator node/client traffic.
+        *
+        * @param       $receiverInstance       An instance of a Receivable class
+        * @return      void
+        * @throws      UnsupportedOperatorException    If this method is called by a mistake
+        */
+       public function monitorIncomingRawData (Receivable $receiverInstance) {
+               throw new UnsupportedOperationException(array($this, __FUNCTION__, $receiverInstance), self::EXCEPTION_UNSPPORTED_OPERATION);
+       }
 }
 
 // [EOF]

diff --git a/application/hub/main/listener/class_BaseListenerDecorator.php b/application/hub/main/listener/class_BaseListenerDecorator.php
index ee2c0a49884e3189ad1618adc03f81e7fe0de101..e71c66f7ca3731f5587383a129faeb932a4648e7 100644 (file)
--- a/application/hub/main/listener/class_BaseListenerDecorator.php
+++ b/application/hub/main/listener/class_BaseListenerDecorator.php
@@ -115,6 +115,26 @@ class BaseListenerDecorator extends BaseDecorator implements Visitable {
        public final function getPoolInstance () {
                return $this->getListenerInstance()->getPoolInstance();
        }
+
+       /**
+        * Monitors incoming raw data from the handler and transfers it to the
+        * given receiver instance.
+        *
+        * @param       $receiverInstance       An instance of a Receivable class
+        * @return      void
+        */
+       public function monitorIncomingRawData (Receivable $receiverInstance) {
+               /*
+                * Does our deocorated listener (or even a decorator again) have a
+                * handler assigned? Remember that a handler will hold all incoming raw
+                * data and not a listener.
+                */
+               if (!$this->getListenerInstance()->getHandlerInstance() instanceof Networkable) {
+                       // Skip this silently for now. Later on, this will become mandatory!
+                       //* NOISY-DEBUG: */ $this->debugOutput('No handler assigned to this listener decorator. this=' . $this->__toString() . ', listenerInstance=' . $this->getListenerInstance()->__toString());
+                       return;
+               } // END - if
+       }
 }
 
 // [EOF]

diff --git a/application/hub/main/listener/tcp/class_TcpListener.php b/application/hub/main/listener/tcp/class_TcpListener.php
index 355019c504600c1039cb472b041c1c6e375319c9..f8a9e21805a8092e3ce7f1c1a7d5da8c77f6cfe5 100644 (file)
--- a/application/hub/main/listener/tcp/class_TcpListener.php
+++ b/application/hub/main/listener/tcp/class_TcpListener.php
@@ -236,7 +236,7 @@ class TcpListener extends BaseListener implements Listenable {
                if ($currentSocket != $this->getSocketResource()) {
                        // ... or else it will raise warnings like 'Transport endpoint is not connected'
                        //* NOISY-DEBUG: */ $this->debugOutput('LISTENER: currentSocket=' . $currentSocket);
-                       $this->getHandlerInstance()->processResourceRawData($currentSocket);
+                       $this->getHandlerInstance()->processRawDataFromResource($currentSocket);
                } // END - if
 
                // Advance to next entry. This should be the last line

diff --git a/application/hub/main/package/class_NetworkPackage.php b/application/hub/main/package/class_NetworkPackage.php
index bdadfa7f8a4f296f04a2dbb4d4d64c58207fd1e0..d54d99b04dc6b7aecb2da612a07a3b6c6dc66b58 100644 (file)
--- a/application/hub/main/package/class_NetworkPackage.php
+++ b/application/hub/main/package/class_NetworkPackage.php
@@ -131,13 +131,6 @@ class NetworkPackage extends BaseFrameworkSystem implements Deliverable, Receiva
        protected function __construct () {
                // Call parent constructor
                parent::__construct(__CLASS__);
-
-               // We need to initialize a stack here for our packages even those
-               // which have no recipient address and stamp... ;-)
-               $stackerInstance = ObjectFactory::createObjectByConfiguredName('network_package_stacker_class');
-
-               // At last, set it in this class
-               $this->setStackerInstance($stackerInstance);
        }
 
        /**
@@ -153,6 +146,19 @@ class NetworkPackage extends BaseFrameworkSystem implements Deliverable, Receiva
                // Now set the compressor instance
                $packageInstance->setCompressorInstance($compressorInstance);
 
+               // We need to initialize a stack here for our packages even those
+               // which have no recipient address and stamp... ;-)
+               $stackerInstance = ObjectFactory::createObjectByConfiguredName('network_package_stacker_class');
+
+               // At last, set it in this class
+               $packageInstance->setStackerInstance($stackerInstance);
+
+               // Get a visitor instance for speeding up things
+               $visitorInstance = ObjectFactory::createObjectByConfiguredName('node_raw_data_monitor_visitor_class', array($packageInstance));
+
+               // Set it in this package
+               $packageInstance->setVisitorInstance($visitorInstance);
+
                // Return the prepared instance
                return $packageInstance;
        }
@@ -465,8 +471,15 @@ class NetworkPackage extends BaseFrameworkSystem implements Deliverable, Receiva
         * @return      $hasArrived             Wether new raw package data has arrived for processing
         */
        public function isNewRawDataPending (PoolableListener $poolInstance) {
-               // @TODO Add some content here
-               $this->partialStub('Do something here. poolInstance=' . $poolInstance->__toString());
+               // By default no new data has arrived
+               $hasArrived = false;
+
+               // Visit the pool
+               $poolInstance->accept($this->getVisitorInstance());
+               // @TODO Check for if new data has arrived
+
+               // Return the status
+               return $hasArrived;
        }
 
        /**

diff --git a/application/hub/main/visitor/class_ b/application/hub/main/visitor/class_
index e8d6b388feb8760139f53c74a3738396311e43e3..bce8b03e1729b0dd5459fc0ba880c3ebb1d13716 100644 (file)
--- a/application/hub/main/visitor/class_
+++ b/application/hub/main/visitor/class_
@@ -32,7 +32,7 @@ class ???Visitor extends BaseVisitor implements Visitor {
                parent::__construct(__CLASS__);
 
                // Set visitor mode
-               $this->setVisitorMode('???');
+               $this->setVisitorMode('!!!');
        }
 
        /**

diff --git a/application/hub/main/visitor/pool/monitor/.htaccess b/application/hub/main/visitor/pool/monitor/.htaccess
new file mode 100644 (file)
index 0000000..3a42882
--- /dev/null
+++ b/application/hub/main/visitor/pool/monitor/.htaccess
@@ -0,0 +1 @@
+Deny from all

diff --git a/application/hub/main/visitor/pool/monitor/class_RawDataPoolMonitorVisitor.php b/application/hub/main/visitor/pool/monitor/class_RawDataPoolMonitorVisitor.php
new file mode 100644 (file)
index 0000000..51eccab
--- /dev/null
+++ b/application/hub/main/visitor/pool/monitor/class_RawDataPoolMonitorVisitor.php
@@ -0,0 +1,94 @@
+<?php
+/**
+ * A RawDataMonitor visitor
+ *
+ * @author             Roland Haeder <webmaster@ship-simu.org>
+ * @version            0.0.0
+ * @copyright  Copyright (c) 2007, 2008 Roland Haeder, 2009 - 2011 Hub Developer Team
+ * @license            GNU GPL 3.0 or any newer version
+ * @link               http://www.ship-simu.org
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+class RawDataPoolMonitorVisitor extends BaseVisitor implements PoolVisitor, ListenerVisitor {
+       /**
+        * Protected constructor
+        *
+        * @return      void
+        */
+       protected function __construct () {
+               // Call parent constructor
+               parent::__construct(__CLASS__);
+
+               // Set visitor mode
+               $this->setVisitorMode('monitor');
+       }
+
+       /**
+        * Creates an instance of this class
+        *
+        * @param       $receiverInstance       An instance of a Receivable class
+        * @return      $visitorInstance        An instance of a Visitorable class
+        */
+       public final static function createRawDataPoolMonitorVisitor (Receivable $receiverInstance) {
+               // Get new instance
+               $visitorInstance = new RawDataPoolMonitorVisitor();
+
+               // Set the receiver instance
+               $visitorInstance->setReceiverInstance($receiverInstance);
+
+               // Return the prepared instance
+               return $visitorInstance;
+       }
+
+       /**
+        * Visits the given pool instance
+        *
+        * @param       $poolInstance   A Poolable instance
+        * @return      void
+        */
+       public function visitPool (Poolable $poolInstance) {
+               // A pool doesn't normally have any raw data waiting
+       }
+
+       /**
+        * Visits the given listener instance
+        *
+        * @param       $listenerInstance       A Listenable instance
+        * @return      void
+        */
+       public function visitListener (Listenable $listenerInstance) {
+               /*
+                * The listener itself cannot distinguish between node and client
+                * traffic. This is why we don't call its monitorIncomingRawData()
+                * method.
+                */
+       }
+
+       /**
+        * Visits the given decorator instance
+        *
+        * @param       $decoratorInstance      A decorator instance
+        * @return      void
+        */
+       public function visitDecorator (BaseDecorator $decoratorInstance) {
+               // Do monitor here
+               //* DEBUG: */ $this->debugOutput('VISITOR: Visiting ' . $listenerInstance->__toString() . ' - START');
+               $decoratorInstance->monitorIncomingRawData($this->getReceiverInstance());
+               //* DEBUG: */ $this->debugOutput('VISITOR: Visiting ' . $listenerInstance->__toString() . ' - FINISH');
+       }
+}
+
+// [EOF]
+?>

diff --git a/application/hub/main/visitor/socket/class_ShutdownSocketVisitor.php b/application/hub/main/visitor/socket/class_ShutdownSocketVisitor.php
index 04dd996947b03f4471bf370981c3dae4b4bc4c37..04d9d85e5ccd7ebf266a0db2d0b389eb38aee318 100644 (file)
--- a/application/hub/main/visitor/socket/class_ShutdownSocketVisitor.php
+++ b/application/hub/main/visitor/socket/class_ShutdownSocketVisitor.php
@@ -32,7 +32,7 @@ class ShutdownSocketVisitor extends BaseVisitor implements Visitor {
                parent::__construct(__CLASS__);
 
                // Set visitor mode
-               $this->setVisitorMode('ShutdownSocket');
+               $this->setVisitorMode('socket');
        }
 
        /**

diff --git a/application/hub/main/visitor/tasks/class_ActiveTaskVisitor.php b/application/hub/main/visitor/tasks/class_ActiveTaskVisitor.php
index 480e2f1e6bdc70d674a23de9bde2238b2804802e..2e8f5d82ffa7928554139720bfb7aed91b4baa34 100644 (file)
--- a/application/hub/main/visitor/tasks/class_ActiveTaskVisitor.php
+++ b/application/hub/main/visitor/tasks/class_ActiveTaskVisitor.php
@@ -69,7 +69,7 @@ class ActiveTaskVisitor extends BaseVisitor implements TaskVisitor, QueryConnect
         */
        public function visitQueryConnector (Connectable $connectorInstance) {
                // Process all pending queries
-               $connectorInstance->handlePanding();
+               $connectorInstance->handlePending();
        }
 
        /**
@@ -80,7 +80,7 @@ class ActiveTaskVisitor extends BaseVisitor implements TaskVisitor, QueryConnect
         */
        public function visitQueueConnector (Connectable $connectorInstance) {
                // Process all pending queries
-               $connectorInstance->handlePanding();
+               $connectorInstance->handlePending();
        }
 
        /**