nx_tcp_socket_send无法连续发送问题

jipolun

1. while(1){
   
2.     ret = nx_packet_allocate(&AppPool, &data_packet, NX_IPv4_TCP_PACKET, TX_WAIT_FOREVER);
   
3. 
   
4.     if (ret != NX_SUCCESS)
   
5.     {
   
6.             printf("aaaa1\r\n");
   
7.       break;
   
8.     }
   
9. 
   
10.     /* append the message to send into the packet */
    
11.     ret = nx_packet_data_append(data_packet, (VOID *)DEFAULT_MESSAGE, sizeof(DEFAULT_MESSAGE), &AppPool, TX_WAIT_FOREVER);
    
12. 
    
13.     if (ret != NX_SUCCESS)
    
14.     {
    
15.             printf("aaaa2\r\n");
    
16.       nx_packet_release(data_packet);
    
17.       break;
    
18.     }
    
19. 
    
20.     /* send the packet over the TCP socket */
    
21.     ret = nx_tcp_socket_send(&TCPSocket, data_packet, DEFAULT_TIMEOUT);
    
22. 
    
23.     if (ret != NX_SUCCESS)
    
24.     {
    
25. printf("tcp send error:%d\r\n",ret);
    
26.       break;
    
27.     }
    
28. 
    
29.    
    
30.    }

复制代码

然后发现报该错误：tcp send error:56我在threadX netxduo的api 文档上看到



然后我在发送函数下面加了个延时，tx_thread_sleep(10);就不会报错
看来跟数据包释放有关系，大家有实现不加延时，可以连续发的方法么？

我看了一下api文档，似乎没有一个api可以去判断该数据包是否已经被释放。。。。。

jipolun

报错 56 ==0x38,但是我能确保网络是一直连接的

eric2013

jipolun 发表于 2021-11-5 17:39
报错 56 ==0x38,但是我能确保网络是一直连接的

貌似是你的姿势不太对，发送玩要释放数据包

1. /*
   
2. *********************************************************************************************************
   
3. *        函 数 名: NetXTest
   
4. *        功能说明: TCPnet应用
   
5. *        形    参: 无
   
6. *        返 回 值: 无
   
7. *********************************************************************************************************
   
8. */   
   
9. void NetXTest(void)
   
10. {
    
11.     UINT status;
    
12.     UINT ret;
    
13.     ULONG socket_state;
    
14.     UINT old_priority;
    
15. 
    
16.     ULONG source_ip_address;
    
17.     NX_PACKET *data_packet;
    
18. 
    
19.     UINT source_port;
    
20.     ULONG bytes_read;
    
21. 
    
22.     /* 创建信号量，用于通知TCP服务器监听到新连接 */
    
23.     tx_semaphore_create(&Semaphore, "App Semaphore", 0);
    
24.    
    
25. 
    
26.     /* 初始化NetX */
    
27.     nx_system_initialize();
    
28. 
    
29.     /* 创建内存池 */
    
30.     status =  nx_packet_pool_create(&pool_0,
    
31.                                      "NetX Main Packet Pool",
    
32.                                      1536,  (ULONG*)(((int)packet_pool_area + 15) & ~15) ,
    
33.                                      NX_PACKET_POOL_SIZE);
    
34. 
    
35.     /* 检测创建是否失败 */
    
36.     if (status) error_counter++;
    
37. 
    
38.     /* 例化IP */
    
39.     status = nx_ip_create(&ip_0,
    
40.                             "NetX IP Instance 0",
    
41.                             IP_ADDRESS(IP_ADDR0, IP_ADDR1, IP_ADDR2, IP_ADDR3),
    
42.                             0xFFFFFF00UL,
    
43.                             &pool_0, nx_driver_stm32f4xx,
    
44.                             (UCHAR*)AppTaskNetXStk,
    
45.                             sizeof(AppTaskNetXStk),
    
46.                             APP_CFG_TASK_NETX_PRIO);
    
47.                            
    
48.             
    
49.     /* 检测创建是否失败 */
    
50.     if (status) error_counter++;
    
51. 
    
52.     /* 使能ARP，并提供ARP缓存 */
    
53.     status =  nx_arp_enable(&ip_0, (void *)arp_space_area, sizeof(arp_space_area));
    
54. 
    
55.     /* 使能fragment */   
    
56.     status = nx_ip_fragment_enable(&ip_0);
    
57. 
    
58.     /* 检测使能成功 */
    
59.     if (status) error_counter++;
    
60. 
    
61.     /* 使能TCP */
    
62.     status =  nx_tcp_enable(&ip_0);
    
63. 
    
64.     /* 检测使能成功 */
    
65.     if (status) error_counter++;
    
66. 
    
67.     /* 使能UDP  */
    
68.     status =  nx_udp_enable(&ip_0);
    
69. 
    
70.     /* 检测使能成功 */
    
71.     if (status) error_counter++;
    
72. 
    
73.     /* 使能ICMP */
    
74.     status =  nx_icmp_enable(&ip_0);
    
75. 
    
76.     /* 检测使能成功 */
    
77.     if (status) error_counter++;   
    
78.    
    
79.     /* NETX初始化完毕后，重新设置优先级 */
    
80.     tx_thread_priority_change(netx_thread_ptr, APP_CFG_TASK_NETX_PRIO1, &old_priority);
    
81.     tx_thread_priority_change(&AppTaskNetXProTCB, APP_CFG_TASK_NetXPro_PRIO1, &old_priority);
    
82.    
    
83.     /////////////////////////////////////////////////////////////////////////////
    
84.     /* 创建TCP Socket */
    
85.     ret = nx_tcp_socket_create(&ip_0,
    
86.                                &TCPSocket,
    
87.                                "TCP Server Socket",
    
88.                                NX_IP_NORMAL,
    
89.                                NX_FRAGMENT_OKAY,
    
90.                                NX_IP_TIME_TO_LIVE,
    
91.                                4320,
    
92.                                NX_NULL,
    
93.                                NX_NULL);
    
94.     if (ret)
    
95.     {
    
96.                 Error_Handler(__FILE__, __LINE__);   
    
97.     }
    
98. 
    
99.     /*
    
100.     * 监听新的链接。
     
101.     * 创建回调TCP_listen_callback表示监听到新连接。
     
102.     */
     
103.     ret = nx_tcp_server_socket_listen(&ip_0, DEFAULT_PORT, &TCPSocket, MAX_TCP_CLIENTS, tcp_listen_callback);
     
104. 
     
105.     if (ret)
     
106.     {
     
107.         Error_Handler(__FILE__, __LINE__);
     
108.     }
     
109. 
     
110.     if(tx_semaphore_get(&Semaphore, TX_WAIT_FOREVER) != TX_SUCCESS)
     
111.     {
     
112. 
     
113.     }
     
114.     else
     
115.     {
     
116.         /* 启动TCP通信前，接收新连接 */
     
117.         ret = nx_tcp_server_socket_accept(&TCPSocket, TX_WAIT_FOREVER);
     
118. 
     
119.         if (ret)
     
120.         {
     
121.             Error_Handler(__FILE__, __LINE__);
     
122.         }
     
123.     }
     
124.    
     
125.    
     
126.         while(1)
     
127.         {
     
128.         TX_MEMSET(data_buffer, '\0', sizeof(data_buffer));
     
129. 
     
130.         /* 获取socket状态 */
     
131.         nx_tcp_socket_info_get(&TCPSocket, NULL, NULL, NULL, NULL, NULL, NULL, NULL, &socket_state, NULL, NULL, NULL);
     
132. 
     
133.         /* 如果连接还没有建立，继续接受新连接，成功的话开启接收数据 */
     
134.         if(socket_state != NX_TCP_ESTABLISHED)
     
135.         {
     
136.             ret = nx_tcp_server_socket_accept(&TCPSocket, NX_IP_PERIODIC_RATE);
     
137.         }
     
138. 
     
139.         if(ret == NX_SUCCESS)
     
140.         {
     
141.             /* 接收TCP客户端发的TCP数据包 */
     
142.             ret = nx_tcp_socket_receive(&TCPSocket, &data_packet, NX_WAIT_FOREVER);
     
143. 
     
144.             if (ret == NX_SUCCESS)
     
145.             {
     
146.                 /* 获取客户端的IP地址和端口 */
     
147.                 nx_udp_source_extract(data_packet, &source_ip_address, &source_port);
     
148. 
     
149.                 /* 获取客户端发来的数据 */
     
150.                 nx_packet_data_retrieve(data_packet, data_buffer, &bytes_read);
     
151. 
     
152.                 /* 打印接收到数据 */
     
153.                 PRINT_DATA(source_ip_address, source_port, data_buffer);
     
154. 
     
155.                 /* 立即将接收到的数据发送回去 */
     
156.                 ret =  nx_tcp_socket_send(&TCPSocket, data_packet, NX_IP_PERIODIC_RATE);
     
157. 
     
158.                 if (ret == NX_SUCCESS)
     
159.                 {
     
160. 
     
161.                 }
     
162. 
     
163.                 /* 释放数据包 */
     
164.                 nx_packet_release(data_packet);
     
165.             }
     
166.             else
     
167.             {
     
168.                 /* 断开连接，重新监听 */
     
169.                 nx_tcp_socket_disconnect(&TCPSocket, NX_WAIT_FOREVER);
     
170.                 nx_tcp_server_socket_unaccept(&TCPSocket);
     
171.                 nx_tcp_server_socket_relisten(&ip_0, DEFAULT_PORT, &TCPSocket);
     
172.             }
     
173.         }
     
174.         else
     
175.         {
     
176.             /* 处于空闲状态 */
     
177.             
     
178.         }
     
179.         }         
     
180. }

复制代码

jipolun

eric2013 发表于 2021-11-6 09:43
貌似是你的姿势不太对，发送玩要释放数据包

楼主您好，之所以不调用release函数，是因为我看了官网上
貌似这个发送函数会自动释放数据包的


而这边官网上说明 release函数不能重复调用

eric2013

jipolun 发表于 2021-11-7 20:00
楼主您好，之所以不调用release函数，是因为我看了官网上
貌似这个发送函数会自动释放数据包的

你看的哪里的说明，方便的话，贴下地址。

jipolun

eric2013 发表于 2021-11-8 00:36
你看的哪里的说明，方便的话，贴下地址。

楼主，您好，是这个地址
https://docs.microsoft.com/zh-cn ... #nx_tcp_socket_send
这个函数下面有一句
警告

除非返回了错误，否则应用程序不应在此调用后释放该数据包。这样做会导致不可预知的结果，因为网络驱动程序还会在传输后尝试释放该数据包。

eric2013

jipolun 发表于 2021-11-8 10:49
楼主，您好，是这个地址
https://docs.microsoft.com/zh-cn/azure/rtos/netx-duo/chapter4#nx_tcp_socke ...

看来要修改，我这个是早期按照他们官方的一个demo设计的，还没有研究他们的API。

近期更新NetXDUO教程得修改下。

jipolun

eric2013 发表于 2021-11-8 16:23
看来要修改，我这个是早期按照他们官方的一个demo设计的，还没有研究他们的API。

近期更新NetXDUO教程 ...

所以 我发现
nx_tcp_socket_send()  无法在一个while 连续发送数据
因为测试发现会报(ox38)错误码

eric2013

jipolun 发表于 2021-11-14 22:12
所以 我发现
nx_tcp_socket_send()  无法在一个while 连续发送数据
因为测试发现会报(ox38)错误码

本周如果如果更新教程的话，我试试，早期我测试没问题的，应该是数据量比较小，无影响。

catro

jipolun 发表于 2021-11-14 22:12
所以 我发现
nx_tcp_socket_send()  无法在一个while 连续发送数据
因为测试发现会报(ox38)错误码

请问用的是哪个Echo Server? 0x38表明连接已经断开了，是不是服务器端主动断开的？可以通过Wireshark抓包来确认下。

jipolun

catro 发表于 2021-11-15 09:27
请问用的是哪个Echo Server? 0x38表明连接已经断开了，是不是服务器端主动断开的？可以通过Wireshark抓包 ...

实际，我能确认没有断开喔

catro

jipolun 发表于 2021-11-15 17:06
实际，我能确认没有断开喔

是否断开这个有很多含义：服务端网线没断，客户端网线没断，服务器端程序没显示断开，客户端程序没显示断开， 等等等。比较有效的方法是提供Wireshark或者tcpdump数据包用来分析网络情况。