out_slots = 2;
max_flow = actual_flow = 0.0f;
updated = true;
+ out_on_zero = out_ready = 0;
}
Splitter::~Splitter()
}
// Me preguntan por el flujo máximo.
// Primero me actualizo, y luego respondo
- actual_flow = *((float *)data);
+ float tmp = *((float *)data);
+
+ if (tmp < actual_flow) actual_flow = tmp;
if (max_flow < actual_flow) actual_flow = max_flow;
- actual_flow /= 2.0f;
+ if (out_on_zero == 0)
+ actual_flow /= 2.0f;
+ if (actual_flow == 0) {
+ out_ready = 2;
+ }
send_msg(OUT, MSG_QUERY_MAX_FLOW_OUT, &actual_flow);
// Listo, mi flujo ahora es el doble de lo que me pueden
break;
case MSG_RESPONSE_MAX_FLOW: {
float max = *((float *)data);
+ if (out_ready == 2) break;
#ifdef DEBUG
std::cout << name << ":Split " << max << std::endl;
#endif
if (pos == OUT) {
- if (max < actual_flow) actual_flow = max;
- if (max_flow < actual_flow) actual_flow = max_flow;
+ if (max == 0) {
+ out_on_zero++;
+ switch (out_on_zero) {
+ case 1:
+ if (out_ready == 0) {
+ actual_flow = max_flow;
+ }
+ break;
+ case 2:
+ actual_flow = 0.0;
+ }
+ } else {
+ if (max < actual_flow) actual_flow = max;
+ if (max_flow < actual_flow) actual_flow = max_flow;
+ }
+ out_ready++;
} else {
if (((2*max) < actual_flow) && (max != 0))
actual_flow = 2*max;
#endif
updated = false;
color_updated = false;
+ out_on_zero = out_ready = 0;
}