Lines Matching refs:cq
1029 chunkqueue * const cq = con->read_queue; in h2_recv_data() local
1042 chunkqueue_mark_written(cq, 9+len); in h2_recv_data()
1057 chunkqueue_mark_written(cq, 9+len); in h2_recv_data()
1094 chunkqueue_mark_written(cq, 9+len); in h2_recv_data()
1107 chunkqueue_mark_written(cq, 9+len); in h2_recv_data()
1137 chunkqueue_mark_written(cq, 9+len); in h2_recv_data()
1157 chunkqueue_mark_written(cq, 9 + ((s[4] & H2_FLAG_PADDED) ? 1 : 0)); in h2_recv_data()
1176 if (0 != chunkqueue_steal_with_tempfiles(dst, cq, (off_t)alen, errh)) { in h2_recv_data()
1182 chunkqueue_steal(dst, cq, (off_t)alen); in h2_recv_data()
1185 chunkqueue_mark_written(cq, pad); in h2_recv_data()
1192 h2_frame_cq_compact (chunkqueue * const cq, uint32_t len) in h2_frame_cq_compact() argument
1200 chunkqueue_compact_mem(cq, len); in h2_frame_cq_compact()
1201 return buffer_clen(cq->first->mem) - (uint32_t)cq->first->offset; in h2_frame_cq_compact()
1207 h2_recv_continuation (uint32_t n, uint32_t clen, const off_t cqlen, chunkqueue * const cq, connecti… in h2_recv_continuation() argument
1209 chunk *c = cq->first; in h2_recv_continuation()
1219 clen = h2_frame_cq_compact(cq, n+9); in h2_recv_continuation()
1220 c = cq->first; /*(reload after h2_frame_cq_compact())*/ in h2_recv_continuation()
1243 clen = h2_frame_cq_compact(cq, n); in h2_recv_continuation()
1245 c = cq->first; /*(reload after h2_frame_cq_compact())*/ in h2_recv_continuation()
1295 cq->bytes_out += plen; in h2_recv_continuation()
1319 cq->bytes_out += 9; in h2_recv_continuation()
1711 chunkqueue * const cq = con->read_queue; in h2_parse_frames() local
1718 for (off_t cqlen = chunkqueue_length(cq); cqlen >= 9; ) { in h2_parse_frames()
1719 chunk *c = cq->first; in h2_parse_frames()
1725 clen = h2_frame_cq_compact(cq, 9); in h2_parse_frames()
1726 c = cq->first; /*(reload after h2_frame_cq_compact())*/ in h2_parse_frames()
1741 clen = h2_frame_cq_compact(cq, 9+flen); in h2_parse_frames()
1742 c = cq->first; /*(reload after h2_frame_cq_compact())*/ in h2_parse_frames()
1750 clen = h2_recv_continuation(9+flen, clen, cqlen, cq, con); in h2_parse_frames()
1753 c = cq->first; /*(reload after h2_recv_continuation())*/ in h2_parse_frames()
1759 cqlen = chunkqueue_length(cq); in h2_parse_frames()
1773 chunkqueue_mark_written(cq, 9+flen); in h2_parse_frames()
1808 clen = h2_frame_cq_compact(cq, 9+flen); UNUSED(clen); in h2_parse_frames()
1809 c = cq->first; /*(reload after h2_frame_cq_compact())*/ in h2_parse_frames()
1842 chunkqueue_mark_written(cq, 9+flen); in h2_parse_frames()
1855 chunkqueue * const cq = con->read_queue; in h2_want_read() local
1856 if (chunkqueue_is_empty(cq)) return 1; in h2_want_read()
1859 const off_t cqlen = chunkqueue_length(cq); in h2_want_read()
1861 chunk *c = cq->first; in h2_want_read()
1864 clen = h2_frame_cq_compact(cq, 9); in h2_want_read()
1865 c = cq->first; /*(reload after h2_frame_cq_compact())*/ in h2_want_read()
1878 clen = h2_frame_cq_compact(cq, n+9); in h2_want_read()
1879 c = cq->first; /*(reload after h2_frame_cq_compact())*/ in h2_want_read()
1896 chunkqueue * const cq = con->read_queue; in h2_recv_client_connection_preface() local
1897 if (chunkqueue_length(cq) < 24) { in h2_recv_client_connection_preface()
1898 chunk * const c = cq->first; in h2_recv_client_connection_preface()
1910 chunk *c = cq->first; in h2_recv_client_connection_preface()
1912 if (clen < 24) h2_frame_cq_compact(cq, 24); in h2_recv_client_connection_preface()
1913 c = cq->first; /*(reload after h2_frame_cq_compact())*/ in h2_recv_client_connection_preface()
1916 chunkqueue_mark_written(cq, 24); in h2_recv_client_connection_preface()
1925 h2_read_client_connection_preface (struct connection * const con, chunkqueue * const cq, off_t max_… in h2_read_client_connection_preface() argument
1934 int rc = (network_read)(con, cq, max_bytes); in h2_read_client_connection_preface()
2622 h2_send_cqdata (request_st * const r, connection * const con, chunkqueue * const cq, uint32_t dlen) in h2_send_cqdata() argument
2650 const off_t cqlen = chunkqueue_length(cq); in h2_send_cqdata()
2665 if (cq->first->type == FILE_CHUNK) { in h2_send_cqdata()
2681 if (0 == chunkqueue_peek_data(cq, &data, &blen, r->conf.errh) in h2_send_cqdata()
2693 chunkqueue_mark_written(cq, len); in h2_send_cqdata()
2698 chunkqueue_remove_empty_chunks(cq); in h2_send_cqdata()
2709 chunkqueue_steal(con->write_queue, cq, (off_t)len); in h2_send_cqdata()
2884 chunkqueue * const cq = con->write_queue; in h2_retire_con() local
2885 const off_t len = chunkqueue_length(cq); in h2_retire_con()
2886 off_t written = cq->bytes_out; in h2_retire_con()
2887 con->network_write(con, cq, len); in h2_retire_con()
2889 written = cq->bytes_out - written; in h2_retire_con()