]> git.ipfire.org Git - thirdparty/haproxy.git/commitdiff
[MINOR] stream_sock: always clear BF_EXPECT_MORE upon complete transfer
authorWilly Tarreau <w@1wt.eu>
Wed, 11 May 2011 18:14:03 +0000 (20:14 +0200)
committerWilly Tarreau <w@1wt.eu>
Mon, 30 May 2011 16:42:40 +0000 (18:42 +0200)
When sending is complete, it's preferred to systematically clear the flags
that were set for that transfer. What could happen is that the to_forward
counter had caused the MSG_MORE flag to be set and BF_EXPECT_MORE not to
be cleared, resulting in this flag being unexpectedly maintained for next
round.

The code has taken extreme care of not doing this till now, but it's not
acceptable that the caller has to know these precise semantics. So let's
unconditionnally clear the flag instead.

For the sake of safety, this fix should be backported to 1.4.

src/stream_sock.c

index 3e9784c28415474d8c7df83afdad07ce8290ed9f..0d55128a808141882b916680c46859f4482e4fde 100644 (file)
@@ -650,8 +650,6 @@ static int stream_sock_write_loop(struct stream_interface *si, struct buffer *b)
                                send_flag |= MSG_MORE;
                        }
                        else if (b->flags & BF_EXPECT_MORE) {
-                               /* it was forced on the buffer, this flag is one-shoot */
-                               b->flags &= ~BF_EXPECT_MORE;
                                send_flag |= MSG_MORE;
                        }
 
@@ -661,9 +659,9 @@ static int stream_sock_write_loop(struct stream_interface *si, struct buffer *b)
 
                        ret = send(si->fd, b->w, max, send_flag);
 
-                       /* disable it only once everything has been sent */
-                       if (ret == max && (b->flags & BF_SEND_DONTWAIT))
-                               b->flags &= ~BF_SEND_DONTWAIT;
+                       /* Always clear both flags once everything has been sent */
+                       if (ret == max)
+                               b->flags &= ~(BF_EXPECT_MORE | BF_SEND_DONTWAIT);
                } else {
                        int skerr;
                        socklen_t lskerr = sizeof(skerr);