Searched defs:bucket (Results 1 - 18 of 18) sorted by relevance

/httpd/server/
H A Dutil_xml.c54 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 Dcore_filters.c135 * 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 Dvhost.c85 /* 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 Dutil.c2548 * 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 Dmod_reflector.c113 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 Dmod_request.c73 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 Dmod_charset_lite.c354 * 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...]
/httpd/include/
H A Dscoreboard.h145 int bucket; /* Listener bucket used by this child */ member in struct:process_score
/httpd/modules/generators/
H A Dmod_cgi.c559 /* 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 Dmod_cgid.c1489 * 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 Dhttp_filters.c487 /* 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/modules/ssl/
H A Dssl_engine_io.c100 * 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/server/mpm/motorz/
H A Dmotorz.c51 *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/prefork/
H A Dprefork.c136 *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 Dmod_auth_digest.c117 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/worker/
H A Dworker.c163 * 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/modules/lua/
H A Dlua_request.c2191 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);
/httpd/server/mpm/event/
H A Devent.c222 /** 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...]

Completed in 89 milliseconds