From 56cc59cf44ec64440ba4d1c0d005196195c758e6 Mon Sep 17 00:00:00 2001 From: hugues Date: Sat, 25 Mar 2006 15:07:51 +0000 Subject: Nettoyage du repository glagen git-svn-id: file:///usr/local/opt/svn/repos/glagen@12 0f7e0d06-a6f9-0310-a55f-d5f984f55e4c --- algo_distribue/Distribue.hh | 97 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 97 insertions(+) create mode 100644 algo_distribue/Distribue.hh (limited to 'algo_distribue/Distribue.hh') diff --git a/algo_distribue/Distribue.hh b/algo_distribue/Distribue.hh new file mode 100644 index 0000000..ff3b76d --- /dev/null +++ b/algo_distribue/Distribue.hh @@ -0,0 +1,97 @@ +// Classe Distribue + + + +#ifndef DISTRIBUE_HH_ +# define DISTRIBUE_HH_ + +#include "tree/tree.hh" +#include "tree/node.hh" +#include "network/data/Data.hh" +#include "network/Server.hh" +#include "tools/matrix.hh" + +template class Distribue +{ +public: + Distribue(const Tree& tree) + : _tree(tree), + _size(tree.get_node_root().get_number_node()), + _mat(new Matrix (_size, _size)) + { + unsigned int ptr1 = 0, ptr2 = 0; + std::list< Node > ptr_node = *new std::list< Node >; + ptr_node.push_back(tree.get_node_root()); + while (ptr_node.size()) + { + std::list< Node >::iterator childs = ptr_node.begin(); + std::list< Node >::iterator child = + childs->get_childs()->begin(); + for (; child != childs->get_childs()->end(); ++child) + { + ptr_node.push_back(*child); + (*_mat)(++ptr2, ptr1) = 1; + } + ptr_node.pop_front(); + ptr1++; + } + } + + void depend(std::list& data, const unsigned int& ptr) + { + data.push_back(_tree.get_node_root().get_node_course_width(ptr).get_data()); + for (unsigned int i = 0; i < _size; ++i) + if ((*_mat)(i, ptr)) + depend(data, i); + } + + void transfer(Server& server) + { + // Calcul du nombre de client necessaire + unsigned int j = 0; + std::list< list > list_data = + *new std::list< list >; + std::list data = *new std::list; + for (unsigned int i = 1; i < _size; ++i) + { + if ((*_mat)(i, 0)) // Ne prend que les noeuds fils du noeud root + { + ++j; + this->depend(data, i); + list_data.push_back(data); + data = *new std::list; + } + } + if (server.get_nb_client() < j) + { + std::cout << "Need more client" << std::endl; + exit(-1); + } + + std::list::const_iterator fd_client = + server.get_list_fd()->begin(); + data = *new std::list; + for (unsigned int i = 1; i < _size; ++i) + { + if ((*_mat)(i, 0)) // Ne prend que les noeuds fils du noeud root + { + ++j; + this->depend(data, i); + server.send_data(*fd_client++, Data(&data)); + data = *new std::list; + } + } + } + + Matrix& get_matrix() + { + return (*_mat); + } + +private: + Tree _tree; + unsigned int _size; + Matrix *_mat; +}; + +#endif // DISTRIBUTE_HH_ -- cgit v1.2.3