diff --git a/src/peers.c b/src/peers.c
index 5088fa0..eabc044 100644
--- a/src/peers.c
+++ b/src/peers.c
@@ -1788,8 +1788,8 @@
 	return 1;
 
  incomplete:
-	if (reql < 0) {
-		/* there was an error */
+	if (reql < 0 || (si_oc(si)->flags & (CF_SHUTW|CF_SHUTW_NOW))) {
+		/* there was an error or the message was truncated */
 		appctx->st0 = PEER_SESS_ST_END;
 		return -1;
 	}