X-Git-Url: https://git.llucax.com/z.facultad/75.42/plaqui.git/blobdiff_plain/b75b5632c75f245e59a00775ffbe0affdedf8b6c..24b6a7f8209541d589b0bdeb38493a67b94d1551:/Model/src/union.cpp?ds=sidebyside diff --git a/Model/src/union.cpp b/Model/src/union.cpp index 331e953..36ae347 100644 --- a/Model/src/union.cpp +++ b/Model/src/union.cpp @@ -8,7 +8,10 @@ Union::Union(const std::string &_name):Transport(_name) { in_slots = 2; out_slots = 1; - max_flow = actual_flow = 0.0f; + max_flow = 0.0f; + in_on_zero = 0; + in_ready = 0; + actual_flow = 999999; } Union::~Union() @@ -19,34 +22,63 @@ void Union::recieve_msg(int msg, IConector *who, void *data) { int pos = OUT; - // Verifico si esta conectado a mi entrada + // Verifico si esta conectado a mi entrada o a mi salida std::list::iterator i; for(i=in_list.begin(); i!=in_list.end(); i++) { if ((*i) == who) pos = IN; } switch (msg) { - case MSG_QUERY_MAX_FLOW: { + case MSG_QUERY_MAX_FLOW_OUT: { // Me preguntan por el flujo máximo. // Primero me actualizo, y luego respondo - update(); + float m_data = *((float *)data)*2; float tmp; - tmp = (actual_flowrecieve_msg(MSG_RESPONSE_MAX_FLOW, this, &tmp); + if (in_on_zero == 1) { + if (in_ready == 0) + tmp = max_flow; + else + tmp = actual_flow/2.0f; + } + send_msg(OUT, MSG_QUERY_MAX_FLOW_OUT, &tmp); + } else { + switch (in_on_zero) { + case 0: + actual_flow = (m_datarecieve_msg(MSG_RESPONSE_MAX_FLOW, this, &tmp); } - who->recieve_msg(MSG_RESPONSE_MAX_FLOW, this, &tmp); + updated = true; + if (pos == IN) in_ready++; } break; case MSG_RESPONSE_MAX_FLOW: { float max = *((float *)data); if (pos == OUT) { if (max < actual_flow) actual_flow = max; + if (in_on_zero == 2) actual_flow = 0; } else { - if ((2*max) < actual_flow) actual_flow = 2*max; + if (((2*max) < actual_flow) && (max != 0)) { + actual_flow = 2*max; + if (in_on_zero == 1) actual_flow /= 2.0; + } } } break; @@ -55,24 +87,63 @@ void Union::recieve_msg(int msg, IConector *who, void *data) } } -void Union::update() +void Union::update(int dir) { // Si ya me actualice, no lo tengo que hacer de nuevo if (updated) return; // Seteo mi actualizar en true para evitar entrar de nuevo + // FIXME : 99999 == INFINITO!! actual_flow = 99999; updated = true; - send_msg(OUT, MSG_QUERY_MAX_FLOW); - send_msg(IN, MSG_QUERY_MAX_FLOW); + switch (dir) { + case IN: + send_msg(IN, MSG_QUERY_MAX_FLOW_IN, (void *)&max_flow); + break; + case OUT: + send_msg(OUT, MSG_QUERY_MAX_FLOW_OUT, (void *)&max_flow); + } } void Union::simulate() { + RGB c_in1, c_in2; + unsigned r=0,g=0,b=0; + float c_f1, c_f2; // para ver los flujos de cada uno + if (!updated) { return; } + std::list::iterator i = in_list.begin(); + if (i != in_list.end()) { + PlantItem *o = (PlantItem *)(*i); + c_in1 = o->get_color(); + c_f1 = o->get_actual_flow(); + i++; + o = (PlantItem *)(*i); + c_in2 = o->get_color(); + c_f2 = o->get_actual_flow(); + } + set_color( RGB(r,g,b) ); + if ((c_f1 != 0) && (c_f2 != 0)) { + // Si ambas entradas traen flujo, sumo sus colores + r = ((c_in1.r()+c_in2.r())/2)%256; + g = ((c_in1.g()+c_in2.g())/2)%256; + b = ((c_in1.b()+c_in2.b())/2)%256; + set_color(RGB(r,g,b)); + } else { + // Veo que entrada trae color + if (c_f1 != 0) { + set_color( c_in1 ); + } + if (c_f2 != 0) { + set_color( c_in2 ); + } + } + std::cout << name << "::Flujo actual = " << actual_flow << std::endl; updated = false; + in_on_zero = 0; + in_ready = 0; }