24 #include <pulse/rtclock.h>
25 #include <pulse/error.h>
36 #define DEFAULT_CODEC_ID AV_NE(AV_CODEC_ID_PCM_S16BE, AV_CODEC_ID_PCM_S16LE)
59 #define CHECK_SUCCESS_GOTO(rerror, expression, label) \
61 if (!(expression)) { \
62 rerror = AVERROR_EXTERNAL; \
67 #define CHECK_DEAD_GOTO(p, rerror, label) \
69 if (!(p)->context || !PA_CONTEXT_IS_GOOD(pa_context_get_state((p)->context)) || \
70 !(p)->stream || !PA_STREAM_IS_GOOD(pa_stream_get_state((p)->stream))) { \
71 rerror = AVERROR_EXTERNAL; \
79 switch (pa_context_get_state(
c)) {
80 case PA_CONTEXT_READY:
81 case PA_CONTEXT_TERMINATED:
82 case PA_CONTEXT_FAILED:
83 pa_threaded_mainloop_signal(p->
mainloop, 0);
91 switch (pa_stream_get_state(
s)) {
93 case PA_STREAM_FAILED:
94 case PA_STREAM_TERMINATED:
95 pa_threaded_mainloop_signal(p->
mainloop, 0);
103 pa_threaded_mainloop_signal(p->
mainloop, 0);
109 pa_threaded_mainloop_signal(p->
mainloop, 0);
117 pa_threaded_mainloop_stop(pd->
mainloop);
120 pa_stream_unref(pd->
stream);
124 pa_context_disconnect(pd->
context);
130 pa_threaded_mainloop_free(pd->
mainloop);
151 pa_buffer_attr attr = { -1 };
153 const pa_buffer_attr *queried_attr;
155 pa_channel_map_init_extend(&cmap, pd->
channels, PA_CHANNEL_MAP_WAVEEX);
166 if (
s->url[0] !=
'\0' && strcmp(
s->url,
"default"))
169 if (!(pd->
mainloop = pa_threaded_mainloop_new())) {
174 if (!(pd->
context = pa_context_new(pa_threaded_mainloop_get_api(pd->
mainloop), pd->
name))) {
186 pa_threaded_mainloop_lock(pd->
mainloop);
188 if (pa_threaded_mainloop_start(pd->
mainloop) < 0) {
190 goto unlock_and_fail;
194 pa_context_state_t
state;
198 if (
state == PA_CONTEXT_READY)
201 if (!PA_CONTEXT_IS_GOOD(
state)) {
203 goto unlock_and_fail;
207 pa_threaded_mainloop_wait(pd->
mainloop);
212 goto unlock_and_fail;
220 ret = pa_stream_connect_record(pd->
stream, device, &attr,
221 PA_STREAM_INTERPOLATE_TIMING
223 |PA_STREAM_AUTO_TIMING_UPDATE);
227 goto unlock_and_fail;
231 pa_stream_state_t
state;
235 if (
state == PA_STREAM_READY)
238 if (!PA_STREAM_IS_GOOD(
state)) {
240 goto unlock_and_fail;
244 pa_threaded_mainloop_wait(pd->
mainloop);
248 queried_attr = pa_stream_get_buffer_attr(pd->
stream);
249 if (!queried_attr || queried_attr->fragsize > INT_MAX/100) {
251 goto unlock_and_fail;
256 pa_threaded_mainloop_unlock(pd->
mainloop);
276 pa_threaded_mainloop_unlock(pd->
mainloop);
293 pa_threaded_mainloop_lock(pd->
mainloop);
297 while (pos < pd->fragment_size) {
303 if (read_length <= 0) {
304 pa_threaded_mainloop_wait(pd->
mainloop);
309 r = pa_stream_drop(pd->
stream);
315 goto unlock_and_fail;
319 pa_operation_unref(pa_stream_update_timing_info(pd->
stream,
NULL,
NULL));
321 if (pa_stream_get_latency(pd->
stream, &latency, &negative) >= 0) {
333 pa_stream_drop(pd->
stream);
336 goto unlock_and_fail;
340 pa_stream_drop(pd->
stream);
344 pa_threaded_mainloop_unlock(pd->
mainloop);
356 pa_threaded_mainloop_unlock(pd->
mainloop);
366 #define OFFSET(a) offsetof(PulseData, a)
367 #define D AV_OPT_FLAG_DECODING_PARAM
376 {
"fragment_size",
"set buffering size, affects latency and cpu usage",
OFFSET(fragment_size),
AV_OPT_TYPE_INT, {.i64 = -1}, -1, INT_MAX,
D },
377 {
"wallclock",
"set the initial pts using the current time",
OFFSET(wallclock),
AV_OPT_TYPE_INT, {.i64 = 1}, -1, 1,
D },
static int read_packet(void *opaque, uint8_t *buf, int buf_size)
#define flags(name, subs,...)
#define ss(width, name, subs,...)
static int read_data(void *opaque, uint8_t *buf, int buf_size)
static int read_header(FFV1Context *f)
AVCodecID
Identify the syntax and semantics of the bitstream.
void av_packet_unref(AVPacket *pkt)
Wipe the packet.
void av_shrink_packet(AVPacket *pkt, int size)
Reduce packet size, correctly zeroing padding.
int av_new_packet(AVPacket *pkt, int size)
Allocate the payload of a packet and initialize its fields with default values.
AVStream * avformat_new_stream(AVFormatContext *s, const AVCodec *c)
Add a new stream to a media file.
#define AVERROR_EXTERNAL
Generic error in an external library.
#define AV_LOG_WARNING
Something somehow does not look correct.
#define AV_LOG_ERROR
Something went wrong and cannot losslessly be recovered.
const char * av_default_item_name(void *ptr)
Return the context name.
#define LIBAVUTIL_VERSION_INT
common internal API header
#define NULL_IF_CONFIG_SMALL(x)
Return NULL if CONFIG_SMALL is true, otherwise the argument without modification.
static av_cold int read_close(AVFormatContext *ctx)
@ AV_CLASS_CATEGORY_DEVICE_AUDIO_INPUT
pa_sample_format_t av_cold ff_codec_id_to_pulse_format(enum AVCodecID codec_id)
int ff_pulse_audio_get_devices(AVDeviceInfoList *devices, const char *server, int output)
static av_cold int pulse_read_header(AVFormatContext *s)
static void stream_state_cb(pa_stream *s, void *userdata)
static av_cold int pulse_close(AVFormatContext *s)
static const AVOption options[]
AVInputFormat ff_pulse_demuxer
#define CHECK_DEAD_GOTO(p, rerror, label)
static void context_state_cb(pa_context *c, void *userdata)
static const AVClass pulse_demuxer_class
static int pulse_get_device_list(AVFormatContext *h, AVDeviceInfoList *device_list)
#define CHECK_SUCCESS_GOTO(rerror, expression, label)
static void stream_request_cb(pa_stream *s, size_t length, void *userdata)
static int pulse_read_packet(AVFormatContext *s, AVPacket *pkt)
static void stream_latency_update_cb(pa_stream *s, void *userdata)
Describe the class of an AVClass context structure.
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
enum AVMediaType codec_type
General type of the encoded data.
enum AVCodecID codec_id
Specific type of the encoded data (the codec used).
int sample_rate
Audio only.
This structure stores compressed data.
int64_t pts
Presentation timestamp in AVStream->time_base units; the time at which the decompressed packet will b...
AVCodecParameters * codecpar
Codec parameters associated with this stream.
pa_threaded_mainloop * mainloop
Opaque type representing a time filter state.
int64_t av_gettime(void)
Get the current time in microseconds.
double ff_timefilter_update(TimeFilter *self, double system_time, double period)
Update the filter.
void ff_timefilter_destroy(TimeFilter *self)
Free all resources associated with the filter.
TimeFilter * ff_timefilter_new(double time_base, double period, double bandwidth)
Create a new Delay Locked Loop time filter.