]> git.ipfire.org Git - thirdparty/haproxy.git/commitdiff
CLEANUP: channel: rename channel_reserved -> channel_is_rewritable
authorWilly Tarreau <w@1wt.eu>
Tue, 13 Jan 2015 13:39:16 +0000 (14:39 +0100)
committerWilly Tarreau <w@1wt.eu>
Wed, 14 Jan 2015 17:41:33 +0000 (18:41 +0100)
channel_reserved is confusingly named. It is used to know whether or
not the rewrite area is left intact for situations where we want to
ensure we can use it before proceeding. Let's rename it to fix this
confusion.

include/proto/channel.h
src/proto_http.c

index d13169bd673cd9fc82fe3a5411e9d42fe00e5ad0..e2424f14741b1fe08fb9b3de72cd4fae3a8a5248 100644 (file)
@@ -103,11 +103,12 @@ static inline unsigned int channel_is_empty(struct channel *c)
        return !(c->buf->o | (long)c->pipe);
 }
 
-/* Returns non-zero if the buffer input has all of its reserve available. This
- * is used to decide when a request or response may be parsed when some data
- * from a previous exchange might still be present.
+/* Returns non-zero if the channel is rewritable, which means that the buffer
+ * it is attached to has at least <maxrewrite> bytes immediately available.
+ * This is used to decide when a request or response may be parsed when some
+ * data from a previous exchange might still be present.
  */
-static inline int channel_reserved(const struct channel *chn)
+static inline int channel_is_rewritable(const struct channel *chn)
 {
        int rem = chn->buf->size;
 
index 4b14b88fa806374d3a6bfc6db4706bbd3587f948..e14b1d69c7317f21eb086d0554ef557513feac55 100644 (file)
@@ -2502,7 +2502,7 @@ int http_wait_for_request(struct session *s, struct channel *req, int an_bit)
         */
        if (buffer_not_empty(req->buf) && msg->msg_state < HTTP_MSG_ERROR) {
                if (txn->flags & TX_NOT_FIRST) {
-                       if (unlikely(!channel_reserved(req))) {
+                       if (unlikely(!channel_is_rewritable(req))) {
                                if (req->flags & (CF_SHUTW|CF_SHUTW_NOW|CF_WRITE_ERROR|CF_WRITE_TIMEOUT))
                                        goto failed_keep_alive;
                                /* some data has still not left the buffer, wake us once that's done */
@@ -2524,7 +2524,7 @@ int http_wait_for_request(struct session *s, struct channel *req, int an_bit)
                 * keep-alive requests.
                 */
                if ((txn->flags & TX_NOT_FIRST) &&
-                   unlikely(!channel_reserved(s->rep) ||
+                   unlikely(!channel_is_rewritable(s->rep) ||
                             bi_end(s->rep->buf) < b_ptr(s->rep->buf, txn->rsp.next) ||
                             bi_end(s->rep->buf) > s->rep->buf->data + s->rep->buf->size - global.tune.maxrewrite)) {
                        if (s->rep->buf->o) {
@@ -5673,7 +5673,7 @@ int http_wait_for_response(struct session *s, struct channel *rep, int an_bit)
         * data later, which is much more complicated.
         */
        if (buffer_not_empty(rep->buf) && msg->msg_state < HTTP_MSG_ERROR) {
-               if (unlikely(!channel_reserved(rep))) {
+               if (unlikely(!channel_is_rewritable(rep))) {
                        /* some data has still not left the buffer, wake us once that's done */
                        if (rep->flags & (CF_SHUTW|CF_SHUTW_NOW|CF_WRITE_ERROR|CF_WRITE_TIMEOUT))
                                goto abort_response;