Initial
authorBuddy Liong <a0270631@ti.com>
Tue, 10 Jan 2017 18:54:50 +0000 (12:54 -0600)
committerBuddy Liong <a0270631@ti.com>
Tue, 10 Jan 2017 18:57:09 +0000 (12:57 -0600)
Adding appA15HeartBeatHost client for A15 Heartbeat implementation
for M4 to know the A15 status.

Signed-off-by: Buddy Liong <a0270631@ti.com>
Android.mk [new file with mode: 0644]
appA15HeartBeatHost.c [new file with mode: 0644]
appA15HeartBeatHost.h [new file with mode: 0644]

diff --git a/Android.mk b/Android.mk
new file mode 100644 (file)
index 0000000..c34195a
--- /dev/null
@@ -0,0 +1,26 @@
+LOCAL_PATH:= $(call my-dir)
+
+#
+# appA15HeartBeatHost
+#
+
+##### appA15HeartBeatHost #####
+include $(CLEAR_VARS)
+
+IPC_ROOT := ../ipc/
+
+LOCAL_C_INCLUDES +=  $(LOCAL_PATH)/$(IPC_ROOT)/linux/include \
+                     $(LOCAL_PATH)/$(IPC_ROOT)/packages \
+                     $(LOCAL_PATH)/hlos_common/include
+
+LOCAL_CFLAGS += -DIPC_BUILDOS_ANDROID
+
+LOCAL_MODULE_TAGS:= optional
+
+LOCAL_SRC_FILES:= appA15HeartBeatHost.c
+
+LOCAL_SHARED_LIBRARIES := \
+    liblog libtiipcutils libtiipc libtitransportrpmsg
+
+LOCAL_MODULE:= appA15HeartBeatHost
+include $(BUILD_EXECUTABLE)
diff --git a/appA15HeartBeatHost.c b/appA15HeartBeatHost.c
new file mode 100644 (file)
index 0000000..f2e6509
--- /dev/null
@@ -0,0 +1,381 @@
+/*
+ * Copyright (c) 2016, Texas Instruments Incorporated
+ * 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 Texas Instruments Incorporated 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 BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+ * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
+ * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+ * PURPOSE 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.
+ */
+
+/*
+ *  ======== appA15HeartBeatHost.c ========
+ *
+ */
+
+/* host header files */
+#include <stdio.h>
+#include <unistd.h>
+#include <time.h>
+
+/* package header files */
+#include <ti/ipc/Std.h>
+#include <ti/ipc/Ipc.h>
+#include <ti/ipc/transports/TransportRpmsg.h>
+#include <ti/ipc/MessageQ.h>
+#include <ti/ipc/MultiProc.h>
+
+/* private functions */
+static Int Main_main(Void);
+static Int Main_parseArgs(Int argc, Char *argv[]);
+
+/* local header files */
+#include "appA15HeartBeatHost.h"
+
+/* module structure */
+typedef struct {
+    MessageQ_MsgHeader  reserved;
+    UInt32              cmd;
+} App_Msg;
+
+typedef struct {
+    MessageQ_Handle         hostQue;    // created locally
+    MessageQ_QueueId        slaveQue;   // opened remotely
+    UInt16                  heapId;     // MessageQ heapId
+    UInt32                  msgSize;
+} App_Module;
+
+/* private data */
+static App_Module Module;
+static String   Main_remoteProcName = NULL;
+#ifdef DEBUG
+static UInt32 MessageCount = 0;
+#endif
+/*
+ *  ======== App_create ========
+ */
+
+Int App_create(UInt16 remoteProcId)
+{
+    Int                 status = 0;
+    MessageQ_Params     msgqParams;
+    char                msgqName[32];
+
+    ALOGE("--> App_create:");
+
+    /* setting default values */
+    Module.hostQue = NULL;
+    Module.slaveQue = MessageQ_INVALIDMESSAGEQ;
+    Module.heapId = App_MsgHeapId;
+    Module.msgSize = sizeof(App_Msg);
+
+    /* create local message queue (inbound messages) */
+    MessageQ_Params_init(&msgqParams);
+
+    Module.hostQue = MessageQ_create(App_HostMsgQueName, &msgqParams);
+
+    if (Module.hostQue == NULL) {
+        ALOGE("App_create: Failed creating MessageQ");
+        status = -1;
+        goto leave;
+    }
+
+    /* open the remote message queue */
+    sprintf(msgqName, App_SlaveMsgQueName, MultiProc_getName(remoteProcId));
+
+    do {
+        status = MessageQ_open(msgqName, &Module.slaveQue);
+        sleep(1);
+    } while (status == MessageQ_E_NOTFOUND);
+
+    if (status < 0) {
+        ALOGE("App_create: Failed opening MessageQ");
+        goto leave;
+    }
+
+    ALOGE("App_create: Host is ready");
+
+leave:
+    ALOGE("<-- App_create:");
+    return(status);
+}
+
+
+/*
+ *  ======== App_delete ========
+ */
+Int App_delete(Void)
+{
+    Int         status;
+
+    ALOGE("--> App_delete:");
+
+    /* close remote resources */
+    status = MessageQ_close(&Module.slaveQue);
+
+    if (status < 0) {
+        goto leave;
+    }
+
+    /* delete the host message queue */
+    status = MessageQ_delete(&Module.hostQue);
+
+    if (status < 0) {
+        goto leave;
+    }
+
+leave:
+    ALOGE("<-- App_delete:");
+    return(status);
+}
+
+
+/*
+ *  ======== App_exec ========
+ */
+Int App_exec(Void)
+{
+    Int         status;
+    Int         i;
+    App_Msg *   msg;
+    Bool        running = TRUE;
+    struct timeval tv;
+
+    ALOGE("--> App_exec:");
+
+    /* allocate message */
+    msg = (App_Msg *)MessageQ_alloc(Module.heapId, Module.msgSize);
+
+    if (msg == NULL) {
+        status = -1;
+        goto leave;
+    }
+
+    /* fill in message payload */
+    msg->cmd = App_CMD_START;
+#ifdef DEBUG
+    MessageCount++;
+    // Get current time of day
+    gettimeofday(&tv, NULL);
+    ALOGE("%ld us: App_exec: sending #%d message %d \n", (tv.tv_sec * 1000000) + tv.tv_usec, MessageCount, msg->cmd);
+#endif
+
+    while (running) {
+        /* send START 1st message */
+        MessageQ_put(Module.slaveQue, (MessageQ_Msg)msg);
+
+        // Sleep for Microseconds - 500ms
+        usleep(Microseconds);
+
+        /* allocate message */
+        msg = (App_Msg *)MessageQ_alloc(Module.heapId, Module.msgSize);
+
+        if (msg == NULL) {
+            ALOGE("--> App_exec: MessageQ_alloc FAILED");
+            status = -1;
+            goto leave;
+        }
+
+        /* fill in message payload */
+        msg->cmd = App_CMD_ALIVE;
+#ifdef DEBUG
+        MessageCount++;
+        gettimeofday(&tv, NULL);
+        ALOGE("%ld us: App_exec: sending #%d App_CMD_ALIVE \n", (tv.tv_sec * 1000000) + tv.tv_usec, MessageCount);
+#endif
+    }
+
+leave:
+    ALOGE("<-- App_exec: %d\n", status);
+    return(status);
+}
+
+/*
+ *  ======== main ========
+ */
+Int main(Int argc, Char* argv[])
+{
+    Int status;
+
+    ALOGE("--> main:");
+
+    /* configure the transport factory */
+    Ipc_transportConfig(&TransportRpmsg_Factory);
+
+    /* parse command line */
+    status = Main_parseArgs(argc, argv);
+
+    if (status < 0) {
+        goto leave;
+    }
+
+    /* Ipc initialization */
+    status = Ipc_start();
+
+    if (status >= 0) {
+        /* application create, exec, delete */
+        status = Main_main();
+
+        /* Ipc finalization */
+        Ipc_stop();
+    }
+    else {
+        ALOGE("Ipc_start failed: status = %d\n", status);
+        goto leave;
+    }
+
+leave:
+    ALOGE("<-- main:\n");
+    status = (status >= 0 ? 0 : status);
+
+    return (status);
+}
+
+
+/*
+ *  ======== Main_main ========
+ */
+Int Main_main(Void)
+{
+    UInt16      remoteProcId;
+    Int         status = 0;
+
+    ALOGE("--> Main_main:\n");
+
+    remoteProcId = MultiProc_getId(Main_remoteProcName);
+
+    /* application create phase */
+    status = App_create(remoteProcId);
+
+    if (status < 0) {
+        goto leave;
+    }
+
+    /* application execute phase */
+    status = App_exec();
+
+    if (status < 0) {
+        goto leave;
+    }
+
+    /* application delete phase */
+    status = App_delete();
+
+    if (status < 0) {
+        goto leave;
+    }
+
+leave:
+    ALOGE("<-- Main_main:");
+
+    status = (status >= 0 ? 0 : status);
+    return (status);
+}
+
+
+/*
+ *  ======== Main_parseArgs ========
+ */
+Int Main_parseArgs(Int argc, Char *argv[])
+{
+    Int             x, cp, opt, argNum;
+    UInt16          i, numProcs;
+    String          name;
+    Int             status = 0;
+
+
+    /* parse the command line options */
+    for (opt = 1; (opt < argc) && (argv[opt][0] == '-'); opt++) {
+        for (x = 0, cp = 1; argv[opt][cp] != '\0'; cp++) {
+            x = (x << 8) | (int)argv[opt][cp];
+        }
+
+        switch (x) {
+            case 'h': /* -h */
+                ALOGE("%s", Main_USAGE);
+                exit(0);
+                break;
+
+            case 'l': /* -l */
+                //ALOGE("Processor List");
+                printf("Processor List\n");
+                status = Ipc_start();
+                if (status >= 0) {
+                    numProcs = MultiProc_getNumProcessors();
+                    for (i = 0; i < numProcs; i++) {
+                        name = MultiProc_getName(i);
+                        //ALOGE("    procId=%d, procName=%s", i, name);
+                        printf("    procId=%d, procName=%s\n", i, name);
+                    }
+                    Ipc_stop();
+                }
+                else {
+                    printf(
+                        "Error: %s, line %d: Ipc_start failed status %d\n",
+                        __FILE__, __LINE__, status);
+                    goto leave;
+                }
+                exit(0);
+                break;
+
+            default:
+                printf(
+                    "Error: %s, line %d: invalid option, %c\n",
+                    __FILE__, __LINE__, (Char)x);
+                printf("%s", Main_USAGE);
+                status = -1;
+                goto leave;
+        }
+    }
+
+    /* parse the command line arguments */
+    for (argNum = 1; opt < argc; argNum++, opt++) {
+
+        switch (argNum) {
+            case 1: /* name of proc #1 */
+                Main_remoteProcName = argv[opt];
+                break;
+
+            default:
+                printf(
+                    "Error: %s, line %d: too many arguments\n",
+                    __FILE__, __LINE__);
+                printf("%s", Main_USAGE);
+                status = -1;
+                goto leave;
+        }
+    }
+
+    /* validate command line arguments */
+    if (Main_remoteProcName == NULL) {
+        printf("Error: missing procName argument\n");
+        printf("%s", Main_USAGE);
+        status = -1;
+        goto leave;
+    }
+
+leave:
+    return(status);
+}
diff --git a/appA15HeartBeatHost.h b/appA15HeartBeatHost.h
new file mode 100644 (file)
index 0000000..3104510
--- /dev/null
@@ -0,0 +1,86 @@
+/*
+ * Copyright (c) 2016, Texas Instruments Incorporated
+ * 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 Texas Instruments Incorporated 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 BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+ * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
+ * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+ * PURPOSE 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.
+ */
+
+/*
+ *  ======== appA15HeartBeatHost.h ========
+ *
+ */
+
+#ifndef appA15HeartBeatHost__include
+#define appA15HeartBeatHost__include
+#if defined (__cplusplus)
+extern "C" {
+#endif
+
+#include <utils/Log.h>
+#define LOG_TAG "AppA15HeartBeatHost"
+
+/* notify commands 00 - FF */
+#define App_CMD_MASK            0xFF000000
+#define App_CMD_START           0x00000000
+#define App_CMD_ALIVE           0x01000000
+#define App_CMD_SHUTDOWN        0x02000000
+
+#define App_MsgHeapId           0
+#define App_HostMsgQueName      "HOST:MsgQ:01"
+#define App_SlaveMsgQueName     "%s:MsgQ:01"  /* %s is each slave's Proc Name */
+
+#define Main_USAGE "\
+Usage:\n\
+    appA15HeartBeatHost [options] procName\n\
+\n\
+Arguments:\n\
+    procName      : the name of the remote processor\n\
+\n\
+Options:\n\
+    h   : print this help message\n\
+    l   : list the available remote names\n\
+\n\
+Examples:\n\
+    appA15HeartBeatHost DSP\n\
+    appA15HeartBeatHost -l\n\
+    appA15HeartBeatHost -h\n\
+\n"
+
+//#define DEBUG
+
+#define Microseconds (500 * 1000)
+
+Int App_create(UInt16 remoteProcId);
+Int App_delete();
+Int App_exec();
+
+
+#if defined (__cplusplus)
+}
+#endif /* defined (__cplusplus) */
+#endif /* appA15HeartBeatHost__include */