/*******************************************************************************
* h2_blist, a brigade without allocations
******************************************************************************/
+
+static apr_array_header_t *beamers;
-APR_HOOK_STRUCT(
- APR_HOOK_LINK(beam_bucket)
-)
-AP_IMPLEMENT_HOOK_RUN_FIRST(apr_bucket *, beam_bucket,
- (h2_bucket_beam *beam, apr_bucket_brigade *dest,
- const apr_bucket *src),
- (beam, dest, src), NULL)
+void h2_register_bucket_beamer(h2_bucket_beamer *beamer)
+{
+ if (!beamers) {
+ beamers = apr_array_make(apr_hook_global_pool, 10,
+ sizeof(h2_bucket_beamer*));
+ }
+ APR_ARRAY_PUSH(beamers, h2_bucket_beamer*) = beamer;
+}
+
+static apr_bucket *h2_beam_bucket(h2_bucket_beam *beam,
+ apr_bucket_brigade *dest,
+ const apr_bucket *src)
+{
+ apr_bucket *b = NULL;
+ int i;
+ if (beamers) {
+ for (i = 0; i < beamers->nelts && b == NULL; ++i) {
+ h2_bucket_beamer *beamer;
+
+ beamer = APR_ARRAY_IDX(beamers, i, h2_bucket_beamer*);
+ b = beamer(beam, dest, src);
+ }
+ }
+ return b;
+}
+
apr_size_t h2_util_bl_print(char *buffer, apr_size_t bmax,
const char *tag, const char *sep,
++transferred;
}
else {
- bgreen = ap_run_beam_bucket(beam, bb, bred);
+ bgreen = h2_beam_bucket(beam, bb, bred);
while (bgreen && bgreen != APR_BRIGADE_SENTINEL(bb)) {
++transferred;
remain -= bgreen->length;
apr_size_t h2_beam_get_files_beamed(h2_bucket_beam *beam);
-AP_DECLARE_HOOK(apr_bucket *, beam_bucket,
- (h2_bucket_beam *beam, apr_bucket_brigade *dest,
- const apr_bucket *src))
+typedef apr_bucket *h2_bucket_beamer(h2_bucket_beam *beam,
+ apr_bucket_brigade *dest,
+ const apr_bucket *src);
+
+void h2_register_bucket_beamer(h2_bucket_beamer *beamer);
#endif /* h2_bucket_beam_h */
* many streams.
*/
l = master->id;
- if (sizeof(long) >= 8 && l < APR_UINT32_MAX) {
- c->id = l|(((unsigned long)slave_id) << 32);
+ if (sizeof(unsigned long) >= 8 && l < APR_UINT32_MAX) {
+ c->id = l|((unsigned long)slave_id << 32);
}
else {
c->id = l^(~slave_id);
}
const apr_bucket_type_t h2_bucket_type_observer = {
- "H2LAZY", 5, APR_BUCKET_METADATA,
+ "H2OBS", 5, APR_BUCKET_METADATA,
bucket_destroy,
bucket_read,
apr_bucket_setaside_noop,
ap_hook_fixups(h2_h2_late_fixups, NULL, NULL, APR_HOOK_LAST);
/* special bucket type transfer through a h2_bucket_beam */
- ap_hook_beam_bucket(h2_bucket_observer_beam, NULL, NULL, APR_HOOK_MIDDLE);
- ap_hook_beam_bucket(h2_bucket_headers_beam, NULL, NULL, APR_HOOK_MIDDLE);
+ h2_register_bucket_beamer(h2_bucket_headers_beam);
+ h2_register_bucket_beamer(h2_bucket_observer_beam);
}
int h2_h2_process_conn(conn_rec* c)
* @macro
* Version number of the http2 module as c string
*/
-#define MOD_HTTP2_VERSION "1.7.0-DEV"
+#define MOD_HTTP2_VERSION "1.7.1"
/**
* @macro
* release. This is a 24 bit number with 8 bits for major number, 8 bits
* for minor and 8 bits for patch. Version 1.2.3 becomes 0x010203.
*/
-#define MOD_HTTP2_VERSION_NUM 0x010700
+#define MOD_HTTP2_VERSION_NUM 0x010701
#endif /* mod_h2_h2_version_h */