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