24 #include <pulse/rtclock.h>
25 #include <pulse/error.h>
33 #define DEFAULT_CODEC_ID AV_NE(AV_CODEC_ID_PCM_S16BE, AV_CODEC_ID_PCM_S16LE)
55 #define CHECK_SUCCESS_GOTO(rerror, expression, label) \
57 if (!(expression)) { \
58 rerror = AVERROR_EXTERNAL; \
63 #define CHECK_DEAD_GOTO(p, rerror, label) \
65 if (!(p)->context || !PA_CONTEXT_IS_GOOD(pa_context_get_state((p)->context)) || \
66 !(p)->stream || !PA_STREAM_IS_GOOD(pa_stream_get_state((p)->stream))) { \
67 rerror = AVERROR_EXTERNAL; \
75 switch (pa_context_get_state(c)) {
76 case PA_CONTEXT_READY:
77 case PA_CONTEXT_TERMINATED:
78 case PA_CONTEXT_FAILED:
79 pa_threaded_mainloop_signal(p->
mainloop, 0);
87 switch (pa_stream_get_state(s)) {
89 case PA_STREAM_FAILED:
90 case PA_STREAM_TERMINATED:
91 pa_threaded_mainloop_signal(p->
mainloop, 0);
99 pa_threaded_mainloop_signal(p->
mainloop, 0);
105 pa_threaded_mainloop_signal(p->
mainloop, 0);
113 pa_threaded_mainloop_stop(pd->
mainloop);
116 pa_stream_unref(pd->
stream);
120 pa_context_disconnect(pd->
context);
126 pa_threaded_mainloop_free(pd->
mainloop);
147 pa_buffer_attr attr = { -1 };
161 if (!(pd->
mainloop = pa_threaded_mainloop_new())) {
166 if (!(pd->
context = pa_context_new(pa_threaded_mainloop_get_api(pd->
mainloop), pd->
name))) {
178 pa_threaded_mainloop_lock(pd->
mainloop);
180 if (pa_threaded_mainloop_start(pd->
mainloop) < 0) {
182 goto unlock_and_fail;
186 pa_context_state_t
state;
188 state = pa_context_get_state(pd->
context);
190 if (state == PA_CONTEXT_READY)
193 if (!PA_CONTEXT_IS_GOOD(state)) {
195 goto unlock_and_fail;
199 pa_threaded_mainloop_wait(pd->
mainloop);
204 goto unlock_and_fail;
212 ret = pa_stream_connect_record(pd->
stream, device, &attr,
213 PA_STREAM_INTERPOLATE_TIMING
214 |PA_STREAM_ADJUST_LATENCY
215 |PA_STREAM_AUTO_TIMING_UPDATE);
219 goto unlock_and_fail;
223 pa_stream_state_t
state;
225 state = pa_stream_get_state(pd->
stream);
227 if (state == PA_STREAM_READY)
230 if (!PA_STREAM_IS_GOOD(state)) {
232 goto unlock_and_fail;
236 pa_threaded_mainloop_wait(pd->
mainloop);
239 pa_threaded_mainloop_unlock(pd->
mainloop);
259 pa_threaded_mainloop_unlock(pd->
mainloop);
275 pa_threaded_mainloop_lock(pd->
mainloop);
282 r = pa_stream_peek(pd->
stream, &read_data, &read_length);
285 if (read_length <= 0) {
286 pa_threaded_mainloop_wait(pd->
mainloop);
288 }
else if (!read_data) {
291 r = pa_stream_drop(pd->
stream);
298 goto unlock_and_fail;
302 pa_operation_unref(pa_stream_update_timing_info(pd->
stream,
NULL,
NULL));
304 if (pa_stream_get_latency(pd->
stream, &latency, &negative) >= 0) {
308 int frame_duration = read_length /
frame_size;
323 memcpy(pkt->
data, read_data, read_length);
324 pa_stream_drop(pd->
stream);
326 pa_threaded_mainloop_unlock(pd->
mainloop);
330 pa_threaded_mainloop_unlock(pd->
mainloop);
340 #define OFFSET(a) offsetof(PulseData, a)
341 #define D AV_OPT_FLAG_DECODING_PARAM
348 {
"channels",
"set number of audio channels",
OFFSET(channels),
AV_OPT_TYPE_INT, {.i64 = 2}, 1, INT_MAX,
D },
350 {
"fragment_size",
"set buffering size, affects latency and cpu usage",
OFFSET(fragment_size),
AV_OPT_TYPE_INT, {.i64 = -1}, -1, INT_MAX,
D },
351 {
"wallclock",
"set the initial pts using the current time",
OFFSET(wallclock),
AV_OPT_TYPE_INT, {.i64 = 1}, -1, 1,
D },
372 .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.
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...