1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
/*
Copyright (C) 2003 Paul Brossier
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
*/
#include "config.h"
#ifdef JACK_SUPPORT
#include <jack/jack.h>
#include "aubio_priv.h"
#include "jackio.h"
/*typedef jack_default_audio_sample_t jack_sample_t; */
/* work with float, never tried in double */
typedef smpl_t jack_sample_t;
/**
* jack device structure
*/
struct _aubio_jack_t {
/** jack client */
jack_client_t *client;
/** jack output ports */
jack_port_t **oports;
/** jack input ports */
jack_port_t **iports;
/** jack input buffer */
jack_sample_t **ibufs;
/** jack output buffer */
jack_sample_t **obufs;
/** jack input channels */
uint_t ichan;
/** jack output channels */
uint_t ochan;
/** jack samplerate (Hz) */
uint_t samplerate;
/** jack processing function */
aubio_process_func_t callback;
};
/* static memory management */
static aubio_jack_t * aubio_jack_alloc(uint_t ichan, uint_t ochan);
static uint_t aubio_jack_free(aubio_jack_t * jack_setup);
/* jack callback functions */
static int aubio_jack_process(jack_nframes_t nframes, void *arg);
static void aubio_jack_shutdown (void *arg);
aubio_jack_t * new_aubio_jack(uint_t ichan, uint_t ochan,
aubio_process_func_t callback) {
aubio_jack_t * jack_setup = aubio_jack_alloc (ichan, ochan);
uint_t i;
char * client_name = "aubio";
char name[64];
/* initial jack client setup */
if ((jack_setup->client = jack_client_new (client_name)) == 0) {
AUBIO_ERR ("jack server not running?\n");
AUBIO_QUIT(AUBIO_FAIL);
}
/* set callbacks */
jack_set_process_callback (jack_setup->client, aubio_jack_process,
(void*) jack_setup);
jack_on_shutdown (jack_setup->client, aubio_jack_shutdown,
(void*) jack_setup);
/* register jack output ports */
for (i = 0; i < ochan; i++)
{
AUBIO_SPRINTF(name, "out_%d", i+1);
AUBIO_MSG("%s\n", name);
if ((jack_setup->oports[i] =
jack_port_register (jack_setup->client, name,
JACK_DEFAULT_AUDIO_TYPE, JackPortIsOutput, 0)) == 0)
{
AUBIO_ERR("failed registering output port \"%s\"!\n", name);
jack_client_close (jack_setup->client);
AUBIO_QUIT(AUBIO_FAIL);
}
}
/* register jack input ports */
for (i = 0; i < ichan; i++)
{
AUBIO_SPRINTF(name, "in_%d", i+1);
AUBIO_MSG("%s\n", name);
if ((jack_setup->iports[i] =
jack_port_register (jack_setup->client, name,
JACK_DEFAULT_AUDIO_TYPE, JackPortIsInput, 0)) == 0)
{
AUBIO_ERR("failed registering input port \"%s\"!\n", name);
jack_client_close (jack_setup->client);
AUBIO_QUIT(AUBIO_FAIL);
}
}
/* set processing callback */
jack_setup->callback = callback;
return jack_setup;
}
uint_t aubio_jack_activate(aubio_jack_t *jack_setup) {
/* get sample rate */
jack_setup->samplerate = jack_get_sample_rate (jack_setup->client);
/* actual jack process activation */
if (jack_activate (jack_setup->client))
{
AUBIO_ERR("jack client activation failed");
return 1;
}
return 0;
}
void aubio_jack_close(aubio_jack_t *jack_setup) {
/* bug : should disconnect all ports first */
jack_client_close(jack_setup->client);
aubio_jack_free(jack_setup);
}
/* memory management */
static aubio_jack_t * aubio_jack_alloc(uint_t ichan, uint_t ochan) {
aubio_jack_t *jack_setup = AUBIO_NEW(aubio_jack_t);
jack_setup->ichan = ichan;
jack_setup->ochan = ochan;
jack_setup->oports = AUBIO_ARRAY(jack_port_t*, ichan);
jack_setup->iports = AUBIO_ARRAY(jack_port_t*, ochan);
jack_setup->ibufs = AUBIO_ARRAY(jack_sample_t*, ichan);
jack_setup->obufs = AUBIO_ARRAY(jack_sample_t*, ochan);
return jack_setup;
}
static uint_t aubio_jack_free(aubio_jack_t * jack_setup) {
AUBIO_FREE(jack_setup->oports);
AUBIO_FREE(jack_setup->iports);
AUBIO_FREE(jack_setup->ibufs );
AUBIO_FREE(jack_setup->obufs );
AUBIO_FREE(jack_setup);
return AUBIO_OK;
}
/* jack callback functions */
static void aubio_jack_shutdown (void *arg UNUSED){
AUBIO_ERR("jack shutdown\n");
AUBIO_QUIT(AUBIO_OK);
}
static int aubio_jack_process(jack_nframes_t nframes, void *arg) {
aubio_jack_t* dev = (aubio_jack_t *)arg;
uint_t i;
for (i=0;i<dev->ichan;i++) {
/* get readable input */
dev->ibufs[i] =
(jack_sample_t *) jack_port_get_buffer (dev->iports[i], nframes);
/* get writable output */
dev->obufs[i] =
(jack_sample_t *) jack_port_get_buffer (dev->oports[i], nframes);
}
dev->callback(dev->ibufs,dev->obufs,nframes);
return 0;
}
#endif /* JACK_SUPPORT */
|
