W5500堵塞接收，关闭socket错误

发布于 2021-01-14 19:53:24 浏览：2671 订阅该版

[tocm]

```c
int main(void)
{	
	int ret = 0;
	int sock, bytes_received;
	struct server_addr;
	
	/* 通过网卡名称获取网卡对象，名称可以通过 ifconfig 命令查看 */
	struct netdev *netdev = netdev_get_by_name("W5500");
	if (netdev == RT_NULL)
	{
			rt_kprintf("not find network interface device name().\n");
			return 0;
	}	
	/* 设置默认网卡对象 */
   netdev_set_default(netdev);

if(sock != RT_NULL)
  {
		closesocket(sock);
		sock = RT_NULL;
  }
			
	/* 创建一个socket，类型是SOCKET_STREAM，TCP类型 */
	if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1)
	{
			/* 创建socket失败 */
			rt_kprintf("Socket error");
			sock = RT_NULL;
	}
	
	/* 初始化预连接的服务端地址 */
	struct hostent *host = gethostbyname("192.168.1.203");
	struct sockaddr_in server_addr;
	server_addr.sin_family = AF_INET;
	server_addr.sin_port = htons(9600);
	server_addr.sin_addr = *((struct in_addr *)host->h_addr);
	rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));
	/* 连接到服务端 */
	if (connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
	{
		 /* 连接失败 */
		rt_kprintf("Connect fail!");
		closesocket(sock);
		/*释放接收缓冲 */
		return 0;
	}
	
	//开启线程
	dt_test_isWhile = 1;
	dt_test_runing = 1;
	rt_thread_t tid;
	tid = rt_thread_create("os_test", dt_WIZ_test_thread_entry, &sock,
											1024, (RT_THREAD_PRIORITY_MAX / 3), 20);
	RT_ASSERT(tid != RT_NULL);
	rt_thread_startup(tid);
	
	rt_thread_mdelay(10000);
	
	closesocket(sock);
}

void dt_WIZ_test_thread_entry(void *parameter)
{
	int sock = *(int*)(parameter);
	char *dev_data_buff = rt_calloc(1,BUFSZ);
	int dev_bytes_received;
	int ret,i=5;
	if (dev_data_buff == RT_NULL)
	{
			rt_kprintf("No memory");
			return;
	}
	while(dt_test_isWhile)
	{	
				//接收设备数据
				dev_bytes_received = recv(sock, dev_data_buff, BUFSZ - 1, 0);
				rt_thread_mdelay(10);  //等待dt_pass_through_stop关闭sock，防止多次关闭同一个sock
				//cmd_printf(1,dev_data_buff,dev_bytes_received);   //打印发送数据
				//发送设备数据到网络
				if(dev_bytes_received>0)
				{
					ret = send(sock, dev_data_buff, dev_bytes_received, 0);
					
					if (ret <= 0)
					{
							/* 接收失败，关闭这个连接 */
						if(sock!=RT_NULL)
							closesocket(sock);
						rt_kprintf("thr_web_sock send error %d,close the socket.",ret);
					}
				}
		}	
			dt_test_isWhile = 0;
	}
	dt_test_runing = 0;
	rt_kprintf("quit.");
}
```

## 问题
在main线程创建线程，w5500开启堵塞接收`recv(sock, dev_data_buff, BUFSZ - 1, 0);`，main函数中延时`closesocket(sock);`
此事会出错`wiz_recvfrom`函数的`wiz_do_event_changes`中`rt_wqueue_wakeup`死掉。
## 目的
在一个堵塞的socket中接收线程中要怎么跳出堵塞函数除了关闭socket