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)
58 #define CHECK_SUCCESS_GOTO(rerror, expression, label) \
60 if (!(expression)) { \
61 rerror = AVERROR_EXTERNAL; \
66 #define CHECK_DEAD_GOTO(p, rerror, label) \
68 if (!(p)->context || !PA_CONTEXT_IS_GOOD(pa_context_get_state((p)->context)) || \
69 !(p)->stream || !PA_STREAM_IS_GOOD(pa_stream_get_state((p)->stream))) { \
70 rerror = AVERROR_EXTERNAL; \
78 switch (pa_context_get_state(c)) {
79 case PA_CONTEXT_READY:
80 case PA_CONTEXT_TERMINATED:
81 case PA_CONTEXT_FAILED:
82 pa_threaded_mainloop_signal(p->
mainloop, 0);
90 switch (pa_stream_get_state(s)) {
92 case PA_STREAM_FAILED:
93 case PA_STREAM_TERMINATED:
94 pa_threaded_mainloop_signal(p->
mainloop, 0);
102 pa_threaded_mainloop_signal(p->
mainloop, 0);
108 pa_threaded_mainloop_signal(p->
mainloop, 0);
116 pa_threaded_mainloop_stop(pd->
mainloop);
119 pa_stream_unref(pd->
stream);
123 pa_context_disconnect(pd->
context);
129 pa_threaded_mainloop_free(pd->
mainloop);
150 pa_buffer_attr attr = { -1 };
164 if (!(pd->
mainloop = pa_threaded_mainloop_new())) {
169 if (!(pd->
context = pa_context_new(pa_threaded_mainloop_get_api(pd->
mainloop), pd->
name))) {
181 pa_threaded_mainloop_lock(pd->
mainloop);
183 if (pa_threaded_mainloop_start(pd->
mainloop) < 0) {
185 goto unlock_and_fail;
189 pa_context_state_t
state;
191 state = pa_context_get_state(pd->
context);
193 if (state == PA_CONTEXT_READY)
196 if (!PA_CONTEXT_IS_GOOD(state)) {
198 goto unlock_and_fail;
202 pa_threaded_mainloop_wait(pd->
mainloop);
207 goto unlock_and_fail;
215 ret = pa_stream_connect_record(pd->
stream, device, &attr,
216 PA_STREAM_INTERPOLATE_TIMING
217 |PA_STREAM_ADJUST_LATENCY
218 |PA_STREAM_AUTO_TIMING_UPDATE);
222 goto unlock_and_fail;
226 pa_stream_state_t
state;
228 state = pa_stream_get_state(pd->
stream);
230 if (state == PA_STREAM_READY)
233 if (!PA_STREAM_IS_GOOD(state)) {
235 goto unlock_and_fail;
239 pa_threaded_mainloop_wait(pd->
mainloop);
242 pa_threaded_mainloop_unlock(pd->
mainloop);
262 pa_threaded_mainloop_unlock(pd->
mainloop);
278 pa_threaded_mainloop_lock(pd->
mainloop);
285 r = pa_stream_peek(pd->
stream, &read_data, &read_length);
288 if (read_length <= 0) {
289 pa_threaded_mainloop_wait(pd->
mainloop);
291 }
else if (!read_data) {
294 r = pa_stream_drop(pd->
stream);
301 goto unlock_and_fail;
305 pa_operation_unref(pa_stream_update_timing_info(pd->
stream,
NULL,
NULL));
307 if (pa_stream_get_latency(pd->
stream, &latency, &negative) >= 0) {
311 int frame_duration = read_length /
frame_size;
326 memcpy(pkt->
data, read_data, read_length);
327 pa_stream_drop(pd->
stream);
329 pa_threaded_mainloop_unlock(pd->
mainloop);
333 pa_threaded_mainloop_unlock(pd->
mainloop);
343 #define OFFSET(a) offsetof(PulseData, a)
344 #define D AV_OPT_FLAG_DECODING_PARAM
351 {
"channels",
"set number of audio channels",
OFFSET(channels),
AV_OPT_TYPE_INT, {.i64 = 2}, 1, INT_MAX,
D },
353 {
"fragment_size",
"set buffering size, affects latency and cpu usage",
OFFSET(fragment_size),
AV_OPT_TYPE_INT, {.i64 = -1}, -1, INT_MAX,
D },
354 {
"wallclock",
"set the initial pts using the current time",
OFFSET(wallclock),
AV_OPT_TYPE_INT, {.i64 = 1}, -1, 1,
D },
375 .priv_class = &pulse_demuxer_class,
void ff_timefilter_destroy(TimeFilter *self)
Free all resources associated with the filter.
#define AV_LOG_WARNING
Something somehow does not look correct.
#define LIBAVUTIL_VERSION_INT
#define CHECK_DEAD_GOTO(p, rerror, label)
static av_cold int pulse_close(AVFormatContext *s)
AVInputFormat ff_pulse_demuxer
static const AVClass pulse_demuxer_class
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
Opaque type representing a time filter state.
AVStream * avformat_new_stream(AVFormatContext *s, const AVCodec *c)
Add a new stream to a media file.
static int read_data(void *opaque, uint8_t *buf, int buf_size)
static av_cold int read_close(AVFormatContext *ctx)
#define CHECK_SUCCESS_GOTO(rerror, expression, label)
int av_new_packet(AVPacket *pkt, int size)
Allocate the payload of a packet and initialize its fields with default values.
AVCodecID
Identify the syntax and semantics of the bitstream.
#define AV_LOG_ERROR
Something went wrong and cannot losslessly be recovered.
int av_get_bits_per_sample(enum AVCodecID codec_id)
Return codec bits per sample.
#define NULL_IF_CONFIG_SMALL(x)
Return NULL if CONFIG_SMALL is true, otherwise the argument without modification. ...
AVCodecContext * codec
Codec context associated with this stream.
common internal API header
char filename[1024]
input or output filename
enum AVCodecID audio_codec_id
Forced audio codec_id.
pa_sample_format_t av_cold ff_codec_id_to_pulse_format(enum AVCodecID codec_id)
static const AVOption options[]
static void stream_request_cb(pa_stream *s, size_t length, void *userdata)
static int read_header(FFV1Context *f)
int64_t av_gettime(void)
Get the current time in microseconds.
static int read_packet(void *opaque, uint8_t *buf, int buf_size)
TimeFilter * ff_timefilter_new(double time_base, double period, double bandwidth)
Create a new Delay Locked Loop time filter.
static void stream_state_cb(pa_stream *s, void *userdata)
enum AVMediaType codec_type
static av_cold int pulse_read_header(AVFormatContext *s)
int sample_rate
samples per second
Describe the class of an AVClass context structure.
int ff_pulse_audio_get_devices(AVDeviceInfoList *devices, const char *server, int output)
static void context_state_cb(pa_context *c, void *userdata)
static int get_device_list(AVOpenCLDeviceList *device_list)
double ff_timefilter_update(TimeFilter *self, double system_time, double period)
Update the filter.
static void stream_latency_update_cb(pa_stream *s, void *userdata)
int channels
number of audio channels
void * priv_data
Format private data.
static int pulse_get_device_list(AVFormatContext *h, AVDeviceInfoList *device_list)
pa_threaded_mainloop * mainloop
static int pulse_read_packet(AVFormatContext *s, AVPacket *pkt)
#define AVERROR_EXTERNAL
Generic error in an external library.
This structure stores compressed data.
int64_t pts
Presentation timestamp in AVStream->time_base units; the time at which the decompressed packet will b...