Lines Matching refs:stream_id
60 int recv_stream_data(ngtcp2_conn *conn, uint32_t flags, int64_t stream_id,
64 if (c->quic_recv_stream_data(flags, stream_id, data, datalen) != 0) {
74 int Client::quic_recv_stream_data(uint32_t flags, int64_t stream_id,
81 auto nconsumed = s->read_stream(flags, stream_id, data, datalen);
86 ngtcp2_conn_extend_max_stream_offset(quic.conn, stream_id, nconsumed);
93 int acked_stream_data_offset(ngtcp2_conn *conn, int64_t stream_id,
97 if (c->quic_acked_stream_data_offset(stream_id, datalen) != 0) {
104 int Client::quic_acked_stream_data_offset(int64_t stream_id, size_t datalen) {
106 if (s->add_ack_offset(stream_id, datalen) != 0) {
113 int stream_close(ngtcp2_conn *conn, uint32_t flags, int64_t stream_id,
122 if (c->quic_stream_close(stream_id, app_error_code) != 0) {
129 int Client::quic_stream_close(int64_t stream_id, uint64_t app_error_code) {
131 if (s->close_stream(stream_id, app_error_code) != 0) {
138 int stream_reset(ngtcp2_conn *conn, int64_t stream_id, uint64_t final_size,
142 if (c->quic_stream_reset(stream_id, app_error_code) != 0) {
149 int Client::quic_stream_reset(int64_t stream_id, uint64_t app_error_code) {
151 if (s->shutdown_stream_read(stream_id) != 0) {
158 int stream_stop_sending(ngtcp2_conn *conn, int64_t stream_id,
162 if (c->quic_stream_stop_sending(stream_id, app_error_code) != 0) {
169 int Client::quic_stream_stop_sending(int64_t stream_id,
172 if (s->shutdown_stream_read(stream_id) != 0) {
200 int extend_max_stream_data(ngtcp2_conn *conn, int64_t stream_id,
205 if (c->quic_extend_max_stream_data(stream_id) != 0) {
213 int Client::quic_extend_max_stream_data(int64_t stream_id) {
215 if (s->unblock_stream(stream_id) != 0) {
668 int64_t stream_id = -1;
673 sveccnt = s->write_stream(stream_id, fin, vec.data(), vec.size());
690 flags, stream_id, reinterpret_cast<const ngtcp2_vec *>(v), vcnt, ts);
695 s->block_stream(stream_id);
699 s->shutdown_stream_write(stream_id);
703 if (s->add_write_offset(stream_id, ndatalen) != 0) {
711 } else if (ndatalen >= 0 && s->add_write_offset(stream_id, ndatalen) != 0) {