From: Roland Haeder Date: Sat, 15 Feb 2014 22:50:00 +0000 (+0100) Subject: Sorted some tasks, so that the package reader will come after writer (self-connect... X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=6253fc8eb621a64749fa3259f1cbedf45c397d74;p=hub.git Sorted some tasks, so that the package reader will come after writer (self-connect on slow computers). 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 fd64698bc..18fd6628d 100644 --- 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');