From: Roland Haeder Date: Sat, 15 Feb 2014 22:57:40 +0000 (+0100) Subject: Socket listener first. ;-) X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=4402e8e4cb2652a0717bfc92d9b0ebb208f14c12;p=hub.git Socket listener first. ;-) Signed-off-by: Roland Haeder --- diff --git a/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php b/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php index 57b7c8c05..79cbb1a62 100644 --- a/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php +++ b/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php @@ -82,6 +82,12 @@ class NodeTaskHandlerInitializerFilter extends BaseNodeFilter implements Filtera // Generate package decoder task $taskInstance = ObjectFactory::createObjectByConfiguredName('node_package_decoder_task_class'); + // Generate socket listener task + $taskInstance = ObjectFactory::createObjectByConfiguredName('node_socket_listener_task_class'); + + // Network package reader, needs to be delayed a little + $handlerInstance->registerTask('socket_listener', $taskInstance); + // Register it as well $handlerInstance->registerTask('package_decoder', $taskInstance); @@ -91,12 +97,6 @@ class NodeTaskHandlerInitializerFilter extends BaseNodeFilter implements Filtera // Register it as well $handlerInstance->registerTask('chunk_assembler', $taskInstance); - // Generate socket listener task - $taskInstance = ObjectFactory::createObjectByConfiguredName('node_socket_listener_task_class'); - - // Network package reader, needs to be delayed a little - $handlerInstance->registerTask('socket_listener', $taskInstance); - // Generate DHT initialization task $taskInstance = ObjectFactory::createObjectByConfiguredName('node_dht_init_task_class');