| 568 | } |
| 569 | |
| 570 | static int on_stream_close(nghttp2_session *ngh2, int32_t stream_id, |
| 571 | uint32_t error_code, void *user_data) |
| 572 | { |
| 573 | h2_proxy_session *session = user_data; |
| 574 | h2_proxy_stream *stream; |
| 575 | if (!session->aborted) { |
| 576 | ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, session->c, APLOGNO(03360) |
| 577 | "h2_proxy_session(%s): stream=%d, closed, err=%d", |
| 578 | session->id, stream_id, error_code); |
| 579 | stream = h2_proxy_ihash_get(session->streams, stream_id); |
| 580 | if (stream) { |
| 581 | stream->error_code = error_code; |
| 582 | } |
| 583 | dispatch_event(session, H2_PROXYS_EV_STREAM_DONE, stream_id, NULL); |
| 584 | } |
| 585 | return 0; |
| 586 | } |
| 587 | |
| 588 | static int on_header(nghttp2_session *ngh2, const nghttp2_frame *frame, |
| 589 | const uint8_t *namearg, size_t nlen, |
nothing calls this directly
no test coverage detected