2aa801f560c9cb6c391804748a2840c621c24914
[ipc/ipcdev.git] / packages / ti / ipc / tests / ping_tasks.c
1 /*
2  * Copyright (c) 2011-2013, Texas Instruments Incorporated
3  * All rights reserved.
4  *
5  * Redistribution and use in source and binary forms, with or without
6  * modification, are permitted provided that the following conditions
7  * are met:
8  *
9  * *  Redistributions of source code must retain the above copyright
10  *    notice, this list of conditions and the following disclaimer.
11  *
12  * *  Redistributions in binary form must reproduce the above copyright
13  *    notice, this list of conditions and the following disclaimer in the
14  *    documentation and/or other materials provided with the distribution.
15  *
16  * *  Neither the name of Texas Instruments Incorporated nor the names of
17  *    its contributors may be used to endorse or promote products derived
18  *    from this software without specific prior written permission.
19  *
20  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
21  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
22  * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
23  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
24  * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
25  * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
26  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
27  * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
28  * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
29  * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE,
30  * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
31  */
32 /*
33  *  ======== ping_tasks.c ========
34  *
35  *  Works with the rpmsg_client_sample and rpmsg_server_sample Linux drivers.
36  */
38 #include <xdc/std.h>
39 #include <xdc/cfg/global.h>
40 #include <xdc/runtime/System.h>
42 #include <ti/ipc/MultiProc.h>
43 #include <ti/sysbios/BIOS.h>
44 #include <ti/sysbios/knl/Task.h>
46 #include <stdio.h>
47 #include <string.h>
48 #include <stdlib.h>
50 #include <ti/ipc/rpmsg/RPMessage.h>
51 #include <ti/ipc/rpmsg/NameMap.h>
53 #define APP_NUM_ITERATIONS 100000
55 Void copyTaskFxn(UArg arg0, UArg arg1)
56 {
57     RPMessage_Handle    handle;
58     Char                   buffer[128];
59     UInt32                 myEndpoint = 0;
60     UInt32                 remoteEndpoint;
61     UInt16                 dstProc;
62     UInt16                 len;
63     Int                    i;
65     System_printf("copyTask %d: Entered...:\n", arg0);
67     dstProc = MultiProc_getId("HOST");
69     /* Create the messageQ for receiving (and get our endpoint for sending). */
70     handle = RPMessage_create(arg0, NULL, NULL, &myEndpoint);
72     NameMap_register("rpmsg-client-sample", "sample-desc", arg0);
74     for (i = 0; i < APP_NUM_ITERATIONS; i++) {
75        /* Await a character message: */
76        RPMessage_recv(handle, (Ptr)buffer, &len, &remoteEndpoint,
77                          RPMessage_FOREVER);
79        buffer[len] = '\0';
80        System_printf("copyTask %d: Received data: %s, len:%d\n", i + 1,
81                       buffer, len);
83        /* Send data back to remote endpoint: */
84        RPMessage_send(dstProc, remoteEndpoint, myEndpoint, (Ptr)buffer, len);
85     }
87     /* Teardown our side: */
88     RPMessage_delete(&handle);
89 }
91 void start_ping_tasks()
92 {
93     Task_Params params;
95     /* Respond to ping tests from Linux side rpmsg sample drivers: */
96     Task_Params_init(&params);
97     params.instance->name = "copy0";
98     params.priority = 3;
99     params.arg0 = 50;
100     Task_create(copyTaskFxn, &params, NULL);
102     Task_Params_init(&params);
103     params.instance->name = "copy1";
104     params.priority = 3;
105     params.arg0 = 51;
106     Task_create(copyTaskFxn, &params, NULL);