24 #include <semaphore.h>
25 #include <jack/jack.h>
39 #define FIFO_PACKETS_NUM 16
65 jack_nframes_t latency, cycle_delay;
74 cycle_delay = jack_frames_since_cycle_start(self->client);
78 av_gettime() / 1000000.0 - (
double) cycle_delay / self->sample_rate,
90 pkt_data = (
float *) pkt.
data;
94 for (i = 0; i <
self->nports; i++) {
95 #if HAVE_JACK_PORT_GET_LATENCY_RANGE
96 jack_latency_range_t range;
97 jack_port_get_latency_range(self->ports[i], JackCaptureLatency, &range);
100 latency += jack_port_get_total_latency(self->client, self->ports[i]);
102 buffer = jack_port_get_buffer(self->ports[i], self->buffer_size);
103 for (j = 0; j <
self->buffer_size; j++)
104 pkt_data[j * self->nports + i] = buffer[j];
108 pkt.
pts = (cycle_time - (double) latency / (self->nports * self->sample_rate)) * 1000000.0;
112 sem_post(&self->packet_count);
134 int test, pkt_size =
self->buffer_size *
self->nports *
sizeof(float);
152 jack_status_t status;
157 self->client = jack_client_open(context->
filename, JackNullOption, &status);
163 sem_init(&self->packet_count, 0, 0);
165 self->sample_rate = jack_get_sample_rate(self->client);
166 self->ports =
av_malloc(self->nports *
sizeof(*self->ports));
167 self->buffer_size = jack_get_buffer_size(self->client);
170 for (i = 0; i <
self->nports; i++) {
172 snprintf(str,
sizeof(str),
"input_%d", i + 1);
173 self->ports[i] = jack_port_register(self->client, str,
174 JACK_DEFAULT_AUDIO_TYPE,
176 if (!self->ports[i]) {
179 jack_client_close(self->client);
190 period = (double) self->buffer_size / self->sample_rate;
191 o = 2 * M_PI * 1.5 * period;
192 self->timefilter =
ff_timefilter_new (1.0 / self->sample_rate, sqrt(2 * o), o * o);
199 jack_client_close(self->client);
221 jack_deactivate(self->client);
222 jack_client_close(self->client);
224 sem_destroy(&self->packet_count);
262 struct timespec timeout = {0, 0};
269 if (!self->activated) {
270 if (!jack_activate(self->client)) {
273 "JACK client registered and activated (rate=%dHz, buffer_size=%d frames)\n",
274 self->sample_rate, self->buffer_size);
283 if (sem_timedwait(&self->packet_count, &timeout)) {
284 if (errno == ETIMEDOUT) {
286 "Input error: timed out when waiting for JACK process callback output\n");
297 if (self->pkt_xrun) {
302 if (self->jack_xrun) {
323 #define OFFSET(x) offsetof(JackData, x)
344 .priv_class = &jack_indev_class,