1 files changed, 150 insertions, 0 deletions
diff --git a/examples/vf6xx_colibri_m4/demo_apps/rpmsg/pingpong/pingpong.c b/examples/vf6xx_colibri_m4/demo_apps/rpmsg/pingpong/pingpong.c
new file mode 100644
index 0000000..2668471
--- /dev/null
+++ b/examples/vf6xx_colibri_m4/demo_apps/rpmsg/pingpong/pingpong.c
@@ -0,0 +1,150 @@
+/*
+ * Copyright (c) 2016, Toradex AG
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without modification,
+ * are permitted provided that the following conditions are met:
+ *
+ * o Redistributions of source code must retain the above copyright notice, this list
+ *   of conditions and the following disclaimer.
+ *
+ * o 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.
+ *
+ * o Neither the name of Freescale Semiconductor, Inc. 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 HOLDER 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 <errno.h>
+
+#include "FreeRTOS.h"
+#include "task.h"
+#include "semphr.h"
+#include "rpmsg/rpmsg.h"
+#include "plat_porting.h"
+#include <ccm_vf6xx.h>
+#include "debug_console_vf6xx.h"
+
+/*
+ * APP decided interrupt priority
+ */
+#define APP_MSCM_IRQ_PRIORITY	3
+
+/* Internal functions */
+static void rpmsg_channel_created(struct rpmsg_channel *rp_chnl);
+static void rpmsg_channel_deleted(struct rpmsg_channel *rp_chnl);
+static void rpmsg_read_cb(struct rpmsg_channel *, void *, int, void *, unsigned long);
+
+/* Globals */
+static struct remote_device *rdev;
+static struct rpmsg_channel *app_chnl;
+static uint32_t msg_var;
+static SemaphoreHandle_t app_sema;
+
+/*!
+ * @brief A basic RPMSG task
+ */
+void PingPongTask(void *pvParameters)
+{
+    printf("RPMSG PingPong Demo...\r\n");
+
+    app_sema = xSemaphoreCreateCounting(2, 0);
+
+    printf("RPMSG Init as Remote\r\n");
+    /*
+    * RPMSG Init as REMOTE
+    */
+    rpmsg_init(0, &rdev, rpmsg_channel_created, rpmsg_channel_deleted, rpmsg_read_cb, RPMSG_MASTER);
+
+    /*
+    * rpmsg_channel_created will post the first semaphore
+    */
+    xSemaphoreTake(app_sema, portMAX_DELAY);
+    printf("Name service handshake is done, M4 has setup a rpmsg channel [%d ---> %d]\r\n", app_chnl->src, app_chnl->dst);
+
+
+    /*
+    * pingpong demo loop
+    */
+    for (;;) {
+	xSemaphoreTake(app_sema, portMAX_DELAY);
+	printf("Get Data From A5 : %d\r\n", msg_var);
+	msg_var++;
+	rpmsg_send(app_chnl, (void*)&msg_var, sizeof(uint32_t));
+    }
+}
+
+int main(void)
+{
+    /* Init Clock Control and UART */
+    CCM_GetClocks();
+    CCM_ControlGate(ccmCcgrGateUart2, ccmClockNeededAll);
+
+    vf6xx_DbgConsole_Init(UART2, ccmIpgBusClk, 115200);
+
+    printf("Starting RPMSG PingPong Demo...\r\n");
+
+    /*
+      * Prepare for the MSCM Interrupt
+      * MSCM must be initialized before rpmsg init is called
+      */
+    platform_interrupt_enable();
+    NVIC_SetPriority(CPU2CPU_INT0_IRQ, APP_MSCM_IRQ_PRIORITY);
+    NVIC_SetPriority(CPU2CPU_INT1_IRQ, APP_MSCM_IRQ_PRIORITY);
+
+    // Create a demo task which will print Hello world and echo user's input.
+    xTaskCreate(PingPongTask, "Ping Pong Task", configMINIMAL_STACK_SIZE,
+		NULL, tskIDLE_PRIORITY+1, NULL);
+
+    // Start FreeRTOS scheduler.
+    vTaskStartScheduler();
+
+    // Should never reach this point.
+    while (true);
+}
+
+/* rpmsg_rx_callback will call into this for a channel creation event*/
+static void rpmsg_channel_created(struct rpmsg_channel *rp_chnl)
+{
+    /*
+      * we should give the created rp_chnl handler to app layer
+      */
+    app_chnl = rp_chnl;
+
+    /*
+      * sync to application layer
+      */
+    xSemaphoreGiveFromISR(app_sema, NULL);
+}
+
+static void rpmsg_channel_deleted(struct rpmsg_channel *rp_chnl)
+{
+    rpmsg_destroy_ept(rp_chnl->rp_ept);
+}
+
+static void rpmsg_read_cb(struct rpmsg_channel *rp_chnl, void *data, int len,
+                void * priv, unsigned long src)
+{
+    msg_var = *(uint32_t*)data;
+    /*
+    * sync to application layer
+    */
+    xSemaphoreGiveFromISR(app_sema, NULL);
+}
+/*******************************************************************************
+ * EOF
+ ******************************************************************************/