Home
last modified time | relevance | path

Searched refs:rob (Results 1 - 5 of 5) sorted by relevance

/third_party/node/deps/ngtcp2/ngtcp2/lib/
H A Dngtcp2_rob.c68 int ngtcp2_rob_init(ngtcp2_rob *rob, size_t chunk, const ngtcp2_mem *mem) { in ngtcp2_rob_init() argument
72 ngtcp2_ksl_init(&rob->gapksl, ngtcp2_ksl_range_compar, sizeof(ngtcp2_range), in ngtcp2_rob_init()
80 rv = ngtcp2_ksl_insert(&rob->gapksl, NULL, &g->range, g); in ngtcp2_rob_init()
85 ngtcp2_ksl_init(&rob->dataksl, ngtcp2_ksl_range_compar, sizeof(ngtcp2_range), in ngtcp2_rob_init()
88 rob->chunk = chunk; in ngtcp2_rob_init()
89 rob->mem = mem; in ngtcp2_rob_init()
96 ngtcp2_ksl_free(&rob->gapksl); in ngtcp2_rob_init()
100 void ngtcp2_rob_free(ngtcp2_rob *rob) { in ngtcp2_rob_free() argument
103 if (rob == NULL) { in ngtcp2_rob_free()
107 for (it = ngtcp2_ksl_begin(&rob in ngtcp2_rob_free()
121 rob_write_data(ngtcp2_rob *rob, uint64_t offset, const uint8_t *data, size_t len) rob_write_data() argument
162 ngtcp2_rob_push(ngtcp2_rob *rob, uint64_t offset, const uint8_t *data, size_t datalen) ngtcp2_rob_push() argument
221 ngtcp2_rob_remove_prefix(ngtcp2_rob *rob, uint64_t offset) ngtcp2_rob_remove_prefix() argument
257 ngtcp2_rob_data_at(ngtcp2_rob *rob, const uint8_t **pdest, uint64_t offset) ngtcp2_rob_data_at() argument
287 ngtcp2_rob_pop(ngtcp2_rob *rob, uint64_t offset, size_t len) ngtcp2_rob_pop() argument
304 ngtcp2_rob_first_gap_offset(ngtcp2_rob *rob) ngtcp2_rob_first_gap_offset() argument
317 ngtcp2_rob_data_buffered(ngtcp2_rob *rob) ngtcp2_rob_data_buffered() argument
[all...]
H A Dngtcp2_rob.h123 * ngtcp2_rob_init initializes |rob|. |chunk| is the size of buffer
132 int ngtcp2_rob_init(ngtcp2_rob *rob, size_t chunk, const ngtcp2_mem *mem);
135 * ngtcp2_rob_free frees resources allocated for |rob|.
137 void ngtcp2_rob_free(ngtcp2_rob *rob);
149 int ngtcp2_rob_push(ngtcp2_rob *rob, uint64_t offset, const uint8_t *data,
162 int ngtcp2_rob_remove_prefix(ngtcp2_rob *rob, uint64_t offset);
170 size_t ngtcp2_rob_data_at(ngtcp2_rob *rob, const uint8_t **pdest,
184 void ngtcp2_rob_pop(ngtcp2_rob *rob, uint64_t offset, size_t len);
190 uint64_t ngtcp2_rob_first_gap_offset(ngtcp2_rob *rob);
195 int ngtcp2_rob_data_buffered(ngtcp2_rob *rob);
[all...]
H A Dngtcp2_strm.c52 strm->rx.rob = NULL; in ngtcp2_strm_init()
83 if (strm->rx.rob) { in ngtcp2_strm_free()
84 ngtcp2_rob_free(strm->rx.rob); in ngtcp2_strm_free()
85 ngtcp2_mem_free(strm->mem, strm->rx.rob); in ngtcp2_strm_free()
96 ngtcp2_rob *rob = ngtcp2_mem_malloc(strm->mem, sizeof(*rob)); in strm_rob_init() local
98 if (rob == NULL) { in strm_rob_init()
102 rv = ngtcp2_rob_init(rob, 8 * 1024, strm->mem); in strm_rob_init()
104 ngtcp2_mem_free(strm->mem, rob); in strm_rob_init()
108 strm->rx.rob in strm_rob_init()
122 strm_rob_heavily_fragmented(ngtcp2_rob *rob) strm_rob_heavily_fragmented() argument
[all...]
H A Dngtcp2_strm.h129 /* rob is the reorder buffer for incoming stream data. The data
132 ngtcp2_rob *rob; member
135 that, rob is used to track the offset and data. */
H A Dngtcp2_conn.c5790 if (!strm->rx.rob) { in conn_emit_pending_crypto_data()
5795 datalen = ngtcp2_rob_data_at(strm->rx.rob, &data, rx_offset); in conn_emit_pending_crypto_data()
5809 ngtcp2_rob_pop(strm->rx.rob, rx_offset - datalen, datalen); in conn_emit_pending_crypto_data()
6868 if (!strm->rx.rob) { in conn_emit_pending_stream_data()
6880 datalen = ngtcp2_rob_data_at(strm->rx.rob, &data, rx_offset); in conn_emit_pending_stream_data()
6903 ngtcp2_rob_pop(strm->rx.rob, rx_offset - datalen, datalen); in conn_emit_pending_stream_data()
9668 if (conn->in_pktns->crypto.strm.rx.rob && in conn_read_handshake()
9669 ngtcp2_rob_data_buffered(conn->in_pktns->crypto.strm.rx.rob)) { in conn_read_handshake()
9868 (!conn->in_pktns->crypto.strm.rx.rob || in ngtcp2_conn_read_pkt_versioned()
9869 !ngtcp2_rob_data_buffered(conn->in_pktns->crypto.strm.rx.rob))) { in ngtcp2_conn_read_pkt_versioned()
[all...]

Completed in 15 milliseconds