korg/bluez
0
0
Fork 0
mirror of https://git.kernel.org/pub/scm/bluetooth/bluez.git synced 2025-01-21 11:53:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

android/hal-audio: Add open/close_endpoint helpers

Browse Source
This commit is contained in:
Andrzej Kaczmarek 2014-03-03 09:56:38 +01:00 committed by Szymon Janc
parent c088a0f5c6
commit 4fe71a03e0
1 changed files with 66 additions and 51 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

117
android/hal-audio.c
View File

@ -914,6 +914,70 @@ static void unregister_endpoints(void)
}
}
static int set_blocking(int fd)
{
int flags;
flags = fcntl(fd, F_GETFL, 0);
if (flags < 0) {
int err = -errno;
error("fcntl(F_GETFL): %s (%d)", strerror(-err), -err);
return err;
}
if (fcntl(fd, F_SETFL, flags & ~O_NONBLOCK) < 0) {
int err = -errno;
error("fcntl(F_SETFL): %s (%d)", strerror(-err), -err);
return err;
}
return 0;
}
static bool open_endpoint(struct audio_endpoint *ep,
struct audio_input_config *cfg)
{
struct audio_preset *preset;
const struct audio_codec *codec;
uint16_t mtu;
int fd;
if (ipc_open_stream_cmd(ep->id, &mtu, &fd, &preset) !=
AUDIO_STATUS_SUCCESS)
return false;
if (set_blocking(fd) < 0)
goto failed;
ep->fd = fd;
codec = ep->codec;
codec->init(preset, mtu, &ep->codec_data);
codec->get_config(ep->codec_data, cfg);
free(preset);
return true;
failed:
close(fd);
free(preset);
return false;
}
static void close_endpoint(struct audio_endpoint *ep)
{
ipc_close_stream_cmd(ep->id);
if (ep->fd >= 0) {
close(ep->fd);
ep->fd = -1;
}
ep->codec->cleanup(ep->codec_data);
ep->codec_data = NULL;
}
static void downmix_to_mono(struct a2dp_stream_out *out, const uint8_t *buffer,
size_t bytes)
{
@ -1260,26 +1324,6 @@ static int in_remove_audio_effect(const struct audio_stream *stream,
return -ENOSYS;
}
static int set_blocking(int fd)
{
int flags;
flags = fcntl(fd, F_GETFL, 0);
if (flags < 0) {
int err = -errno;
error("fcntl(F_GETFL): %s (%d)", strerror(-err), -err);
return err;
}
if (fcntl(fd, F_SETFL, flags & ~O_NONBLOCK) < 0) {
int err = -errno;
error("fcntl(F_SETFL): %s (%d)", strerror(-err), -err);
return err;
}
return 0;
}
static int audio_open_output_stream(struct audio_hw_device *dev,
audio_io_handle_t handle,
audio_devices_t devices,
@ -1290,10 +1334,6 @@ static int audio_open_output_stream(struct audio_hw_device *dev,
{
struct a2dp_audio_dev *a2dp_dev = (struct a2dp_audio_dev *) dev;
struct a2dp_stream_out *out;
struct audio_preset *preset;
const struct audio_codec *codec;
uint16_t mtu;
int fd;
out = calloc(1, sizeof(struct a2dp_stream_out));
if (!out)
@ -1321,29 +1361,12 @@ static int audio_open_output_stream(struct audio_hw_device *dev,
/* TODO: for now we always use endpoint 0 */
out->ep = &audio_endpoints[0];
if (ipc_open_stream_cmd(out->ep->id, &mtu, &fd, &preset) !=
AUDIO_STATUS_SUCCESS)
if (!open_endpoint(out->ep, &out->cfg))
goto fail;
if (!preset || fd < 0)
goto fail;
if (set_blocking(fd) < 0) {
free(preset);
goto fail;
}
out->ep->fd = fd;
codec = out->ep->codec;
codec->init(preset, mtu, &out->ep->codec_data);
codec->get_config(out->ep->codec_data, &out->cfg);
DBG("rate=%d channels=%d format=%d", out->cfg.rate,
out->cfg.channels, out->cfg.format);
free(preset);
if (out->cfg.channels == AUDIO_CHANNEL_OUT_MONO) {
out->downmix_buf = malloc(FIXED_BUFFER_SIZE / 2);
if (!out->downmix_buf)
@ -1369,18 +1392,10 @@ static void audio_close_output_stream(struct audio_hw_device *dev,
{
struct a2dp_audio_dev *a2dp_dev = (struct a2dp_audio_dev *) dev;
struct a2dp_stream_out *out = (struct a2dp_stream_out *) stream;
struct audio_endpoint *ep = a2dp_dev->out->ep;
DBG("");
ipc_close_stream_cmd(ep->id);
if (ep->fd >= 0) {
close(ep->fd);
ep->fd = -1;
}
ep->codec->cleanup(ep->codec_data);
ep->codec_data = NULL;
close_endpoint(a2dp_dev->out->ep);
free(out->downmix_buf);