RepoMirrors/haproxy
1
0
Fork 0
mirror of http://git.haproxy.org/git/haproxy.git/ synced 2025-01-05 19:52:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

MINOR: threads/checks: Set the task process_mask when a check is executed

Browse Source 
Tasks used to process checks are created to be processed by any threads. But,
once a check is started, we must be sure to be sticky on the running thread
because I/O will be also sticky on it. This is a requirement for now: Tasks and
I/O handlers linked to the same session must be executed on the same thread.
This commit is contained in:
Christopher Faulet 2017-10-20 15:41:18 +02:00 committed by Willy Tarreau
parent cfda847643
commit 88ce5d18a5
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/checks.c
View File

@ -1977,7 +1977,7 @@ static struct task *process_chk_proc(struct task *t)
int t_con = tick_add(now_ms, s->proxy->timeout.connect);
t->expire = tick_first(t->expire, t_con);
}
task_set_affinity(t, tid_bit);
goto reschedule;
}
@ -2040,6 +2040,7 @@ static struct task *process_chk_proc(struct task *t)
/* a success was detected */
check_notify_success(check);
}
task_set_affinity(t, MAX_THREADS_MASK);
check->state &= ~CHK_ST_INPROGRESS;
pid_list_del(check->curpid);
@ -2114,6 +2115,7 @@ static struct task *process_chk_conn(struct task *t)
if (check->type)
conn_xprt_want_recv(conn); /* prepare for reading a possible reply */
task_set_affinity(t, tid_bit);
goto reschedule;
case SF_ERR_SRVTO: /* ETIMEDOUT */
@ -2205,6 +2207,7 @@ static struct task *process_chk_conn(struct task *t)
/* a success was detected */
check_notify_success(check);
}
task_set_affinity(t, MAX_THREADS_MASK);
check->state &= ~CHK_ST_INPROGRESS;
rv = 0;