| 1493 | } |
| 1494 | |
| 1495 | static void dispatch_event(h2_proxy_session *session, h2_proxys_event_t ev, |
| 1496 | int arg, const char *msg) |
| 1497 | { |
| 1498 | switch (ev) { |
| 1499 | case H2_PROXYS_EV_INIT: |
| 1500 | ev_init(session, arg, msg); |
| 1501 | break; |
| 1502 | case H2_PROXYS_EV_LOCAL_GOAWAY: |
| 1503 | ev_local_goaway(session, arg, msg); |
| 1504 | break; |
| 1505 | case H2_PROXYS_EV_REMOTE_GOAWAY: |
| 1506 | ev_remote_goaway(session, arg, msg); |
| 1507 | break; |
| 1508 | case H2_PROXYS_EV_CONN_ERROR: |
| 1509 | ev_conn_error(session, arg, msg); |
| 1510 | break; |
| 1511 | case H2_PROXYS_EV_PROTO_ERROR: |
| 1512 | ev_proto_error(session, arg, msg); |
| 1513 | break; |
| 1514 | case H2_PROXYS_EV_CONN_TIMEOUT: |
| 1515 | ev_conn_timeout(session, arg, msg); |
| 1516 | break; |
| 1517 | case H2_PROXYS_EV_NO_IO: |
| 1518 | ev_no_io(session, arg, msg); |
| 1519 | break; |
| 1520 | case H2_PROXYS_EV_STREAM_SUBMITTED: |
| 1521 | ev_stream_submitted(session, arg, msg); |
| 1522 | break; |
| 1523 | case H2_PROXYS_EV_STREAM_DONE: |
| 1524 | ev_stream_done(session, arg, msg); |
| 1525 | break; |
| 1526 | case H2_PROXYS_EV_STREAM_RESUMED: |
| 1527 | ev_stream_resumed(session, arg, msg); |
| 1528 | break; |
| 1529 | case H2_PROXYS_EV_DATA_READ: |
| 1530 | ev_data_read(session, arg, msg); |
| 1531 | break; |
| 1532 | case H2_PROXYS_EV_NGH2_DONE: |
| 1533 | ev_ngh2_done(session, arg, msg); |
| 1534 | break; |
| 1535 | case H2_PROXYS_EV_PRE_CLOSE: |
| 1536 | ev_pre_close(session, arg, msg); |
| 1537 | break; |
| 1538 | default: |
| 1539 | ap_log_cerror(APLOG_MARK, APLOG_TRACE1, 0, session->c, |
| 1540 | "h2_proxy_session(%s): unknown event %d", |
| 1541 | session->id, ev); |
| 1542 | break; |
| 1543 | } |
| 1544 | } |
| 1545 | |
| 1546 | static int send_loop(h2_proxy_session *session) |
| 1547 | { |
no test coverage detected