22     serf_bucket_t *bucket;  member
51             serf_bucket_destroy(ctx->done->bucket);  in cleanup_aggregate()
60     serf_bucket_t *bucket, serf_bucket_alloc_t *allocator)  in serf_bucket_aggregate_cleanup()  argument
62     aggregate_context_t *ctx = bucket->data;  in serf_bucket_aggregate_cleanup()
98     serf_bucket_t *bucket = serf_bucket_aggregate_create(allocator);  in serf__bucket_stream_create()  local
99     aggregate_context_t *ctx = bucket->data;  in serf__bucket_stream_create()
101     serf_bucket_aggregate_hold_open(bucket, fn, baton);  in serf__bucket_stream_create()
105     return bucket;  in serf__bucket_stream_create()
109 static void serf_aggregate_destroy_and_data(serf_bucket_t *bucket)  in serf_aggregate_destroy_and_data()  argument
111     aggregate_context_t *ctx = bucket->data;  in serf_aggregate_destroy_and_data()
116             serf_bucket_destroy(ctx->list->bucket);  in serf_aggregate_destroy_and_data()
119         serf_bucket_mem_free(bucket->allocator, ctx->list);  in serf_aggregate_destroy_and_data()
122     cleanup_aggregate(ctx, bucket->allocator);  in serf_aggregate_destroy_and_data()
124     serf_default_destroy_and_data(bucket);  in serf_aggregate_destroy_and_data()
127 void serf_bucket_aggregate_become(serf_bucket_t *bucket)  in serf_bucket_aggregate_become()  argument
131     ctx = create_aggregate(bucket->allocator);  in serf_bucket_aggregate_become()
133     bucket->type = &serf_bucket_type_aggregate;  in serf_bucket_aggregate_become()
134     bucket->data = ctx;  in serf_bucket_aggregate_become()
149     new_list->bucket = prepend_bucket;  in serf_bucket_aggregate_prepend()
164     new_list->bucket = append_bucket;  in serf_bucket_aggregate_append()
224 static apr_status_t read_aggregate(serf_bucket_t *bucket,  in read_aggregate()  argument
229     aggregate_context_t *ctx = bucket->data;  in read_aggregate()
237             return ctx->hold_open(ctx->hold_open_baton, bucket);  in read_aggregate()
246         serf_bucket_t *head = ctx->list->bucket;  in read_aggregate()
282                     return ctx->hold_open(ctx->hold_open_baton, bucket);  in read_aggregate()
315 static apr_status_t serf_aggregate_read(serf_bucket_t *bucket,  in serf_aggregate_read()  argument
319     aggregate_context_t *ctx = bucket->data;  in serf_aggregate_read()
324     cleanup_aggregate(ctx, bucket->allocator);  in serf_aggregate_read()
326     status = read_aggregate(bucket, requested, 1, &vec, &vecs_used);  in serf_aggregate_read()
339 static apr_status_t serf_aggregate_read_iovec(serf_bucket_t *bucket,  in serf_aggregate_read_iovec()  argument
345     aggregate_context_t *ctx = bucket->data;  in serf_aggregate_read_iovec()
347     cleanup_aggregate(ctx, bucket->allocator);  in serf_aggregate_read_iovec()
349     return read_aggregate(bucket, requested, vecs_size, vecs, vecs_used);  in serf_aggregate_read_iovec()
352 static apr_status_t serf_aggregate_readline(serf_bucket_t *bucket,  in serf_aggregate_readline()  argument
356     aggregate_context_t *ctx = bucket->data;  in serf_aggregate_readline()
359     cleanup_aggregate(ctx, bucket->allocator);  in serf_aggregate_readline()
368                 return ctx->hold_open(ctx->hold_open_baton, bucket);  in serf_aggregate_readline()
375         head = ctx->list->bucket;  in serf_aggregate_readline()
394                     return ctx->hold_open(ctx->hold_open_baton, bucket);  in serf_aggregate_readline()
412 static apr_status_t serf_aggregate_peek(serf_bucket_t *bucket,  in serf_aggregate_peek()  argument
416     aggregate_context_t *ctx = bucket->data;  in serf_aggregate_peek()
420     cleanup_aggregate(ctx, bucket->allocator);  in serf_aggregate_peek()
426             status = ctx->hold_open(ctx->hold_open_baton, bucket);  in serf_aggregate_peek()
436     head = ctx->list->bucket;  in serf_aggregate_peek()
445                 status = ctx->hold_open(ctx->hold_open_baton, bucket);  in serf_aggregate_peek()
457     serf_bucket_t *bucket,  in serf_aggregate_read_bucket()  argument
460     aggregate_context_t *ctx = bucket->data;  in serf_aggregate_read_bucket()
467     if (ctx->list->bucket->type == type) {  in serf_aggregate_read_bucket()
469         found_bucket = ctx->list->bucket;  in serf_aggregate_read_bucket()
475     return serf_bucket_read_bucket(ctx->list->bucket, type);  in serf_aggregate_read_bucket()