| /httpd/server/ |
| H A D | util_xml.c | 54 apr_bucket *bucket; local
66 for (bucket = APR_BRIGADE_FIRST(brigade);
67 bucket != APR_BRIGADE_SENTINEL(brigade);
68 bucket = APR_BUCKET_NEXT(bucket))
73 if (APR_BUCKET_IS_EOS(bucket)) {
78 if (APR_BUCKET_IS_METADATA(bucket)) {
82 status = apr_bucket_read(bucket, &data, &len, APR_BLOCK_READ);
|
| H A D | core_filters.c | 135 * If we have lost our socket bucket (see above), we are EOF.
137 * Ideally, this should be returning SUCCESS with EOS bucket, but
194 /* If we reach here, we were a bucket just full of CRLFs, so
195 * just toss the bucket. */
219 * likely simply be the socket bucket) we know this is the end,
249 * When we are in normal mode, return an EOS bucket to the
252 * that the next call returns an EOS bucket.
279 * Read from bucket, but non blocking. If there isn't any
356 apr_bucket *bucket,
377 apr_bucket *bucket, *nex local
654 apr_bucket *bucket, *next; local
751 apr_bucket *bucket; local
825 apr_bucket *bucket = APR_BRIGADE_FIRST(bb); local
863 sendfile_nonblocking(apr_socket_t *s, apr_bucket *bucket, apr_size_t *cumulative_bytes_written, conn_rec *c) argument
[all...] |
| H A D | vhost.c | 85 /* A (n) bucket hash table, each entry has a pointer to a server rec and
86 * a pointer to the other entries in that bucket. Each individual address,
380 unsigned bucket; local
385 bucket = hash_addr(sa);
386 for (trav = iphash_table[bucket]; trav; trav = trav->next) {
616 unsigned bucket = hash_addr(sar->host_addr); local
618 ic->next = *iphash_table_tail[bucket];
619 *iphash_table_tail[bucket] = ic;
|
| H A D | util.c | 2548 * values as bucket brigades. This allows values to be arbitrarily
2622 apr_bucket *bucket = NULL, *last = NULL; local
2631 for (bucket = APR_BRIGADE_FIRST(bb);
2632 bucket != APR_BRIGADE_SENTINEL(bb);
2633 last = bucket, bucket = APR_BUCKET_NEXT(bucket)) {
2640 if (APR_BUCKET_IS_EOS(bucket)) {
2644 if (bucket->length == 0) {
2648 rv = apr_bucket_read(bucket,
[all...] |
| /httpd/modules/filters/ |
| H A D | mod_reflector.c | 113 apr_bucket *bucket; local
123 for (bucket = APR_BRIGADE_FIRST(bbin);
124 bucket != APR_BRIGADE_SENTINEL(bbin);
125 bucket = APR_BUCKET_NEXT(bucket)) {
129 if (APR_BUCKET_IS_EOS(bucket)) {
135 if (bucket->length == 0) {
141 * bucket or one that morphs, we want to exhaust it.
143 status = apr_bucket_read(bucket, &data, &len, APR_BLOCK_READ);
|
| H A D | mod_request.c | 73 apr_bucket *bucket; local
157 for (bucket = APR_BRIGADE_FIRST(b);
158 bucket != APR_BRIGADE_SENTINEL(b);
159 bucket = APR_BUCKET_NEXT(bucket))
161 apr_bucket_copy(bucket, &e);
252 /* As above; this should not fail since the bucket has
|
| H A D | mod_charset_lite.c | 354 * bucket handling:
355 * why create an eos bucket when we see it come down the stream? just send the one
379 * bucket brigade and passes the brigade to the next filter
490 msg = APLOGNO(02195) "xlate filter - bucket read routine failed";
639 * translated characters; the eos bucket, if
643 * hit_eos: did we hit an EOS bucket?
653 const char *bucket; local
654 apr_size_t bytes_in_bucket; /* total bytes read from current bucket */
655 apr_size_t bucket_avail; /* bytes left in current bucket */
662 if (!bucket_avail) { /* no bytes left to process in the current bucket
[all...] |
| H A D | mod_proxy_html.c | 991 "Error in bucket read");
|
| H A D | mod_include.c | 3370 * This is the main loop over the current bucket brigade.
3402 /* loop over the current bucket brigade */
3422 * just re-insert the EOS bucket to allow for an extra loop.
3471 /* read the current bucket data */
3494 /* zero length bucket, fetch next one */
3501 * it's actually a data containing bucket, start/continue parsing
3523 /* now delete the start_seq stuff from the remaining bucket */
3552 /* now delete the start_seq stuff from the remaining bucket */
3763 /* don't forget to finally insert the EOS bucket */
|
| /httpd/include/ |
| H A D | util_filter.h | 100 * pointer to "this" filter, and a "bucket brigade" containing the content
117 * The bucket brigade always belongs to the caller, but the filter
284 * Get the current bucket brigade from the next filter on the filter
287 * The bucket brigade will be empty when there is nothing left to get.
289 * @param bucket The current bucket brigade. The original brigade passed
297 apr_bucket_brigade *bucket,
303 * Pass the current bucket brigade down to the next filter on the filter
307 * @param bucket The current bucket brigad
[all...] |
| H A D | scoreboard.h | 145 int bucket; /* Listener bucket used by this child */ member in struct:process_score
|
| /httpd/modules/ssl/ |
| H A D | ssl_engine_io.c | 100 * EOS or FLUSH bucket. this was not possible with the mem BIO where we
148 /* Send a FLUSH bucket down the output filter stack; returns 1 on
180 * apache will destroy the bucket brigade for us
212 /* Use a transient bucket for the output data - any downstream
395 * particular characteristics of the bucket we are
402 /* This stream bucket was consumed */
422 /* This physical bucket was consumed */
426 /* Only part of this physical bucket was consumed */
919 apr_bucket *bucket; local
934 bucket
1392 apr_bucket *bucket = apr_bucket_eos_create(f->c->bucket_alloc); local
1400 apr_bucket *bucket = apr_bucket_immortal_create(CRLF, 2, f->c->bucket_alloc); local
1482 apr_bucket *bucket = local
1729 apr_bucket *bucket = APR_BRIGADE_FIRST(bb); local
[all...] |
| /httpd/modules/generators/ |
| H A D | mod_cgi.c | 559 /* A CGI bucket type is needed to catch any output to stderr from the
568 /* Create a CGI bucket using pipes from script stdout 'out'
620 /* Create a duplicate CGI bucket using given bucket data */
636 * method of the real APR pipe bucket implementation. */
658 /* Change the current bucket to refer to what we read */
673 /* Read method of CGI bucket: polls on stderr and stdout of the child,
847 apr_bucket *bucket; local
863 for (bucket = APR_BRIGADE_FIRST(bb);
864 bucket !
[all...] |
| H A D | mod_cgid.c | 1489 * use a pipe bucket to send the data to the client. APR will create
1515 apr_bucket *bucket; local
1531 for (bucket = APR_BRIGADE_FIRST(bb);
1532 bucket != APR_BRIGADE_SENTINEL(bb);
1533 bucket = APR_BUCKET_NEXT(bucket))
1538 if (APR_BUCKET_IS_EOS(bucket)) {
1544 if (APR_BUCKET_IS_FLUSH(bucket)) {
1554 apr_bucket_read(bucket, &data, &len, APR_BLOCK_READ);
1837 * use a pipe bucket t
[all...] |
| /httpd/modules/http/ |
| H A D | http_filters.c | 487 /* If this happens, we have a bucket of unknown length. Die because
1161 * If we see an EOC bucket it is a signal that we should get out
1282 * 2.0, if a handler returns, then the core sends an EOS bucket down
1427 apr_bucket *bucket; local
1437 for (bucket = APR_BRIGADE_FIRST(bb);
1438 bucket != APR_BRIGADE_SENTINEL(bb);
1439 bucket = APR_BUCKET_NEXT(bucket))
1444 if (APR_BUCKET_IS_EOS(bucket)) {
1450 if (bucket
[all...] |
| /httpd/server/mpm/prefork/ |
| H A D | prefork.c | 136 *my_bucket; /* Current child bucket */
753 static int make_child(server_rec *s, int slot, int bucket) argument
805 my_bucket = &all_buckets[bucket];
836 child_main(slot, bucket);
839 ap_scoreboard_image->parent[slot].bucket = bucket;
1101 ap_get_scoreboard_process(child_slot)->bucket);
|
| /httpd/modules/aaa/ |
| H A D | mod_auth_digest.c | 117 struct hash_entry *next; /* next entry in the bucket */
686 * bucket number.
691 * it is moved to the beginning of the linked list in its bucket (this
694 * end of the list) in each bucket.
698 * in each bucket). The major disadvantage is that you may be throwing
732 int bucket; local
738 bucket = key % client_list->tbl_len;
739 entry = client_list->table[bucket];
750 entry->next = client_list->table[bucket];
751 client_list->table[bucket]
815 int bucket; local
[all...] |
| /httpd/server/mpm/motorz/ |
| H A D | motorz.c | 51 *my_bucket; /* Current child bucket */
1038 static int make_child(motorz_core_t *mz, server_rec *s, int slot, int bucket) argument
1085 my_bucket = &all_buckets[bucket];
1116 child_main(mz, slot, bucket);
1119 ap_scoreboard_image->parent[slot].bucket = bucket;
1310 ap_get_scoreboard_process(child_slot)->bucket);
|
| /httpd/server/mpm/worker/ |
| H A D | worker.c | 163 * maintained per listeners bucket, doubled up to MAX_SPAWN_RATE, and
186 *my_bucket; /* Current child bucket */
1402 static int make_child(server_rec *s, int slot, int bucket) argument
1440 my_bucket = &all_buckets[bucket];
1456 child_main(slot, bucket);
1470 ap_scoreboard_image->parent[slot].bucket = bucket;
1549 ps->bucket == child_bucket) {
1743 retained->idle_spawn_rate[ps->bucket] = 1;
1750 make_child(ap_server_conf, child_slot, ps->bucket);
[all...] |
| /httpd/server/mpm/event/ |
| H A D | event.c | 222 /** bucket allocator */
371 * maintained per listeners bucket, doubled up to MAX_SPAWN_RATE, and
393 *my_bucket; /* Current child bucket */
2673 static int make_child(server_rec * s, int slot, int bucket) argument
2712 my_bucket = &all_buckets[bucket];
2728 child_main(slot, bucket);
2743 ap_scoreboard_image->parent[slot].bucket = bucket;
2822 && ps->bucket == child_bucket)
3005 retained->idle_spawn_rate[ps->bucket]
[all...] |
| /httpd/modules/lua/ |
| H A D | lua_request.c | 2191 apr_bucket* bucket = APR_BRIGADE_FIRST(brigade); local
2194 rv = apr_bucket_read(bucket, &data, &data_length, APR_BLOCK_READ);
2198 apr_bucket_delete(bucket);
|