Searched refs:strmq (Results 1 – 3 of 3) sorted by relevance
385 ngtcp2_pq strmq; member
1018 ngtcp2_pq_init(&(*pconn)->tx.strmq, cycle_less, mem); in conn_new()1389 ngtcp2_pq_free(&conn->tx.strmq); in ngtcp2_conn_del()1712 for (; !ngtcp2_pq_empty(&conn->tx.strmq);) { in conn_retry_early_payloadlen()3621 for (; !ngtcp2_pq_empty(&conn->tx.strmq);) { in conn_write_pkt()4791 if (ngtcp2_pq_empty(&conn->tx.strmq)) { in conn_tx_strmq_first_cycle()4802 if (ngtcp2_pq_empty(&conn->tx.strmq)) { in ngtcp2_conn_tx_strmq_first_cycle()11136 ngtcp2_pq_remove(&conn->tx.strmq, &strm->pe); in ngtcp2_conn_close_stream()11293 if (!ngtcp2_pq_empty(&conn->tx.strmq)) { in conn_extend_max_stream_offset()11351 ngtcp2_pq_remove(&conn->tx.strmq, &s->pe); in delete_strms_pq_each()11766 assert(!ngtcp2_pq_empty(&conn->tx.strmq)); in ngtcp2_conn_tx_strmq_top()[all …]
956 CU_ASSERT(3 == ngtcp2_pq_size(&conn->tx.strmq)); in test_ngtcp2_conn_stream_rx_flow_control()973 CU_ASSERT(ngtcp2_pq_empty(&conn->tx.strmq)); in test_ngtcp2_conn_stream_rx_flow_control()3266 CU_ASSERT(ngtcp2_pq_empty(&conn->tx.strmq)); in test_ngtcp2_conn_send_max_stream_data()