Lines Matching refs:self
64 JackData *self = arg;
71 if (!self->client)
75 cycle_delay = jack_frames_since_cycle_start(self->client);
78 cycle_time = ff_timefilter_update(self->timefilter,
79 av_gettime() / 1000000.0 - (double) cycle_delay / self->sample_rate,
80 self->buffer_size);
83 if ((av_fifo_size(self->new_pkts) < sizeof(pkt)) || (av_fifo_space(self->filled_pkts) < sizeof(pkt))) {
84 self->pkt_xrun = 1;
89 av_fifo_generic_read(self->new_pkts, &pkt, sizeof(pkt), NULL);
95 for (i = 0; i < self->nports; i++) {
98 jack_port_get_latency_range(self->ports[i], JackCaptureLatency, &range);
101 latency += jack_port_get_total_latency(self->client, self->ports[i]);
103 buffer = jack_port_get_buffer(self->ports[i], self->buffer_size);
104 for (j = 0; j < self->buffer_size; j++)
105 pkt_data[j * self->nports + i] = buffer[j];
109 pkt.pts = (cycle_time - (double) latency / (self->nports * self->sample_rate)) * 1000000.0;
112 av_fifo_generic_write(self->filled_pkts, &pkt, sizeof(pkt), NULL);
113 sem_post(&self->packet_count);
120 JackData *self = arg;
121 self->client = NULL;
126 JackData *self = arg;
127 self->jack_xrun = 1;
128 ff_timefilter_reset(self->timefilter);
132 static int supply_new_packets(JackData *self, AVFormatContext *context)
135 int test, pkt_size = self->buffer_size * self->nports * sizeof(float);
140 while (av_fifo_space(self->new_pkts) >= sizeof(pkt)) {
145 av_fifo_generic_write(self->new_pkts, &pkt, sizeof(pkt), NULL);
152 JackData *self = context->priv_data;
157 self->client = jack_client_open(context->filename, JackNullOption, &status);
158 if (!self->client) {
163 sem_init(&self->packet_count, 0, 0);
165 self->sample_rate = jack_get_sample_rate(self->client);
166 self->ports = av_malloc_array(self->nports, sizeof(*self->ports));
167 self->buffer_size = jack_get_buffer_size(self->client);
170 for (i = 0; i < self->nports; i++) {
173 self->ports[i] = jack_port_register(self->client, str,
176 if (!self->ports[i]) {
179 jack_client_close(self->client);
185 jack_set_process_callback(self->client, process_callback, self);
186 jack_on_shutdown(self->client, shutdown_callback, self);
187 jack_set_xrun_callback(self->client, xrun_callback, self);
190 self->timefilter = ff_timefilter_new (1.0 / self->sample_rate, self->buffer_size, 1.5);
191 if (!self->timefilter) {
192 jack_client_close(self->client);
197 self->filled_pkts = av_fifo_alloc_array(FIFO_PACKETS_NUM, sizeof(AVPacket));
199 self->new_pkts = av_fifo_alloc_array((FIFO_PACKETS_NUM + 1), sizeof(AVPacket));
200 if ((test = supply_new_packets(self, context))) {
201 jack_client_close(self->client);
219 static void stop_jack(JackData *self)
221 if (self->client) {
222 if (self->activated)
223 jack_deactivate(self->client);
224 jack_client_close(self->client);
226 sem_destroy(&self->packet_count);
227 free_pkt_fifo(&self->new_pkts);
228 free_pkt_fifo(&self->filled_pkts);
229 av_freep(&self->ports);
230 ff_timefilter_destroy(self->timefilter);
235 JackData *self = context->priv_data;
244 stop_jack(self);
254 stream->codec->sample_rate = self->sample_rate;
255 stream->codec->channels = self->nports;
263 JackData *self = context->priv_data;
271 if (!self->activated) {
272 if (!jack_activate(self->client)) {
273 self->activated = 1;
276 self->sample_rate, self->buffer_size);
285 if (sem_timedwait(&self->packet_count, &timeout)) {
293 if (!self->client)
299 if (self->pkt_xrun) {
301 self->pkt_xrun = 0;
304 if (self->jack_xrun) {
306 self->jack_xrun = 0;
310 av_fifo_generic_read(self->filled_pkts, pkt, sizeof(*pkt), NULL);
312 if ((test = supply_new_packets(self, context)))
320 JackData *self = context->priv_data;
321 stop_jack(self);