// Import framework stuff
use CoreFramework\Object\BaseFrameworkSystem;
+use CoreFramework\Pool\Poolable;
/**
* A general hub system class
* @param $listenerPoolInstance The new listener pool instance
* @return void
*/
- protected final function setListenerPoolInstance (PoolableListener $listenerPoolInstance) {
+ protected final function setListenerPoolInstance (Poolable $listenerPoolInstance) {
$this->listenerPoolInstance = $listenerPoolInstance;
}
use Hub\Generic\BaseHubSystem;
// Import framework stuff
+use CoreFramework\Listener\Listenable;
use CoreFramework\Registry\Registerable;
use CoreFramework\Registry\Registry;
use CoreFramework\Factory\ObjectFactory;
use CoreFramework\Registry\Registry;
use CoreFramework\Task\Taskable;
-use CoreFramework\Visitor\Visitable;
/**
* A factory class for URL sources
foreach ($clients as $send_sock) {
// if its the listening sock or the client that we got the message from, go to the next one in the list
- if ($send_sock == $mainSocket || $send_sock == $read_sock)
+ if ($send_sock == $mainSocket || $send_sock == $read_sock) {
continue;
+ } // END - if
// write the message to the client -- add a newline character to the end of the message
socket_write($send_sock, "{$ip}:{$data}\n");
// Import application-specific stuff
use Hub\Helper\Node\NodeHelper;
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+use CoreFramework\Visitor\Visitable;
+
<?php
/**
* A TCP ??? listener
<?php
+// Own namespace
+namespace Hub\Handler\RawData\Tcp;
+
+// Import application-specific stuff
+use Hub\Pool\BasePool;
+
/**
* A TCP raw data handler
*
<?php
+// Own namespace
+namespace Hub\Handler\RawData\Udp;
+
+// Import application-specific stuff
+use Hub\Pool\BasePool;
+
/**
* A UDP raw data handler
*
use CoreFramework\Factory\ObjectFactory;
use CoreFramework\Registry\Registry;
use CoreFramework\Registry\Registerable;
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A general ConnectionHelper class
* 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 BaseConnectionHelper extends BaseHubSystemHelper implements Registerable {
+class BaseConnectionHelper extends BaseHubSystemHelper implements Visitable, Registerable {
// Exception codes
const EXCEPTION_UNSUPPORTED_ERROR_HANDLER = 0x9100;
namespace Hub\Information\Connection;
// Import framework stuff
+use CoreFramework\Listener\Listenable;
use CoreFramework\Registry\Registerable;
/**
// Import application-specific stuff
use Hub\Helper\Node\NodeHelper;
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+use CoreFramework\Visitor\Visitable;
+
<?php
/**
* A TCP ??? listener
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
use CoreFramework\Generic\UnsupportedOperationException;
+use CoreFramework\Listener\Listenable;
/**
* A TCP connection listener
<?php
+// Own namespace
+namespace Hub\Listener\Client\Tcp;
+
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+
/**
* A decorator for the TcpListener to communicate to peers
*
<?php
+// Own namespace
+namespace Hub\Listener\Hub\Tcp;
+
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+
/**
* A decorator for the TcpListener to communicate to hubs
*
// Import application-specific stuff
use Hub\Helper\Node\NodeHelper;
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+
/**
* An UDP ??? listener
*
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
+use CoreFramework\Listener\Listenable;
/**
* An UDP connection listener
<?php
+// Own namespace
+namespace Hub\Listener\Client\Udp;
+
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+
/**
* A decorator for the UdpListener to communicate to peers
*
<?php
+// Own namespace
+namespace Hub\Listener\Hub\Udp;
+
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+
/**
* A decorator for the UdpListener to communicate to hubs
*
use CoreFramework\Request\Requestable;
use CoreFramework\Response\Responseable;
use CoreFramework\Task\Taskable;
-use CoreFramework\Visitor\Visitable;
/**
* A general hub node class
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
use CoreFramework\Registry\Registerable;
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A PackageAssembler class to assemble a package content stream fragemented
use CoreFramework\Factory\ObjectFactory;
use CoreFramework\Registry\Registry;
use CoreFramework\Registry\Registerable;
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A NetworkPackage class. This class implements Deliverable and Receivable
<?php
+// Own namespace
+namespace Hub\Pool\;
+
+// Import application-specific stuff
+use Hub\Pool\BasePool;
+
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+use CoreFramework\Pool\Poolable;
+
/**
*
*
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
use CoreFramework\Registry\Registry;
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A general pool class
// Import application-specific stuff
use Hub\Helper\Node\NodeHelper;
+use Hub\Pool\BasePool;
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
+use CoreFramework\Listener\Listenable;
+use CoreFramework\Pool\Poolable;
/**
* A default listener pool
* 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 DefaultListenerPool extends BasePool implements PoolableListener {
+class DefaultListenerPool extends BasePool implements Poolable {
/**
* Protected constructor
*
}
/**
- * Run the shutdown seqeuence by a Visitor Pattern
+ * Run the shutdown seqeuence by a visitor pattern
*
* @return void
*/
<?php
+// Own namespace
+namespace Hub\Pool\Peer;
+
+// Import application-specific stuff
+use Hub\Pool\BasePool;
+
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+use CoreFramework\Pool\Poolable;
+
/**
* A default peer pool class
*
// Import framework stuff
use CoreFramework\Factory\ObjectFactory;
+use CoreFramework\Listener\Listenable;
use CoreFramework\Registry\Registerable;
/**
namespace Hub\Tag\Network;
// Import framework stuff
+use CoreFramework\Listener\Listenable;
use CoreFramework\Registry\Registry;
/**
<?php
+// Own namespace
+namespace Hub\Task\AptProxy\;
+
+// Import framework stuff
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
+
/**
* A ??? task for apt-proxy consoles
*
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A proxy listener task for apt-proxy consoles
<?php
+// Own namespace
+namespace Hub\Task\Chat\;
+
+// Import framework stuff
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
+
/**
* A ??? task for chat consoles
*
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A TelnetListener task for chat consoles
<?php
+// Own namespace
+namespace Hub\Task\Crawler\;
+
+// Import framework stuff
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
+
/**
* A ??? task for crawlers
*
use CoreFramework\Registry\Registry;
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A NodeCommunicator task for crawlers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A DocumentParser task for crawlers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A MimeSniffer task for crawlers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A Ping task for crawlers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A RemoteJobPublisher task for crawlers
<?php
+// Own namespace
+namespace Hub\Task\Crawler\Scanner\;
+
+// Import framework stuff
+use CoreFramework\Task\Taskable;
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
+
/**
* A ??? scanner task for crawlers
*
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A UploadedList scanner task for crawlers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A SnippetExtractor task for crawlers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A StructureAnalyzer task for crawlers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A LocalUrlCrawler task for crawlers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A RemoteUrlCrawler task for crawlers
<?php
+// Own namespace
+namespace Hub\Task\Crawler\Source\Url\;
+
+// Import framework stuff
+use CoreFramework\Task\Taskable;
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
+
/**
* An URL source task for ??? for crawlers
*
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* An URL source task for FoundRss for crawlers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* An URL source task for LocalStart for crawlers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* An URL source task for RssStart for crawlers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* An URL source task for UploadedList for crawlers
<?php
+// Own namespace
+namespace Hub\Task\Cruncher\;
+
+// Import framework stuff
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
+
/**
* A ??? task for crunchers
*
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A KeyProducer task for crunchers
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A TestUnitProducer task for crunchers
use CoreFramework\Registry\Registry;
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A WorkUnitFetcher task for crunchers which asks the cruncher to fetch work
use CoreFramework\Registry\Registry;
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A BlockFetcher task for miners which asks the network for new blocks and
use CoreFramework\Registry\Registry;
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A RealGenesisBlockProducer task for miners
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A TestGenesisBlockProducer task for miners
<?php
+// Own namespace
+namespace Hub\Task\Miner\;
+
+// Import framework stuff
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
+
/**
* A ??? task for miners
*
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A MinerCommunicator task for miners
<?php
+// Own namespace
+namespace Hub\Task\AptProxy\Task\Network\;
+
+// Import framework stuff
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
+
/**
* A ??? task for NetworkPackage
*
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A NetworkPackageReader task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A NetworkPackageWriter task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A Announcement node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A ChunkAssembler node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A ??? node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A PackageDecoder node-task
<?php
+// Own namespace
+namespace Hub\Task\Node\Dht\;
+
+// Import framework stuff
+use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
+
/**
* A ??? node DHT task
*
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A DhtBootstrap node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A DhtInitialization node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A DhtBootstrap node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A DhtPublicationCheck node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A DhtPublication node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A DhtQuery node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A HubSocketListener task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A Ping node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A SelfConnect node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A PackageTagsInit node-task
// Import framework stuff
use CoreFramework\Task\Taskable;
use CoreFramework\Visitor\Visitable;
+use CoreFramework\Visitor\Visitor;
/**
* A UpdateCheck node-task
<?php
+// Own namespace
+namespace Hub\Visitor\;
+
+// Import framework stuff
+use CoreFramework\Pool\Poolable;
+use CoreFramework\Visitor\Visitor;
+
/**
* A ??? visitor
*
<?php
+// Own namespace
+namespace Hub\Visitor\Handler\;
+
+// Import framework stuff
+use CoreFramework\Pool\Poolable;
+
/**
* A ??? handler visitor
*
public function visitPool (Poolable $poolInstance) {
$this->partialStub('Please implement this method.');
}
-}
-// [EOF]
-?>
+}
// Import application-specific stuff
use Hub\Network\Receive\Receivable;
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+use CoreFramework\Pool\Poolable;
+
/**
* A RawDataMonitor visitor
*
<?php
+// Own namespace
+namespace Hub\Visitor\;
+
+// Import framework stuff
+use CoreFramework\Pool\Poolable;
+
/**
* A ??? shutdown visitor
*
<?php
+// Own namespace
+namespace Hub\Visitor\Pool\Listener;
+
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+use CoreFramework\Pool\Poolable;
+
/**
* A ListenerPool shutdown visitor
*
<?php
+// Own namespace
+namespace Hub\Visitor\Shutdown\Socket;
+
+// Import framework stuff
+use CoreFramework\Visitor\Visitor;
+
/**
* A HalfShutdownSocket visitor
*
<?php
+// Own namespace
+namespace Hub\Visitor\Shutdown\Socket;
+
+// Import framework stuff
+use CoreFramework\Visitor\Visitor;
+
/**
* A ShutdownSocket visitor
*
$cfg->setConfigEntry('web_content_type', '');
// CFG: LISTENER-POOL-CLAS
-$cfg->setConfigEntry('listener_pool_class', 'DefaultListenerPool');
+$cfg->setConfigEntry('listener_pool_class', 'Hub\Pool\Listener\DefaultListenerPool');
// CFG: TCP-LISTENER-CLASS
$cfg->setConfigEntry('tcp_listener_class', 'TcpListener');
* @return $listenerInstance An instance of a Listenable instance or null
*/
function discoverListenerInstance (HandleableProtocol $protocolInstance, array $packageData);
-}
-// [EOF]
-?>
+}
// Import framework stuff
use CoreFramework\Generic\FrameworkInterface;
+use CoreFramework\Listener\Listenable;
/**
* An interface for shareable informations
// Import framework stuff
use CoreFramework\Generic\FrameworkInterface;
+use CoreFramework\Listener\Listenable;
/**
* An interface for tags
<?php
+// Own namespace
+namespace Hub\Visitor\Pool\Listener;
+
+// Import framework stuff
+use CoreFramework\Listener\Listenable;
+
/**
* An interface for the visitor implementation for pools
*
* @return void
*/
function visitDecorator (Listenable $listenerInstance);
-}
-// [EOF]
-?>
+}
-Subproject commit aa425d10f8eef36160fcfd87bcd9a7d44af9ff16
+Subproject commit 1e0fc6320d565605e15aa4f023915ca1574272e4
projects / hub.git / commitdiff