float m_data = *((float *)data)*2;
float tmp;
- if (updated) {
- float tmp = actual_flow/2.0f;
+/* if (updated) {
+ if (m_data == 0) {
+ tmp = 0;
+ actual_flow /= 2.0f;
+ } else {
+ tmp = actual_flow/2.0f;
+ }
who->recieve_msg(MSG_RESPONSE_MAX_FLOW, this, &tmp);
break;
- }
+ }*/
updated = true;
if (m_data == 0) {
in_on_zero++;
case 2:
actual_flow = 0;
}
- send_msg(OUT, MSG_QUERY_MAX_FLOW_OUT, &actual_flow);
+ if (!updated)
+ send_msg(OUT, MSG_QUERY_MAX_FLOW_OUT, &actual_flow);
tmp = (in_on_zero==0)?actual_flow/2.0f:actual_flow;
who->recieve_msg(MSG_RESPONSE_MAX_FLOW, this, &tmp);
}