Sorted some tasks, so that the package reader will come after writer (self-connect...

Signed-off-by: Roland Haeder <roland@mxchange.org>

diff --git a/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php b/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php
index fd64698bc37c123f97f64128babc6a62e4716f99..18fd6628d8969fecdc55af354b3b5a3adcf5ff48 100644 (file)
--- a/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php
+++ b/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php
@@ -67,11 +67,11 @@ class NodeTaskHandlerInitializerFilter extends BaseNodeFilter implements Filtera
                // Register it
                $handlerInstance->registerTask('package_tags_init', $taskInstance);
 
-               // Generate socket listener task
-               $taskInstance = ObjectFactory::createObjectByConfiguredName('node_socket_listener_task_class');
+               // Generate package writer task
+               $taskInstance = ObjectFactory::createObjectByConfiguredName('node_package_writer_task_class');
 
-               // Network package reader, needs to be delayed a little
-               $handlerInstance->registerTask('socket_listener', $taskInstance);
+               // Register it as well
+               $handlerInstance->registerTask('network_package_writer', $taskInstance);
 
                // Generate package reader task
                $taskInstance = ObjectFactory::createObjectByConfiguredName('node_package_reader_task_class', array($nodeInstance->getListenerPoolInstance()));
@@ -79,12 +79,6 @@ class NodeTaskHandlerInitializerFilter extends BaseNodeFilter implements Filtera
                // Network package reader, needs to be delayed a little
                $handlerInstance->registerTask('network_package_reader', $taskInstance);
 
-               // Generate package writer task
-               $taskInstance = ObjectFactory::createObjectByConfiguredName('node_package_writer_task_class');
-
-               // Register it as well
-               $handlerInstance->registerTask('network_package_writer', $taskInstance);
-
                // Generate chunk assembler task
                $taskInstance = ObjectFactory::createObjectByConfiguredName('node_chunk_assembler_task_class');
 
@@ -97,6 +91,12 @@ class NodeTaskHandlerInitializerFilter extends BaseNodeFilter implements Filtera
                // Register it as well
                $handlerInstance->registerTask('package_decoder', $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');