Model/src/union.cpp

   1
   2 #include "union.h"
   3 #include <iostream>
   4
   5 using namespace PlaQui::Model;
   6
   7 Union::Union(const std::string &_name):Transport(_name)
   8 {
   9         in_slots = 2;
  10         out_slots = 1;
  11         max_flow = actual_flow = 0.0f;
  12 }
  13
  14 Union::~Union()
  15 {
  16 }
  17
  18 void Union::recieve_msg(int msg, IConector *who, void *data)
  19 {
  20         int pos = OUT;
  21
  22         // Verifico si esta conectado a mi entrada
  23         std::list<IConector *>::iterator i;
  24         for(i=in_list.begin(); i!=in_list.end(); i++) {
  25                 if ((*i) == who) pos = IN;
  26         }
  27
  28         switch (msg) {
  29                 case MSG_QUERY_MAX_FLOW: {
  30                         // Me preguntan por el flujo máximo.
  31                         // Primero me actualizo, y luego respondo
  32                         update();
  33                         float tmp;
  34
  35                         tmp = (actual_flow<max_flow)?actual_flow:max_flow;
  36                         if (pos == IN) {
  37                                         // Si esta conectado a mi entrada, le puedo aceptar
  38                                         // solo la mitad del flujo maximo
  39                                         tmp /= 2;
  40                         }
  41                         who->recieve_msg(MSG_RESPONSE_MAX_FLOW, this, &tmp);
  42                 }
  43                 break;
  44                 case MSG_RESPONSE_MAX_FLOW: {
  45                         float max = *((float *)data);
  46                         if (pos == OUT) {
  47                                 if (max < actual_flow)  actual_flow = max;
  48                         } else {
  49                                 if ((2*max) < actual_flow) actual_flow = 2*max;
  50                         }
  51                 }
  52                 break;
  53                 default:
  54                         Transport::recieve_msg(msg, who, data);
  55         }
  56 }
  57
  58 void Union::update()
  59 {
  60         // Si ya me actualice, no lo tengo que hacer de nuevo
  61         if (updated) return;
  62         // Seteo mi actualizar en true para evitar entrar de nuevo
  63         actual_flow = 99999;
  64         updated = true;
  65         send_msg(OUT, MSG_QUERY_MAX_FLOW);
  66         send_msg(IN, MSG_QUERY_MAX_FLOW);
  67 }
  68
  69 void Union::simulate()
  70 {
  71         if (!updated) {
  72                 return;
  73         }
  74
  75         std::cout << name << "::Flujo actual = " << actual_flow << std::endl;
  76         updated = false;
  77 }
  78