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.
diff --git a/src/peers.c b/src/peers.c
index 9e14685..6b8f7f9 100644
--- a/src/peers.c
+++ b/src/peers.c
@@ -172,7 +172,7 @@
#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 @@
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 @@
/*
* 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 @@
/* 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;
}