Lines Matching defs:chunk
149 pa_memchunk chunk;
193 chunk.memblock = c->playback.current_memblock;
194 chunk.index = c->playback.memblock_index;
195 chunk.length = (size_t) r;
199 pa_asyncmsgq_post(c->sink_input->sink->asyncmsgq, PA_MSGOBJECT(c->sink_input), SINK_INPUT_MESSAGE_POST_DATA, NULL, 0, &chunk, NULL);
206 pa_memchunk chunk;
215 if (pa_memblockq_peek(c->output_memblockq, &chunk) < 0) {
220 pa_assert(chunk.memblock);
221 pa_assert(chunk.length);
223 p = pa_memblock_acquire(chunk.memblock);
224 r = pa_iochannel_write(c->io, (uint8_t*) p+chunk.index, chunk.length);
225 pa_memblock_release(chunk.memblock);
227 pa_memblock_unref(chunk.memblock);
277 static int connection_process_msg(pa_msgobject *o, int code, void*userdata, int64_t offset, pa_memchunk *chunk) {
290 /* pa_log("got data %u", chunk->length); */
291 pa_memblockq_push_align(c->output_memblockq, chunk);
306 static int sink_input_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offset, pa_memchunk *chunk) {
317 pa_assert(chunk);
320 pa_memblockq_push_align(c->input_memblockq, chunk);
345 return pa_sink_input_process_msg(o, code, userdata, offset, chunk);
350 static int sink_input_pop_cb(pa_sink_input *i, size_t length, pa_memchunk *chunk) {
356 pa_assert(chunk);
358 if (pa_memblockq_peek(c->input_memblockq, chunk) < 0) {
369 chunk->length = PA_MIN(length, chunk->length);
373 pa_memblockq_drop(c->input_memblockq, chunk->length);
420 static void source_output_push_cb(pa_source_output *o, const pa_memchunk *chunk) {
426 pa_assert(chunk);
428 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(c), CONNECTION_MESSAGE_POST_DATA, NULL, 0, chunk, NULL);