| /* Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| #ifndef __mod_h2__h2_filter__ |
| #define __mod_h2__h2_filter__ |
| |
| struct h2_bucket_beam; |
| struct h2_headers; |
| struct h2_stream; |
| struct h2_session; |
| |
| typedef struct h2_filter_cin { |
| apr_pool_t *pool; |
| apr_socket_t *socket; |
| apr_interval_time_t timeout; |
| apr_bucket_brigade *bb; |
| struct h2_session *session; |
| apr_bucket *cur; |
| } h2_filter_cin; |
| |
| h2_filter_cin *h2_filter_cin_create(struct h2_session *session); |
| |
| void h2_filter_cin_timeout_set(h2_filter_cin *cin, apr_interval_time_t timeout); |
| |
| apr_status_t h2_filter_core_input(ap_filter_t* filter, |
| apr_bucket_brigade* brigade, |
| ap_input_mode_t mode, |
| apr_read_type_e block, |
| apr_off_t readbytes); |
| |
| /******* observer bucket ******************************************************/ |
| |
| typedef enum { |
| H2_BUCKET_EV_BEFORE_DESTROY, |
| H2_BUCKET_EV_BEFORE_MASTER_SEND |
| } h2_bucket_event; |
| |
| extern const apr_bucket_type_t h2_bucket_type_observer; |
| |
| typedef apr_status_t h2_bucket_event_cb(void *ctx, h2_bucket_event event, apr_bucket *b); |
| |
| #define H2_BUCKET_IS_OBSERVER(e) (e->type == &h2_bucket_type_observer) |
| |
| apr_bucket * h2_bucket_observer_make(apr_bucket *b, h2_bucket_event_cb *cb, |
| void *ctx); |
| |
| apr_bucket * h2_bucket_observer_create(apr_bucket_alloc_t *list, |
| h2_bucket_event_cb *cb, void *ctx); |
| |
| apr_status_t h2_bucket_observer_fire(apr_bucket *b, h2_bucket_event event); |
| |
| apr_bucket *h2_bucket_observer_beam(struct h2_bucket_beam *beam, |
| apr_bucket_brigade *dest, |
| const apr_bucket *src); |
| |
| /******* /.well-known/h2/state handler ****************************************/ |
| |
| int h2_filter_h2_status_handler(request_rec *r); |
| |
| #endif /* __mod_h2__h2_filter__ */ |