audio: Add new Audio daemon process

 - Add new audio daemon process.
 - Pupose of this daemon is to monitor and report changes ADSP
   processor state to audio framework/Audio flinger.
 - Specific sysfs node file on device indicates ADSP processor
   state as ONLINE or OFFLINE

Change-Id: Ibad54ea93cbb4fbc59ba599c76541c1f255d4c48

4 files changed, 393 insertions, 0 deletions

diff --git a/audiod/Android.mk b/audiod/Android.mk
new file mode 100644
index 00000000..8f25125e
--- /dev/null
+++ b/audiod/Android.mk
@@ -0,0 +1,24 @@
+LOCAL_PATH:= $(call my-dir)
+
+include $(CLEAR_VARS)
+include external/stlport/libstlport.mk
+
+LOCAL_SRC_FILES:= \
+	audiod_main.cpp \
+	AudioDaemon.cpp \
+
+LOCAL_CFLAGS += -DGL_GLEXT_PROTOTYPES -DEGL_EGLEXT_PROTOTYPES
+
+LOCAL_SHARED_LIBRARIES := \
+	libcutils \
+	libutils \
+	libbinder \
+	libmedia \
+	libstlport
+
+LOCAL_ADDITIONAL_DEPENDENCIES += $(TARGET_OUT_INTERMEDIATES)/KERNEL_OBJ/usr
+
+LOCAL_MODULE:= audiod
+LOCAL_MODULE_TAGS:= debug
+
+include $(BUILD_EXECUTABLE)
diff --git a/audiod/AudioDaemon.cpp b/audiod/AudioDaemon.cpp
new file mode 100644
index 00000000..6c8d9912
--- /dev/null
+++ b/audiod/AudioDaemon.cpp
@@ -0,0 +1,242 @@
+/* AudioDaemon.cpp
+Copyright (c) 2012-2013, The Linux Foundation. All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are
+met:
+    * Redistributions of source code must retain the above copyright
+      notice, this list of conditions and the following disclaimer.
+    * Redistributions in binary form must reproduce the above
+      copyright notice, this list of conditions and the following
+      disclaimer in the documentation and/or other materials provided
+      with the distribution.
+    * Neither the name of The Linux Foundation nor the names of its
+      contributors may be used to endorse or promote products derived
+      from this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
+WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
+MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
+ARE DISCLAIMED.  IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
+BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
+BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
+WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
+OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
+IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.*/
+
+#define LOG_TAG "AudioDaemon"
+#define LOG_NDEBUG 0
+#define LOG_NDDEBUG 0
+
+#include <media/AudioSystem.h>
+#include <sys/poll.h>
+
+#include "AudioDaemon.h"
+
+int bootup_complete = 0;
+
+namespace android {
+
+    AudioDaemon::AudioDaemon() : Thread(false) {
+    }
+
+    AudioDaemon::~AudioDaemon() {
+        putStateFDs(mSndCardFd);
+    }
+
+    void AudioDaemon::onFirstRef() {
+        ALOGV("Start audiod daemon");
+        run("AudioDaemon", PRIORITY_AUDIO);
+    }
+
+    void AudioDaemon::binderDied(const wp<IBinder>& who)
+    {
+        requestExit();
+    }
+
+    bool AudioDaemon::getStateFDs(std::vector<std::pair<int,int> > &sndcardFdPair)
+    {
+        FILE *fp;
+        int fd;
+        char *ptr, *saveptr;
+        char buffer[128];
+        int line = 0;
+        String8 path;
+        int sndcard;
+        const char* cards = "/proc/asound/cards";
+
+        if ((fp = fopen(cards, "r")) == NULL) {
+            ALOGE("Cannot open %s file to get list of sound cars", cards);
+            return false;
+        }
+
+        sndcardFdPair.clear();
+        memset(buffer, 0x0, sizeof(buffer));
+        while ((fgets(buffer, sizeof(buffer), fp) != NULL)) {
+            if (line % 2)
+                continue;
+            ptr = strtok_r(buffer, " [", &saveptr);
+            if (ptr) {
+                path = "/proc/asound/card";
+                path += ptr;
+                path += "/state";
+                ALOGD("Opening sound card state : %s", path.string());
+                fd = open(path.string(), O_RDONLY);
+                if (fd == -1) {
+                    ALOGE("Open %s failed : %s", path.string(), strerror(errno));
+                } else {
+                    /* returns vector of pair<sndcard, fd> */
+                    sndcard = atoi(ptr);
+                    sndcardFdPair.push_back(std::make_pair(sndcard, fd));
+                }
+            }
+            line++;
+        }
+
+        ALOGV("%s: %d sound cards detected", __func__, sndcardFdPair.size());
+        fclose(fp);
+
+        return sndcardFdPair.size() > 0 ? true : false;
+    }
+
+    void AudioDaemon::putStateFDs(std::vector<std::pair<int,int> > &sndcardFdPair)
+    {
+        unsigned int i;
+        for (i = 0; i < sndcardFdPair.size(); i++)
+            close(sndcardFdPair[i].second);
+        sndcardFdPair.clear();
+    }
+
+    status_t AudioDaemon::readyToRun() {
+
+        ALOGV("readyToRun: open snd card state node files");
+        return NO_ERROR;
+    }
+
+#define MAX_SLEEP_RETRY 100
+#define AUDIO_INIT_SLEEP_WAIT 100 /* 100 ms */
+
+    bool AudioDaemon::threadLoop()
+    {
+        int max = -1;
+        unsigned int i;
+        bool ret = true;
+        snd_card_status cur_state = snd_card_offline;
+        struct pollfd *pfd = NULL;
+        char rd_buf[9];
+        unsigned int sleepRetry = 0;
+        bool audioInitDone = false;
+
+        ALOGV("Start threadLoop()");
+        while (audioInitDone == false && sleepRetry < MAX_SLEEP_RETRY) {
+            if (mSndCardFd.empty() && !getStateFDs(mSndCardFd)) {
+                ALOGE("Sleeping for 100 ms");
+                usleep(AUDIO_INIT_SLEEP_WAIT*1000);
+                sleepRetry++;
+            } else {
+                audioInitDone = true;
+            }
+        }
+
+        if (audioInitDone == false)
+            ALOGE("Sound Card is empty!!!");
+
+        pfd = new pollfd[mSndCardFd.size()];
+        bzero(pfd, sizeof(*pfd) * mSndCardFd.size());
+        for (i = 0; i < mSndCardFd.size(); i++) {
+            pfd[i].fd = mSndCardFd[i].second;
+            pfd[i].events = POLLPRI;
+        }
+
+       ALOGD("read for sound card state change before while");
+       for (i = 0; i < mSndCardFd.size(); i++) {
+           if (!read(pfd[i].fd, (void *)rd_buf, 8)) {
+               ALOGE("Error receiving sound card state event (%s)", strerror(errno));
+               ret = false;
+           } else {
+               rd_buf[8] = '\0';
+               ALOGD("sound card state file content: %s before while",rd_buf);
+               lseek(pfd[i].fd, 0, SEEK_SET);
+
+               if (strstr(rd_buf, "OFFLINE")) {
+                   ALOGE("put cur_state to offline");
+                   cur_state = snd_card_offline;
+               } else if (strstr(rd_buf, "ONLINE")){
+                   ALOGE("put cur_state to online");
+                   cur_state = snd_card_online;
+               } else {
+                   ALOGE("ERROR rd_buf %s", rd_buf);
+               }
+
+               ALOGD("cur_state=%d, bootup_complete=%d", cur_state, cur_state );
+               if (cur_state == snd_card_online && !bootup_complete) {
+                   bootup_complete = 1;
+                   ALOGE("sound card up is deteced before while");
+                   ALOGE("bootup_complete set to 1");
+               }
+           }
+       }
+
+        while (1) {
+           ALOGD("poll() for sound card state change ");
+           if (poll(pfd, mSndCardFd.size(), -1) < 0) {
+              ALOGE("poll() failed (%s)", strerror(errno));
+              ret = false;
+              break;
+           }
+
+           ALOGD("out of poll() for sound card state change, SNDCARD size=%d", mSndCardFd.size());
+           for (i = 0; i < mSndCardFd.size(); i++) {
+               if (pfd[i].revents & POLLPRI) {
+                   if (!read(pfd[i].fd, (void *)rd_buf, 8)) {
+                       ALOGE("Error receiving sound card state event (%s)", strerror(errno));
+                       ret = false;
+                   } else {
+                       rd_buf[8] = '\0';
+                       ALOGV("sound card state file content: %s, bootup_complete=%d",rd_buf, bootup_complete);
+                       lseek(pfd[i].fd, 0, SEEK_SET);
+
+                       if (strstr(rd_buf, "OFFLINE")) {
+                           cur_state = snd_card_offline;
+                       } else if (strstr(rd_buf, "ONLINE")){
+                           cur_state = snd_card_online;
+                       }
+
+                       if (bootup_complete) {
+                           ALOGV("bootup_complete, so NofityAudioSystem");
+                           notifyAudioSystem(mSndCardFd[i].first, cur_state);
+                       }
+
+                       if (cur_state == snd_card_online && !bootup_complete) {
+                           bootup_complete = 1;
+                       }
+                   }
+               }
+           }
+       }
+
+       putStateFDs(mSndCardFd);
+       delete [] pfd;
+
+       ALOGV("Exiting Poll ThreadLoop");
+       return ret;
+    }
+
+    void AudioDaemon::notifyAudioSystem(int snd_card, snd_card_status status) {
+
+        String8 str;
+        char buf[4] = {0,};
+
+        str = "SND_CARD_STATUS=";
+        snprintf(buf, sizeof(buf), "%d", snd_card);
+        str += buf;
+        if (status == snd_card_online)
+            str += ",ONLINE";
+        else
+            str += ",OFFLINE";
+        ALOGV("%s: notifyAudioSystem : %s", __func__, str.string());
+        AudioSystem::setParameters(0, str);
+    }
+}
diff --git a/audiod/AudioDaemon.h b/audiod/AudioDaemon.h
new file mode 100644
index 00000000..15c0cf1a
--- /dev/null
+++ b/audiod/AudioDaemon.h
@@ -0,0 +1,67 @@
+/* AudioDaemon.h
+
+Copyright (c) 2012-2013, The Linux Foundation. All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are
+met:
+    * Redistributions of source code must retain the above copyright
+      notice, this list of conditions and the following disclaimer.
+    * Redistributions in binary form must reproduce the above
+      copyright notice, this list of conditions and the following
+      disclaimer in the documentation and/or other materials provided
+      with the distribution.
+    * Neither the name of The Linux Foundation nor the names of its
+      contributors may be used to endorse or promote products derived
+      from this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
+WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
+MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
+ARE DISCLAIMED.  IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
+BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
+BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
+WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
+OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
+IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.*/
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <string.h>
+#include <fcntl.h>
+#include <vector>
+
+#include <utils/threads.h>
+#include <utils/String8.h>
+
+
+namespace android {
+
+enum snd_card_status { snd_card_online, snd_card_offline};
+
+class AudioDaemon:public Thread, public IBinder :: DeathRecipient
+{
+    /*Overrides*/
+    virtual bool        threadLoop();
+    virtual status_t    readyToRun();
+    virtual void        onFirstRef();
+    virtual void        binderDied(const wp < IBinder > &who);
+
+    bool processUeventMessage();
+    void notifyAudioSystem(int snd_card, snd_card_status status);
+    int mUeventSock;
+    bool getStateFDs(std::vector<std::pair<int,int> > &sndcardFdPair);
+    void putStateFDs(std::vector<std::pair<int,int> > &sndcardFdPair);
+
+public:
+    AudioDaemon();
+    virtual ~AudioDaemon();
+
+private:
+    std::vector<std::pair<int,int> > mSndCardFd;
+};
+
+}
diff --git a/audiod/audiod_main.cpp b/audiod/audiod_main.cpp
new file mode 100644
index 00000000..50691fd5
--- /dev/null
+++ b/audiod/audiod_main.cpp
@@ -0,0 +1,60 @@
+/* Copyright (C) 2007 The Android Open Source Project
+
+Copyright (c) 2012-2013, The Linux Foundation. All rights reserved.
+
+Not a Contribution, Apache license notifications and license are retained
+for attribution purposes only.
+
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+#define LOG_TAG "AudioDaemonMain"
+#define LOG_NDEBUG 0
+#define LOG_NDDEBUG 0
+
+#include <cutils/properties.h>
+
+#include <binder/IPCThreadState.h>
+#include <binder/ProcessState.h>
+#include <binder/IServiceManager.h>
+
+#include <utils/Log.h>
+#include <utils/threads.h>
+
+#if defined(HAVE_PTHREADS)
+# include <pthread.h>
+# include <sys/resource.h>
+#endif
+
+#include "AudioDaemon.h"
+
+using namespace android;
+
+// ---------------------------------------------------------------------------
+
+int main(int argc, char** argv)
+{
+#if defined(HAVE_PTHREADS)
+    setpriority(PRIO_PROCESS, 0, ANDROID_PRIORITY_AUDIO);
+#endif
+
+
+    ALOGV("Audio daemon starting sequence..");
+    sp<ProcessState> proc(ProcessState::self());
+    ProcessState::self()->startThreadPool();
+
+    sp<AudioDaemon> audioService = new AudioDaemon();
+    IPCThreadState::self()->joinThreadPool();
+
+    return 0;
+}