input = new ByPass();
output = new ByPass();
((ByPass *)output)->set_control(this);
+ updated = false;
}
Exclusa::~Exclusa()
{
+ delete input;
+ delete output;
}
void Exclusa::update(int dir)
{
+ std::list<IConector *>::iterator i = in_list.begin();
+ if (i != in_list.end()) {
+ PlantItem *o = (PlantItem *)(*i);
+ set_color( o->get_color() );
+ }
// Primero me fijo si la entrada esta operando, es decir
// si hay alguien conectado para automatizar.
if (input->is_operational()) {
void Exclusa::simulate()
{
+#ifdef DEBUG
std::cout << name << ": " << ((is_open)?"Abierta":"Cerrada") << std::endl;
+#endif
}
void Exclusa::recieve_msg(int msg, IConector *who, void *data)
{
switch (msg) {
case MSG_QUERY_MAX_FLOW_OUT:
+ if (updated) {
+ who->recieve_msg(MSG_RESPONSE_MAX_FLOW, this, &temp);
+ }
temp = *((float *)data);
+ if (!is_open) temp = 0;
send_msg(OUT, MSG_QUERY_MAX_FLOW_OUT, &temp);
who->recieve_msg(MSG_RESPONSE_MAX_FLOW, this, &temp);
break;
case MSG_RESPONSE_MAX_FLOW:
- temp = *((float *)data);
+ if (is_open)
+ temp = *((float *)data);
break;
default:
Control::recieve_msg(msg, who, data);