Commit 67fb2265 authored by Dridi Boukelmoune's avatar Dridi Boukelmoune

vtc_sess: Simplify the main for loop

The nested while loop made more sense when the surroundings were more
complicated.

Better diff with the --ignore-all-space option.
parent 7456b167
...@@ -120,7 +120,7 @@ sess_thread(void *priv) ...@@ -120,7 +120,7 @@ sess_thread(void *priv)
struct vtclog *vl; struct vtclog *vl;
struct vtc_sess *vsp; struct vtc_sess *vsp;
struct thread_arg ta, *tap; struct thread_arg ta, *tap;
int i, fd; int i, fd = -1;
CAST_OBJ_NOTNULL(tap, priv, THREAD_ARG_MAGIC); CAST_OBJ_NOTNULL(tap, priv, THREAD_ARG_MAGIC);
ta = *tap; ta = *tap;
...@@ -135,15 +135,15 @@ sess_thread(void *priv) ...@@ -135,15 +135,15 @@ sess_thread(void *priv)
vtc_log(vl, 2, "Started on %s (%u iterations%s)", ta.listen_addr, vtc_log(vl, 2, "Started on %s (%u iterations%s)", ta.listen_addr,
vsp->repeat, vsp->keepalive ? " using keepalive" : ""); vsp->repeat, vsp->keepalive ? " using keepalive" : "");
for (i = 0; i < vsp->repeat; i++) { for (i = 0; i < vsp->repeat; i++) {
fd = ta.conn_f(ta.priv, vl); if (fd < 0)
fd = ta.conn_f(ta.priv, vl);
fd = sess_process(vl, ta.vsp, ta.spec, fd,
ta.asocket, ta.listen_addr);
if (! vsp->keepalive) if (! vsp->keepalive)
fd = sess_process(vl, ta.vsp, ta.spec, fd, ta.asocket, ta.listen_addr); ta.disc_f(ta.priv, vl, &fd);
else
while (fd >= 0 && i++ < vsp->repeat)
fd = sess_process(vl, ta.vsp, ta.spec, fd,
ta.asocket, ta.listen_addr);
ta.disc_f(ta.priv, vl, &fd);
} }
if (vsp->keepalive)
ta.disc_f(ta.priv, vl, &fd);
vtc_log(vl, 2, "Ending"); vtc_log(vl, 2, "Ending");
pthread_cleanup_pop(0); pthread_cleanup_pop(0);
vtc_logclose(vl); vtc_logclose(vl);
......
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