static apr_status_t read_prefix()

in buckets/prefix_buckets.c [58:138]

• 54 lines of code
• 18 McCabe index (conditional complexity)

static apr_status_t read_prefix(serf_bucket_t *bucket)
{
    prefix_context_t *ctx = bucket->data;
    const char *data;
    apr_size_t len;
    apr_status_t status;

    if (!ctx->read_len) {

        /* Perhaps we can handle this without copying any data? */
        status = serf_bucket_read(ctx->stream, ctx->prefix_len, &data, &len);

        if (!status && !len)
            return SERF_ERROR_EMPTY_READ;
        else if (SERF_BUCKET_READ_ERROR(status))
            return status;

        if (APR_STATUS_IS_EOF(status) || (len == ctx->prefix_len)) {
            apr_status_t cb_status;

            /* Prefix reading is done */
            ctx->prefix_len = 0;

            cb_status = ctx->handler(ctx->handler_baton, ctx->stream,
                                     data, len);

            if (SERF_BUCKET_READ_ERROR(cb_status))
                return cb_status;

            return status;
        }
        else if (len == 0) {
            /* Nothing read at all. Try again later */
            return status;
        }

        /* Create a buffer to hold what we already read */
        ctx->buffer = serf_bucket_mem_alloc(bucket->allocator, ctx->prefix_len);
        memcpy(ctx->buffer, data, len);
        ctx->read_len = len;

        if (status)
            return status;

        /* Else: Try filling the rest of the buffer */
    }

    while (TRUE) {

        status = serf_bucket_read(ctx->stream, ctx->prefix_len - ctx->read_len,
                                  &data, &len);

        if (SERF_BUCKET_READ_ERROR(status))
            return status;
        else if (!status && !len)
            return SERF_ERROR_EMPTY_READ;

        memcpy(ctx->buffer + ctx->read_len, data, len);
        ctx->read_len += len;

        if (APR_STATUS_IS_EOF(status) || (ctx->prefix_len == ctx->read_len)) {
            apr_status_t cb_status;

            /* Prefix reading is done */
            ctx->prefix_len = 0;

            cb_status = ctx->handler(ctx->handler_baton, ctx->stream,
                                     ctx->buffer, ctx->read_len);

            serf_bucket_mem_free(bucket->allocator, ctx->buffer);
            ctx->buffer = NULL;

            if (SERF_BUCKET_READ_ERROR(cb_status))
              return cb_status;

            return status;
        }
        else if (status)
            return status;
    }
}