Lines Matching refs:rv
53 int rv; in conn_call_begin_headers() local
59 rv = conn->callbacks.begin_headers(conn, stream->node.nid.id, conn->user_data, in conn_call_begin_headers()
61 if (rv != 0) { in conn_call_begin_headers()
71 int rv; in conn_call_end_headers() local
77 rv = conn->callbacks.end_headers(conn, stream->node.nid.id, fin, in conn_call_end_headers()
79 if (rv != 0) { in conn_call_end_headers()
89 int rv; in conn_call_begin_trailers() local
95 rv = conn->callbacks.begin_trailers(conn, stream->node.nid.id, in conn_call_begin_trailers()
97 if (rv != 0) { in conn_call_begin_trailers()
107 int rv; in conn_call_end_trailers() local
113 rv = conn->callbacks.end_trailers(conn, stream->node.nid.id, fin, in conn_call_end_trailers()
115 if (rv != 0) { in conn_call_end_trailers()
124 int rv; in conn_call_end_stream() local
130 rv = conn->callbacks.end_stream(conn, stream->node.nid.id, conn->user_data, in conn_call_end_stream()
132 if (rv != 0) { in conn_call_end_stream()
141 int rv; in conn_call_stop_sending() local
147 rv = conn->callbacks.stop_sending(conn, stream->node.nid.id, app_error_code, in conn_call_stop_sending()
149 if (rv != 0) { in conn_call_stop_sending()
158 int rv; in conn_call_reset_stream() local
164 rv = conn->callbacks.reset_stream(conn, stream->node.nid.id, app_error_code, in conn_call_reset_stream()
166 if (rv != 0) { in conn_call_reset_stream()
176 int rv; in conn_call_deferred_consume() local
182 rv = conn->callbacks.deferred_consume(conn, stream->node.nid.id, nconsumed, in conn_call_deferred_consume()
184 if (rv != 0) { in conn_call_deferred_consume()
217 int rv; in conn_new() local
238 rv = nghttp3_qpack_decoder_init(&conn->qdec, in conn_new()
241 if (rv != 0) { in conn_new()
245 rv = nghttp3_qpack_encoder_init( in conn_new()
247 if (rv != 0) { in conn_new()
285 return rv; in conn_new()
294 int rv; in nghttp3_conn_client_new_versioned() local
296 rv = conn_new(pconn, /* server = */ 0, callbacks_version, callbacks, in nghttp3_conn_client_new_versioned()
298 if (rv != 0) { in nghttp3_conn_client_new_versioned()
299 return rv; in nghttp3_conn_client_new_versioned()
311 int rv; in nghttp3_conn_server_new_versioned() local
313 rv = conn_new(pconn, /* server = */ 1, callbacks_version, callbacks, in nghttp3_conn_server_new_versioned()
315 if (rv != 0) { in nghttp3_conn_server_new_versioned()
316 return rv; in nghttp3_conn_server_new_versioned()
363 int rv; in conn_bidi_idtr_open() local
365 rv = nghttp3_idtr_open(&conn->remote.bidi.idtr, stream_id); in conn_bidi_idtr_open()
366 if (rv != 0) { in conn_bidi_idtr_open()
367 return rv; in conn_bidi_idtr_open()
382 int rv; in nghttp3_conn_read_stream() local
390 rv = conn_bidi_idtr_open(conn, stream_id); in nghttp3_conn_read_stream()
391 if (rv != 0) { in nghttp3_conn_read_stream()
392 if (nghttp3_err_is_fatal(rv)) { in nghttp3_conn_read_stream()
393 return rv; in nghttp3_conn_read_stream()
405 rv = nghttp3_conn_create_stream(conn, &stream, stream_id); in nghttp3_conn_read_stream()
406 if (rv != 0) { in nghttp3_conn_read_stream()
407 return rv; in nghttp3_conn_read_stream()
414 rv = nghttp3_conn_reject_stream(conn, stream); in nghttp3_conn_read_stream()
415 if (rv != 0) { in nghttp3_conn_read_stream()
416 return rv; in nghttp3_conn_read_stream()
425 rv = nghttp3_conn_create_stream(conn, &stream, stream_id); in nghttp3_conn_read_stream()
426 if (rv != 0) { in nghttp3_conn_read_stream()
427 return rv; in nghttp3_conn_read_stream()
438 rv = nghttp3_conn_create_stream(conn, &stream, stream_id); in nghttp3_conn_read_stream()
439 if (rv != 0) { in nghttp3_conn_read_stream()
440 return rv; in nghttp3_conn_read_stream()
543 int rv; in nghttp3_conn_read_uni() local
556 rv = conn_delete_stream(conn, stream); in nghttp3_conn_read_uni()
557 assert(0 == rv); in nghttp3_conn_read_uni()
600 rv = conn_call_stop_sending(conn, stream, NGHTTP3_H3_STREAM_CREATION_ERROR); in nghttp3_conn_read_uni()
601 if (rv != 0) { in nghttp3_conn_read_uni()
602 return rv; in nghttp3_conn_read_uni()
625 int rv; in nghttp3_conn_read_control() local
787 rv = in nghttp3_conn_read_control()
789 if (rv != 0) { in nghttp3_conn_read_control()
790 return rv; in nghttp3_conn_read_control()
838 rv = nghttp3_conn_on_settings_entry_received(conn, &rstate->fr.settings); in nghttp3_conn_read_control()
839 if (rv != 0) { in nghttp3_conn_read_control()
840 return rv; in nghttp3_conn_read_control()
877 rv = in nghttp3_conn_read_control()
879 if (rv != 0) { in nghttp3_conn_read_control()
934 rv = nghttp3_conn_on_priority_update(conn, &rstate->fr.priority_update); in nghttp3_conn_read_control()
935 if (rv != 0) { in nghttp3_conn_read_control()
936 return rv; in nghttp3_conn_read_control()
994 rv = nghttp3_conn_on_priority_update(conn, &rstate->fr.priority_update); in nghttp3_conn_read_control()
995 if (rv != 0) { in nghttp3_conn_read_control()
996 return rv; in nghttp3_conn_read_control()
1026 int rv; in conn_delete_stream() local
1028 rv = conn_call_deferred_consume(conn, stream, in conn_delete_stream()
1030 if (rv != 0) { in conn_delete_stream()
1031 return rv; in conn_delete_stream()
1035 rv = conn->callbacks.stream_close(conn, stream->node.nid.id, in conn_delete_stream()
1038 if (rv != 0) { in conn_delete_stream()
1043 rv = nghttp3_map_remove(&conn->streams, in conn_delete_stream()
1046 assert(0 == rv); in conn_delete_stream()
1058 int rv; in conn_process_blocked_stream_data() local
1080 rv = conn_call_deferred_consume(conn, stream, (size_t)nconsumed); in conn_process_blocked_stream_data()
1081 if (rv != 0) { in conn_process_blocked_stream_data()
1099 rv = conn_delete_stream(conn, stream); in conn_process_blocked_stream_data()
1100 if (rv != 0) { in conn_process_blocked_stream_data()
1101 return rv; in conn_process_blocked_stream_data()
1114 int rv; in nghttp3_conn_read_qpack_encoder() local
1132 rv = conn_process_blocked_stream_data(conn, stream); in nghttp3_conn_read_qpack_encoder()
1133 if (rv != 0) { in nghttp3_conn_read_qpack_encoder()
1134 return rv; in nghttp3_conn_read_qpack_encoder()
1174 int rv; in nghttp3_conn_read_bidi() local
1195 rv = nghttp3_stream_buffer_data(stream, p, (size_t)(end - p)); in nghttp3_conn_read_bidi()
1196 if (rv != 0) { in nghttp3_conn_read_bidi()
1197 return rv; in nghttp3_conn_read_bidi()
1243 rv = nghttp3_stream_transit_rx_http_state( in nghttp3_conn_read_bidi()
1245 if (rv != 0) { in nghttp3_conn_read_bidi()
1246 return rv; in nghttp3_conn_read_bidi()
1250 rv = nghttp3_stream_transit_rx_http_state( in nghttp3_conn_read_bidi()
1252 assert(0 == rv); in nghttp3_conn_read_bidi()
1260 rv = nghttp3_stream_transit_rx_http_state( in nghttp3_conn_read_bidi()
1262 if (rv != 0) { in nghttp3_conn_read_bidi()
1263 return rv; in nghttp3_conn_read_bidi()
1266 rv = nghttp3_stream_empty_headers_allowed(stream); in nghttp3_conn_read_bidi()
1267 if (rv != 0) { in nghttp3_conn_read_bidi()
1268 return rv; in nghttp3_conn_read_bidi()
1271 rv = nghttp3_stream_transit_rx_http_state( in nghttp3_conn_read_bidi()
1273 assert(0 == rv); in nghttp3_conn_read_bidi()
1282 rv = conn_call_begin_headers(conn, stream); in nghttp3_conn_read_bidi()
1286 rv = conn_call_begin_trailers(conn, stream); in nghttp3_conn_read_bidi()
1293 if (rv != 0) { in nghttp3_conn_read_bidi()
1294 return rv; in nghttp3_conn_read_bidi()
1320 rv = nghttp3_conn_on_data(conn, stream, p, len); in nghttp3_conn_read_bidi()
1321 if (rv != 0) { in nghttp3_conn_read_bidi()
1322 return rv; in nghttp3_conn_read_bidi()
1331 rv = nghttp3_stream_transit_rx_http_state(stream, in nghttp3_conn_read_bidi()
1333 assert(0 == rv); in nghttp3_conn_read_bidi()
1355 rv = nghttp3_stream_buffer_data(stream, p, (size_t)(end - p)); in nghttp3_conn_read_bidi()
1356 if (rv != 0) { in nghttp3_conn_read_bidi()
1357 return rv; in nghttp3_conn_read_bidi()
1370 rv = nghttp3_http_on_request_headers(&stream->rx.http); in nghttp3_conn_read_bidi()
1373 rv = nghttp3_http_on_response_headers(&stream->rx.http); in nghttp3_conn_read_bidi()
1377 rv = 0; in nghttp3_conn_read_bidi()
1385 if (rv != 0) { in nghttp3_conn_read_bidi()
1386 if (rv == NGHTTP3_ERR_MALFORMED_HTTP_HEADER) { in nghttp3_conn_read_bidi()
1390 return rv; in nghttp3_conn_read_bidi()
1401 rv = conn_update_stream_priority(conn, stream, stream->rx.http.pri); in nghttp3_conn_read_bidi()
1402 if (rv != 0) { in nghttp3_conn_read_bidi()
1403 return rv; in nghttp3_conn_read_bidi()
1408 rv = conn_call_end_headers(conn, stream, p == end && fin); in nghttp3_conn_read_bidi()
1412 rv = conn_call_end_trailers(conn, stream, p == end && fin); in nghttp3_conn_read_bidi()
1419 if (rv != 0) { in nghttp3_conn_read_bidi()
1420 return rv; in nghttp3_conn_read_bidi()
1423 rv = nghttp3_stream_transit_rx_http_state(stream, in nghttp3_conn_read_bidi()
1425 assert(0 == rv); in nghttp3_conn_read_bidi()
1437 rv = conn_call_stop_sending(conn, stream, NGHTTP3_H3_MESSAGE_ERROR); in nghttp3_conn_read_bidi()
1438 if (rv != 0) { in nghttp3_conn_read_bidi()
1439 return rv; in nghttp3_conn_read_bidi()
1442 rv = conn_call_reset_stream(conn, stream, NGHTTP3_H3_MESSAGE_ERROR); in nghttp3_conn_read_bidi()
1443 if (rv != 0) { in nghttp3_conn_read_bidi()
1444 return rv; in nghttp3_conn_read_bidi()
1474 rv = nghttp3_stream_transit_rx_http_state(stream, in nghttp3_conn_read_bidi()
1476 if (rv != 0) { in nghttp3_conn_read_bidi()
1477 return rv; in nghttp3_conn_read_bidi()
1479 rv = conn_call_end_stream(conn, stream); in nghttp3_conn_read_bidi()
1480 if (rv != 0) { in nghttp3_conn_read_bidi()
1481 return rv; in nghttp3_conn_read_bidi()
1497 int rv; in nghttp3_conn_on_data() local
1499 rv = nghttp3_http_on_data_chunk(stream, datalen); in nghttp3_conn_on_data()
1500 if (rv != 0) { in nghttp3_conn_on_data()
1501 return rv; in nghttp3_conn_on_data()
1508 rv = conn->callbacks.recv_data(conn, stream->node.nid.id, data, datalen, in nghttp3_conn_on_data()
1510 if (rv != 0) { in nghttp3_conn_on_data()
1530 int rv; in conn_decode_headers() local
1581 rv = nghttp3_conn_qpack_blocked_streams_push(conn, stream); in conn_decode_headers()
1582 if (rv != 0) { in conn_decode_headers()
1583 return rv; in conn_decode_headers()
1598 rv = nghttp3_http_on_header( in conn_decode_headers()
1601 switch (rv) { in conn_decode_headers()
1605 rv = 0; in conn_decode_headers()
1609 rv = recv_header(conn, stream->node.nid.id, nv.token, nv.name, in conn_decode_headers()
1612 if (rv != 0) { in conn_decode_headers()
1613 rv = NGHTTP3_ERR_CALLBACK_FAILURE; in conn_decode_headers()
1625 if (rv != 0) { in conn_decode_headers()
1626 return rv; in conn_decode_headers()
1713 int rv; in conn_on_priority_update_stream() local
1728 rv = conn_bidi_idtr_open(conn, stream_id); in conn_on_priority_update_stream()
1729 if (rv != 0) { in conn_on_priority_update_stream()
1730 if (nghttp3_err_is_fatal(rv)) { in conn_on_priority_update_stream()
1731 return rv; in conn_on_priority_update_stream()
1734 assert(rv == NGHTTP3_ERR_STREAM_IN_USE); in conn_on_priority_update_stream()
1742 rv = nghttp3_conn_create_stream(conn, &stream, stream_id); in conn_on_priority_update_stream()
1743 if (rv != 0) { in conn_on_priority_update_stream()
1744 return rv; in conn_on_priority_update_stream()
1774 int rv; in conn_stream_acked_data() local
1780 rv = conn->callbacks.acked_stream_data(conn, stream_id, datalen, in conn_stream_acked_data()
1782 if (rv != 0) { in conn_stream_acked_data()
1792 int rv; in nghttp3_conn_create_stream() local
1797 rv = nghttp3_stream_new(&stream, stream_id, conn->next_seq, &callbacks, in nghttp3_conn_create_stream()
1800 if (rv != 0) { in nghttp3_conn_create_stream()
1801 return rv; in nghttp3_conn_create_stream()
1806 rv = nghttp3_map_insert(&conn->streams, in nghttp3_conn_create_stream()
1808 if (rv != 0) { in nghttp3_conn_create_stream()
1810 return rv; in nghttp3_conn_create_stream()
1827 int rv; in nghttp3_conn_bind_control_stream() local
1836 rv = nghttp3_conn_create_stream(conn, &stream, stream_id); in nghttp3_conn_bind_control_stream()
1837 if (rv != 0) { in nghttp3_conn_bind_control_stream()
1838 return rv; in nghttp3_conn_bind_control_stream()
1845 rv = nghttp3_stream_write_stream_type(stream); in nghttp3_conn_bind_control_stream()
1846 if (rv != 0) { in nghttp3_conn_bind_control_stream()
1847 return rv; in nghttp3_conn_bind_control_stream()
1859 int rv; in nghttp3_conn_bind_qpack_streams() local
1870 rv = nghttp3_conn_create_stream(conn, &stream, qenc_stream_id); in nghttp3_conn_bind_qpack_streams()
1871 if (rv != 0) { in nghttp3_conn_bind_qpack_streams()
1872 return rv; in nghttp3_conn_bind_qpack_streams()
1879 rv = nghttp3_stream_write_stream_type(stream); in nghttp3_conn_bind_qpack_streams()
1880 if (rv != 0) { in nghttp3_conn_bind_qpack_streams()
1881 return rv; in nghttp3_conn_bind_qpack_streams()
1884 rv = nghttp3_conn_create_stream(conn, &stream, qdec_stream_id); in nghttp3_conn_bind_qpack_streams()
1885 if (rv != 0) { in nghttp3_conn_bind_qpack_streams()
1886 return rv; in nghttp3_conn_bind_qpack_streams()
1899 int rv; in conn_writev_stream() local
1907 rv = nghttp3_stream_fill_outq(stream); in conn_writev_stream()
1908 if (rv != 0) { in conn_writev_stream()
1909 return rv; in conn_writev_stream()
1945 int rv; in nghttp3_conn_writev_stream() local
1963 rv = nghttp3_stream_write_qpack_decoder_stream(conn->tx.qdec); in nghttp3_conn_writev_stream()
1964 if (rv != 0) { in nghttp3_conn_writev_stream()
1965 return rv; in nghttp3_conn_writev_stream()
2023 int rv; in nghttp3_conn_add_write_offset() local
2029 rv = nghttp3_stream_add_outq_offset(stream, n); in nghttp3_conn_add_write_offset()
2030 if (rv != 0) { in nghttp3_conn_add_write_offset()
2031 return rv; in nghttp3_conn_add_write_offset()
2066 int rv; in conn_submit_headers_data() local
2070 rv = nghttp3_nva_copy(&nnva, nva, nvlen, conn->mem); in conn_submit_headers_data()
2071 if (rv != 0) { in conn_submit_headers_data()
2072 return rv; in conn_submit_headers_data()
2079 rv = nghttp3_stream_frq_add(stream, &frent); in conn_submit_headers_data()
2080 if (rv != 0) { in conn_submit_headers_data()
2082 return rv; in conn_submit_headers_data()
2089 rv = nghttp3_stream_frq_add(stream, &frent); in conn_submit_headers_data()
2090 if (rv != 0) { in conn_submit_headers_data()
2091 return rv; in conn_submit_headers_data()
2105 int rv; in nghttp3_conn_schedule_stream() local
2107 rv = nghttp3_tnode_schedule(node, conn_get_sched_pq(conn, node), in nghttp3_conn_schedule_stream()
2109 if (rv != 0) { in nghttp3_conn_schedule_stream()
2110 return rv; in nghttp3_conn_schedule_stream()
2139 int rv; in nghttp3_conn_submit_request() local
2161 rv = nghttp3_conn_create_stream(conn, &stream, stream_id); in nghttp3_conn_submit_request()
2162 if (rv != 0) { in nghttp3_conn_submit_request()
2163 return rv; in nghttp3_conn_submit_request()
2239 int rv; in nghttp3_conn_submit_shutdown_notice() local
2249 rv = nghttp3_stream_frq_add(conn->tx.ctrl, &frent); in nghttp3_conn_submit_shutdown_notice()
2250 if (rv != 0) { in nghttp3_conn_submit_shutdown_notice()
2251 return rv; in nghttp3_conn_submit_shutdown_notice()
2262 int rv; in nghttp3_conn_shutdown() local
2276 rv = nghttp3_stream_frq_add(conn->tx.ctrl, &frent); in nghttp3_conn_shutdown()
2277 if (rv != 0) { in nghttp3_conn_shutdown()
2278 return rv; in nghttp3_conn_shutdown()
2288 int rv; in nghttp3_conn_reject_stream() local
2290 rv = conn_call_stop_sending(conn, stream, NGHTTP3_H3_REQUEST_REJECTED); in nghttp3_conn_reject_stream()
2291 if (rv != 0) { in nghttp3_conn_reject_stream()
2292 return rv; in nghttp3_conn_reject_stream()