TI中文支持网求助AM572x的UDP通信demo
yongqing wang：
UDP通信：开发板ite9854，网卡RTL8201F(32pins)，操作系统freertos，通信协议lwip
实现功能：电脑端使用网络调试助手，发送信息给开发板，开发板回复信息
锘?include <sys/ioctl.h>
#include <sys/socket.h>
#include <pthread.h>
#include <time.h>
#include "lwip/ip.h"
#include "lwip/dns.h"
#include "ite/itp.h"
#include "iniparser/iniparser.h"
#include "ctrlboard.h"
#include "wifiMgr.h"#define DHCP_TIMEOUT_MSEC (60 * 1000) //60sec
static bool networkIsReady;
static int networkSocket;
static bool networkToReset;
//CreatSocket
static int networkSocket;
struct sockaddr_in sockAddr;
int val = 1;
//Receive/Send
struct sockaddr_in sockAddr;
int slen = sizeof(sockAddr);
int count, diff;
char buf[4];//—————————————————————————–
//
// 函数名称 : CreatSocket
// 函数功能 : 无connect仅建立UDP，
//
// 输入参数 : 无
//
// 返回参数 : 无
//
//—————————————————————————–
static void CreatSocket()
{
// create socket
networkSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
printf("*****networkSocket=%d\n",networkSocket);
if (networkSocket != -1)
{
// set to asynchronous mode
ioctlsocket(networkSocket, FIONBIO, &val);
// init bind parameters
memset((char*)&sockAddr, 0, sizeof(sockAddr));
sockAddr.sin_family = AF_INET;
// target to any
sockAddr.sin_addr.s_addr = htonl(INADDR_ANY);
// port to 49201
sockAddr.sin_port = htons(8080);
// bind
if (bind(networkSocket, (struct sockaddr*)&sockAddr, sizeof(sockAddr)) != -1)
{
// binding success
}
}
}
//—————————————————————————–
//
// 函数名称 : TransforMessage
// 函数功能 :
//
// 输入参数 : 无
//
// 返回参数 : 无
//
//—————————————————————————–
static void TransforMessage()
{// receive 1 byte data from center 非阻塞的
count = recvfrom(networkSocket, buf, 1, 0, (struct sockaddr*)&sockAddr, &slen);
if (count > 0)
{
printf("*****count=%d\n",count);
// send "*" to 192.168.1.121 此处可注释掉
//sockAddr.sin_family = AF_INET;
//sockAddr.sin_addr.s_addr = inet_addr("192.168.1.121");
count = sendto(networkSocket, "*", 1, 0, (const struct sockaddr*)&sockAddr, sizeof (sockAddr));
}
}
#ifdef CFG_NET_WIFI
static WIFI_MGR_SETTING gWifiSetting;
#endifstatic struct timeval tvStart = {0, 0}, tvEnd = {0, 0};
// wifi init
static int gInit =0;bool NetworkIsReady(void)
{
return networkIsReady;
}static void ResetEthernet(void)
{
ITPEthernetSetting setting;
ITPEthernetInfo info;
unsigned long mscnt = 0;
char buf[16], *saveptr;memset(&setting, 0, sizeof (ITPEthernetSetting));
setting.index = 0;
// dhcp
setting.dhcp = theConfig.dhcp;// autoip
setting.autoip = 1;// ipaddr
strcpy(buf, theConfig.ipaddr);
setting.ipaddr[0] = atoi(strtok_r(buf, ".", &saveptr));
setting.ipaddr[1] = atoi(strtok_r(NULL, ".", &saveptr));
setting.ipaddr[2] = atoi(strtok_r(NULL, ".", &saveptr));
setting.ipaddr[3] = atoi(strtok_r(NULL, " ", &saveptr));// netmask
strcpy(buf, theConfig.netmask);
setting.netmask[0] = atoi(strtok_r(buf, ".", &saveptr));
setting.netmask[1] = atoi(strtok_r(NULL, ".", &saveptr));
setting.netmask[2] = atoi(strtok_r(NULL, ".", &saveptr));
setting.netmask[3] = atoi(strtok_r(NULL, " ", &saveptr));// gateway
strcpy(buf, theConfig.gw);
setting.gw[0] = atoi(strtok_r(buf, ".", &saveptr));
setting.gw[1] = atoi(strtok_r(NULL, ".", &saveptr));
setting.gw[2] = atoi(strtok_r(NULL, ".", &saveptr));
setting.gw[3] = atoi(strtok_r(NULL, " ", &saveptr));ioctl(ITP_DEVICE_ETHERNET, ITP_IOCTL_RESET, &setting);
printf("Wait ethernet cable to plugin");
while (!ioctl(ITP_DEVICE_ETHERNET, ITP_IOCTL_IS_CONNECTED, NULL))
{
sleep(1);
putchar('.');
fflush(stdout);
}printf("\nWait DHCP settings");
while (!ioctl(ITP_DEVICE_ETHERNET, ITP_IOCTL_IS_AVAIL, NULL))
{
usleep(100000);
mscnt += 100;putchar('.');
fflush(stdout);if (mscnt >= DHCP_TIMEOUT_MSEC)
{
printf("\nDHCP timeout, use default settings\n");
setting.dhcp = setting.autoip = 0;
ioctl(ITP_DEVICE_ETHERNET, ITP_IOCTL_RESET, &setting);
break;
}
}
puts("");if (ioctl(ITP_DEVICE_ETHERNET, ITP_IOCTL_IS_AVAIL, NULL))
{
char* ip;info.index = 0;
ioctl(ITP_DEVICE_ETHERNET, ITP_IOCTL_GET_INFO, &info);
ip = ipaddr_ntoa((const ip_addr_t*)&info.address);printf("IP address: %s\n", ip);
networkIsReady = true;
}
}#ifdef CFG_NET_WIFI
static int wifiCallbackFucntion(int nState)
{
switch (nState)
{
case WIFIMGR_STATE_CALLBACK_CONNECTION_FINISH:
printf("[Indoor]WifiCallback connection finish \n");
WebServerInit();
break;case WIFIMGR_STATE_CALLBACK_CLIENT_MODE_DISCONNECT_30S:
printf("[Indoor]WifiCallback connection disconnect 30s \n");
break;case WIFIMGR_STATE_CALLBACK_CLIENT_MODE_RECONNECTION:
printf("[Indoor]WifiCallback connection reconnection \n");
break;case WIFIMGR_STATE_CALLBACK_CLIENT_MODE_TEMP_DISCONNECT:
printf("[Indoor]WifiCallback connection temp disconnect \n");
break;case WIFIMGR_STATE_CALLBACK_CLIENT_MODE_CONNECTING_FAIL:
printf("[Indoor]WifiCallback connecting fail, please check ssid,password,secmode \n");
break;default:
printf("[Indoor]WifiCallback unknown %d state \n",nState);
break;}
}
static ResetWifi()
{
// ITPEthernetSetting setting;
char buf[16], *saveptr;memset(&gWifiSetting.setting, 0, sizeof (ITPEthernetSetting));
gWifiSetting.setting.index = 0;
// dhcp
gWifiSetting.setting.dhcp = theConfig.dhcp;// autoip
gWifiSetting.setting.autoip = 0;// ipaddr
strcpy(buf, theConfig.ipaddr);
gWifiSetting.setting.ipaddr[0] = atoi(strtok_r(buf, ".", &saveptr));
gWifiSetting.setting.ipaddr[1] = atoi(strtok_r(NULL, ".", &saveptr));
gWifiSetting.setting.ipaddr[2] = atoi(strtok_r(NULL, ".", &saveptr));
gWifiSetting.setting.ipaddr[3] = atoi(strtok_r(NULL, " ", &saveptr));// netmask
strcpy(buf, theConfig.netmask);
gWifiSetting.setting.netmask[0] = atoi(strtok_r(buf, ".", &saveptr));
gWifiSetting.setting.netmask[1] = atoi(strtok_r(NULL, ".", &saveptr));
gWifiSetting.setting.netmask[2] = atoi(strtok_r(NULL, ".", &saveptr));
gWifiSetting.setting.netmask[3] = atoi(strtok_r(NULL, " ", &saveptr));// gateway
strcpy(buf, theConfig.gw);
gWifiSetting.setting.gw[0] = atoi(strtok_r(buf, ".", &saveptr));
gWifiSetting.setting.gw[1] = atoi(strtok_r(NULL, ".", &saveptr));
gWifiSetting.setting.gw[2] = atoi(strtok_r(NULL, ".", &saveptr));
gWifiSetting.setting.gw[3] = atoi(strtok_r(NULL, " ", &saveptr));}
#endif
static void* NetworkTask(void* arg)
{
#ifdef CFG_NET_WIFIint nTemp;
#else
ResetEthernet();
#endif
CreatSocket();
for (;;)
{#ifdef CFG_NET_WIFI
gettimeofday(&tvEnd, NULL);nTemp = itpTimevalDiff(&tvStart, &tvEnd);
if (nTemp>5000 && gInit == 0){
printf("init wifi \n");
//printf("[NetworkTask] wifi status = %d\n", theConfig.wifi_status);WifiMgr_clientMode_switch(theConfig.wifi_status);
nTemp = wifiMgr_init(WIFIMGR_MODE_CLIENT, 0,gWifiSetting);
gInit = 1;} else if (gInit == 1){
networkIsReady = wifiMgr_is_wifi_available(&nTemp);
networkIsReady = (bool)nTemp;
}#else
networkIsReady = ioctl(ITP_DEVICE_ETHERNET, ITP_IOCTL_IS_CONNECTED, NULL);
#endifif (networkToReset)
{
#ifdef CFG_NET_WIFI#else
ResetEthernet();
#endif
networkToReset = false;
}
if(networkIsReady)
{
printf("*****networkIsReady=%d\n",networkIsReady);
TransforMessage();
}
sleep(1);
}
return NULL;
}void NetworkInit(void)
{
pthread_t task;networkIsReady = false;
networkToReset = false;
networkSocket = -1;
#ifdef CFG_NET_WIFIsnprintf(gWifiSetting.ssid , WIFI_SSID_MAXLEN, theConfig.ssid);
snprintf(gWifiSetting.password, WIFI_PASSWORD_MAXLEN, theConfig.password);
snprintf(gWifiSetting.secumode, WIFI_SECUMODE_MAXLEN, theConfig.secumode);
gWifiSetting.wifiCallback = wifiCallbackFucntion;
ResetWifi();
// init client mode
//ret = wifiMgr_init(WIFIMGR_MODE_CLIENT, 0,gWifiSetting);// ret = wifiMgr_init(WIFIMGR_MODE_SOFTAP, 0,gWifiSetting);
gettimeofday(&tvStart, NULL);#endif
pthread_create(&task, NULL, NetworkTask, NULL);
}void NetworkReset(void)
{
networkToReset = true;
}
user5239677：
现在是在TI-RTOS上要实现AM5728与PC的UDP通信，一直实现不了，找不到相关的例程。
user5239677：
回复 yongqing wang:
现在是在TI-RTOS上要实现AM5728与PC的UDP通信，一直实现不了，找不到相关的例程。
yongqing wang：
回复 user5239677:
他的SDK下应该是相应的例子吧
