Lines Matching refs:pstream
184 pa_pstream *pstream; member
379 if (!pa_pstream_is_pending(s->connection->pstream)) in record_stream_process_msg()
627 pa_pstream_send_tagstruct(r->connection->pstream, t); in record_stream_send_killed()
644 pa_pstream_send_error(s->connection->pstream, s->drain_tag, PA_ERR_NOENTITY); in playback_stream_unlink()
689 pa_pstream_send_tagstruct(s->connection->pstream, t); in playback_stream_process_msg()
711 pa_pstream_send_tagstruct(s->connection->pstream, t); in playback_stream_process_msg()
723 pa_pstream_send_tagstruct(s->connection->pstream, t); in playback_stream_process_msg()
737 pa_pstream_send_tagstruct(s->connection->pstream, t); in playback_stream_process_msg()
743 pa_pstream_send_simple_ack(s->connection->pstream, PA_PTR_TO_UINT(userdata)); in playback_stream_process_msg()
762 pa_pstream_send_tagstruct(s->connection->pstream, t); in playback_stream_process_msg()
1150 pa_pstream_send_tagstruct(p->connection->pstream, t); in playback_stream_send_killed()
1164 pa_pstream_send_revoke(c->pstream, PA_PTR_TO_UINT(userdata)); in native_connection_process_msg()
1168 pa_pstream_send_release(c->pstream, PA_PTR_TO_UINT(userdata)); in native_connection_process_msg()
1205 if (c->pstream) in native_connection_unlink()
1206 pa_pstream_unlink(c->pstream); in native_connection_unlink()
1230 pa_pstream_unref(c->pstream); in native_connection_free()
1262 pa_pstream_send_memblock(c->pstream, r->index, 0, PA_SEEK_RELATIVE, &schunk); in native_connection_send_memblock()
1617 pa_pstream_send_tagstruct(s->connection->pstream, t); in sink_input_send_event_cb()
1645 pa_pstream_send_tagstruct(s->connection->pstream, t); in sink_input_suspend_cb()
1683 pa_pstream_send_tagstruct(s->connection->pstream, t); in sink_input_moving_cb()
1763 pa_pstream_send_tagstruct(s->connection->pstream, t); in source_output_send_event_cb()
1791 pa_pstream_send_tagstruct(s->connection->pstream, t); in source_output_suspend_cb()
1828 pa_pstream_send_tagstruct(s->connection->pstream, t); in source_output_moving_cb()
1838 #define CHECK_VALIDITY(pstream, expression, tag, error) do { \ argument
1840 pa_pstream_send_error((pstream), (tag), (error)); \
1845 #define CHECK_VALIDITY_GOTO(pstream, expression, tag, error, label) do { \ argument
1847 pa_pstream_send_error((pstream), (tag), (error)); \
1923 CHECK_VALIDITY_GOTO(c->pstream, c->authorized, tag, PA_ERR_ACCESS, finish); in command_create_playback_stream()
1924 …CHECK_VALIDITY_GOTO(c->pstream, !sink_name || pa_namereg_is_valid_name_or_wildcard(sink_name, PA_N… in command_create_playback_stream()
1925 …CHECK_VALIDITY_GOTO(c->pstream, sink_index == PA_INVALID_INDEX || !sink_name, tag, PA_ERR_INVALID,… in command_create_playback_stream()
1926 …CHECK_VALIDITY_GOTO(c->pstream, !sink_name || sink_index == PA_INVALID_INDEX, tag, PA_ERR_INVALID,… in command_create_playback_stream()
1927 CHECK_VALIDITY_GOTO(c->pstream, pa_cvolume_valid(&volume), tag, PA_ERR_INVALID, finish); in command_create_playback_stream()
2020 CHECK_VALIDITY_GOTO(c->pstream, pa_sample_spec_valid(&ss), tag, PA_ERR_INVALID, finish); in command_create_playback_stream()
2021 …CHECK_VALIDITY_GOTO(c->pstream, map.channels == ss.channels && volume.channels == ss.channels, tag… in command_create_playback_stream()
2022 CHECK_VALIDITY_GOTO(c->pstream, pa_channel_map_valid(&map), tag, PA_ERR_INVALID, finish); in command_create_playback_stream()
2025 … CHECK_VALIDITY_GOTO(c->pstream, pa_format_info_valid(format), tag, PA_ERR_INVALID, finish); in command_create_playback_stream()
2037 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_create_playback_stream()
2044 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_create_playback_stream()
2070 CHECK_VALIDITY_GOTO(c->pstream, s, tag, ret, finish); in command_create_playback_stream()
2119 pa_pstream_send_tagstruct(c->pstream, reply); in command_create_playback_stream()
2141 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_delete_stream()
2148 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_delete_stream()
2159 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_delete_stream()
2171 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_delete_stream()
2183 pa_pstream_send_simple_ack(c->pstream, tag); in command_delete_stream()
2245 CHECK_VALIDITY_GOTO(c->pstream, c->authorized, tag, PA_ERR_ACCESS, finish); in command_create_record_stream()
2246 …CHECK_VALIDITY_GOTO(c->pstream, !source_name || pa_namereg_is_valid_name_or_wildcard(source_name, … in command_create_record_stream()
2247 …CHECK_VALIDITY_GOTO(c->pstream, source_index == PA_INVALID_INDEX || !source_name, tag, PA_ERR_INVA… in command_create_record_stream()
2248 …CHECK_VALIDITY_GOTO(c->pstream, !source_name || source_index == PA_INVALID_INDEX, tag, PA_ERR_INVA… in command_create_record_stream()
2334 CHECK_VALIDITY_GOTO(c->pstream, pa_cvolume_valid(&volume), tag, PA_ERR_INVALID, finish); in command_create_record_stream()
2338 CHECK_VALIDITY_GOTO(c->pstream, pa_sample_spec_valid(&ss), tag, PA_ERR_INVALID, finish); in command_create_record_stream()
2339 CHECK_VALIDITY_GOTO(c->pstream, map.channels == ss.channels, tag, PA_ERR_INVALID, finish); in command_create_record_stream()
2340 …CHECK_VALIDITY_GOTO(c->pstream, c->version < 22 || (volume.channels == ss.channels), tag, PA_ERR_I… in command_create_record_stream()
2341 CHECK_VALIDITY_GOTO(c->pstream, pa_channel_map_valid(&map), tag, PA_ERR_INVALID, finish); in command_create_record_stream()
2344 … CHECK_VALIDITY_GOTO(c->pstream, pa_format_info_valid(format), tag, PA_ERR_INVALID, finish); in command_create_record_stream()
2356 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_create_record_stream()
2363 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_create_record_stream()
2371 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_create_record_stream()
2393 CHECK_VALIDITY_GOTO(c->pstream, s, tag, ret, finish); in command_create_record_stream()
2435 pa_pstream_send_tagstruct(c->pstream, reply); in command_create_record_stream()
2456 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_exit()
2458 CHECK_VALIDITY(c->pstream, ret >= 0, tag, PA_ERR_ACCESS); in command_exit()
2462 pa_pstream_send_simple_ack(c->pstream, tag); /* nonsense */ in command_exit()
2487 if (!pa_pstream_get_shm(c->pstream)) { in setup_srbchannel()
2506 if (pa_pstream_register_memfd_mempool(c->pstream, c->rw_mempool, &reason)) { in setup_srbchannel()
2527 pa_pstream_send_tagstruct_with_fds(c->pstream, t, 2, fdlist, false); in setup_srbchannel()
2533 pa_pstream_send_memblock(c->pstream, 0, 0, 0, &mc); in setup_srbchannel()
2554 pa_pstream_set_srbchannel(c->pstream, c->srbpending); in command_enable_srbchannel()
2578 pa_pstream_send_error(c->pstream, tag, PA_ERR_VERSION); in command_auth()
2645 pa_pstream_send_error(c->pstream, tag, PA_ERR_ACCESS); in command_auth()
2680 pa_pstream_enable_shm(c->pstream, do_shm); in command_auth()
2694 pa_pstream_enable_memfd(c->pstream); in command_auth()
2716 pa_pstream_send_tagstruct_with_creds(c->pstream, reply, &ucred); in command_auth()
2719 pa_pstream_send_tagstruct(c->pstream, reply); in command_auth()
2730 if (pa_pstream_register_memfd_mempool(c->pstream, c->protocol->core->mempool, &reason)) in command_auth()
2743 if (pa_common_command_register_memfd_shmid(c->pstream, pd, c->version, command, t)) in command_register_memfd_shmid()
2769 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID); in command_set_client_name()
2782 pa_pstream_send_tagstruct(c->pstream, reply); in command_set_client_name()
2799 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_lookup()
2800 …CHECK_VALIDITY(c->pstream, name && pa_namereg_is_valid_name_or_wildcard(name, command == PA_COMMAN… in command_lookup()
2814 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_lookup()
2819 pa_pstream_send_tagstruct(c->pstream, reply); in command_lookup()
2837 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_drain_playback_stream()
2839 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_drain_playback_stream()
2840 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY); in command_drain_playback_stream()
2858 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_stat()
2868 pa_pstream_send_tagstruct(c->pstream, reply); in command_stat()
2888 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_get_playback_latency()
2890 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_get_playback_latency()
2891 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY); in command_get_playback_latency()
2915 pa_pstream_send_tagstruct(c->pstream, reply); in command_get_playback_latency()
2935 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_get_record_latency()
2937 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_get_record_latency()
2954 pa_pstream_send_tagstruct(c->pstream, reply); in command_get_record_latency()
2978 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_create_upload_stream()
2979 CHECK_VALIDITY(c->pstream, pa_sample_spec_valid(&ss), tag, PA_ERR_INVALID); in command_create_upload_stream()
2980 CHECK_VALIDITY(c->pstream, pa_channel_map_valid(&map), tag, PA_ERR_INVALID); in command_create_upload_stream()
2981 CHECK_VALIDITY(c->pstream, map.channels == ss.channels, tag, PA_ERR_INVALID); in command_create_upload_stream()
2982 … CHECK_VALIDITY(c->pstream, (length % pa_frame_size(&ss)) == 0 && length > 0, tag, PA_ERR_INVALID); in command_create_upload_stream()
2983 CHECK_VALIDITY(c->pstream, length <= PA_SCACHE_ENTRY_SIZE_MAX, tag, PA_ERR_TOOLARGE); in command_create_upload_stream()
3003 CHECK_VALIDITY(c->pstream, false, tag, PA_ERR_INVALID); in command_create_upload_stream()
3009 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_INVALID); in command_create_upload_stream()
3014 pa_pstream_send_tagstruct(c->pstream, reply); in command_create_upload_stream()
3032 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_finish_upload_stream()
3035 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_finish_upload_stream()
3036 CHECK_VALIDITY(c->pstream, upload_stream_isinstance(s), tag, PA_ERR_NOENTITY); in command_finish_upload_stream()
3039 pa_pstream_send_error(c->pstream, tag, PA_ERR_TOOLARGE); in command_finish_upload_stream()
3041 pa_pstream_send_error(c->pstream, tag, PA_ERR_INTERNAL); in command_finish_upload_stream()
3043 pa_pstream_send_simple_ack(c->pstream, tag); in command_finish_upload_stream()
3061 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_play_sample()
3071 …CHECK_VALIDITY(c->pstream, !sink_name || pa_namereg_is_valid_name_or_wildcard(sink_name, PA_NAMERE… in command_play_sample()
3072 CHECK_VALIDITY(c->pstream, sink_index == PA_INVALID_INDEX || !sink_name, tag, PA_ERR_INVALID); in command_play_sample()
3073 CHECK_VALIDITY(c->pstream, !sink_name || sink_index == PA_INVALID_INDEX, tag, PA_ERR_INVALID); in command_play_sample()
3074 CHECK_VALIDITY(c->pstream, name && pa_namereg_is_valid_name(name), tag, PA_ERR_INVALID); in command_play_sample()
3081 CHECK_VALIDITY(c->pstream, sink, tag, PA_ERR_NOENTITY); in command_play_sample()
3095 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_play_sample()
3107 pa_pstream_send_tagstruct(c->pstream, reply); in command_play_sample()
3123 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_remove_sample()
3124 CHECK_VALIDITY(c->pstream, name && pa_namereg_is_valid_name(name), tag, PA_ERR_INVALID); in command_remove_sample()
3127 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_remove_sample()
3131 pa_pstream_send_simple_ack(c->pstream, tag); in command_remove_sample()
3541 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_get_info()
3542 CHECK_VALIDITY(c->pstream, !name || in command_get_info()
3548 CHECK_VALIDITY(c->pstream, command == PA_COMMAND_GET_SINK_INFO || in command_get_info()
3551 CHECK_VALIDITY(c->pstream, idx == PA_INVALID_INDEX || !name, tag, PA_ERR_INVALID); in command_get_info()
3585 pa_pstream_send_error(c->pstream, tag, PA_ERR_NOENTITY); in command_get_info()
3606 pa_pstream_send_tagstruct(c->pstream, reply); in command_get_info()
3624 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_get_info_list()
3670 pa_pstream_send_tagstruct(c->pstream, reply); in command_get_info_list()
3688 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_get_server_info()
3715 pa_pstream_send_tagstruct(c->pstream, reply); in command_get_server_info()
3729 pa_pstream_send_tagstruct(c->pstream, t); in subscription_cb()
3745 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_subscribe()
3746 CHECK_VALIDITY(c->pstream, (m & ~PA_SUBSCRIPTION_MASK_ALL) == 0, tag, PA_ERR_INVALID); in command_subscribe()
3757 pa_pstream_send_simple_ack(c->pstream, tag); in command_subscribe()
3789 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_set_volume()
3790 …CHECK_VALIDITY(c->pstream, !name || pa_namereg_is_valid_name_or_wildcard(name, command == PA_COMMA… in command_set_volume()
3791 CHECK_VALIDITY(c->pstream, (idx != PA_INVALID_INDEX) ^ (name != NULL), tag, PA_ERR_INVALID); in command_set_volume()
3792 CHECK_VALIDITY(c->pstream, pa_cvolume_valid(&volume), tag, PA_ERR_INVALID); in command_set_volume()
3822 CHECK_VALIDITY(c->pstream, si || so || sink || source, tag, PA_ERR_NOENTITY); in command_set_volume()
3827 …CHECK_VALIDITY(c->pstream, volume.channels == 1 || pa_cvolume_compatible(&volume, &sink->sample_sp… in command_set_volume()
3832 …CHECK_VALIDITY(c->pstream, volume.channels == 1 || pa_cvolume_compatible(&volume, &source->sample_… in command_set_volume()
3837 CHECK_VALIDITY(c->pstream, si->volume_writable, tag, PA_ERR_BADSTATE); in command_set_volume()
3838 …CHECK_VALIDITY(c->pstream, volume.channels == 1 || pa_cvolume_compatible(&volume, &si->sample_spec… in command_set_volume()
3845 CHECK_VALIDITY(c->pstream, so->volume_writable, tag, PA_ERR_BADSTATE); in command_set_volume()
3846 …CHECK_VALIDITY(c->pstream, volume.channels == 1 || pa_cvolume_compatible(&volume, &so->sample_spec… in command_set_volume()
3854 pa_pstream_send_simple_ack(c->pstream, tag); in command_set_volume()
3885 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_set_mute()
3886 …CHECK_VALIDITY(c->pstream, !name || pa_namereg_is_valid_name_or_wildcard(name, command == PA_COMMA… in command_set_mute()
3887 CHECK_VALIDITY(c->pstream, (idx != PA_INVALID_INDEX) ^ (name != NULL), tag, PA_ERR_INVALID); in command_set_mute()
3919 CHECK_VALIDITY(c->pstream, si || so || sink || source, tag, PA_ERR_NOENTITY); in command_set_mute()
3941 pa_pstream_send_simple_ack(c->pstream, tag); in command_set_mute()
3960 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_cork_playback_stream()
3961 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX, tag, PA_ERR_INVALID); in command_cork_playback_stream()
3963 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_cork_playback_stream()
3964 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY); in command_cork_playback_stream()
3971 pa_pstream_send_simple_ack(c->pstream, tag); in command_cork_playback_stream()
3988 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_trigger_or_flush_or_prebuf_playback_stream()
3989 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX, tag, PA_ERR_INVALID); in command_trigger_or_flush_or_prebuf_playback_stream()
3991 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_trigger_or_flush_or_prebuf_playback_stream()
3992 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY); in command_trigger_or_flush_or_prebuf_playback_stream()
4011 pa_pstream_send_simple_ack(c->pstream, tag); in command_trigger_or_flush_or_prebuf_playback_stream()
4030 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_cork_record_stream()
4032 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_cork_record_stream()
4036 pa_pstream_send_simple_ack(c->pstream, tag); in command_cork_record_stream()
4053 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_flush_record_stream()
4055 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_flush_record_stream()
4058 pa_pstream_send_simple_ack(c->pstream, tag); in command_flush_record_stream()
4077 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_set_stream_buffer_attr()
4084 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_set_stream_buffer_attr()
4085 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY); in command_set_stream_buffer_attr()
4123 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_set_stream_buffer_attr()
4154 pa_pstream_send_tagstruct(c->pstream, reply); in command_set_stream_buffer_attr()
4172 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_update_stream_sample_rate()
4173 CHECK_VALIDITY(c->pstream, pa_sample_rate_valid(rate), tag, PA_ERR_INVALID); in command_update_stream_sample_rate()
4179 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_update_stream_sample_rate()
4180 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY); in command_update_stream_sample_rate()
4189 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_update_stream_sample_rate()
4194 pa_pstream_send_simple_ack(c->pstream, tag); in command_update_stream_sample_rate()
4206 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_update_proplist()
4234 CHECK_VALIDITY(c->pstream, false, tag, PA_ERR_INVALID); in command_update_proplist()
4243 CHECK_VALIDITY(c->pstream, false, tag, PA_ERR_NOENTITY); in command_update_proplist()
4252 CHECK_VALIDITY(c->pstream, false, tag, PA_ERR_NOENTITY); in command_update_proplist()
4262 pa_pstream_send_simple_ack(c->pstream, tag); in command_update_proplist()
4276 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_remove_proplist()
4290 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_remove_proplist()
4291 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY); in command_remove_proplist()
4299 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_remove_proplist()
4341 pa_pstream_send_simple_ack(c->pstream, tag); in command_remove_proplist()
4376 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_set_default_sink_or_source()
4377 CHECK_VALIDITY(c->pstream, !s || pa_namereg_is_valid_name(s), tag, PA_ERR_INVALID); in command_set_default_sink_or_source()
4383 CHECK_VALIDITY(c->pstream, source, tag, PA_ERR_NOENTITY); in command_set_default_sink_or_source()
4391 CHECK_VALIDITY(c->pstream, sink, tag, PA_ERR_NOENTITY); in command_set_default_sink_or_source()
4396 pa_pstream_send_simple_ack(c->pstream, tag); in command_set_default_sink_or_source()
4414 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_set_stream_name()
4415 CHECK_VALIDITY(c->pstream, name && pa_utf8_valid(name), tag, PA_ERR_INVALID); in command_set_stream_name()
4421 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_set_stream_name()
4422 CHECK_VALIDITY(c->pstream, playback_stream_isinstance(s), tag, PA_ERR_NOENTITY); in command_set_stream_name()
4431 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_set_stream_name()
4436 pa_pstream_send_simple_ack(c->pstream, tag); in command_set_stream_name()
4452 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_kill()
4458 CHECK_VALIDITY(c->pstream, client, tag, PA_ERR_NOENTITY); in command_kill()
4467 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_kill()
4477 CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY); in command_kill()
4483 pa_pstream_send_simple_ack(c->pstream, tag); in command_kill()
4503 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_load_module()
4504 …CHECK_VALIDITY(c->pstream, name && *name && pa_utf8_valid(name) && !strchr(name, '/'), tag, PA_ERR… in command_load_module()
4505 CHECK_VALIDITY(c->pstream, !argument || pa_utf8_valid(argument), tag, PA_ERR_INVALID); in command_load_module()
4508 pa_pstream_send_error(c->pstream, tag, PA_ERR_MODINITFAILED); in command_load_module()
4514 pa_pstream_send_tagstruct(c->pstream, reply); in command_load_module()
4531 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_unload_module()
4533 CHECK_VALIDITY(c->pstream, m, tag, PA_ERR_NOENTITY); in command_unload_module()
4536 pa_pstream_send_simple_ack(c->pstream, tag); in command_unload_module()
4555 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_move_stream()
4556 CHECK_VALIDITY(c->pstream, idx != PA_INVALID_INDEX, tag, PA_ERR_INVALID); in command_move_stream()
4558 …CHECK_VALIDITY(c->pstream, !name_device || pa_namereg_is_valid_name_or_wildcard(name_device, comma… in command_move_stream()
4559 …CHECK_VALIDITY(c->pstream, (idx_device != PA_INVALID_INDEX) ^ (name_device != NULL), tag, PA_ERR_I… in command_move_stream()
4572 CHECK_VALIDITY(c->pstream, si && sink, tag, PA_ERR_NOENTITY); in command_move_stream()
4575 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID); in command_move_stream()
4591 CHECK_VALIDITY(c->pstream, so && source, tag, PA_ERR_NOENTITY); in command_move_stream()
4594 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID); in command_move_stream()
4599 pa_pstream_send_simple_ack(c->pstream, tag); in command_move_stream()
4619 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_suspend()
4620 …CHECK_VALIDITY(c->pstream, !name || pa_namereg_is_valid_name_or_wildcard(name, command == PA_COMMA… in command_suspend()
4621 CHECK_VALIDITY(c->pstream, (idx != PA_INVALID_INDEX) ^ (name != NULL), tag, PA_ERR_INVALID); in command_suspend()
4630 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID); in command_suspend()
4641 CHECK_VALIDITY(c->pstream, sink, tag, PA_ERR_NOENTITY); in command_suspend()
4647 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID); in command_suspend()
4660 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID); in command_suspend()
4672 CHECK_VALIDITY(c->pstream, source, tag, PA_ERR_NOENTITY); in command_suspend()
4678 pa_pstream_send_error(c->pstream, tag, PA_ERR_INVALID); in command_suspend()
4684 pa_pstream_send_simple_ack(c->pstream, tag); in command_suspend()
4703 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_extension()
4704 CHECK_VALIDITY(c->pstream, !name || pa_utf8_valid(name), tag, PA_ERR_INVALID); in command_extension()
4705 CHECK_VALIDITY(c->pstream, (idx != PA_INVALID_INDEX) ^ (name != NULL), tag, PA_ERR_INVALID); in command_extension()
4714 CHECK_VALIDITY(c->pstream, m, tag, PA_ERR_NOEXTENSION); in command_extension()
4715 CHECK_VALIDITY(c->pstream, m->load_once || idx != PA_INVALID_INDEX, tag, PA_ERR_INVALID); in command_extension()
4718 CHECK_VALIDITY(c->pstream, cb, tag, PA_ERR_NOEXTENSION); in command_extension()
4743 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_set_card_profile()
4744 CHECK_VALIDITY(c->pstream, !name || pa_namereg_is_valid_name(name), tag, PA_ERR_INVALID); in command_set_card_profile()
4745 CHECK_VALIDITY(c->pstream, (idx != PA_INVALID_INDEX) ^ (name != NULL), tag, PA_ERR_INVALID); in command_set_card_profile()
4746 CHECK_VALIDITY(c->pstream, profile_name, tag, PA_ERR_INVALID); in command_set_card_profile()
4753 CHECK_VALIDITY(c->pstream, card, tag, PA_ERR_NOENTITY); in command_set_card_profile()
4757 CHECK_VALIDITY(c->pstream, profile, tag, PA_ERR_NOENTITY); in command_set_card_profile()
4765 pa_pstream_send_error(c->pstream, tag, -ret); in command_set_card_profile()
4769 pa_pstream_send_simple_ack(c->pstream, tag); in command_set_card_profile()
4789 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_set_sink_or_source_port()
4790 …CHECK_VALIDITY(c->pstream, !name || pa_namereg_is_valid_name_or_wildcard(name, command == PA_COMMA… in command_set_sink_or_source_port()
4791 CHECK_VALIDITY(c->pstream, (idx != PA_INVALID_INDEX) ^ (name != NULL), tag, PA_ERR_INVALID); in command_set_sink_or_source_port()
4792 CHECK_VALIDITY(c->pstream, port, tag, PA_ERR_INVALID); in command_set_sink_or_source_port()
4802 CHECK_VALIDITY(c->pstream, sink, tag, PA_ERR_NOENTITY); in command_set_sink_or_source_port()
4805 pa_pstream_send_error(c->pstream, tag, -ret); in command_set_sink_or_source_port()
4818 CHECK_VALIDITY(c->pstream, source, tag, PA_ERR_NOENTITY); in command_set_sink_or_source_port()
4821 pa_pstream_send_error(c->pstream, tag, -ret); in command_set_sink_or_source_port()
4826 pa_pstream_send_simple_ack(c->pstream, tag); in command_set_sink_or_source_port()
4849 CHECK_VALIDITY(c->pstream, c->authorized, tag, PA_ERR_ACCESS); in command_set_port_latency_offset()
4850 …CHECK_VALIDITY(c->pstream, !card_name || pa_namereg_is_valid_name(card_name), tag, PA_ERR_INVALID); in command_set_port_latency_offset()
4851 … CHECK_VALIDITY(c->pstream, (idx != PA_INVALID_INDEX) ^ (card_name != NULL), tag, PA_ERR_INVALID); in command_set_port_latency_offset()
4852 CHECK_VALIDITY(c->pstream, port_name, tag, PA_ERR_INVALID); in command_set_port_latency_offset()
4859 CHECK_VALIDITY(c->pstream, card, tag, PA_ERR_NOENTITY); in command_set_port_latency_offset()
4862 CHECK_VALIDITY(c->pstream, port, tag, PA_ERR_NOENTITY); in command_set_port_latency_offset()
4866 pa_pstream_send_simple_ack(c->pstream, tag); in command_set_port_latency_offset()
5136 pa_pstream_send_tagstruct(c->pstream, t); in client_send_event_cb()
5218 c->pstream = pa_pstream_new(p->core->mainloop, io, p->core->mempool); in pa_native_protocol_connect()
5219 pa_pstream_set_receive_packet_callback(c->pstream, pstream_packet_callback, c); in pa_native_protocol_connect()
5220 pa_pstream_set_receive_memblock_callback(c->pstream, pstream_memblock_callback, c); in pa_native_protocol_connect()
5221 pa_pstream_set_die_callback(c->pstream, pstream_die_callback, c); in pa_native_protocol_connect()
5222 pa_pstream_set_drain_callback(c->pstream, pstream_drain_callback, c); in pa_native_protocol_connect()
5223 pa_pstream_set_revoke_callback(c->pstream, pstream_revoke_callback, c); in pa_native_protocol_connect()
5224 pa_pstream_set_release_callback(c->pstream, pstream_release_callback, c); in pa_native_protocol_connect()
5507 return c->pstream; in pa_native_connection_get_pstream()