RepoMirrors
/
haproxy
mirror of http://git.haproxy.org/git/haproxy.git/
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

MINOR: peers: make peer_session_forceshutdown() use the appctx and not the stream 

It was inherited from initial code but we must only manipulate the appctx
and never the stream, otherwise we always risk shooting ourselves in the
foot.
This commit is contained in:
Willy Tarreau 2016-10-31 17:37:39 +01:00
parent b21d08e249
commit 81bc3b062b
1 changed files with 7 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/peers.c
View File

@ -172,7 +172,7 @@ enum {
#define PEER_DWNGRD_MINOR_VER 0
struct peers *peers = NULL;
static void peer_session_forceshutdown(struct stream * stream);
static void peer_session_forceshutdown(struct appctx *appctx);
int intencode(uint64_t i, char **str) {
int idx = 0;
@ -669,7 +669,7 @@ static void peer_io_handler(struct appctx *appctx)
appctx->st1 = PEER_SESS_SC_TRYAGAIN;
goto switchstate;
}
peer_session_forceshutdown(curpeer->stream);
peer_session_forceshutdown(curpeer->appctx);
}
if (maj_ver != (unsigned int)-1 && min_ver != (unsigned int)-1) {
if (min_ver == PEER_DWNGRD_MINOR_VER) {
@ -1708,25 +1708,16 @@ static struct applet peer_applet = {
/*
* Use this function to force a close of a peer session
*/
static void peer_session_forceshutdown(struct stream * stream)
static void peer_session_forceshutdown(struct appctx *appctx)
{
struct appctx *appctx = NULL;
struct peer *ps;
int i;
for (i = 0; i <= 1; i++) {
appctx = objt_appctx(stream->si[i].end);
if (!appctx)
continue;
if (appctx->applet != &peer_applet)
continue;
break;
}
if (!appctx)
return;
if (appctx->applet != &peer_applet)
return;
ps = appctx->ctx.peers.ptr;
/* we're killing a connection, we must apply a random delay before
* retrying otherwise the other end will do the same and we can loop
@ -1980,7 +1971,7 @@ static struct task *process_peer_sync(struct task * task)
/* disconnect all connected peers */
for (ps = peers->remote; ps; ps = ps->next) {
if (ps->stream) {
peer_session_forceshutdown(ps->stream);
peer_session_forceshutdown(ps->appctx);
ps->stream = NULL;
ps->appctx = NULL;
}