// Import hub-specific stuff
use Hub\Factory\Node\NodeObjectFactory;
use Hub\Generic\BaseHubSystem;
+use Hub\Helper\Connection\BaseConnectionHelper;
// Import framework stuff
use CoreFramework\Listener\Listenable;
<?php
// Own namespace
-namespace Hub\Factory\List\Recipient;
+namespace Hub\Factory\Lists\Recipient;
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
<?php
+// Own namespace
+namespace Hub\Helper\;
+
+// Import application-specific stuff
+use Hub\Helper\BaseHubSystemHelper;
+
/**
* A ??? !!! helper class
*
<?php
+// Own namespace
+namespace Hub\Helper\Connection\;
+
+// Import application-specific stuff
+use Hub\Helper\Connection\BaseConnectionHelper;
+
/**
* A ??? connection helper class
*
// Import application-specific stuff
use Hub\Factory\Fragmenter\FragmenterFactory;
+use Hub\Helper\BaseHubSystemHelper;
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
* @param $visitorInstance A Visitor instance
* @return void
*/
- protected final function accept (Visitor $visitorInstance) {
+ public function accept (Visitor $visitorInstance) {
// Just call the visitor
$visitorInstance->visitConnectionHelper($this);
}
<?php
+// Own namespace
+namespace Hub\Helper\Connection\IpV4;
+
+// Import application-specific stuff
+use Hub\Helper\Connection\BaseConnectionHelper;
+
/**
* A ??? connection helper class
*
// Import hub-specific stuff
use Hub\Generic\BaseHubSystem;
+use Hub\Helper\BaseHubSystemHelper;
/**
* A Bootstrap Dht helper class
// Import hub-specific stuff
use Hub\Generic\BaseHubSystem;
+use Hub\Helper\BaseHubSystemHelper;
/**
* A PublishingEntry Dht helper class
// Import hub-specific stuff
use Hub\Generic\BaseHubSystem;
+use Hub\Helper\BaseHubSystemHelper;
/**
* A general node helper class
<?php
+// Own namespace
+namespace Hub\Iterator\Network\Listener;
+
+// Import framework stuff
+use CoreFramework\Lists\Listable;
+
/**
* A NetworkListen iterator
*
<?php
+// Own namespace
+namespace Hub\Iterator\Handler\Pool;
+
+// Import framework stuff
+use CoreFramework\Lists\Listable;
+
/**
* A HandlerPool iterator
*
// Import framework stuff
use CoreFramework\Registry\Registerable;
+use CoreFramework\Lists\Listable;
/**
* A MonitorPool iterator
<?php
+// Own namespace
+namespace Hub\Iterator\Pool\Shutdown;
+
+// Import framework stuff
+use CoreFramework\Lists\Listable;
+
/**
* A ShutdownPool iterator
*
namespace Hub\Iterator\Pool\Task;
// Import framework stuff
+use CoreFramework\Lists\Listable;
use CoreFramework\Registry\Registerable;
/**
// Own namespace
namespace Hub\Listener\Tcp;
+// Import application-specific stuff
+use Hub\Helper\Connection\BaseConnectionHelper;
+
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
use CoreFramework\Generic\UnsupportedOperationException;
<?php
+// Own namespace
+namespace Hub\Lists\Hub;
+
+// Import framework stuff
+use CoreFramework\Lists\BaseList;
+use CoreFramework\Lists\Listable;
+
/**
* A Hub list
*
<?php
// Own namespace
-namespace Hub\List\Pool;
+namespace Hub\Lists\Pool;
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
+use CoreFramework\Lists\BaseList;
+use CoreFramework\Lists\Listable;
/**
* A list for pool entries
<?php
// Own namespace
-namespace Hub\List\Recipient;
+namespace Hub\Lists\Recipient;
// Import framework stuff
+use CoreFramework\Lists\BaseList;
+use CoreFramework\Lists\Listable;
use CoreFramework\Registry\Registerable;
/**
use Hub\Factory\Dht\DhtObjectFactory;
use Hub\Factory\Node\NodeObjectFactory;
use Hub\Generic\BaseHubSystem;
+use Hub\Helper\Connection\BaseConnectionHelper;
use Hub\Network\Receive\Receivable;
use Hub\Tools\HubTools;
// Import hub-specific stuff
use Hub\Generic\BaseHubSystem;
+use Hub\Helper\Connection\BaseConnectionHelper;
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
}
/**
- * Run the shutdown seqeuence by a visitor pattern
+ * Run the pre-shutdown seqeuence by a visitor pattern
*
* @return void
*/
- public function doShutdown () {
+ public function preShutdown () {
// Debug message
/* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('POOL[' . __METHOD__ . ':' . __LINE__ . ']: Shutting down listener pool - CALLED!');
<?php
+// Own namespace
+namespace Hub\Recipient\;
+
+// Import framework stuff
+use CoreFramework\Lists\Listable;
+
/**
* A ??? recipient
*
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
+use CoreFramework\Lists\Listable;
/**
* A DHT recipient
// Import hub-specific sutff
use Hub\Tools\HubTools;
+// Import framework stuff
+use CoreFramework\Lists\Listable;
+
/**
* A Direct recipient
*
// Import hub-specific sutff
use Hub\Tools\HubTools;
+// Import framework stuff
+use CoreFramework\Lists\Listable;
+
/**
* A Self recipient
*
// Import hub-specific stuff
use Hub\Generic\BaseHubSystem;
+// Import framework stuff
+use CoreFramework\Lists\Listable;
+
/**
* A Upper recipient
*
namespace Hub\Node\Ping;
// Import framework stuff
+use CoreFramework\Lists\Listable;
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
use CoreFramework\Visitor\Visitor;
$cfg->setConfigEntry('udp_listener_class', 'UdpListener');
// CFG: SOCKET-FILE-LISTENER-CLASS
-$cfg->setConfigEntry('socket_file_listener_class', 'SocketFileListener');
+$cfg->setConfigEntry('socket_file_listener_class', 'CoreFramework\Listener\Socket\SocketFileListener');
// CFG: SOCKET-FILE-DECORATOR-LISTENER-CLASS
-$cfg->setConfigEntry('socket_file_decorator_listener_class', 'SocketFileListenerDecorator');
+$cfg->setConfigEntry('socket_file_decorator_listener_class', 'CoreFramework\Listener\Socket\SocketFileListenerDecorator');
// CFG: NODE-TCP-LISTENER-CLASS
$cfg->setConfigEntry('node_tcp_listener_class', 'HubTcpListenerDecorator');
$cfg->setConfigEntry('application_pool_class', 'DefaultPeerPool');
// CFG: POOL-ENTRIES-LIST-CLASS
-$cfg->setConfigEntry('pool_entries_list_class', 'PoolEntriesList');
+$cfg->setConfigEntry('pool_entries_list_class', 'Hub\Lists\Pool\PoolEntriesList');
// CFG: SHUTDOWN-POOL-ITERATOR-CLASS
$cfg->setConfigEntry('shutdown_pool_iterator_class', 'ShutdownPoolIterator');
// Import framework stuff
use CoreFramework\Generic\FrameworkInterface;
+use CoreFramework\Lists\Listable;
/**
* An interface for recipients
-Subproject commit 1e0fc6320d565605e15aa4f023915ca1574272e4
+Subproject commit 6cf40d9bfbe6159ce08cbec4c87d504f5829429d