MINI2440 LWIP问题

发布于 2011-08-13 19:14:30 浏览：4011 订阅该版

在Application.c文件中增加一个测试TCP通讯的服务器
```
void rt_tcptest_thread_entry(void* parameter)
{
    int  xListenSocket,xClientSocket;
    int  nRet,nLen;
    struct sockaddr_in  xService, xRemote;
    xClientSocket = -1;

xService.sin_family = AF_INET;
    xService.sin_port = htons(502);
    xService.sin_addr.s_addr = INADDR_ANY;
	
   if( ( xListenSocket = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP ) ) == -1 )
    {
        rt_kprintf( "can't create socket!
" );
    }
    else if( bind( xListenSocket, ( struct  sockaddr  * ) & xService, sizeof( xService ) ) != ERR_OK )
    {
        rt_kprintf( "can't bind on socket!
" );            
    }
    else if( listen( xListenSocket, 5 ) != ERR_OK )
    {
        rt_kprintf( "can't listen on socket
" );
    }

nLen = sizeof(struct  sockaddr);
    while(1)
     {    // Task body, always written as an infinite loop.           
        xClientSocket = accept (xListenSocket,(struct  sockaddr*)&xRemote,&nLen);
        if (xClientSocket!= -1)
        {
             while(1)
             {
                  nRet = recv (xClientSocket,(void*)&stcpbuf[0],512,0);
	     if  (nRet > 0)
	          send(xClientSocket,stcpbuf,nRet,0);
	     else
                       break;
             }
             close(xClientSocket);
	xClientSocket = -1;
        }
    }	
}
```
然后创建该服务器
tcptest_thread = rt_thread_create("lwip_tcptest",rt_lwiptcptest_thread_entry, RT_NUL,512, 220, 50);
在PC上用TCP程序去测试，过程如下
1 Connect 成功
2 发送数据成功，发送若干次后
3 断开连接成功
然后再Connetct Mini2440时失败，串口打印出如下信息
Execption:
r00:0xe59ff018 r01:0x30168140 r02:0x30168110 r03:0xffffffff
r04:0x30168170 r05:0x00000000 r06:0x30168170 r07:0x00000000
r08:0x00000000 r09:0x00000000 r10:0x00000000
fp :0x00000000 ip :0x00000000
sp :0x30168ac0 lr :0x30079f14 pc :0x30079f14
cpsr:0x20000013
data abort
thread - lwip_tcptest stack:
 thread  pri  status      sp     stack size max used   left tick  error
-------- ---- ------- ---------- ---------- ---------- ---------- ---
tcpip    0x80 suspend 0x000000cc 0x00001000 0x0000026c 0x00000010 000
etx      0x90 suspend 0x00000094 0x00000400 0x00000094 0x00000002 000
erx      0x90 suspend 0x00000094 0x00000400 0x000000d4 0x00000004 000
wb       0x19 suspend 0x000000d4 0x00001000 0x00000248 0x00000004 000
rtgui    0x0f suspend 0x000001ac 0x00000800 0x000001b0 0x00000005 000
tidle    0xff ready   0x0000004c 0x00000100 0x00000088 0x00000017 000
timer    0x08 suspend 0x0000007c 0x00000200 0x0000007c 0x00000009 000
tshell   0x14 suspend 0x00000084 0x00001000 0x00000084 0x00000009 000
lwip_tcptest 0xdc ready   0x00000174 0x00000200 0x00000184 0x00000025 000
led      0xc8 suspend 0x0000007c 0x00000200 0x0000007c 0x00000014 000
shutdown...
不知这是什么问题？请高人指点

4 个回答

bernard 2011-08-13

这家伙很懒，什么也没写！

粗看还看不出什么问题，你可以试试我的代码：

```

/*
 * TCP socket echo server
 */
#define TCP_SOCKET_ECHO_PORT	700
#define TCP_SOCKET_BUFFER_SIZE	4096
rt_thread_t tcpecho_socket_tid = RT_NULL;
void tcpecho_socket_entry(void *parameter)
{
   char *recv_data;
   rt_uint32_t sin_size;
   int sock = -1, connected, bytes_received;
   struct sockaddr_in server_addr, client_addr;

recv_data = rt_malloc(TCP_SOCKET_BUFFER_SIZE);
	if (recv_data == RT_NULL)
	{
		rt_kprintf("no memory
");
		goto _exit;
	}

/* create a TCP socket */
	if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1)
	{
		rt_kprintf("create socket error
");
		goto _exit;
	}

/* initialize server address */
	server_addr.sin_family = AF_INET;
	server_addr.sin_port = htons(TCP_SOCKET_ECHO_PORT);
	server_addr.sin_addr.s_addr = INADDR_ANY;
	rt_memset(&(server_addr.sin_zero),8, sizeof(server_addr.sin_zero));

/* bind to server address */
	if (bind(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
	{
		rt_kprintf("bind address failed
");
		goto _exit;
   }

/* listen */
	if (listen(sock, 5) == -1)
	{
		rt_kprintf("listen error
");
		goto _exit;
	}

sin_size = sizeof(struct sockaddr_in);
	while(1)
	{
		/* accept client connected */
		connected = accept(sock, (struct sockaddr *)&client_addr, &sin_size);
		if (connected > 0)
		{
			int timeout;
			
			/* set timeout option */
			timeout = 5000; /* 5second */
			setsockopt(connected, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout));

/* handle this client */
			while (1)
			{
				/* receive data from this connection */
				bytes_received = recv(connected,recv_data, TCP_SOCKET_BUFFER_SIZE, 0);
				if (bytes_received <= 0)
				{
					rt_kprintf("close client connection, errno: %d, socket error: %d
", 
						rt_get_errno(),
						lwip_get_error());
					/* connection closed. */
					lwip_close(connected);
					break;
				}

/* send data to client */
				send(connected, recv_data, bytes_received, 0);
			}
		}
   }

_exit:
	/* close socket */
	if (sock != -1) lwip_close(sock);
	rt_free(recv_data);

return ;
}

/* network test utilities entry */
void net_test(void)
{
	rt_thread_t tcpecho_socket_tid;

if (tcpecho_socket_tid == RT_NULL)
	{
		tcpecho_socket_tid = rt_thread_create("techo_s",
									tcpecho_socket_entry, RT_NULL,
									512, RT_THREAD_PRIORITY_MAX/2 + 3, 5);
		if (tcpecho_socket_tid != RT_NULL)
			rt_thread_startup(tcpecho_socket_tid);
	}
}

```