From 4cff880509f76831687e90133f471e55831b791e Mon Sep 17 00:00:00 2001 From: =?utf8?q?Roland=20H=C3=A4der?= Date: Wed, 20 Apr 2011 04:15:33 +0000 Subject: [PATCH] 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 --- .gitattributes | 378 ++++++++---------- application/hub/config.php | 6 + .../connectors/class_Connectable.php | 2 +- .../handler/network/class_Networkable.php | 2 +- .../interfaces/listener/class_Listenable.php | 9 + application/hub/main/class_BaseHubSystem.php | 24 ++ .../query/local/class_LocalQueryConnector.php | 2 +- .../local/class_LocalQueueConnector.php | 2 +- .../tcp/class_TcpNetworkPackageHandler.php | 2 +- .../udp/class_UdpNetworkPackageHandler.php | 2 +- .../hub/main/iterator/pool/monitor/.htaccess | 1 + .../monitor/class_MonitorPoolIterator.php | 124 ++++++ .../hub/main/listener/class_BaseListener.php | 13 + .../listener/class_BaseListenerDecorator.php | 20 + .../main/listener/tcp/class_TcpListener.php | 2 +- .../hub/main/package/class_NetworkPackage.php | 31 +- application/hub/main/visitor/class_ | 2 +- .../hub/main/visitor/pool/monitor/.htaccess | 1 + .../class_RawDataPoolMonitorVisitor.php | 94 +++++ .../socket/class_ShutdownSocketVisitor.php | 2 +- .../visitor/tasks/class_ActiveTaskVisitor.php | 4 +- 21 files changed, 496 insertions(+), 227 deletions(-) create mode 100644 application/hub/main/iterator/pool/monitor/.htaccess create mode 100644 application/hub/main/iterator/pool/monitor/class_MonitorPoolIterator.php create mode 100644 application/hub/main/visitor/pool/monitor/.htaccess create mode 100644 application/hub/main/visitor/pool/monitor/class_RawDataPoolMonitorVisitor.php diff --git a/.gitattributes b/.gitattributes index 7d10afbd6..45d2e21b2 100644 --- 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 311ea3594..99051c872 100644 --- 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 4a734ce1d..a806e4850 100644 --- 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 12b1ad2ad..0e88879ed 100644 --- 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 c32a2d8b6..05782bb3a 100644 --- 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 d9f33239b..824353d67 100644 --- 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 f77945448..94a5c9ac1 100644 --- 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 f8cd16ddf..a0c64191c 100644 --- 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 56a6fe5bc..f11045886 100644 --- 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 84e98fcb6..5bd1ea09b 100644 --- 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 index 000000000..3a4288278 --- /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 index 000000000..67a0f2319 --- /dev/null +++ b/application/hub/main/iterator/pool/monitor/class_MonitorPoolIterator.php @@ -0,0 +1,124 @@ + + * @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 . + */ +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 5fc36c055..9c5f3fade 100644 --- 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 ee2c0a498..e71c66f7c 100644 --- 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 355019c50..f8a9e2180 100644 --- 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 bdadfa7f8..d54d99b04 100644 --- 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 e8d6b388f..bce8b03e1 100644 --- 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 index 000000000..3a4288278 --- /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 index 000000000..51eccab2e --- /dev/null +++ b/application/hub/main/visitor/pool/monitor/class_RawDataPoolMonitorVisitor.php @@ -0,0 +1,94 @@ + + * @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 . + */ +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 04dd99694..04d9d85e5 100644 --- 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 480e2f1e6..2e8f5d82f 100644 --- 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(); } /** -- 2.39.2