Lines Matching defs:chunk
83 static int sink_input_pop_cb(pa_sink_input *i, size_t length, pa_memchunk *chunk);
95 static void source_output_push_cb(pa_source_output *o, const pa_memchunk *chunk);
101 static int sink_input_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offset, pa_memchunk *chunk);
102 static int source_output_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offset, pa_memchunk *chunk);
199 static int record_stream_process_msg(pa_msgobject *o, int code, void*userdata, int64_t offset, pa_memchunk *chunk) {
212 pa_atomic_sub(&s->on_the_fly, chunk->length);
214 if (pa_memblockq_push_align(s->memblockq, chunk) < 0) {
304 * hardware-buffer-sized chunk at a time to the client. */
503 static int playback_stream_process_msg(pa_msgobject *o, int code, void*userdata, int64_t offset, pa_memchunk *chunk) {
982 static int native_connection_process_msg(pa_msgobject *o, int code, void*userdata, int64_t offset, pa_memchunk *chunk) {
1074 pa_memchunk chunk;
1084 if (pa_memblockq_peek(r->memblockq, &chunk) >= 0) {
1085 pa_memchunk schunk = chunk;
1146 static int sink_input_process_msg(pa_msgobject *o, int code, void *userdata, int64_t offset, pa_memchunk *chunk) {
1169 if (chunk && pa_memblockq_push_align(s->memblockq, chunk) < 0) {
1173 pa_memblockq_seek(s->memblockq, (int64_t) chunk->length, PA_SEEK_RELATIVE, true);
1295 return pa_sink_input_process_msg(o, code, userdata, offset, chunk);
1363 static int sink_input_pop_cb(pa_sink_input *i, size_t nbytes, pa_memchunk *chunk) {
1369 pa_assert(chunk);
1380 if (pa_memblockq_peek(s->memblockq, chunk) < 0)
1383 chunk->length = PA_MIN(nbytes, chunk->length);
1388 pa_memblockq_drop(s->memblockq, chunk->length);
1549 static int source_output_process_msg(pa_msgobject *_o, int code, void *userdata, int64_t offset, pa_memchunk *chunk) {
1568 return pa_source_output_process_msg(_o, code, userdata, offset, chunk);
1572 static void source_output_push_cb(pa_source_output *o, const pa_memchunk *chunk) {
1578 pa_assert(chunk);
1580 pa_atomic_add(&s->on_the_fly, chunk->length);
1581 pa_asyncmsgq_post(pa_thread_mq_get()->outq, PA_MSGOBJECT(s), RECORD_STREAM_MESSAGE_POST_DATA, NULL, 0, chunk, NULL);
4915 static void pstream_memblock_callback(pa_pstream *p, uint32_t channel, int64_t offset, pa_seek_mode_t seek, const pa_memchunk *chunk, void *userdata) {
4920 pa_assert(chunk);
4930 pa_log("got %lu bytes from client", (unsigned long) chunk->length);
4937 if (chunk->index % frame_size != 0 || chunk->length % frame_size != 0) {
4939 "%d", (int) chunk->index, (int) chunk->length, (int) frame_size);
4944 if (chunk->memblock) {
4946 pa_asyncmsgq_post(ps->sink_input->sink->asyncmsgq, PA_MSGOBJECT(ps->sink_input), SINK_INPUT_MESSAGE_SEEK, PA_UINT_TO_PTR(seek), offset, chunk, NULL);
4948 pa_asyncmsgq_post(ps->sink_input->sink->asyncmsgq, PA_MSGOBJECT(ps->sink_input), SINK_INPUT_MESSAGE_POST_DATA, NULL, 0, chunk, NULL);
4950 pa_asyncmsgq_post(ps->sink_input->sink->asyncmsgq, PA_MSGOBJECT(ps->sink_input), SINK_INPUT_MESSAGE_SEEK, PA_UINT_TO_PTR(seek), offset+chunk->length, NULL, NULL);
4957 if (u->length == chunk->length && chunk->memblock) {
4958 u->memchunk = *chunk;
4970 if (l > chunk->length)
4971 l = chunk->length;
4977 if (chunk->memblock) {
4979 src = pa_memblock_acquire(chunk->memblock);
4982 (uint8_t*) src + chunk->index, l);
4984 pa_memblock_release(chunk->memblock);