serf/buckets/response_buckets.c

171 static apr_status_t fetch_headers(serf_bucket_t *bkt, response_context_t *ctx)
225 static apr_status_t run_machine(serf_bucket_t *bkt, response_context_t *ctx)
240             status = parse_status_line(ctx, bkt->allocator);
247                     serf_bucket_barrier_create(ctx->stream, bkt->allocator);
266         status = fetch_headers(bkt, ctx);
283                                                       bkt->allocator);
289                 serf_bucket_barrier_create(ctx->stream, bkt->allocator);
300                               ctx->body, length, bkt->allocator);
309                                                            bkt->allocator);
317                         serf_bucket_deflate_create(ctx->body, bkt->allocator,
322                         serf_bucket_deflate_create(ctx->body, bkt->allocator,
332         status = fetch_headers(bkt, ctx);
352 static apr_status_t wait_for_body(serf_bucket_t *bkt, response_context_t *ctx)
358         status = run_machine(bkt, ctx);
380     serf_bucket_t *bkt,
383     response_context_t *ctx = bkt->data;
398     status = run_machine(bkt, ctx);
461     serf_bucket_t *bkt;
472     bkt = serf_bucket_simple_copy_create(buf, size,
474     serf_bucket_aggregate_append(bucket, bkt);
475     bkt = serf_bucket_simple_copy_create(ctx->sl.reason, strlen(ctx->sl.reason),
477     serf_bucket_aggregate_append(bucket, bkt);
478     bkt = SERF_BUCKET_SIMPLE_STRING_LEN("\r\n", 2,
480     serf_bucket_aggregate_append(bucket, bkt);