| 1652 | } |
| 1653 | |
| 1654 | static void ev_stream_open(h2_session *session, h2_stream *stream) |
| 1655 | { |
| 1656 | if (H2_STREAM_CLIENT_INITIATED(stream->id)) { |
| 1657 | if (stream->id > session->remote.accepted_max) { |
| 1658 | session->local.accepted_max = stream->id; |
| 1659 | } |
| 1660 | } |
| 1661 | else { |
| 1662 | if (stream->id > session->local.emitted_max) { |
| 1663 | ++session->local.emitted_count; |
| 1664 | session->remote.emitted_max = stream->id; |
| 1665 | } |
| 1666 | } |
| 1667 | /* Stream state OPEN means we have received all request headers |
| 1668 | * and can start processing the stream. */ |
| 1669 | h2_iq_append(session->ready_to_process, stream->id); |
| 1670 | update_child_status(session, SERVER_BUSY_READ, "schedule", stream); |
| 1671 | } |
| 1672 | |
| 1673 | static void ev_stream_closed(h2_session *session, h2_stream *stream) |
| 1674 | { |
no test coverage detected