Tests: ping_tasks: Use different description names for each channel
[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     Char                desc[32];
60     UInt32              myEndpoint = 0;
61     UInt32              remoteEndpoint;
62     UInt16              dstProc;
63     UInt16              len;
64     Int                 i;
66     System_printf("copyTask sample%d:%d: Entered...:\n", arg1, arg0);
68     dstProc = MultiProc_getId("HOST");
70     /* Create the messageQ for receiving (and get our endpoint for sending). */
71     handle = RPMessage_create(arg0, NULL, NULL, &myEndpoint);
73     System_sprintf(desc, "sample%d", arg1);
75 #ifdef RPMSG_NS_2_0
76     NameMap_register("rpmsg-client-sample", desc, arg0);
77 #else
78     NameMap_register("rpmsg-client-sample", arg0);
79 #endif
81     for (i = 0; i < APP_NUM_ITERATIONS; i++) {
82        /* Await a character message: */
83        RPMessage_recv(handle, (Ptr)buffer, &len, &remoteEndpoint,
84                          RPMessage_FOREVER);
86        buffer[len] = '\0';
87        System_printf("copyTask %d: Received data: %s, len:%d\n", i + 1,
88                       buffer, len);
90        /* Send data back to remote endpoint: */
91        RPMessage_send(dstProc, remoteEndpoint, myEndpoint, (Ptr)buffer, len);
92     }
94     /* Teardown our side: */
95     RPMessage_delete(&handle);
96 }
98 void start_ping_tasks()
99 {
100     Task_Params params;
102     /* Respond to ping tests from Linux side rpmsg sample drivers: */
103     Task_Params_init(&params);
104     params.instance->name = "copy0";
105     params.priority = 3;
106     params.arg0 = 50;
107     params.arg1 = 1;
108     Task_create(copyTaskFxn, &params, NULL);
110     Task_Params_init(&params);
111     params.instance->name = "copy1";
112     params.priority = 3;
113     params.arg0 = 51;
114     params.arg1 = 2;
115     Task_create(copyTaskFxn, &params, NULL);