Commit 9c90bf9f authored by Valentin Reis's avatar Valentin Reis Committed by Swann Perarnau

[Fix] rate limiting never let any message through

parent 1288b051
...@@ -87,8 +87,8 @@ int nrm_send_progress(struct nrm_context *ctxt, unsigned long progress) ...@@ -87,8 +87,8 @@ int nrm_send_progress(struct nrm_context *ctxt, unsigned long progress)
int err = zmq_send(ctxt->socket, buf, strnlen(buf, 512), 0); int err = zmq_send(ctxt->socket, buf, strnlen(buf, 512), 0);
assert(err > 0); assert(err > 0);
ctxt->acc = 0; ctxt->acc = 0;
ctxt->time = now;
} }
ctxt->time = now;
return 0; return 0;
} }
...@@ -108,7 +108,7 @@ int nrm_send_phase_context(struct nrm_context *ctxt, unsigned int cpu, unsigned ...@@ -108,7 +108,7 @@ int nrm_send_phase_context(struct nrm_context *ctxt, unsigned int cpu, unsigned
computeTime, totalTime, ctxt->app_uuid); computeTime, totalTime, ctxt->app_uuid);
int err = zmq_send(ctxt->socket, buf, strnlen(buf, 512), 0); int err = zmq_send(ctxt->socket, buf, strnlen(buf, 512), 0);
assert(err > 0); assert(err > 0);
ctxt->time = now;
} }
ctxt->time = now;
return 0; return 0;
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment