Return-Path: From: Lukasz Rymanowski To: CC: , , , Lukasz Rymanowski Subject: [PATCH 2/2] android/audio: Add listener thread on the Audio HAL socket Date: Wed, 8 Jan 2014 14:37:09 +0100 Message-ID: <1389188229-3977-2-git-send-email-lukasz.rymanowski@tieto.com> In-Reply-To: <1389188229-3977-1-git-send-email-lukasz.rymanowski@tieto.com> References: <1389188229-3977-1-git-send-email-lukasz.rymanowski@tieto.com> MIME-Version: 1.0 Content-Type: text/plain Sender: linux-bluetooth-owner@vger.kernel.org List-ID: This patch add thread which is reponsible for listen on audio HAL socket and later open a2dp endpoint(s) and maintain socket. When bluetooth daemon goes down, HAL audio plugin starts to listen on Audio HAL socket again. --- android/Makefile.am | 5 ++- android/hal-audio.c | 126 +++++++++++++++++++++++++++++++++++++++++++++++++++- 2 files changed, 129 insertions(+), 2 deletions(-) diff --git a/android/Makefile.am b/android/Makefile.am index 8810369..88ffa7f 100644 --- a/android/Makefile.am +++ b/android/Makefile.am @@ -112,7 +112,8 @@ android_android_tester_LDFLAGS = -pthread noinst_LTLIBRARIES += android/libaudio-internal.la -android_libaudio_internal_la_SOURCES = android/hal-audio.c \ +android_libaudio_internal_la_SOURCES = androdid/audio-msg.h \ + android/hal-audio.c \ android/hardware/audio.h \ android/hardware/audio_effect.h \ android/hardware/hardware.h \ @@ -120,6 +121,8 @@ android_libaudio_internal_la_SOURCES = android/hal-audio.c \ android_libaudio_internal_la_CFLAGS = -I$(srcdir)/android +android_libaudio_internal_la_LDFLAGS = -pthread + endif EXTRA_DIST += android/Android.mk android/hal-ipc-api.txt android/README \ diff --git a/android/hal-audio.c b/android/hal-audio.c index bb68648..c3d3bf4 100644 --- a/android/hal-audio.c +++ b/android/hal-audio.c @@ -16,15 +16,28 @@ */ #include +#include +#include #include #include #include +#include +#include +#include #include #include +#include "audio-msg.h" #include "hal-log.h" +static int audio_sk = -1; +static bool close_thread; + +static pthread_t bt_watcher_th = 0; +static pthread_mutex_t sk_mutex = PTHREAD_MUTEX_INITIALIZER; +static pthread_mutex_t close_mutex = PTHREAD_MUTEX_INITIALIZER; + struct a2dp_stream_out { struct audio_stream_out stream; }; @@ -391,15 +404,117 @@ static int audio_dump(const audio_hw_device_t *device, int fd) static int audio_close(hw_device_t *device) { + struct a2dp_audio_dev *a2dp_dev = (struct a2dp_audio_dev *)device; + DBG(""); - free(device); + + pthread_mutex_lock(&close_mutex); + shutdown(audio_sk, SHUT_RDWR); + close_thread = true; + pthread_mutex_unlock(&close_mutex); + + (void) pthread_join(bt_watcher_th, NULL); + + free(a2dp_dev); return 0; } +static bool create_audio_ipc(void) +{ + struct sockaddr_un addr; + int err; + int sk; + + DBG(""); + + sk = socket(PF_LOCAL, SOCK_SEQPACKET, 0); + if (sk < 0) { + err = errno; + error("Failed to create socket: %d (%s)", err, strerror(err)); + return false; + } + + memset(&addr, 0, sizeof(addr)); + addr.sun_family = AF_UNIX; + + memcpy(addr.sun_path, BLUEZ_AUDIO_SK_PATH, + sizeof(BLUEZ_AUDIO_SK_PATH)); + + if (bind(sk, (struct sockaddr *) &addr, sizeof(addr)) < 0) { + err = errno; + error("Failed to bind socket: %d (%s)", err, strerror(err)); + goto error; + } + + if (listen(sk, 1) < 0) { + err = errno; + error("Failed to bind socket: %d (%s)", err, strerror(err)); + goto error; + } + + audio_sk = accept(sk, NULL, NULL); + if (audio_sk < 0) { + err = errno; + error("Failed to accept socket: %d (%s)", err, strerror(err)); + goto error; + } + + close(sk); + return true; + +error: + close(sk); + return false; +} + +static void *bluetoothd_watcher_thread(void *data) +{ + bool done = false; + struct a2dp_audio_dev *a2dp_dev = (struct a2dp_audio_dev *)data; + struct pollfd pfd; + + DBG(""); + + close_thread = false; + + while (!done) { + if(!create_audio_ipc()) { + error("Failed to create listening socket"); + continue; + } + + DBG("Audio IPC: Connected"); + + /* TODO: Register ENDPOINT here */ + + memset(&pfd, 0, sizeof(pfd)); + pfd.fd = audio_sk; + pfd.events = POLLHUP | POLLERR | POLLNVAL; + + /* Check if socket is still alive */ + while (poll(&pfd, 1, -1) < 0 && errno == EINTR); + + if (pfd.revents & (POLLHUP | POLLERR | POLLNVAL)) { + info("Audio HAL: Socket closed"); + audio_sk = -1; + } + + /*Check if audio_dev is closed */ + pthread_mutex_lock(&close_mutex); + done = close_thread; + pthread_mutex_unlock(&close_mutex); + } + + info("Closing bluetooth_watcher thread"); + pthread_exit(NULL); + return NULL; +} + static int audio_open(const hw_module_t *module, const char *name, hw_device_t **device) { struct a2dp_audio_dev *a2dp_dev; + int err; DBG(""); @@ -437,6 +552,15 @@ static int audio_open(const hw_module_t *module, const char *name, * audio_hw_device. We will rely on this later in the code.*/ *device = &a2dp_dev->dev.common; + err = pthread_create(&bt_watcher_th, NULL, bluetoothd_watcher_thread, + NULL); + if (err < 0) { + bt_watcher_th = 0; + error("Failed to start bluetoothd watcher thread: %d (%s)", + -err, strerror(-err)); + return (-err); + } + return 0; } -- 1.8.4