Lines Matching defs:chunk
146 static int sink_input_pop_cb(pa_sink_input *i, size_t length, pa_memchunk *chunk);
150 static int sink_input_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offset, pa_memchunk *chunk);
153 static void source_output_push_cb(pa_source_output *o, const pa_memchunk *chunk);
1129 pa_memchunk chunk;
1175 chunk.memblock = c->playback.current_memblock;
1176 chunk.index = c->playback.memblock_index;
1177 chunk.length = (size_t) r;
1182 pa_asyncmsgq_post(c->sink_input->sink->asyncmsgq, PA_MSGOBJECT(c->sink_input), SINK_INPUT_MESSAGE_POST_DATA, NULL, 0, &chunk, NULL);
1209 pa_memchunk chunk;
1213 if (pa_memblockq_peek(c->output_memblockq, &chunk) < 0)
1216 pa_assert(chunk.memblock);
1217 pa_assert(chunk.length);
1219 p = pa_memblock_acquire(chunk.memblock);
1220 r = pa_iochannel_write(c->io, (uint8_t*) p+chunk.index, chunk.length);
1221 pa_memblock_release(chunk.memblock);
1223 pa_memblock_unref(chunk.memblock);
1296 static int connection_process_msg(pa_msgobject *o, int code, void*userdata, int64_t offset, pa_memchunk *chunk) {
1309 /* pa_log("got data %u", chunk->length); */
1310 pa_memblockq_push_align(c->output_memblockq, chunk);
1325 static int sink_input_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offset, pa_memchunk *chunk) {
1336 pa_assert(chunk);
1339 pa_memblockq_push_align(c->input_memblockq, chunk);
1364 return pa_sink_input_process_msg(o, code, userdata, offset, chunk);
1369 static int sink_input_pop_cb(pa_sink_input *i, size_t length, pa_memchunk *chunk) {
1375 pa_assert(chunk);
1377 if (pa_memblockq_peek(c->input_memblockq, chunk) < 0) {
1390 chunk->length = PA_MIN(length, chunk->length);
1391 pa_memblockq_drop(c->input_memblockq, chunk->length);
1437 static void source_output_push_cb(pa_source_output *o, const pa_memchunk *chunk) {
1443 pa_assert(chunk);
1445 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(c), CONNECTION_MESSAGE_POST_DATA, NULL, 0, chunk, NULL);