CCS+C6678LE以太网接口测试示例代码

sick

为了方便贴代码，将原始实例的代码做了精简；

为了探索其原理，修改/添加了少量代码。

主要代码如下#include <stdio.h>

1. <p style="line-height: 28px;"><font color="rgb(51, 51, 51)"><font face="" "=""></font></font></p><p style="line-height: 28px;"><font color="rgb(51, 51, 51)"><font face="" "="">#include <ti/ndk/inc/netmain.h>
   
2. #include <ti/sysbios/BIOS.h>
   
3. #include <ti/sysbios/knl/Task.h>
   
4. #include <xdc/runtime/Error.h>
   
5. #include <xdc/runtime/System.h>
   
6. #include "ti/platform/platform.h"
   
7. #include "ti/platform/resource_mgr.h"
   
8. 
   
9. static int counter=0;
   
10. static HANDLE hHello=0;
    
11. char *HostName    = "TMS320C6678";
    
12. char *LocalIPAddr = "169.254.11.119";   // My PC Local IP
    
13. char *LocalIPMask = "255.255.255.0";    // Not used when using DHCP
    
14. char *GatewayIP   = "192.168.2.101";    // Not used when using DHCP
    
15. char *DomainName  = "demo.net";         // Not used when using DHCP
    
16. char *DNSServer   = "0.0.0.0";          // Used when set to anything but zero
    
17. Uint8 clientMACAddress[6] = {0x01, 0x02, 0x03, 0x04, 0x0C, 0xEF}; /* MAC Addr */
    
18. 
    
19. 
    
20. static void   NetworkOpen();
    
21. static void   NetworkClose();
    
22. static void   NetworkIPAddr(IPN IPAddr, uint IfIdx, uint fAdd);
    
23. extern int    dtask_udp_hello();
    
24. 
    
25. void EVM_init()
    
26. {
    
27.     printf("\nEVM_Init()\n");
    
28.     platform_init_flags   sFlags;
    
29.     platform_init_config  sConfig;
    
30.     memset( (void *) &sFlags,  0, sizeof(platform_init_flags));
    
31.     memset( (void *) &sConfig, 0, sizeof(platform_init_config));
    
32.     sFlags.pll  = 0;  /* PLLs for clocking  */
    
33.     sFlags.ddr  = 0;  /* External memory    */
    
34.     sFlags.tcsl = 1;  /* Time stamp counter */
    
35.     sFlags.phy  = 1;  /* Ethernet           */
    
36.     sFlags.ecc  = 0;  /* Memory ECC         */
    
37.     sConfig.pllm = 0; /* Use libraries default clock divisor */
    
38.     platform_init(&sFlags, &sConfig);
    
39. }
    
40. 
    
41. Void Hello(UArg arg0, UArg arg1)
    
42. {
    
43.     while(1)
    
44.     {
    
45.         printf("Hello\n");
    
46.         Task_sleep(2000);
    
47.         if(counter>=3) break;
    
48.     }
    
49. }
    
50. 
    
51. Void Test(UArg arg0,UArg arg1);
    
52. 
    
53. int main()
    
54. {
    
55.     Task_Handle task1 = Task_create(Test, NULL, NULL);
    
56.     Task_Handle task2 = Task_create(Hello, NULL, NULL);
    
57.     if (task1==NULL || task2==NULL)
    
58.     {
    
59.         printf("Task_create() failed!\n");
    
60.         BIOS_exit(0);
    
61.     }
    
62.     BIOS_start();
    
63. }
    
64. 
    
65. Void Test(UArg arg0,UArg arg1)
    
66. {
    
67.         QMSS_CFG_T qmss_cfg;
    
68.         CPPI_CFG_T cppi_cfg;
    
69. 
    
70.         uint32_t coreID = platform_get_coreid();
    
71.         uint32_t master=(coreID==0)?1:0;
    
72. 
    
73.         qmss_cfg.master_core = master;
    
74.         qmss_cfg.max_num_desc = MAX_NUM_DESC;
    
75.         qmss_cfg.desc_size = MAX_DESC_SIZE;
    
76.         qmss_cfg.mem_region = Qmss_MemRegion_MEMORY_REGION0;
    
77. 
    
78.         cppi_cfg.master_core = master;
    
79.         cppi_cfg.dma_num = Cppi_CpDma_PASS_CPDMA;
    
80.         cppi_cfg.num_tx_queues = NUM_PA_TX_QUEUES;
    
81.         cppi_cfg.num_rx_channels = NUM_PA_RX_CHANNELS;
    
82. 
    
83.         res_mgr_init_qmss(&qmss_cfg);
    
84.         res_mgr_init_cppi(&cppi_cfg);
    
85.         res_mgr_init_pass();
    
86. 
    
87. 
    
88.         int rc = NC_SystemOpen( NC_PRIORITY_LOW, NC_OPMODE_INTERRUPT );
    
89.         if( rc!=0 )
    
90.         {
    
91.             NC_SystemClose();
    
92.             return;
    
93.         }
    
94. 
    
95.         HANDLE hCfg = CfgNew();
    
96.         if( !hCfg )
    
97.         {
    
98.             NC_SystemClose();
    
99.             return;
    
100.         }
     
101.         CfgAddEntry( hCfg,CFGTAG_SYSINFO,CFGITEM_DHCP_HOSTNAME,0,strlen(HostName),(UINT8*)HostName,0);
     
102. 
     
103.     CI_IPNET NA;
     
104.     bzero( &NA, sizeof(NA) );
     
105.     NA.IPAddr  = inet_addr(LocalIPAddr);
     
106.     NA.IPMask  = inet_addr(LocalIPMask);
     
107.     strcpy( NA.Domain, DomainName );
     
108.     NA.NetType = 0;
     
109.         CfgAddEntry( hCfg, CFGTAG_IPNET, 1, 0,sizeof(CI_IPNET), (UINT8 *)&NA, 0 );
     
110. 
     
111.     CI_ROUTE RT;
     
112.     bzero( &RT, sizeof(RT) );
     
113.     RT.IPDestAddr = 0;
     
114.     RT.IPDestMask = 0;
     
115.     RT.IPGateAddr = inet_addr(GatewayIP);
     
116.     CfgAddEntry( hCfg, CFGTAG_ROUTE, 0, 0,sizeof(CI_ROUTE), (UINT8 *)&RT, 0 );
     
117. 
     
118.     IPN IPTmp = inet_addr(DNSServer);
     
119.     if( IPTmp )
     
120.     {
     
121.         CfgAddEntry( hCfg, CFGTAG_SYSINFO, CFGITEM_DHCP_DOMAINNAMESERVER,0, sizeof(IPTmp), (UINT8 *)&IPTmp, 0 );
     
122.     }
     
123. 
     
124.         rc = DBG_WARN;
     
125.         CfgAddEntry(hCfg,CFGTAG_OS,CFGITEM_OS_DBGPRINTLEVEL,CFG_ADDMODE_UNIQUE, sizeof(uint),(UINT8 *)&rc,0);
     
126. 
     
127.         rc = 8192;
     
128.         CfgAddEntry(hCfg,CFGTAG_IP,CFGITEM_IP_SOCKUDPRXLIMIT,CFG_ADDMODE_UNIQUE,sizeof(uint),(UINT8 *)&rc,0);
     
129. 
     
130.         do
     
131.         {
     
132.             rc = NC_NetStart( hCfg, NetworkOpen, NetworkClose, NetworkIPAddr );
     
133.         } while( rc > 0 );
     
134. 
     
135.         CfgFree( hCfg );
     
136. 
     
137.         NC_SystemClose();
     
138. }
     
139. 
     
140. static void NetworkOpen()
     
141. {
     
142.         hHello = DaemonNew( SOCK_DGRAM,0,7,dtask_udp_hello,OS_TASKPRINORM,OS_TASKSTKNORM,0,1);
     
143. }
     
144. 
     
145. static void NetworkClose()
     
146. {
     
147.         DaemonFree( hHello );
     
148. }
     
149. 
     
150. static void NetworkIPAddr( IPN IPAddr, uint IfIdx, uint fAdd )
     
151. {
     
152.         IPN IPTmp;
     
153.         if( fAdd )  printf("Network Added: ");
     
154.         else  printf("Network Removed: ");
     
155.         IPTmp = ntohl( IPAddr );
     
156.         printf("If-%d:%d.%d.%d.%d\n", IfIdx,
     
157.             (UINT8)(IPTmp>>24)&0xFF,(UINT8)(IPTmp>>16)&0xFF,
     
158.             (UINT8)(IPTmp>>8)&0xFF, (UINT8)IPTmp&0xFF );
     
159. }
     
160. 
     
161. int dtask_udp_hello( SOCKET s, UINT32 unused )
     
162. {
     
163.     printf("TASK execution %d\n",++counter);
     
164. 
     
165.         (void)unused;
     
166. 
     
167.         struct timeval tv;
     
168.         tv.tv_sec  = 3;
     
169.         tv.tv_usec = 0;
     
170.         setsockopt(s,SOL_SOCKET,SO_SNDTIMEO,&tv,sizeof(tv));
     
171.         setsockopt(s,SOL_SOCKET,SO_RCVTIMEO,&tv,sizeof(tv));
     
172. 
     
173.         struct sockaddr_in sin1;
     
174.         int sz=sizeof(sin1);
     
175.         int recvSize;
     
176.         HANDLE hBuffer;
     
177.         unsigned char* pBuf;
     
178.         while(1)
     
179.         {
     
180.             recvSize=recvncfrom( s, (void**)&pBuf, 0, (PSA)&sin1, &sz, &hBuffer );
     
181.             if(recvSize<=0) break;
     
182.             sendto( s, pBuf, recvSize, 0, (PSA)&sin1, sz );
     
183.             recvncfree( hBuffer );
     
184.         }
     
185. 
     
186.         // Since the socket is still open, return "1"
     
187.         // (we need to leave UDP sockets open)
     
188.         return 1;
     
189. }</font></font></p>

复制代码

其中EVM_init()函数被设置为在main()函数之前执行，具体设置在一个*.cfg文件中，

部分内容如下

1. var Memory  =   xdc.useModule('xdc.runtime.Memory');
   
2. var BIOS    =   xdc.useModule('ti.sysbios.BIOS');
   
3. var Task    =   xdc.useModule('ti.sysbios.knl.Task');
   
4. var HeapBuf =   xdc.useModule('ti.sysbios.heaps.HeapBuf');
   
5. var Log     =   xdc.useModule('xdc.runtime.Log');
   
6. //...省略...
   
7. Program.sectMap["sharedL2"] = "DDR3";
   
8. Program.sectMap["systemHeap"] = "DDR3";
   
9. Program.sectMap[".sysmem"]  = "DDR3";
   
10. Program.sectMap[".args"]    = "DDR3";
    
11. Program.sectMap[".cio"]     = "DDR3";
    
12. Program.sectMap[".far"]     =     "DDR3";
    
13. Program.sectMap[".rodata"]     =     "DDR3";
    
14. Program.sectMap[".neardata"]     =     "DDR3";
    
15. //...省略...
    
16. Startup.lastFxns.$add('&EVM_init');
    
17. BIOS.taskEnabled            =   true;
    
18. 
    
19. Ecm.eventGroupHwiNum[0] = 7;
    
20. Ecm.eventGroupHwiNum[1] = 8;
    
21. Ecm.eventGroupHwiNum[2] = 9;
    
22. Ecm.eventGroupHwiNum[3] = 10;
    
23. Global.IPv6 = true;

复制代码

注意其中的

1. Startup.lastFxns.$add('&EVM_init');

复制代码

在主函数中执行BIOS_start()会完成一些主动操作

（似乎是因为main函数在DSP中的地位和在PC上不一样）

总之，在执行完EVM_init()完成基本的初始化后，创建我们的主要任务：

1. Task_Handle task1 = Task_create(Test, NULL, NULL);
   
2. Task_Handle task2 = Task_create(Hello, NULL, NULL);

复制代码

其中Hello任务只是为了演示一下，每隔2秒(sleep(2000))打印一个“Hello”字样
而Test任务则执行了QMSS、CPPI、PA等等的初始化，完成了基本网络配置

启动Network服务后，关联了dtask_udp_hello任务，等待以太网接口的连接

另一边使用PC执行测试，发送字符串进行交互。

因为我们的程序中设置了一个计数器counter

每次发送一个字符串，dtask_udp_hello()就执行一次,counter++

在Hello任务中，一旦发现条件counter>=3满足了就会退出while()循环，它的使命也就终结了

（注意并不是真的终结，因为没有执行KillTask这样的命令，只是Hello任务不再执行任何操作罢了）

这样只剩下Test任务独自运行了

某次测试如下