Lines Matching defs:core
52 #include <pulsecore/core-scache.h>
53 #include <pulsecore/core-subscribe.h>
61 #include <pulsecore/core-util.h>
400 *ret = -pa_source_output_new(&source_output, c->protocol->core, &data);
886 *ret = -pa_sink_input_new(&sink_input, c->protocol->core, &data);
1037 c->protocol->core->mainloop->time_free(c->auth_timeout_event);
1898 if (!(sink = pa_idxset_get_by_index(c->protocol->core->sinks, sink_index))) {
1905 if (!(sink = pa_namereg_get(c->protocol->core, sink_name, PA_NAMEREG_SINK))) {
2217 if (!(source = pa_idxset_get_by_index(c->protocol->core->sources, source_index))) {
2224 if (!(source = pa_namereg_get(c->protocol->core, source_name, PA_NAMEREG_SOURCE))) {
2232 if (!(direct_on_input = pa_idxset_get_by_index(c->protocol->core->sink_inputs, direct_on_input_idx))) {
2319 ret = pa_core_exit(c->protocol->core, false, 0);
2361 if (!(c->rw_mempool = pa_mempool_new(shm_type, c->protocol->core->shm_size, true))) {
2376 srb = pa_srbchannel_new(c->protocol->core->mainloop, c->rw_mempool);
2522 c->protocol->core->mainloop->time_free(c->auth_timeout_event);
2529 pa_mempool_is_shared(c->protocol->core->mempool) &&
2560 c->version >= 32 && do_shm && pa_mempool_is_memfd_backed(c->protocol->core->mempool);
2601 if (pa_pstream_register_memfd_mempool(c->pstream, c->protocol->core->mempool, &reason))
2675 if ((sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK)))
2680 if ((source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE)))
2731 stat = pa_mempool_get_stat(c->protocol->core->mempool);
2738 pa_tagstruct_putu32(reply, (uint32_t) pa_scache_total_size(c->protocol->core));
2911 else if (pa_scache_add_item(c->protocol->core, s->name, &s->sample_spec, &s->channel_map, &s->memchunk, s->proplist, &idx) < 0)
2948 sink = pa_idxset_get_by_index(c->protocol->core->sinks, sink_index);
2950 sink = pa_namereg_get(c->protocol->core, sink_name, PA_NAMEREG_SINK);
2965 if (pa_scache_play_item(c->protocol->core, name, sink, volume, p, &idx) < 0) {
2997 if (pa_scache_remove_item(c->protocol->core, name) < 0) {
3426 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx);
3428 sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK);
3431 source = pa_idxset_get_by_index(c->protocol->core->sources, idx);
3433 source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE);
3436 card = pa_idxset_get_by_index(c->protocol->core->cards, idx);
3438 card = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_CARD);
3440 client = pa_idxset_get_by_index(c->protocol->core->clients, idx);
3442 module = pa_idxset_get_by_index(c->protocol->core->modules, idx);
3444 si = pa_idxset_get_by_index(c->protocol->core->sink_inputs, idx);
3446 so = pa_idxset_get_by_index(c->protocol->core->source_outputs, idx);
3450 sce = pa_idxset_get_by_index(c->protocol->core->scache, idx);
3452 sce = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SAMPLE);
3500 i = c->protocol->core->sinks;
3502 i = c->protocol->core->sources;
3504 i = c->protocol->core->clients;
3506 i = c->protocol->core->cards;
3508 i = c->protocol->core->modules;
3510 i = c->protocol->core->sink_inputs;
3512 i = c->protocol->core->source_outputs;
3515 i = c->protocol->core->scache;
3549 pa_core *core;
3573 core = c->protocol->core;
3575 fixup_sample_spec(c, &fixed_ss, &core->default_sample_spec);
3578 pa_tagstruct_puts(reply, core->default_sink ? core->default_sink->name : NULL);
3579 pa_tagstruct_puts(reply, core->default_source ? core->default_source->name : NULL);
3581 pa_tagstruct_putu32(reply, c->protocol->core->cookie);
3584 pa_tagstruct_put_channel_map(reply, &core->default_channel_map);
3589 static void subscription_cb(pa_core *core, pa_subscription_event_type_t e, uint32_t idx, void *userdata) {
3623 c->subscription = pa_subscription_new(c->protocol->core, m, subscription_cb, c);
3669 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx);
3671 sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK);
3676 source = pa_idxset_get_by_index(c->protocol->core->sources, idx);
3678 source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE);
3682 si = pa_idxset_get_by_index(c->protocol->core->sink_inputs, idx);
3686 so = pa_idxset_get_by_index(c->protocol->core->source_outputs, idx);
3764 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx);
3766 sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK);
3772 source = pa_idxset_get_by_index(c->protocol->core->sources, idx);
3774 source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE);
3779 si = pa_idxset_get_by_index(c->protocol->core->sink_inputs, idx);
3783 so = pa_idxset_get_by_index(c->protocol->core->source_outputs, idx);
4219 pa_subscription_post(c->protocol->core, PA_SUBSCRIPTION_EVENT_SINK_INPUT|PA_SUBSCRIPTION_EVENT_CHANGE, s->sink_input->index);
4225 pa_subscription_post(c->protocol->core, PA_SUBSCRIPTION_EVENT_SOURCE_OUTPUT|PA_SUBSCRIPTION_EVENT_CHANGE, s->source_output->index);
4229 pa_subscription_post(c->protocol->core, PA_SUBSCRIPTION_EVENT_CLIENT|PA_SUBSCRIPTION_EVENT_CHANGE, c->client->index);
4253 source = pa_namereg_get(c->protocol->core, s, PA_NAMEREG_SOURCE);
4256 pa_core_set_configured_default_source(c->protocol->core, source->name);
4261 sink = pa_namereg_get(c->protocol->core, s, PA_NAMEREG_SINK);
4264 pa_core_set_configured_default_sink(c->protocol->core, sink->name);
4328 client = pa_idxset_get_by_index(c->protocol->core->clients, idx);
4337 s = pa_idxset_get_by_index(c->protocol->core->sink_inputs, idx);
4347 s = pa_idxset_get_by_index(c->protocol->core->source_outputs, idx);
4378 if (pa_module_load(&m, c->protocol->core, name, argument) < 0) {
4403 m = pa_idxset_get_by_index(c->protocol->core->modules, idx);
4436 si = pa_idxset_get_by_index(c->protocol->core->sink_inputs, idx);
4439 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx_device);
4441 sink = pa_namereg_get(c->protocol->core, name_device, PA_NAMEREG_SINK);
4455 so = pa_idxset_get_by_index(c->protocol->core->source_outputs, idx);
4458 source = pa_idxset_get_by_index(c->protocol->core->sources, idx_device);
4460 source = pa_namereg_get(c->protocol->core, name_device, PA_NAMEREG_SOURCE);
4500 if (pa_sink_suspend_all(c->protocol->core, b, PA_SUSPEND_USER) < 0) {
4508 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx);
4510 sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK);
4530 if (pa_source_suspend_all(c->protocol->core, b, PA_SUSPEND_USER) < 0) {
4539 source = pa_idxset_get_by_index(c->protocol->core->sources, idx);
4541 source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE);
4579 m = pa_idxset_get_by_index(c->protocol->core->modules, idx);
4581 PA_IDXSET_FOREACH(m, c->protocol->core->modules, idx)
4630 ret = pa_message_handler_send_message(c->protocol->core, object_path, message, message_parameters, &response);
4669 card = pa_idxset_get_by_index(c->protocol->core->cards, idx);
4671 card = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_CARD);
4718 sink = pa_idxset_get_by_index(c->protocol->core->sinks, idx);
4720 sink = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SINK);
4734 source = pa_idxset_get_by_index(c->protocol->core->sources, idx);
4736 source = pa_namereg_get(c->protocol->core, name, PA_NAMEREG_SOURCE);
4775 card = pa_idxset_get_by_index(c->protocol->core->cards, idx);
4777 card = pa_namereg_get(c->protocol->core, card_name, PA_NAMEREG_CARD);
4962 u->memchunk.memblock = pa_memblock_new(c->protocol->core->mempool, u->length);
5098 client = pa_client_new(p->core, &data);
5126 c->auth_timeout_event = pa_core_rttime_new(p->core, pa_rtclock_now() + AUTH_TIMEOUT, auth_timeout, c);
5140 c->pstream = pa_pstream_new(p->core->mainloop, io, p->core->mempool);
5148 c->pdispatch = pa_pdispatch_new(p->core->mainloop, true, command_table, PA_COMMAND_MAX);
5186 p->core = c;
5241 pa_assert_se(pa_shared_remove(p->core, "native-protocol") >= 0);