Lines Matching refs:chunk
119 while (PA_LIKELY(bq->current_read != NULL) && PA_UNLIKELY(bq->current_read->index + (int64_t) bq->current_read->chunk.length <= bq->read_index))
139 while (PA_UNLIKELY(bq->current_write->index + (int64_t) bq->current_write->chunk.length <= bq->write_index))
169 end = bq->blocks_tail ? bq->blocks_tail->index + (int64_t) bq->blocks_tail->chunk.length : bq->write_index;
211 pa_memchunk chunk;
227 chunk = *uchunk;
236 while (bq->write_index + (int64_t) chunk.length > q->index)
251 if (bq->write_index >= q->index + (int64_t) q->chunk.length)
254 else if (bq->write_index + (int64_t) chunk.length <= q->index) {
258 bq->write_index + (int64_t) chunk.length >= q->index + (int64_t) q->chunk.length) {
270 if (bq->write_index + (int64_t) chunk.length < q->index + (int64_t) q->chunk.length) {
280 p->chunk = q->chunk;
281 pa_memblock_ref(p->chunk.memblock);
284 d = (size_t) (bq->write_index + (int64_t) chunk.length - q->index);
289 p->chunk.length -= d;
302 /* Truncate the chunk */
303 if (!(q->chunk.length = (size_t) (bq->write_index - q->index))) {
315 pa_assert(bq->write_index + (int64_t)chunk.length > q->index &&
316 bq->write_index + (int64_t)chunk.length < q->index + (int64_t)q->chunk.length &&
321 d = (size_t) (bq->write_index + (int64_t) chunk.length - q->index);
323 q->chunk.index += d;
324 q->chunk.length -= d;
331 pa_assert(bq->write_index >= q->index + (int64_t)q->chunk.length);
332 pa_assert(!q->next || (bq->write_index + (int64_t)chunk.length <= q->next->index));
336 if (q->chunk.memblock == chunk.memblock &&
337 q->chunk.index + q->chunk.length == chunk.index &&
338 bq->write_index == q->index + (int64_t) q->chunk.length) {
340 q->chunk.length += chunk.length;
341 bq->write_index += (int64_t) chunk.length;
345 pa_assert(!bq->blocks || (bq->write_index + (int64_t)chunk.length <= bq->blocks->index));
350 n->chunk = chunk;
351 pa_memblock_ref(n->chunk.memblock);
353 bq->write_index += (int64_t) n->chunk.length;
406 int pa_memblockq_peek(pa_memblockq* bq, pa_memchunk *chunk) {
409 pa_assert(chunk);
431 *chunk = bq->silence;
432 pa_memblock_ref(chunk->memblock);
434 if (length > 0 && length < chunk->length)
435 chunk->length = length;
444 chunk->memblock = NULL;
445 chunk->length = length;
448 chunk->index = 0;
453 *chunk = bq->current_read->chunk;
454 pa_memblock_ref(chunk->memblock);
458 chunk->index += (size_t) d;
459 chunk->length -= (size_t) d;
464 int pa_memblockq_peek_fixed_size(pa_memblockq *bq, size_t block_size, pa_memchunk *chunk) {
472 pa_assert(chunk);
479 *chunk = tchunk;
480 chunk->length = block_size;
513 tchunk = item->chunk;
533 *chunk = rchunk;
558 p = bq->current_read->index + (int64_t) bq->current_read->chunk.length;
632 bq->write_index = (bq->blocks_tail ? bq->blocks_tail->index + (int64_t) bq->blocks_tail->chunk.length : bq->read_index) + offset;
698 int pa_memblockq_push_align(pa_memblockq* bq, const pa_memchunk *chunk) {
702 pa_assert(chunk);
705 return pa_memblockq_push(bq, chunk);
707 if (!can_push(bq, pa_mcalign_csize(bq->mcalign, chunk->length)))
710 pa_mcalign_push(bq->mcalign, chunk);
880 pa_memchunk chunk;
882 if (pa_memblockq_peek(source, &chunk) < 0)
885 pa_assert(chunk.length > 0);
887 if (chunk.memblock) {
889 if (pa_memblockq_push_align(bq, &chunk) < 0) {
890 pa_memblock_unref(chunk.memblock);
894 pa_memblock_unref(chunk.memblock);
896 pa_memblockq_seek(bq, (int64_t) chunk.length, PA_SEEK_RELATIVE, true);
898 pa_memblockq_drop(bq, chunk.length);
910 pa_memchunk_will_need(&q->chunk);