Home
last modified time | relevance | path

Searched refs:memchunk (Results 1 – 25 of 34) sorted by relevance

12

/third_party/pulseaudio/src/modules/
Dmodule-pipe-source.c77 pa_memchunk memchunk; member
143 if (!u->memchunk.memblock) { in thread_func()
144 u->memchunk.memblock = pa_memblock_new(u->core->mempool, pa_pipe_buf(u->fd)); in thread_func()
145 u->memchunk.index = u->memchunk.length = 0; in thread_func()
148 pa_assert(pa_memblock_get_length(u->memchunk.memblock) > u->memchunk.index); in thread_func()
150 p = pa_memblock_acquire(u->memchunk.memblock); in thread_func()
151 …l = pa_read(u->fd, (uint8_t*) p + u->memchunk.index, pa_memblock_get_length(u->memchunk.memblock) … in thread_func()
152 pa_memblock_release(u->memchunk.memblock); in thread_func()
167 u->memchunk.length = (size_t) l; in thread_func()
168 pa_source_post(u->source, &u->memchunk); in thread_func()
[all …]
Dmodule-solaris.c94 pa_memchunk memchunk; member
183 if (u->memchunk.memblock) in sink_get_latency()
184 r += pa_bytes_to_usec(u->memchunk.length, ss); in sink_get_latency()
630 rewind_nbytes = PA_MIN(u->memchunk.length, rewind_nbytes); in process_rewind()
631 u->memchunk.length -= rewind_nbytes; in process_rewind()
632 if (u->memchunk.length <= 0 && u->memchunk.memblock) { in process_rewind()
633 pa_memblock_unref(u->memchunk.memblock); in process_rewind()
634 pa_memchunk_reset(&u->memchunk); in process_rewind()
707 if (!u->memchunk.length) in thread_func()
708 pa_sink_render(u->sink, u->sink->thread_info.max_request, &u->memchunk); in thread_func()
[all …]
Dmodule-pipe-sink.c86 pa_memchunk memchunk; member
128 n += u->memchunk.length; in sink_process_msg()
274 if (u->memchunk.length <= 0) in process_render()
275 pa_sink_render(u->sink, u->buffer_size, &u->memchunk); in process_render()
277 pa_assert(u->memchunk.length > 0); in process_render()
283 p = pa_memblock_acquire(u->memchunk.memblock); in process_render()
284 l = pa_write(u->fd, (uint8_t*) p + u->memchunk.index, u->memchunk.length, &u->write_type); in process_render()
285 pa_memblock_release(u->memchunk.memblock); in process_render()
302 u->memchunk.index += (size_t) l; in process_render()
303 u->memchunk.length -= (size_t) l; in process_render()
[all …]
Dmodule-sine.c47 pa_memchunk memchunk; member
65 *chunk = u->memchunk; in sink_input_pop_cb()
82 nbytes %= u->memchunk.length; in sink_input_process_rewind_cb()
87 u->peek_index = u->memchunk.length + u->peek_index - nbytes; in sink_input_process_rewind_cb()
156 pa_memchunk_sine(&u->memchunk, m->core->mempool, ss.rate, frequency); in pa__init()
205 if (u->memchunk.memblock) in pa__done()
206 pa_memblock_unref(u->memchunk.memblock); in pa__done()
Dmodule-esound-sink.c92 pa_memchunk memchunk; member
148 w = pa_bytes_to_usec((uint64_t) u->offset + u->memchunk.length, &u->sink->sample_spec); in sink_process_msg()
239 if (u->memchunk.length <= 0) in thread_func()
240 pa_sink_render(u->sink, u->block_size, &u->memchunk); in thread_func()
242 pa_assert(u->memchunk.length > 0); in thread_func()
244 p = pa_memblock_acquire(u->memchunk.memblock); in thread_func()
245 … l = pa_write(u->fd, (uint8_t*) p + u->memchunk.index, u->memchunk.length, &write_type); in thread_func()
246 pa_memblock_release(u->memchunk.memblock); in thread_func()
268 u->memchunk.index += (size_t) l; in thread_func()
269 u->memchunk.length -= (size_t) l; in thread_func()
[all …]
Dmodule-tunnel-source-new.c141 pa_memchunk memchunk; in read_new_samples() local
146 pa_memchunk_reset(&memchunk); in read_new_samples()
162 … memchunk.memblock = pa_memblock_new_fixed(u->module->core->mempool, (void *) p, nbytes, true); in read_new_samples()
163 memchunk.length = nbytes; in read_new_samples()
164 memchunk.index = 0; in read_new_samples()
166 pa_source_post(u->source, &memchunk); in read_new_samples()
167 pa_memblock_unref_fixed(memchunk.memblock); in read_new_samples()
172 memchunk = u->source->silence; in read_new_samples()
173 pa_memblock_ref(memchunk.memblock); in read_new_samples()
176 if (bytes_to_generate < memchunk.length) in read_new_samples()
[all …]
Dmodule-waveout.c117 pa_memchunk memchunk; in do_write() local
146 pa_sink_render(u->sink, len, &memchunk); in do_write()
148 pa_assert(memchunk.memblock); in do_write()
149 pa_assert(memchunk.length); in do_write()
151 if (memchunk.length < len) in do_write()
152 len = memchunk.length; in do_write()
154 p = pa_memblock_acquire(memchunk.memblock); in do_write()
155 memcpy(hdr->lpData + hdr->dwBufferLength, (char*) p + memchunk.index, len); in do_write()
156 pa_memblock_release(memchunk.memblock); in do_write()
160 pa_memblock_unref(memchunk.memblock); in do_write()
[all …]
Dmodule-sine-source.c64 pa_memchunk memchunk; member
141 chunk = u->memchunk; in process_render()
149 while (u->peek_index >= u->memchunk.length) in process_render()
150 u->peek_index -= u->memchunk.length; in process_render()
240 pa_memchunk_sine(&u->memchunk, m->core->mempool, ss.rate, frequency); in pa__init()
326 if (u->memchunk.memblock) in pa__done()
327 pa_memblock_unref(u->memchunk.memblock); in pa__done()
Dmodule-tunnel-sink-new.c196 pa_memchunk memchunk; in thread_func() local
199 pa_sink_render_full(u->sink, writable, &memchunk); in thread_func()
201 pa_assert(memchunk.length > 0); in thread_func()
204 p = pa_memblock_acquire(memchunk.memblock); in thread_func()
207 (uint8_t*) p + memchunk.index, in thread_func()
208 memchunk.length, in thread_func()
212 pa_memblock_release(memchunk.memblock); in thread_func()
213 pa_memblock_unref(memchunk.memblock); in thread_func()
/third_party/pulseaudio/src/modules/rtp/
Drtp-native.c58 pa_memchunk memchunk; member
80 pa_memchunk_reset(&c->memchunk); in pa_rtp_context_new_send()
187 pa_memchunk_reset(&c->memchunk); in pa_rtp_context_new_recv()
327 if (c->memchunk.length < (unsigned) audio_length) { in pa_rtp_recv()
330 if (c->memchunk.memblock) in pa_rtp_recv()
331 pa_memblock_unref(c->memchunk.memblock); in pa_rtp_recv()
335 c->memchunk.memblock = pa_memblock_new(pool, l); in pa_rtp_recv()
336 c->memchunk.index = 0; in pa_rtp_recv()
337 c->memchunk.length = pa_memblock_get_length(c->memchunk.memblock); in pa_rtp_recv()
340 memcpy(pa_memblock_acquire_chunk(&c->memchunk), c->recv_buf + metadata_length, audio_length); in pa_rtp_recv()
[all …]
/third_party/curl/tests/libtest/
Dlib518.c103 int *memchunk = NULL; in rlimit() local
259 num_open.rlim_max = sizeof(*memchunk) * (size_t)nitems; in rlimit()
262 memchunk = malloc(sizeof(*memchunk) * (size_t)nitems); in rlimit()
263 if(!memchunk) { in rlimit()
267 } while(nitems && !memchunk); in rlimit()
268 if(!memchunk) { in rlimit()
279 memchunk[i] = -1; in rlimit()
293 free(memchunk); in rlimit()
306 free(memchunk); in rlimit()
331 free(memchunk); in rlimit()
[all …]
Dlib537.c105 int *memchunk = NULL; local
233 num_open.rlim_max = sizeof(*memchunk) * nitems;
236 memchunk = malloc(sizeof(*memchunk) * (size_t)nitems);
237 if(!memchunk) {
241 } while(nitems && !memchunk);
242 if(!memchunk) {
253 memchunk[i] = -1;
282 free(memchunk);
300 free(memchunk);
325 free(memchunk);
[all …]
/third_party/pulseaudio/src/pulsecore/
Dasyncmsgq.c47 pa_memchunk memchunk; member
89 if (i->memchunk.memblock) in asyncmsgq_free()
90 pa_memblock_unref(i->memchunk.memblock); in asyncmsgq_free()
132 i->memchunk = *chunk; in pa_asyncmsgq_post()
133 pa_memblock_ref(i->memchunk.memblock); in pa_asyncmsgq_post()
135 pa_memchunk_reset(&i->memchunk); in pa_asyncmsgq_post()
156 i.memchunk = *chunk; in pa_asyncmsgq_send()
158 pa_memchunk_reset(&i.memchunk); in pa_asyncmsgq_send()
198 *chunk = a->current->memchunk; in pa_asyncmsgq_get()
227 if (a->current->memchunk.memblock) in pa_asyncmsgq_done()
[all …]
Dcore-scache.c85 if (e->memchunk.memblock) in free_entry()
86 pa_memblock_unref(e->memchunk.memblock); in free_entry()
100 if (e->memchunk.memblock) in scache_add_item()
101 pa_memblock_unref(e->memchunk.memblock); in scache_add_item()
129 pa_memchunk_reset(&e->memchunk); in scache_add_item()
188 e->memchunk = *chunk; in pa_scache_add_item()
189 pa_memblock_ref(e->memchunk.memblock); in pa_scache_add_item()
199 name, e->index, (unsigned long) e->memchunk.length, in pa_scache_add_item()
320 if (e->lazy && !e->memchunk.memblock) { in pa_scache_play_item()
323 …und_file_load(c->mempool, e->filename, &e->sample_spec, &e->channel_map, &e->memchunk, merged) < 0) in pa_scache_play_item()
[all …]
Dasyncmsgq.h58 …ect, int code, const void *userdata, int64_t offset, const pa_memchunk *memchunk, pa_free_cb_t use…
59 …pa_msgobject *object, int code, const void *userdata, int64_t offset, const pa_memchunk *memchunk);
61 …msgobject **object, int *code, void **userdata, int64_t *offset, pa_memchunk *memchunk, bool wait);
62 …gq_dispatch(pa_msgobject *object, int code, void *userdata, int64_t offset, pa_memchunk *memchunk);
Dprotocol-esound.c110 pa_memchunk memchunk; member
271 if (c->scache.memchunk.memblock) in connection_free()
272 pa_memblock_unref(c->scache.memchunk.memblock); in connection_free()
707 if (ce->memchunk.memblock) in esd_proto_all_info()
744 len = PA_MAYBE_INT32_SWAP(c->swap_byte_order, (int) ce->memchunk.length); in esd_proto_all_info()
867 pa_assert(!c->scache.memchunk.memblock); in esd_proto_sample_cache()
868 c->scache.memchunk.memblock = pa_memblock_new(c->protocol->core->mempool, (size_t) sc_length); in esd_proto_sample_cache()
869 c->scache.memchunk.index = 0; in esd_proto_sample_cache()
870 c->scache.memchunk.length = (size_t) sc_length; in esd_proto_sample_cache()
1091 pa_assert(c->scache.memchunk.memblock); in do_read()
[all …]
Dpstream.c143 pa_memchunk memchunk; member
421 if (p->write.memchunk.memblock) in pstream_free()
422 pa_memblock_unref(p->write.memchunk.memblock); in pstream_free()
606 pa_memchunk_reset(&p->write.memchunk); in prepare_next_write_item()
714 p->write.memchunk = p->write.current->chunk; in prepare_next_write_item()
715 pa_memblock_ref(p->write.memchunk.memblock); in prepare_next_write_item()
766 pa_assert(p->write.data || p->write.memchunk.memblock); in do_write()
771 d = pa_memblock_acquire_chunk(&p->write.memchunk); in do_write()
772 release_memblock = p->write.memchunk.memblock; in do_write()
811 if (p->write.memchunk.memblock) in do_write()
[all …]
Dcli-text.c623 if (e->memchunk.memblock) { in pa_scache_list_to_string()
626 l = (double) e->memchunk.length / (double) pa_bytes_per_second(&e->sample_spec); in pa_scache_list_to_string()
647 (long unsigned)(e->memchunk.memblock ? e->memchunk.length : 0), in pa_scache_list_to_string()
650 …(e->memchunk.memblock && e->volume_is_set) ? pa_cvolume_get_balance(&e->volume, &e->channel_map) :… in pa_scache_list_to_string()
Dcore-scache.h40 pa_memchunk memchunk; member
/third_party/pulseaudio/src/modules/raop/
Draop-sink.c95 pa_memchunk memchunk; member
543 if (u->memchunk.length <= 0) { in thread_func()
545 if (u->memchunk.memblock) in thread_func()
546 pa_memblock_unref(u->memchunk.memblock); in thread_func()
547 pa_memchunk_reset(&u->memchunk); in thread_func()
550 pa_sink_render_full(u->sink, u->block_size, &u->memchunk); in thread_func()
551 offset = u->memchunk.index; in thread_func()
555 if (u->memchunk.length > 0) { in thread_func()
556 index = u->memchunk.index; in thread_func()
558 if (sendstream && pa_raop_client_send_audio_packet(u->raop, &u->memchunk, offset) < 0) { in thread_func()
[all …]
/third_party/pulseaudio/src/modules/oss/
Dmodule-oss.c112 pa_memchunk memchunk; member
449 if (u->memchunk.memblock) in io_sink_get_latency()
450 r += pa_bytes_to_usec(u->memchunk.length, &u->sink->sample_spec); in io_sink_get_latency()
968 if (u->memchunk.length <= 0) in thread_func()
969 pa_sink_render(u->sink, (size_t) l, &u->memchunk); in thread_func()
971 pa_assert(u->memchunk.length > 0); in thread_func()
973 p = pa_memblock_acquire(u->memchunk.memblock); in thread_func()
974 … t = pa_write(u->fd, (uint8_t*) p + u->memchunk.index, u->memchunk.length, &write_type); in thread_func()
975 pa_memblock_release(u->memchunk.memblock); in thread_func()
999 u->memchunk.index += (size_t) t; in thread_func()
[all …]
/third_party/pulseaudio/src/modules/bluetooth/
Dmodule-bluez5-device.c252 pa_memchunk memchunk; in sco_process_render() local
260 pa_sink_render_full(u->sink, u->write_block_size, &memchunk); in sco_process_render()
262 pa_assert(memchunk.length == u->write_block_size); in sco_process_render()
271 p = (const uint8_t *) pa_memblock_acquire_chunk(&memchunk); in sco_process_render()
272 l = pa_write(u->stream_fd, p, memchunk.length, &u->stream_write_type); in sco_process_render()
273 pa_memblock_release(memchunk.memblock); in sco_process_render()
286 pa_memblock_unref(memchunk.memblock); in sco_process_render()
299 pa_assert((size_t) l <= memchunk.length); in sco_process_render()
301 if ((size_t) l != memchunk.length) { in sco_process_render()
304 (unsigned long long) memchunk.length); in sco_process_render()
[all …]
/third_party/pulseaudio/src/modules/dbus/
Diface-sample.c169 if (!s->sample->memchunk.memblock) { in handle_get_sample_format()
188 if (!s->sample->memchunk.memblock) { in handle_get_sample_rate()
208 if (!s->sample->memchunk.memblock) { in handle_get_channels()
249 if (!s->sample->memchunk.memblock) { in handle_get_duration()
255 duration = pa_bytes_to_usec(s->sample->memchunk.length, &s->sample->sample_spec); in handle_get_duration()
268 if (!s->sample->memchunk.memblock) { in handle_get_bytes()
274 bytes = s->sample->memchunk.length; in handle_get_bytes()
308 if (s->sample->memchunk.memblock) { in handle_get_all()
313 duration = pa_bytes_to_usec(s->sample->memchunk.length, &s->sample->sample_spec); in handle_get_all()
314 bytes = s->sample->memchunk.length; in handle_get_all()
[all …]
/third_party/glib/tests/
Dslice-test.c71 memchunk_free (GMemChunk *memchunk, in memchunk_free() argument
74 old_mem_chunk_free (memchunk, chunk); in memchunk_free()
76 old_mem_chunk_clean (memchunk); in memchunk_free()
/third_party/pulseaudio/src/modules/alsa/
Dalsa-sink.c148 pa_memchunk memchunk; member
877 if (u->memchunk.length <= 0) in unix_write()
878 pa_sink_render(u->sink, n_bytes, &u->memchunk); in unix_write()
880 pa_assert(u->memchunk.length > 0); in unix_write()
882 frames = (snd_pcm_sframes_t) (u->memchunk.length / u->frame_size); in unix_write()
887 p = pa_memblock_acquire(u->memchunk.memblock); in unix_write()
888 …frames = snd_pcm_writei(u->pcm_handle, (const uint8_t*) p + u->memchunk.index, (snd_pcm_uframes_t)… in unix_write()
889 pa_memblock_release(u->memchunk.memblock); in unix_write()
912 u->memchunk.index += written; in unix_write()
913 u->memchunk.length -= written; in unix_write()
[all …]

12