Lines Matching defs:rstate
412 stream->rstate.state = NGHTTP3_REQ_STREAM_STATE_IGN_REST;
482 nghttp3_stream_read_state *rstate = &stream->rstate;
483 nghttp3_varint_read_state *rvint = &rstate->rvint;
508 rstate->state = NGHTTP3_CTRL_STREAM_STATE_FRAME_TYPE;
552 if (stream->rstate.rvint.left) {
617 static int frame_fin(nghttp3_stream_read_state *rstate, size_t len) {
618 return (int64_t)len >= rstate->left;
626 nghttp3_stream_read_state *rstate = &stream->rstate;
627 nghttp3_varint_read_state *rvint = &rstate->rvint;
639 switch (rstate->state) {
653 rstate->fr.hd.type = rvint->acc;
655 rstate->state = NGHTTP3_CTRL_STREAM_STATE_FRAME_LENGTH;
673 rstate->left = rstate->fr.hd.length = rvint->acc;
677 if (rstate->fr.hd.type != NGHTTP3_FRAME_SETTINGS) {
681 } else if (rstate->fr.hd.type == NGHTTP3_FRAME_SETTINGS) {
685 switch (rstate->fr.hd.type) {
688 if (rstate->left == 0) {
689 nghttp3_stream_read_state_reset(rstate);
692 rstate->state = NGHTTP3_CTRL_STREAM_STATE_SETTINGS;
695 if (rstate->left == 0) {
698 rstate->state = NGHTTP3_CTRL_STREAM_STATE_GOAWAY;
704 if (rstate->left == 0) {
707 rstate->state = NGHTTP3_CTRL_STREAM_STATE_MAX_PUSH_ID;
713 if (rstate->left == 0) {
716 rstate->state = NGHTTP3_CTRL_STREAM_STATE_PRIORITY_UPDATE_PRI_ELEM_ID;
733 rstate->state = NGHTTP3_CTRL_STREAM_STATE_IGN_FRAME;
739 if (rstate->left == 0) {
740 nghttp3_stream_read_state_reset(rstate);
744 len = (size_t)nghttp3_min(rstate->left, (int64_t)(end - p));
746 nread = nghttp3_read_varint(rvint, p, len, frame_fin(rstate, len));
753 rstate->left -= nread;
755 rstate->state = NGHTTP3_CTRL_STREAM_STATE_SETTINGS_ID;
758 rstate->fr.settings.iv[0].id = (uint64_t)rvint->acc;
762 if (rstate->left == 0) {
768 rstate->state = NGHTTP3_CTRL_STREAM_STATE_SETTINGS_VALUE;
772 nread = nghttp3_read_varint(rvint, p, len, frame_fin(rstate, len));
779 rstate->left -= nread;
781 rstate->state = NGHTTP3_CTRL_STREAM_STATE_SETTINGS_VALUE;
784 rstate->fr.settings.iv[0].value = (uint64_t)rvint->acc;
788 nghttp3_conn_on_settings_entry_received(conn, &rstate->fr.settings);
795 len = (size_t)nghttp3_min(rstate->left, (int64_t)(end - p));
797 nread = nghttp3_read_varint(rvint, p, len, frame_fin(rstate, len));
804 rstate->left -= nread;
808 rstate->fr.settings.iv[0].id = (uint64_t)rvint->acc;
811 if (rstate->left == 0) {
815 rstate->state = NGHTTP3_CTRL_STREAM_STATE_SETTINGS_VALUE;
822 len = (size_t)nghttp3_min(rstate->left, (int64_t)(end - p));
824 nread = nghttp3_read_varint(rvint, p, len, frame_fin(rstate, len));
831 rstate->left -= nread;
835 rstate->fr.settings.iv[0].value = (uint64_t)rvint->acc;
838 rv = nghttp3_conn_on_settings_entry_received(conn, &rstate->fr.settings);
843 if (rstate->left) {
844 rstate->state = NGHTTP3_CTRL_STREAM_STATE_SETTINGS;
848 nghttp3_stream_read_state_reset(rstate);
851 len = (size_t)nghttp3_min(rstate->left, (int64_t)(end - p));
853 nread = nghttp3_read_varint(rvint, p, len, frame_fin(rstate, len));
860 rstate->left -= nread;
884 nghttp3_stream_read_state_reset(rstate);
888 len = (size_t)nghttp3_min(rstate->left, (int64_t)(end - p));
890 nread = nghttp3_read_varint(rvint, p, len, frame_fin(rstate, len));
897 rstate->left -= nread;
909 nghttp3_stream_read_state_reset(rstate);
913 len = (size_t)nghttp3_min(rstate->left, (int64_t)(end - p));
915 nread = nghttp3_read_varint(rvint, p, len, frame_fin(rstate, len));
922 rstate->left -= nread;
927 rstate->fr.priority_update.pri_elem_id = rvint->acc;
930 if (rstate->left == 0) {
931 rstate->fr.priority_update.pri.urgency = NGHTTP3_DEFAULT_URGENCY;
932 rstate->fr.priority_update.pri.inc = 0;
934 rv = nghttp3_conn_on_priority_update(conn, &rstate->fr.priority_update);
939 nghttp3_stream_read_state_reset(rstate);
943 rstate->state = NGHTTP3_CTRL_STREAM_STATE_PRIORITY_UPDATE;
949 len = (size_t)nghttp3_min(rstate->left, (int64_t)(end - p));
951 if (conn->rx.pri_fieldbuflen == 0 && rstate->left == (int64_t)len) {
956 rstate->state = NGHTTP3_CTRL_STREAM_STATE_IGN_FRAME;
965 rstate->state = NGHTTP3_CTRL_STREAM_STATE_IGN_FRAME;
971 if (rstate->left == (int64_t)len) {
979 rstate->left -= (int64_t)len;
981 if (rstate->left) {
985 rstate->fr.priority_update.pri.urgency = NGHTTP3_DEFAULT_URGENCY;
986 rstate->fr.priority_update.pri.inc = 0;
988 if (nghttp3_http_parse_priority(&rstate->fr.priority_update.pri,
994 rv = nghttp3_conn_on_priority_update(conn, &rstate->fr.priority_update);
1001 nghttp3_stream_read_state_reset(rstate);
1004 len = (size_t)nghttp3_min(rstate->left, (int64_t)(end - p));
1007 rstate->left -= (int64_t)len;
1009 if (rstate->left) {
1013 nghttp3_stream_read_state_reset(rstate);
1175 nghttp3_stream_read_state *rstate = &stream->rstate;
1176 nghttp3_varint_read_state *rvint = &rstate->rvint;
1204 switch (rstate->state) {
1218 rstate->fr.hd.type = rvint->acc;
1220 rstate->state = NGHTTP3_REQ_STREAM_STATE_FRAME_LENGTH;
1238 rstate->left = rstate->fr.hd.length = rvint->acc;
1241 switch (rstate->fr.hd.type) {
1249 if (rstate->left == 0) {
1254 nghttp3_stream_read_state_reset(rstate);
1257 rstate->state = NGHTTP3_REQ_STREAM_STATE_DATA;
1265 if (rstate->left == 0) {
1275 nghttp3_stream_read_state_reset(rstate);
1297 rstate->state = NGHTTP3_REQ_STREAM_STATE_HEADERS;
1314 rstate->state = NGHTTP3_REQ_STREAM_STATE_IGN_FRAME;
1319 len = (size_t)nghttp3_min(rstate->left, (int64_t)(end - p));
1325 rstate->left -= (int64_t)len;
1327 if (rstate->left) {
1335 nghttp3_stream_read_state_reset(rstate);
1338 len = (size_t)nghttp3_min(rstate->left, (int64_t)(end - p));
1340 (int64_t)len == rstate->left);
1351 rstate->left -= nread;
1364 if (rstate->left) {
1427 nghttp3_stream_read_state_reset(rstate);
1435 rstate->state = NGHTTP3_REQ_STREAM_STATE_IGN_REST;
1449 len = (size_t)nghttp3_min(rstate->left, (int64_t)(end - p));
1452 rstate->left -= (int64_t)len;
1454 if (rstate->left) {
1458 nghttp3_stream_read_state_reset(rstate);
1469 switch (rstate->state) {
2468 return (uint64_t)stream->rstate.left;