2011-06-10 11:57:32 +08:00
|
|
|
#include <lwip/api.h>
|
|
|
|
|
|
|
|
|
|
#define UDP_ECHO_PORT 7
|
|
|
|
|
|
|
|
|
|
void udpecho_entry(void *parameter)
|
|
|
|
|
{
|
|
|
|
|
struct netconn *conn;
|
|
|
|
|
struct netbuf *buf;
|
|
|
|
|
struct ip_addr *addr;
|
|
|
|
|
unsigned short port;
|
|
|
|
|
|
|
|
|
|
conn = netconn_new(NETCONN_UDP);
|
|
|
|
|
netconn_bind(conn, IP_ADDR_ANY, 7);
|
|
|
|
|
|
|
|
|
|
while(1)
|
|
|
|
|
{
|
|
|
|
|
/* received data to buffer */
|
|
|
|
|
netconn_recv(conn, &buf);
|
|
|
|
|
|
|
|
|
|
addr = netbuf_fromaddr(buf);
|
|
|
|
|
port = netbuf_fromport(buf);
|
|
|
|
|
|
|
|
|
|
/* send the data to buffer */
|
|
|
|
|
netconn_connect(conn, addr, port);
|
|
|
|
|
|
|
|
|
|
/* reset address, and send to client */
|
|
|
|
|
buf->addr = *IP_ADDR_ANY;
|
|
|
|
|
netconn_send(conn, buf);
|
|
|
|
|
|
|
|
|
|
/* release buffer */
|
|
|
|
|
netbuf_delete(buf);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#ifdef RT_USING_FINSH
|
|
|
|
|
#include <finsh.h>
|
|
|
|
|
static rt_thread_t echo_tid = RT_NULL;
|
|
|
|
|
void udpecho(rt_uint32_t startup)
|
|
|
|
|
{
|
|
|
|
|
if (startup && echo_tid == RT_NULL)
|
|
|
|
|
{
|
|
|
|
|
echo_tid = rt_thread_create("uecho",
|
|
|
|
|
udpecho_entry, RT_NULL,
|
|
|
|
|
512, 30, 5);
|
|
|
|
|
if (echo_tid != RT_NULL)
|
|
|
|
|
rt_thread_startup(echo_tid);
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
if (echo_tid != RT_NULL)
|
|
|
|
|
rt_thread_delete(echo_tid); /* delete thread */
|
|
|
|
|
echo_tid = RT_NULL;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
FINSH_FUNCTION_EXPORT(udpecho, startup or stop UDP echo server);
|
|
|
|
|
#endif
|
