Lines Matching refs:cq
2305 chunkqueue * const cq = &r->write_queue; in magnet_respbody() local
2306 chunkqueue_length(cq) in magnet_respbody()
2308 chunkqueue_read_squash(cq,r->conf.errh)) in magnet_respbody()
2344 chunkqueue * const cq = &r->reqbody_queue; in magnet_reqbody_add() local
2345 const int tempfile = (cq->last && cq->last->file.is_temp); in magnet_reqbody_add()
2350 chunkqueue_append_mem(cq, data.ptr, data.len); in magnet_reqbody_add()
2351 else if (chunkqueue_append_mem_to_tempfile(cq, data.ptr, data.len, in magnet_reqbody_add()
2366 chunkqueue_append_mem(cq, data.ptr, data.len); in magnet_reqbody_add()
2367 else if (chunkqueue_append_mem_to_tempfile(cq, data.ptr, data.len, in magnet_reqbody_add()
2394 chunkqueue * const cq = &r->reqbody_queue; in magnet_reqbody() local
2395 if (cq->bytes_in == (off_t)r->reqbody_length) { in magnet_reqbody()
2416 chunkqueue * const cq = &r->reqbody_queue; in magnet_reqbody() local
2417 if (cq->bytes_in == (off_t)r->reqbody_length) in magnet_reqbody()
2442 chunkqueue * const cq = &r->reqbody_queue; in magnet_reqbody() local
2443 if (cq->bytes_in == (off_t)r->reqbody_length) in magnet_reqbody()
2444 chunkqueue_length(cq) in magnet_reqbody()
2446 chunkqueue_read_squash(cq, r->conf.errh)) in magnet_reqbody()
2461 chunkqueue * const cq = &r->reqbody_queue; in magnet_reqbody() local
2462 if (cq->bytes_in == (off_t)r->reqbody_length) { in magnet_reqbody()