/* PipeWire * * Copyright © 2020 Wim Taymans * * Permission is hereby granted, free of charge, to any person obtaining a * copy of this software and associated documentation files (the "Software"), * to deal in the Software without restriction, including without limitation * the rights to use, copy, modify, merge, publish, distribute, sublicense, * and/or sell copies of the Software, and to permit persons to whom the * Software is furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice (including the next * paragraph) shall be included in all copies or substantial portions of the * Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER * DEALINGS IN THE SOFTWARE. */ #ifndef PULSER_SERVER_STREAM_H #define PULSER_SERVER_STREAM_H #include #include #include #include #include #include "format.h" #include "volume.h" struct impl; struct client; struct spa_io_rate_match; struct buffer_attr { uint32_t maxlength; uint32_t tlength; uint32_t prebuf; uint32_t minreq; uint32_t fragsize; }; enum stream_type { STREAM_TYPE_RECORD, STREAM_TYPE_PLAYBACK, STREAM_TYPE_UPLOAD, }; struct stream { struct spa_list link; uint32_t create_tag; uint32_t channel; /* index in map */ uint32_t id; /* id of global */ uint32_t index; /* index */ uint32_t peer_index; struct impl *impl; struct client *client; enum stream_type type; enum pw_direction direction; struct pw_properties *props; struct pw_stream *stream; struct spa_hook stream_listener; struct spa_io_position *position; struct spa_ringbuffer ring; void *buffer; int64_t read_index; int64_t write_index; uint64_t underrun_for; uint64_t playing_for; uint64_t ticks_base; uint64_t timestamp; uint64_t idle_time; int64_t delay; uint32_t last_quantum; int64_t requested; struct spa_fraction min_req; struct spa_fraction default_req; struct spa_fraction min_frag; struct spa_fraction default_frag; struct spa_fraction default_tlength; struct spa_fraction min_quantum; uint32_t idle_timeout_sec; struct sample_spec ss; struct channel_map map; struct buffer_attr attr; uint32_t frame_size; uint32_t rate; uint64_t lat_usec; struct volume volume; bool muted; uint32_t drain_tag; unsigned int corked:1; unsigned int draining:1; unsigned int volume_set:1; unsigned int muted_set:1; unsigned int early_requests:1; unsigned int adjust_latency:1; unsigned int is_underrun:1; unsigned int in_prebuf:1; unsigned int killed:1; unsigned int pending:1; unsigned int is_idle:1; unsigned int is_paused:1; }; struct stream *stream_new(struct client *client, enum stream_type type, uint32_t create_tag, const struct sample_spec *ss, const struct channel_map *map, const struct buffer_attr *attr); void stream_free(struct stream *stream); void stream_flush(struct stream *stream); uint32_t stream_pop_missing(struct stream *stream); void stream_set_paused(struct stream *stream, bool paused, const char *reason); int stream_send_underflow(struct stream *stream, int64_t offset); int stream_send_overflow(struct stream *stream); int stream_send_killed(struct stream *stream); int stream_send_started(struct stream *stream); int stream_send_request(struct stream *stream); int stream_update_minreq(struct stream *stream, uint32_t minreq); int stream_send_moved(struct stream *stream, uint32_t peer_index, const char *peer_name); #endif /* PULSER_SERVER_STREAM_H */