]> sigrok.org Git - libsigrok.git/blame - hardware/alsa/api.c
Add sr_dev_open()/sr_dev_close()
[libsigrok.git] / hardware / alsa / api.c
CommitLineData
6ed4f044 1/*
6944b2d0 2 * This file is part of the libsigrok project.
6ed4f044
DR
3 *
4 * Copyright (C) 2011 Daniel Ribeiro <drwyrm@gmail.com>
0254651d 5 * Copyright (C) 2012 Uwe Hermann <uwe@hermann-uwe.de>
6944b2d0 6 * Copyright (C) 2012 Alexandru Gagniuc <mr.nuke.me@gmail.com>
6ed4f044
DR
7 *
8 * This program is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation; either version 2 of the License, or
11 * (at your option) any later version.
12 *
13 * This program is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 * GNU General Public License for more details.
17 *
18 * You should have received a copy of the GNU General Public License
19 * along with this program; if not, write to the Free Software
20 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
21 */
22
9cd9f6b7
AG
23#include <stdlib.h>
24#include <unistd.h>
25#include <string.h>
721ecf3d
UH
26#include "libsigrok.h"
27#include "libsigrok-internal.h"
28#include "protocol.h"
472bbb46 29
aa0dbd68 30static const int32_t hwcaps[] = {
1953564a
BV
31 SR_CONF_SAMPLERATE,
32 SR_CONF_LIMIT_SAMPLES,
33 SR_CONF_CONTINUOUS,
6ed4f044
DR
34};
35
0254651d
UH
36SR_PRIV struct sr_dev_driver alsa_driver_info;
37static struct sr_dev_driver *di = &alsa_driver_info;
6ed4f044 38
0254651d
UH
39static int clear_instances(void)
40{
6944b2d0
AG
41 struct drv_context *drvc;
42
43 if (!(drvc = di->priv))
44 return SR_OK;
45
46 g_slist_free_full(drvc->instances, (GDestroyNotify)alsa_dev_inst_clear);
47 drvc->instances = NULL;
0254651d
UH
48
49 return SR_OK;
50}
51
34f06b90 52static int hw_init(struct sr_context *sr_ctx)
6ed4f044 53{
063e7aef 54 return std_hw_init(sr_ctx, di, DRIVER_LOG_DOMAIN);
0254651d
UH
55}
56
57static GSList *hw_scan(GSList *options)
58{
6944b2d0 59 return alsa_scan(options, di);
6ed4f044
DR
60}
61
0254651d 62static GSList *hw_dev_list(void)
6ed4f044 63{
0e94d524 64 return ((struct drv_context *)(di->priv))->instances;
0254651d
UH
65}
66
67static int hw_dev_open(struct sr_dev_inst *sdi)
68{
69 struct dev_context *devc;
ebc34738 70 int ret;
6ed4f044 71
0254651d 72 devc = sdi->priv;
6ed4f044 73
6944b2d0
AG
74 if (!(devc->hwdev)) {
75 sr_err("devc->hwdev was NULL.");
76 return SR_ERR_BUG;
77 }
78
79 sr_dbg("Opening audio device '%s' for stream capture.", devc->hwdev);
80 ret = snd_pcm_open(&devc->capture_handle, devc->hwdev,
ea9cfed7 81 SND_PCM_STREAM_CAPTURE, 0);
ebc34738 82 if (ret < 0) {
0254651d 83 sr_err("Can't open audio device: %s.", snd_strerror(ret));
e46b8fb1 84 return SR_ERR;
6ed4f044
DR
85 }
86
0254651d
UH
87 sr_dbg("Initializing hardware parameter structure.");
88 ret = snd_pcm_hw_params_any(devc->capture_handle, devc->hw_params);
ebc34738 89 if (ret < 0) {
0254651d 90 sr_err("Can't initialize hardware parameter structure: %s.",
472bbb46 91 snd_strerror(ret));
e46b8fb1 92 return SR_ERR;
6ed4f044
DR
93 }
94
e46b8fb1 95 return SR_OK;
6ed4f044
DR
96}
97
0254651d 98static int hw_dev_close(struct sr_dev_inst *sdi)
6ed4f044 99{
0254651d
UH
100 int ret;
101 struct dev_context *devc;
6ed4f044 102
0254651d
UH
103 devc = sdi->priv;
104
0254651d
UH
105 if (devc->capture_handle) {
106 sr_dbg("Closing PCM device.");
107 if ((ret = snd_pcm_close(devc->capture_handle)) < 0) {
108 sr_err("Failed to close device: %s.",
109 snd_strerror(ret));
6944b2d0 110 devc->capture_handle = NULL;
0254651d
UH
111 }
112 } else {
113 sr_dbg("No capture handle, no need to close audio device.");
114 }
697785d1
UH
115
116 return SR_OK;
6ed4f044
DR
117}
118
57ab7d9f 119static int hw_cleanup(void)
6ed4f044 120{
0254651d 121 clear_instances();
57ab7d9f
UH
122
123 return SR_OK;
6ed4f044
DR
124}
125
aa0dbd68 126static int config_get(int id, GVariant **data, const struct sr_dev_inst *sdi)
6ed4f044 127{
0254651d 128 struct dev_context *devc;
6ed4f044 129
035a1078 130 switch (id) {
123e1313 131 case SR_CONF_SAMPLERATE:
9a6517d1 132 devc = sdi->priv;
aa0dbd68 133 *data = g_variant_new_uint64(devc->cur_samplerate);
6ed4f044 134 break;
0254651d 135 default:
bd6fbf62 136 return SR_ERR_NA;
6ed4f044
DR
137 }
138
0254651d 139 return SR_OK;
6ed4f044
DR
140}
141
aa0dbd68 142static int config_set(int id, GVariant *data, const struct sr_dev_inst *sdi)
6ed4f044 143{
0254651d 144 struct dev_context *devc;
6ed4f044 145
0254651d 146 devc = sdi->priv;
6ed4f044 147
035a1078 148 switch (id) {
1953564a 149 case SR_CONF_SAMPLERATE:
aa0dbd68 150 alsa_set_samplerate(sdi, g_variant_get_uint64(data));
0254651d 151 break;
1953564a 152 case SR_CONF_LIMIT_SAMPLES:
aa0dbd68 153 devc->limit_samples = g_variant_get_uint64(data);
0254651d 154 break;
6ed4f044 155 default:
bd6fbf62 156 return SR_ERR_NA;
6ed4f044 157 }
0254651d
UH
158
159 return SR_OK;
6ed4f044
DR
160}
161
aa0dbd68 162static int config_list(int key, GVariant **data, const struct sr_dev_inst *sdi)
a1c743fc
BV
163{
164 struct dev_context *devc;
aa0dbd68
BV
165 GVariant *gvar;
166 GVariantBuilder gvb;
167 int i;
a1c743fc
BV
168
169 (void)sdi;
170
171 switch (key) {
9a6517d1 172 case SR_CONF_DEVICE_OPTIONS:
aa0dbd68
BV
173 *data = g_variant_new_fixed_array(G_VARIANT_TYPE_INT32,
174 hwcaps, ARRAY_SIZE(hwcaps), sizeof(int32_t));
9a6517d1 175 break;
a1c743fc
BV
176 case SR_CONF_SAMPLERATE:
177 if (!sdi || !sdi->priv)
178 return SR_ERR_ARG;
179 devc = sdi->priv;
aa0dbd68 180 if (!devc->samplerates) {
a1c743fc
BV
181 sr_err("Instance did not contain a samplerate list.");
182 return SR_ERR_ARG;
183 }
aa0dbd68
BV
184 for (i = 0; devc->samplerates[i]; i++)
185 ;
186 g_variant_builder_init(&gvb, G_VARIANT_TYPE("a{sv}"));
187 gvar = g_variant_new_fixed_array(G_VARIANT_TYPE("t"),
188 devc->samplerates, i, sizeof(uint64_t));
189 g_variant_builder_add(&gvb, "{sv}", "samplerates", gvar);
190 *data = g_variant_builder_end(&gvb);
a1c743fc
BV
191 break;
192 default:
bd6fbf62 193 return SR_ERR_NA;
a1c743fc
BV
194 }
195
196 return SR_OK;
197}
198
0254651d
UH
199static int hw_dev_acquisition_start(const struct sr_dev_inst *sdi,
200 void *cb_data)
6ed4f044 201{
0254651d
UH
202 struct dev_context *devc;
203 int count, ret;
721ecf3d 204 char *endianness;
6ed4f044 205
0254651d
UH
206 devc = sdi->priv;
207 devc->cb_data = cb_data;
729850c9 208 devc->num_samples = 0;
6ed4f044 209
0254651d
UH
210 sr_dbg("Setting audio access type to RW/interleaved.");
211 ret = snd_pcm_hw_params_set_access(devc->capture_handle,
212 devc->hw_params, SND_PCM_ACCESS_RW_INTERLEAVED);
ebc34738 213 if (ret < 0) {
0254651d 214 sr_err("Can't set audio access type: %s.", snd_strerror(ret));
e46b8fb1 215 return SR_ERR;
6ed4f044
DR
216 }
217
0254651d 218 /* FIXME: Hardcoded for 16bits. */
729850c9 219 if (SND_PCM_FORMAT_S16 == SND_PCM_FORMAT_S16_LE)
721ecf3d 220 endianness = "little endian";
729850c9 221 else
721ecf3d
UH
222 endianness = "big endian";
223 sr_dbg("Setting audio sample format to signed 16bit (%s).", endianness);
0254651d 224 ret = snd_pcm_hw_params_set_format(devc->capture_handle,
729850c9
AG
225 devc->hw_params,
226 SND_PCM_FORMAT_S16);
ebc34738 227 if (ret < 0) {
0254651d 228 sr_err("Can't set audio sample format: %s.", snd_strerror(ret));
e46b8fb1 229 return SR_ERR;
6ed4f044
DR
230 }
231
0254651d
UH
232 sr_dbg("Setting audio samplerate to %" PRIu64 "Hz.",
233 devc->cur_samplerate);
0d6ff103
AG
234 ret = snd_pcm_hw_params_set_rate(devc->capture_handle, devc->hw_params,
235 (unsigned int)devc->cur_samplerate, 0);
ebc34738 236 if (ret < 0) {
0254651d 237 sr_err("Can't set audio sample rate: %s.", snd_strerror(ret));
e46b8fb1 238 return SR_ERR;
6ed4f044
DR
239 }
240
9cd9f6b7 241 sr_dbg("Setting audio channel count to %d.", devc->num_probes);
0254651d 242 ret = snd_pcm_hw_params_set_channels(devc->capture_handle,
9cd9f6b7 243 devc->hw_params, devc->num_probes);
ebc34738 244 if (ret < 0) {
0254651d 245 sr_err("Can't set channel count: %s.", snd_strerror(ret));
e46b8fb1 246 return SR_ERR;
6ed4f044
DR
247 }
248
0254651d
UH
249 sr_dbg("Setting audio parameters.");
250 ret = snd_pcm_hw_params(devc->capture_handle, devc->hw_params);
ebc34738 251 if (ret < 0) {
0254651d 252 sr_err("Can't set parameters: %s.", snd_strerror(ret));
e46b8fb1 253 return SR_ERR;
6ed4f044
DR
254 }
255
0254651d
UH
256 sr_dbg("Preparing audio interface for use.");
257 ret = snd_pcm_prepare(devc->capture_handle);
ebc34738 258 if (ret < 0) {
0254651d 259 sr_err("Can't prepare audio interface for use: %s.",
ebc34738 260 snd_strerror(ret));
e46b8fb1 261 return SR_ERR;
6ed4f044
DR
262 }
263
0254651d 264 count = snd_pcm_poll_descriptors_count(devc->capture_handle);
6ed4f044 265 if (count < 1) {
472bbb46 266 sr_err("Unable to obtain poll descriptors count.");
e46b8fb1 267 return SR_ERR;
6ed4f044
DR
268 }
269
0254651d
UH
270 if (!(devc->ufds = g_try_malloc(count * sizeof(struct pollfd)))) {
271 sr_err("Failed to malloc ufds.");
e46b8fb1 272 return SR_ERR_MALLOC;
92b3101c 273 }
6ed4f044 274
3d6de074 275 sr_spew("Getting %d poll descriptors.", count);
0254651d 276 ret = snd_pcm_poll_descriptors(devc->capture_handle, devc->ufds, count);
ebc34738 277 if (ret < 0) {
0254651d 278 sr_err("Unable to obtain poll descriptors: %s.",
ebc34738 279 snd_strerror(ret));
0254651d 280 g_free(devc->ufds);
e46b8fb1 281 return SR_ERR;
6ed4f044
DR
282 }
283
0254651d 284 /* Send header packet to the session bus. */
4afdfd46 285 std_session_send_df_header(cb_data, DRIVER_LOG_DOMAIN);
0254651d 286
0254651d
UH
287 /* Poll every 10ms, or whenever some data comes in. */
288 sr_source_add(devc->ufds[0].fd, devc->ufds[0].events, 10,
9cd9f6b7 289 alsa_receive_data, (void *)sdi);
0254651d
UH
290
291 // g_free(devc->ufds); /* FIXME */
6ed4f044 292
e46b8fb1 293 return SR_OK;
6ed4f044
DR
294}
295
0254651d 296static int hw_dev_acquisition_stop(struct sr_dev_inst *sdi, void *cb_data)
6ed4f044 297{
0254651d
UH
298 struct sr_datafeed_packet packet;
299 struct dev_context *devc;
300
301 devc = sdi->priv;
302 devc->cb_data = cb_data;
303
304 sr_source_remove(devc->ufds[0].fd);
305
306 /* Send end packet to the session bus. */
307 sr_dbg("Sending SR_DF_END packet.");
308 packet.type = SR_DF_END;
309 sr_session_send(cb_data, &packet);
3010f21c
UH
310
311 return SR_OK;
6ed4f044
DR
312}
313
c09f0b57 314SR_PRIV struct sr_dev_driver alsa_driver_info = {
e519ba86
UH
315 .name = "alsa",
316 .longname = "ALSA driver",
317 .api_version = 1,
318 .init = hw_init,
319 .cleanup = hw_cleanup,
0254651d
UH
320 .scan = hw_scan,
321 .dev_list = hw_dev_list,
322 .dev_clear = clear_instances,
035a1078
BV
323 .config_get = config_get,
324 .config_set = config_set,
a1c743fc 325 .config_list = config_list,
e7eb703f
UH
326 .dev_open = hw_dev_open,
327 .dev_close = hw_dev_close,
69040b7c
UH
328 .dev_acquisition_start = hw_dev_acquisition_start,
329 .dev_acquisition_stop = hw_dev_acquisition_stop,
0254651d 330 .priv = NULL,
6ed4f044 331};